Compare commits
	
		
			62 Commits 
		
	
	
		
			022432cce7
			...
			b4d3bcf240
		
	
	| Author | SHA1 | Date | 
|---|---|---|
|  | b4d3bcf240 | |
|  | 5cefe8bcdb | |
|  | d96e9d4f11 | |
|  | a0dcf14aba | |
|  | 1705afb607 | |
|  | dafd5a3ca5 | |
|  | b9dde98d1e | |
|  | 1616cc0e82 | |
|  | 0a2ed195a7 | |
|  | 28e8628c61 | |
|  | b734245183 | |
|  | dc2c379d86 | |
|  | be84d0dae1 | |
|  | bdc3bc9219 | |
|  | 9232d09440 | |
|  | f96bd51442 | |
|  | 6555ccfbba | |
|  | 75d1d007fb | |
|  | 2bdbe0f20e | |
|  | a117177759 | |
|  | 30060a83c9 | |
|  | 156a35b606 | |
|  | 89e241c132 | |
|  | df8d1274ae | |
|  | 0916b707e2 | |
|  | 45788b0b53 | |
|  | 38a1f0b9ee | |
|  | f291654dbe | |
|  | e9fa422916 | |
|  | 5304a36b87 | |
|  | 089c79e905 | |
|  | d848050b52 | |
|  | ddffe2bec6 | |
|  | 19b4ca9d85 | |
|  | f037f851d8 | |
|  | a3ab8dd8fe | |
|  | 6fa0d4bcf3 | |
|  | a4f7fa9c1a | |
|  | 266ecf6206 | |
|  | ea6126d310 | |
|  | 1f4a5b80c4 | |
|  | ac6f52088a | |
|  | 960298514c | |
|  | 71f3a0a4cd | |
|  | b25a7699ab | |
|  | b39affc96e | |
|  | be8629929b | |
|  | 4776be6736 | |
|  | 008e68174b | |
|  | b4a9b86783 | |
|  | d3ca571c0e | |
|  | b3bbef30c0 | |
|  | 499b2d0090 | |
|  | 8b0f1e7045 | |
|  | b2cfa3444f | |
|  | 0be454c3d6 | |
|  | de6189da4d | |
|  | cc5b21a7e6 | |
|  | 35a9d8ec9d | |
|  | a831212c86 | |
|  | e987d7d7c4 | |
|  | 5ec756234a | 
							
								
								
									
										152
									
								
								default.nix
								
								
								
								
							
							
						
						
									
										152
									
								
								default.nix
								
								
								
								
							|  | @ -1,134 +1,82 @@ | |||
| with (import <nixpkgs> {}); | ||||
| with python312Packages; | ||||
| let | ||||
|   glibStorePath = lib.getLib glib; | ||||
|   zlibStorePath = lib.getLib zlib; | ||||
|   zstdStorePath = lib.getLib zstd; | ||||
|   dbusStorePath = lib.getLib dbus; | ||||
|   libGLStorePath = lib.getLib libGL; | ||||
|   freetypeStorePath = lib.getLib freetype; | ||||
|   qtpyStorePath = lib.getLib qtpy; | ||||
|   pyqt6StorePath = lib.getLib pyqt6; | ||||
|   pyqt6SipStorePath = lib.getLib pyqt6-sip; | ||||
|   qt6baseStorePath = lib.getLib qt6.qtbase; | ||||
|   fontconfigStorePath = lib.getLib fontconfig; | ||||
|   libxkbcommonStorePath = lib.getLib libxkbcommon; | ||||
|   xcbutilcursorStorePath = lib.getLib xcb-util-cursor; | ||||
| 
 | ||||
|   qtpyStorePath = lib.getLib python312Packages.qtpy; | ||||
|   pyqt6StorePath = lib.getLib python312Packages.pyqt6; | ||||
|   pyqt6SipStorePath = lib.getLib python312Packages.pyqt6-sip; | ||||
|   rapidfuzzStorePath = lib.getLib python312Packages.rapidfuzz; | ||||
|   qdarkstyleStorePath = lib.getLib python312Packages.qdarkstyle; | ||||
| 
 | ||||
|   xorgLibX11StorePath = lib.getLib xorg.libX11; | ||||
|   xorgLibxcbStorePath = lib.getLib xorg.libxcb; | ||||
|   xorgxcbutilwmStorePath = lib.getLib xorg.xcbutilwm; | ||||
|   xorgxcbutilimageStorePath = lib.getLib xorg.xcbutilimage; | ||||
|   xorgxcbutilerrorsStorePath = lib.getLib xorg.xcbutilerrors; | ||||
|   xorgxcbutilkeysymsStorePath = lib.getLib xorg.xcbutilkeysyms; | ||||
|   xorgxcbutilrenderutilStorePath = lib.getLib xorg.xcbutilrenderutil; | ||||
|   rapidfuzzStorePath = lib.getLib rapidfuzz; | ||||
|   qdarkstyleStorePath = lib.getLib qdarkstyle; | ||||
| in | ||||
| stdenv.mkDerivation { | ||||
|   name = "piker-qt6-uv"; | ||||
|   name = "piker-qt6-poetry-shell"; | ||||
|   buildInputs = [ | ||||
|     # System requirements. | ||||
|     glib | ||||
|     zlib | ||||
|     dbus | ||||
|     zstd | ||||
|     libGL | ||||
|     freetype | ||||
|     qt6.qtbase | ||||
|     libgcc.lib | ||||
|     fontconfig | ||||
|     libxkbcommon | ||||
| 
 | ||||
|     # Xorg requirements | ||||
|     xcb-util-cursor | ||||
|     xorg.libxcb | ||||
|     xorg.libX11 | ||||
|     xorg.xcbutilwm | ||||
|     xorg.xcbutilimage | ||||
|     xorg.xcbutilerrors | ||||
|     xorg.xcbutilkeysyms | ||||
|     xorg.xcbutilrenderutil | ||||
| 
 | ||||
|     # Python requirements. | ||||
|     python312Full | ||||
|     python312Packages.uv | ||||
|     python312Packages.qdarkstyle | ||||
|     python312Packages.rapidfuzz | ||||
|     python312Packages.pyqt6 | ||||
|     python312Packages.qtpy | ||||
|     poetry-core | ||||
|     qdarkstyle | ||||
|     rapidfuzz | ||||
|     pyqt6 | ||||
|     qtpy | ||||
|   ]; | ||||
|   src = null; | ||||
|   shellHook = '' | ||||
|     set -e | ||||
| 
 | ||||
|     export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:${libgcc.lib}/lib:${glibStorePath}/lib | ||||
| 
 | ||||
|     # Set the Qt plugin path | ||||
|     # export QT_DEBUG_PLUGINS=1 | ||||
| 
 | ||||
|     QTBASE_PATH="${qt6baseStorePath}/lib" | ||||
|     QT_PLUGIN_PATH="$QTBASE_PATH/qt-6/plugins" | ||||
|     QT_QPA_PLATFORM_PLUGIN_PATH="$QT_PLUGIN_PATH/platforms" | ||||
|     QTBASE_PATH="${qt6baseStorePath}" | ||||
|     echo "qtbase path:    $QTBASE_PATH" | ||||
|     echo "" | ||||
|     export QT_PLUGIN_PATH="$QTBASE_PATH/lib/qt-6/plugins" | ||||
|     export QT_QPA_PLATFORM_PLUGIN_PATH="$QT_PLUGIN_PATH/platforms" | ||||
|     echo "qt plugin path: $QT_PLUGIN_PATH" | ||||
|     echo "" | ||||
| 
 | ||||
|     LIB_GCC_PATH="${libgcc.lib}/lib" | ||||
|     GLIB_PATH="${glibStorePath}/lib" | ||||
|     ZSTD_PATH="${zstdStorePath}/lib" | ||||
|     ZLIB_PATH="${zlibStorePath}/lib" | ||||
|     DBUS_PATH="${dbusStorePath}/lib" | ||||
|     LIBGL_PATH="${libGLStorePath}/lib" | ||||
|     FREETYPE_PATH="${freetypeStorePath}/lib" | ||||
|     FONTCONFIG_PATH="${fontconfigStorePath}/lib" | ||||
|     LIB_XKB_COMMON_PATH="${libxkbcommonStorePath}/lib" | ||||
|     # Maybe create venv & install deps | ||||
|     poetry install --with uis | ||||
| 
 | ||||
|     XCB_UTIL_CURSOR_PATH="${xcbutilcursorStorePath}/lib" | ||||
|     XORG_LIB_X11_PATH="${xorgLibX11StorePath}/lib" | ||||
|     XORG_LIB_XCB_PATH="${xorgLibxcbStorePath}/lib" | ||||
|     XORG_XCB_UTIL_IMAGE_PATH="${xorgxcbutilimageStorePath}/lib" | ||||
|     XORG_XCB_UTIL_WM_PATH="${xorgxcbutilwmStorePath}/lib" | ||||
|     XORG_XCB_UTIL_RENDER_UTIL_PATH="${xorgxcbutilrenderutilStorePath}/lib" | ||||
|     XORG_XCB_UTIL_KEYSYMS_PATH="${xorgxcbutilkeysymsStorePath}/lib" | ||||
|     XORG_XCB_UTIL_ERRORS_PATH="${xorgxcbutilerrorsStorePath}/lib" | ||||
|     # Use pyqt6 from System, patch activate script | ||||
|     ACTIVATE_SCRIPT_PATH="$(poetry env info --path)/bin/activate" | ||||
| 
 | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QTBASE_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QT_PLUGIN_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QT_QPA_PLATFORM_PLUGIN_PATH" | ||||
|     export RPDFUZZ_PATH="${rapidfuzzStorePath}/lib/python3.12/site-packages" | ||||
|     export QDRKSTYLE_PATH="${qdarkstyleStorePath}/lib/python3.12/site-packages" | ||||
|     export QTPY_PATH="${qtpyStorePath}/lib/python3.12/site-packages" | ||||
|     export PYQT6_PATH="${pyqt6StorePath}/lib/python3.12/site-packages" | ||||
|     export PYQT6_SIP_PATH="${pyqt6SipStorePath}/lib/python3.12/site-packages" | ||||
|     echo "rapidfuzz at:   $RPDFUZZ_PATH" | ||||
|     echo "qdarkstyle at:  $QDRKSTYLE_PATH" | ||||
|     echo "qtpy at:        $QTPY_PATH"  | ||||
|     echo "pyqt6 at:       $PYQT6_PATH" | ||||
|     echo "pyqt6-sip at:   $PYQT6_SIP_PATH" | ||||
|     echo "" | ||||
| 
 | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$LIB_GCC_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$DBUS_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$GLIB_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$ZLIB_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$ZSTD_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$LIBGL_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$FONTCONFIG_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$FREETYPE_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$LIB_XKB_COMMON_PATH" | ||||
|     PATCH="export PYTHONPATH=\"" | ||||
| 
 | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XCB_UTIL_CURSOR_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_LIB_X11_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_LIB_XCB_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_XCB_UTIL_IMAGE_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_XCB_UTIL_WM_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_XCB_UTIL_RENDER_UTIL_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_XCB_UTIL_KEYSYMS_PATH" | ||||
|     LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_XCB_UTIL_ERRORS_PATH" | ||||
|     PATCH="$PATCH\$RPDFUZZ_PATH" | ||||
|     PATCH="$PATCH:\$QDRKSTYLE_PATH" | ||||
|     PATCH="$PATCH:\$QTPY_PATH" | ||||
|     PATCH="$PATCH:\$PYQT6_PATH" | ||||
|     PATCH="$PATCH:\$PYQT6_SIP_PATH" | ||||
| 
 | ||||
|     export LD_LIBRARY_PATH | ||||
|     PATCH="$PATCH\"" | ||||
| 
 | ||||
|     RPDFUZZ_PATH="${rapidfuzzStorePath}/lib/python3.12/site-packages" | ||||
|     QDRKSTYLE_PATH="${qdarkstyleStorePath}/lib/python3.12/site-packages" | ||||
|     QTPY_PATH="${qtpyStorePath}/lib/python3.12/site-packages" | ||||
|     PYQT6_PATH="${pyqt6StorePath}/lib/python3.12/site-packages" | ||||
|     PYQT6_SIP_PATH="${pyqt6SipStorePath}/lib/python3.12/site-packages" | ||||
| 
 | ||||
|     PATCH="$PATCH:$RPDFUZZ_PATH" | ||||
|     PATCH="$PATCH:$QDRKSTYLE_PATH" | ||||
|     PATCH="$PATCH:$QTPY_PATH" | ||||
|     PATCH="$PATCH:$PYQT6_PATH" | ||||
|     PATCH="$PATCH:$PYQT6_SIP_PATH" | ||||
| 
 | ||||
|     export PATCH | ||||
| 
 | ||||
|     # Install deps | ||||
|     uv lock | ||||
|     if grep -q "$PATCH" "$ACTIVATE_SCRIPT_PATH"; then | ||||
|         echo "venv is already patched." | ||||
|     else | ||||
|         echo "patching $ACTIVATE_SCRIPT_PATH to use pyqt6 from nixos..." | ||||
|         sed -i "\$i$PATCH" $ACTIVATE_SCRIPT_PATH | ||||
|     fi | ||||
| 
 | ||||
|     poetry shell | ||||
|   ''; | ||||
| } | ||||
|  |  | |||
|  | @ -30,8 +30,7 @@ from types import ModuleType | |||
| from typing import ( | ||||
|     Any, | ||||
|     Iterator, | ||||
|     Generator, | ||||
|     TYPE_CHECKING, | ||||
|     Generator | ||||
| ) | ||||
| 
 | ||||
| import pendulum | ||||
|  | @ -60,10 +59,8 @@ from ..clearing._messages import ( | |||
|     BrokerdPosition, | ||||
| ) | ||||
| from piker.types import Struct | ||||
| from piker.log import get_logger | ||||
| 
 | ||||
| if TYPE_CHECKING: | ||||
|     from piker.data._symcache import SymbologyCache | ||||
| from piker.data._symcache import SymbologyCache | ||||
| from ..log import get_logger | ||||
| 
 | ||||
| log = get_logger(__name__) | ||||
| 
 | ||||
|  | @ -496,17 +493,6 @@ class Account(Struct): | |||
| 
 | ||||
|         _mktmap_table: dict[str, MktPair] | None = None, | ||||
| 
 | ||||
|         only_require: list[str]|True = True, | ||||
|         # ^list of fqmes that are "required" to be processed from | ||||
|         # this ledger pass; we often don't care about others and | ||||
|         # definitely shouldn't always error in such cases. | ||||
|         # (eg. broker backend loaded that doesn't yet supsport the | ||||
|         # symcache but also, inside the paper engine we don't ad-hoc | ||||
|         # request `get_mkt_info()` for every symbol in the ledger, | ||||
|         # only the one for which we're simulating against). | ||||
|         # TODO, not sure if there's a better soln for this, ideally | ||||
|         # all backends get symcache support afap i guess.. | ||||
| 
 | ||||
|     ) -> dict[str, Position]: | ||||
|         ''' | ||||
|         Update the internal `.pps[str, Position]` table from input | ||||
|  | @ -549,32 +535,11 @@ class Account(Struct): | |||
|                 if _mktmap_table is None: | ||||
|                     raise | ||||
| 
 | ||||
|                 required: bool = ( | ||||
|                     only_require is True | ||||
|                     or ( | ||||
|                         only_require is not True | ||||
|                         and | ||||
|                         fqme in only_require | ||||
|                     ) | ||||
|                 ) | ||||
|                 # XXX: caller is allowed to provide a fallback | ||||
|                 # mktmap table for the case where a new position is | ||||
|                 # being added and the preloaded symcache didn't | ||||
|                 # have this entry prior (eg. with frickin IB..) | ||||
|                 if ( | ||||
|                     not (mkt := _mktmap_table.get(fqme)) | ||||
|                     and | ||||
|                     required | ||||
|                 ): | ||||
|                     raise | ||||
| 
 | ||||
|                 elif not required: | ||||
|                     continue | ||||
| 
 | ||||
|                 else: | ||||
|                     # should be an entry retreived somewhere | ||||
|                     assert mkt | ||||
| 
 | ||||
|                 mkt = _mktmap_table[fqme] | ||||
| 
 | ||||
|             if not (pos := pps.get(bs_mktid)): | ||||
| 
 | ||||
|  | @ -691,7 +656,7 @@ class Account(Struct): | |||
|     def write_config(self) -> None: | ||||
|         ''' | ||||
|         Write the current account state to the user's account TOML file, normally | ||||
|         something like `pps.toml`. | ||||
|         something like ``pps.toml``. | ||||
| 
 | ||||
|         ''' | ||||
|         # TODO: show diff output? | ||||
|  |  | |||
|  | @ -61,12 +61,13 @@ async def _setup_persistent_brokerd( | |||
|     ctx: tractor.Context, | ||||
|     brokername: str, | ||||
|     loglevel: str | None = None, | ||||
|     debug_mode: bool = False, | ||||
| 
 | ||||
| ) -> None: | ||||
|     ''' | ||||
|     Allocate a actor-wide service nursery in ``brokerd`` | ||||
|     such that feeds can be run in the background persistently by | ||||
|     the broker backend as needed. | ||||
|     Allocate a actor-wide service nursery in `brokerd` such that | ||||
|     feeds can be run in the background persistently by the broker | ||||
|     backend as needed. | ||||
| 
 | ||||
|     ''' | ||||
|     # NOTE: we only need to setup logging once (and only) here | ||||
|  | @ -87,6 +88,18 @@ async def _setup_persistent_brokerd( | |||
|     from piker.data import feed | ||||
|     assert not feed._bus | ||||
| 
 | ||||
|     if ( | ||||
|         debug_mode | ||||
|         and | ||||
|         tractor.current_actor().is_infected_aio() | ||||
|     ): | ||||
|         # NOTE, whenever running `asyncio` in provider's actor | ||||
|         # runtime be sure we enabled `breakpoint()` support | ||||
|         # for non-`trio.Task` usage. | ||||
|         from tractor.devx._debug import maybe_init_greenback | ||||
|         await maybe_init_greenback() | ||||
|         # breakpoint()  # XXX, SHOULD WORK from `trio.Task`! | ||||
| 
 | ||||
|     # allocate a nursery to the bus for spawning background | ||||
|     # tasks to service client IPC requests, normally | ||||
|     # `tractor.Context` connections to explicitly required | ||||
|  | @ -146,18 +159,21 @@ def broker_init( | |||
|       above. | ||||
| 
 | ||||
|     ''' | ||||
|     from ..brokers import get_brokermod | ||||
|     brokermod = get_brokermod(brokername) | ||||
|     brokermod: ModuleType = get_brokermod(brokername) | ||||
|     modpath: str = brokermod.__name__ | ||||
| 
 | ||||
|     start_actor_kwargs['name'] = f'brokerd.{brokername}' | ||||
|     start_actor_kwargs.update( | ||||
|         getattr( | ||||
|             brokermod, | ||||
|             '_spawn_kwargs', | ||||
|             {}, | ||||
|         ) | ||||
|     spawn_kws: dict = getattr( | ||||
|         brokermod, | ||||
|         '_spawn_kwargs', | ||||
|         {}, | ||||
|     ) | ||||
|     # ^^ NOTE, here we pull any runtime parameters specific | ||||
|     # to spawning the sub-actor for the backend. For ex. | ||||
|     # both `ib` and `deribit` rely on, | ||||
|     #  `'infect_asyncio': True,` since they both | ||||
|     #  use `tractor`'s "infected `asyncio` mode" | ||||
|     #  for their libs but you could also do something like | ||||
|     #  `'debug_mode: True` which would be like passing | ||||
|     #  `--pdb` for just that provider backend. | ||||
| 
 | ||||
|     # XXX TODO: make this not so hacky/monkeypatched.. | ||||
|     # -> we need a sane way to configure the logging level for all | ||||
|  | @ -167,8 +183,7 @@ def broker_init( | |||
| 
 | ||||
|     # lookup actor-enabled modules declared by the backend offering the | ||||
|     # `brokerd` endpoint(s). | ||||
|     enabled: list[str] | ||||
|     enabled = start_actor_kwargs['enable_modules'] = [ | ||||
|     enabled: list[str] = [ | ||||
|         __name__,  # so that eps from THIS mod can be invoked | ||||
|         modpath, | ||||
|     ] | ||||
|  | @ -180,9 +195,13 @@ def broker_init( | |||
|         subpath: str = f'{modpath}.{submodname}' | ||||
|         enabled.append(subpath) | ||||
| 
 | ||||
|     datad_kwargs: dict = { | ||||
|         'name': f'brokerd.{brokername}', | ||||
|         'enable_modules': enabled, | ||||
|     } | ||||
|     return ( | ||||
|         brokermod, | ||||
|         start_actor_kwargs,  # to `ActorNursery.start_actor()` | ||||
|         start_actor_kwargs | datad_kwargs | spawn_kws,  # to `ActorNursery.start_actor()` | ||||
| 
 | ||||
|         # XXX see impl above; contains all (actor global) | ||||
|         # setup/teardown expected in all `brokerd` actor instances. | ||||
|  | @ -215,10 +234,6 @@ async def spawn_brokerd( | |||
|         **tractor_kwargs, | ||||
|     ) | ||||
| 
 | ||||
|     brokermod = get_brokermod(brokername) | ||||
|     extra_tractor_kwargs = getattr(brokermod, '_spawn_kwargs', {}) | ||||
|     tractor_kwargs.update(extra_tractor_kwargs) | ||||
| 
 | ||||
|     # ask `pikerd` to spawn a new sub-actor and manage it under its | ||||
|     # actor nursery | ||||
|     from piker.service import ( | ||||
|  | @ -236,8 +251,12 @@ async def spawn_brokerd( | |||
|             # passed to daemon_fixture_ep(**kwargs) | ||||
|             brokername=brokername, | ||||
|             loglevel=loglevel, | ||||
|             debug_mode=mngr.debug_mode, | ||||
|         ), | ||||
|         debug_mode=mngr.debug_mode, | ||||
|         # ^TODO, allow overriding this per-daemon from client side? | ||||
|         # |_ it's already supported in `tractor` so.. | ||||
| 
 | ||||
|         loglevel=loglevel, | ||||
|         enable_modules=( | ||||
|             _data_mods | ||||
|  |  | |||
|  | @ -653,7 +653,6 @@ async def open_trade_dialog( | |||
|                 # in) use manually constructed table from calling | ||||
|                 # the `.get_mkt_info()` provider EP above. | ||||
|                 _mktmap_table=mkt_by_fqme, | ||||
|                 only_require=list(mkt_by_fqme), | ||||
|             ) | ||||
| 
 | ||||
|             pp_msgs: list[BrokerdPosition] = [] | ||||
|  |  | |||
|  | @ -499,7 +499,7 @@ async def open_jsonrpc_session( | |||
|                         # response in original "result" msg, | ||||
|                         # THEN FINALLY set the event to signal caller | ||||
|                         # to raise the error in the parent task. | ||||
|                         req_id: int = error['id'] | ||||
|                         req_id: int = msg['id'] | ||||
|                         req_msg: dict = req_msgs[req_id] | ||||
|                         result: dict = rpc_results[req_id] | ||||
|                         result['error'] = error | ||||
|  |  | |||
										
											
												File diff suppressed because it is too large
												Load Diff
											
										
									
								
							
							
								
								
									
										221
									
								
								pyproject.toml
								
								
								
								
							
							
						
						
									
										221
									
								
								pyproject.toml
								
								
								
								
							|  | @ -15,8 +15,8 @@ | |||
| # You should have received a copy of the GNU Affero General Public License | ||||
| # along with this program.  If not, see <https://www.gnu.org/licenses/>. | ||||
| [build-system] | ||||
| requires = ["hatchling"] | ||||
| build-backend = "hatchling.build" | ||||
| requires = ["poetry-core"] | ||||
| build-backend = "poetry.core.masonry.api" | ||||
| 
 | ||||
| # ------ - ------ | ||||
| 
 | ||||
|  | @ -34,114 +34,119 @@ ignore = [] | |||
| 
 | ||||
| # ------ - ------ | ||||
| 
 | ||||
| [project] | ||||
| [tool.poetry] | ||||
| name = "piker" | ||||
| version = "0.1.0a0dev0" | ||||
| version = "0.1.0.alpha0.dev0" | ||||
| description = "trading gear for hackers" | ||||
| authors = [{ name = "Tyler Goodlet", email = "goodboy_foss@protonmail.com" }] | ||||
| requires-python = ">=3.12, <3.13" | ||||
| license = "AGPL-3.0-or-later" | ||||
| authors = ["Tyler Goodlet <goodboy_foss@protonmail.com>"] | ||||
| license = "AGPLv3" | ||||
| readme = "README.rst" | ||||
| keywords = [ | ||||
|     "async", | ||||
|     "trading", | ||||
|     "finance", | ||||
|     "quant", | ||||
|     "charting", | ||||
| 
 | ||||
| # ------ - ------ | ||||
| 
 | ||||
| [tool.poetry.dependencies] | ||||
| async-generator = "^1.10" | ||||
| attrs = "^23.1.0" | ||||
| bidict = "^0.22.1" | ||||
| colorama = "^0.4.6" | ||||
| colorlog = "^6.7.0" | ||||
| ib-insync = "^0.9.86" | ||||
| msgspec = "^0.18.6" | ||||
| numba = "^0.59.0" | ||||
| numpy = "^1.25" | ||||
| polars = "^0.18.13" | ||||
| pygments = "^2.16.1" | ||||
| python = ">=3.11, <3.13" | ||||
| rich = "^13.5.2" | ||||
| # setuptools = "^68.0.0" | ||||
| tomli = "^2.0.1" | ||||
| tomli-w = "^1.0.0" | ||||
| trio-util = "^0.7.0" | ||||
| trio-websocket = "^0.10.3" | ||||
| typer = "^0.9.0" | ||||
| rapidfuzz = "^3.5.2" | ||||
| pdbp = "^1.5.0" | ||||
| trio = "^0.24" | ||||
| pendulum = "^3.0.0" | ||||
| httpx = "^0.27.0" | ||||
| cryptofeed = "^2.4.0" | ||||
| pyarrow = "^17.0.0" | ||||
| 
 | ||||
| tractor = {path = "../tractor", develop = true} | ||||
| websockets = "12.0" | ||||
| [tool.poetry.dependencies.asyncvnc] | ||||
| git = 'https://github.com/pikers/asyncvnc.git' | ||||
| branch = 'main' | ||||
| 
 | ||||
| [tool.poetry.dependencies.tomlkit] | ||||
| develop = true | ||||
| git = 'https://github.com/pikers/tomlkit.git' | ||||
| branch = 'piker_pin' | ||||
| # path = "../tomlkit/" | ||||
| 
 | ||||
| [tool.poetry.group.uis] | ||||
| optional = true | ||||
| [tool.poetry.group.uis.dependencies] | ||||
| # https://python-poetry.org/docs/managing-dependencies/#dependency-groups | ||||
| # TODO: make sure the levenshtein shit compiles on nix.. | ||||
| # rapidfuzz = {extras = ["speedup"], version = "^0.18.0"} | ||||
| rapidfuzz = "^3.2.0" | ||||
| qdarkstyle = ">=3.0.2" | ||||
| pyqtgraph = { git = 'https://github.com/pikers/pyqtgraph.git' } | ||||
| 
 | ||||
| # ------ - ------ | ||||
| pyqt6 = "^6.7.0" | ||||
| 
 | ||||
| [tool.poetry.group.dev] | ||||
| optional = true | ||||
| [tool.poetry.group.dev.dependencies] | ||||
| # testing / CI | ||||
| pytest = "^6.0.0" | ||||
| elasticsearch = "^8.9.0" | ||||
| xonsh = "^0.14.2" | ||||
| prompt-toolkit = "3.0.40" | ||||
| cython = "^3.0.0" | ||||
| greenback = "^1.1.1" | ||||
| 
 | ||||
| # console ehancements and eventually remote debugging | ||||
| # extras/helpers. | ||||
| # TODO: add a toolset that makes debugging a `pikerd` service | ||||
| # (tree) easy to hack on directly using more or less the local env: | ||||
| # - xonsh + xxh | ||||
| # - rsyscall + pdbp | ||||
| # - actor runtime control console like BEAM/OTP | ||||
| 
 | ||||
| # ------ - ------ | ||||
| 
 | ||||
| # TODO: add an `--only daemon` group for running non-ui / pikerd | ||||
| # service tree in distributed mode B) | ||||
| # https://python-poetry.org/docs/managing-dependencies/#installing-group-dependencies | ||||
| # [tool.poetry.group.daemon.dependencies] | ||||
| 
 | ||||
| [tool.poetry.scripts] | ||||
| piker = 'piker.cli:cli' | ||||
| pikerd = 'piker.cli:pikerd' | ||||
| ledger = 'piker.accounting.cli:ledger' | ||||
| 
 | ||||
| 
 | ||||
| [project] | ||||
| keywords=[ | ||||
|   "async", | ||||
|   "trading", | ||||
|   "finance", | ||||
|   "quant", | ||||
|   "charting", | ||||
| ] | ||||
| classifiers = [ | ||||
|     "Development Status :: 3 - Alpha", | ||||
|     "License :: OSI Approved :: GNU Affero General Public License v3 or later (AGPLv3+)", | ||||
|     "Operating System :: POSIX :: Linux", | ||||
|     "Programming Language :: Python :: Implementation :: CPython", | ||||
|     "Programming Language :: Python :: 3 :: Only", | ||||
|     "Programming Language :: Python :: 3.11", | ||||
|     "Programming Language :: Python :: 3.12", | ||||
|     "Intended Audience :: Financial and Insurance Industry", | ||||
|     "Intended Audience :: Science/Research", | ||||
|     "Intended Audience :: Developers", | ||||
|     "Intended Audience :: Education", | ||||
| classifiers=[ | ||||
|   'Development Status :: 3 - Alpha', | ||||
|   "License :: OSI Approved :: GNU Affero General Public License v3 or later (AGPLv3+)", | ||||
|   'Operating System :: POSIX :: Linux', | ||||
|   "Programming Language :: Python :: Implementation :: CPython", | ||||
|   "Programming Language :: Python :: 3 :: Only", | ||||
|   "Programming Language :: Python :: 3.11", | ||||
|   "Programming Language :: Python :: 3.12", | ||||
|   'Intended Audience :: Financial and Insurance Industry', | ||||
|   'Intended Audience :: Science/Research', | ||||
|   'Intended Audience :: Developers', | ||||
|   'Intended Audience :: Education', | ||||
| ] | ||||
| dependencies = [ | ||||
|     "async-generator >=1.10, <2.0.0", | ||||
|     "attrs >=23.1.0, <24.0.0", | ||||
|     "bidict >=0.22.1, <0.23.0", | ||||
|     "colorama >=0.4.6, <0.5.0", | ||||
|     "colorlog >=6.7.0, <7.0.0", | ||||
|     "ib-insync >=0.9.86, <0.10.0", | ||||
|     "numba >=0.59.0, <0.60.0", | ||||
|     "numpy >=1.25, <2.0", | ||||
|     "polars >=0.18.13, <0.19.0", | ||||
|     "pygments >=2.16.1, <3.0.0", | ||||
|     "rich >=13.5.2, <14.0.0", | ||||
|     "tomli >=2.0.1, <3.0.0", | ||||
|     "tomli-w >=1.0.0, <2.0.0", | ||||
|     "trio-util >=0.7.0, <0.8.0", | ||||
|     "trio-websocket >=0.10.3, <0.11.0", | ||||
|     "typer >=0.9.0, <1.0.0", | ||||
|     "rapidfuzz >=3.5.2, <4.0.0", | ||||
|     "pdbp >=1.5.0, <2.0.0", | ||||
|     "trio >=0.24, <0.25", | ||||
|     "pendulum >=3.0.0, <4.0.0", | ||||
|     "httpx >=0.27.0, <0.28.0", | ||||
|     "cryptofeed >=2.4.0, <3.0.0", | ||||
|     "pyarrow >=17.0.0, <18.0.0", | ||||
|     "websockets ==12.0", | ||||
|     "msgspec", | ||||
|     "tractor", | ||||
|     "asyncvnc", | ||||
|     "tomlkit", | ||||
| ] | ||||
| 
 | ||||
| [project.optional-dependencies] | ||||
| uis = [ | ||||
|     # https://docs.astral.sh/uv/concepts/projects/dependencies/#optional-dependencies | ||||
|     # TODO: make sure the levenshtein shit compiles on nix.. | ||||
|     # rapidfuzz = {extras = ["speedup"], version = "^0.18.0"} | ||||
|     "rapidfuzz >=3.2.0, <4.0.0", | ||||
|     "qdarkstyle >=3.0.2, <4.0.0", | ||||
|     "pyqt6 >=6.7.0, <7.0.0", | ||||
|     "pyqtgraph", | ||||
| 
 | ||||
|     # ------ - ------ | ||||
| 
 | ||||
|     # TODO: add an `--only daemon` group for running non-ui / pikerd | ||||
|     # service tree in distributed mode B) | ||||
|     # https://docs.astral.sh/uv/concepts/projects/dependencies/#optional-dependencies | ||||
|     # [project.optional-dependencies] | ||||
| ] | ||||
| 
 | ||||
| [dependency-groups] | ||||
| dev = [ | ||||
|     "pytest >=6.0.0, <7.0.0", | ||||
|     "elasticsearch >=8.9.0, <9.0.0", | ||||
|     "xonsh >=0.14.2, <0.15.0", | ||||
|     "prompt-toolkit ==3.0.40", | ||||
|     "cython >=3.0.0, <4.0.0", | ||||
|     "greenback >=1.1.1, <2.0.0", | ||||
|     # console ehancements and eventually remote debugging | ||||
|     # extras/helpers. | ||||
|     # TODO: add a toolset that makes debugging a `pikerd` service | ||||
|     # (tree) easy to hack on directly using more or less the local env: | ||||
|     # - xonsh + xxh | ||||
|     # - rsyscall + pdbp | ||||
|     # - actor runtime control console like BEAM/OTP | ||||
| ] | ||||
| 
 | ||||
| [project.scripts] | ||||
| piker = "piker.cli:cli" | ||||
| pikerd = "piker.cli:pikerd" | ||||
| ledger = "piker.accounting.cli:ledger" | ||||
| 
 | ||||
| [tool.hatch.build.targets.sdist] | ||||
| include = ["piker"] | ||||
| 
 | ||||
| [tool.hatch.build.targets.wheel] | ||||
| include = ["piker"] | ||||
| 
 | ||||
| [tool.uv.sources] | ||||
| pyqtgraph = { git = "https://github.com/pikers/pyqtgraph.git" } | ||||
| asyncvnc = { git = "https://github.com/pikers/asyncvnc.git", branch = "main" } | ||||
| tomlkit = { git = "https://github.com/pikers/tomlkit.git", branch ="piker_pin" } | ||||
| msgspec = { git = "https://github.com/jcrist/msgspec.git" } | ||||
| tractor = { path = "../tractor" } | ||||
|  |  | |||
		Loading…
	
		Reference in New Issue