50 Commits

Author	SHA1	Message	Date
Matthias	1d4658e978	chore: update rpc to modern typing syntax	2024-10-04 07:06:27 +02:00
Matthias	986ff7d1b1	chore: rename parameter to avoid naming collision	2024-08-19 18:19:42 +02:00
Matthias	5f64cc8e76	ruff format: rpc modules	2024-05-13 07:10:25 +02:00
Matthias	a8eabd0b2e	Update remaining files with new import sorting	2024-05-13 07:10:24 +02:00
Matthias	47850ce1b0	Don''t use deprecated pydantic methods	2023-08-02 19:51:50 +02:00
Matthias	5f98530ef9	Catch and send exceptions from websockets	2023-06-24 20:26:05 +02:00
Matthias	69087c30e7	Don't overwrite "type" with a variable	2023-06-24 20:18:24 +02:00
Matthias	2c1457fb95	Ensure limit is integer (on server)	2023-01-31 11:06:23 +00:00
Timothy Pogue	fce1e9d6d0	update analyzed df request to allow specifying a single pair	2022-12-12 22:47:35 -07:00
Matthias	fcf13580f1	Revert "offload initial df computation to thread" ... This reverts commit f268187e9b.	2022-11-26 13:33:54 +01:00
Timothy Pogue	bd95392eea	fix formatted string in warning message :)	2022-11-25 13:10:22 -07:00
Timothy Pogue	f268187e9b	offload initial df computation to thread	2022-11-25 12:56:33 -07:00
Timothy Pogue	afc00bc30a	log warning if channel too far behind, add docstrings to message stream	2022-11-25 12:48:57 -07:00
Timothy Pogue	fc59b02255	prevent ws endpoint from running without valid token	2022-11-24 13:41:10 -07:00
Timothy Pogue	a5442772fc	ensure only broadcasting to subscribed topics	2022-11-22 09:42:09 -07:00
Timothy Pogue	60a167bdef	add dynamic send timeout	2022-11-20 14:09:45 -07:00
Timothy Pogue	0cb6f71c02	better error handling, true async sending, more readable api	2022-11-18 13:32:27 -07:00
Timothy Pogue	442467e8ae	remove old comments and code	2022-11-14 22:26:34 -07:00
Timothy Pogue	d713af045f	remove main queue completely	2022-11-14 22:21:40 -07:00
Timothy Pogue	659c8c237f	initial revision	2022-11-14 20:27:45 -07:00
Matthias	a951b49541	Use Generator when sending initial dataframes	2022-11-14 19:43:59 +01:00
Timothy Pogue	e25dea7e0e	update channel disconnecting	2022-11-02 13:26:27 -06:00
Timothy Pogue	fd5f31368c	fix indent in initial df send	2022-10-25 14:08:28 -06:00
Matthias	3fa50077c9	Don't use pydantic to type-verify outgoing messages	2022-10-25 20:00:53 +02:00
Timothy Pogue	94b65a007a	fix message typing in channel manager, minor improvements	2022-10-23 11:42:59 -06:00
Timothy Pogue	3d7a311caa	removed sleep calls, better channel sending	2022-10-22 19:02:05 -06:00
Matthias	c7fff1213c	Rate-limit EMC startup to avoid overwelming the queue	2022-10-17 20:46:15 +02:00
Timothy Pogue	5ada5eb540	fix error message, update exception import	2022-10-10 23:30:43 -06:00
Timothy Pogue	3e8d8fd1b0	refactor broadcasting to a queue per client	2022-10-09 15:04:52 -06:00
Timothy Pogue	8e75852ff3	fix constants, update config example, add emc config validation	2022-09-15 11:12:05 -06:00
Matthias	d2abc9417f	Simplify ws imports	2022-09-13 20:51:13 +02:00
Matthias	79c70bd52d	use WebSocketState from fastapi ... available since 0.82.0	2022-09-13 20:50:12 +02:00
Matthias	b344f78d00	Improve logic for token validation	2022-09-10 14:20:49 +02:00
Timothy Pogue	6cbc03a96a	support jwt token in place of ws token	2022-09-09 11:38:42 -06:00
Timothy Pogue	75cf8dbfe4	missed await	2022-09-08 15:11:36 -06:00
Timothy Pogue	2b9c8550b0	moved ws_schemas, first ws tests	2022-09-08 13:58:28 -06:00
Timothy Pogue	b9e7af1ce2	fix ws token auth	2022-09-08 11:25:30 -06:00
Timothy Pogue	379b1cbc90	remove unnecessary returns	2022-09-08 10:37:41 -06:00
Timothy Pogue	df3c126146	fix mypy error	2022-09-08 10:34:37 -06:00
Timothy Pogue	5934495dda	add websocket request/message schemas	2022-09-07 15:08:01 -06:00
Timothy Pogue	8f261d8edf	change from bytes to text in websocket, remove old logs	2022-09-05 13:47:17 -06:00
Timothy Pogue	07f806a314	minor improvements, fixes, old config+constant removal	2022-09-04 10:22:10 -06:00
Timothy Pogue	cf917ad2f5	initial candle request limit, better error reporting, split up _handle_producer_connection	2022-09-02 15:05:16 -06:00
Timothy Pogue	eb4cd6ba82	split initial data into separate requests	2022-09-01 23:52:13 -06:00
Timothy Pogue	00f35f4870	remove old constant, add initial_data requesting, minor changes	2022-09-01 20:06:36 -06:00
Timothy Pogue	510cf4f305	remove data waiting, remove explicit analyzing of external df	2022-08-31 10:40:26 -06:00
Timothy Pogue	346e73dd75	client implementation, minor fixes	2022-08-30 19:21:34 -06:00
Timothy Pogue	418bd26a80	minor fixes, rework consumer request, update requirements.txt	2022-08-30 11:04:16 -06:00
Timothy Pogue	47f7c384fb	consumer subscriptions, fix serializer bug	2022-08-29 15:48:29 -06:00
Timothy Pogue	7952e0df25	initial rework separating server and client impl	2022-08-29 13:41:15 -06:00