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 (import <nixpkgs> {});
|
||||||
|
with python312Packages;
|
||||||
let
|
let
|
||||||
glibStorePath = lib.getLib glib;
|
glibStorePath = lib.getLib glib;
|
||||||
zlibStorePath = lib.getLib zlib;
|
qtpyStorePath = lib.getLib qtpy;
|
||||||
zstdStorePath = lib.getLib zstd;
|
pyqt6StorePath = lib.getLib pyqt6;
|
||||||
dbusStorePath = lib.getLib dbus;
|
pyqt6SipStorePath = lib.getLib pyqt6-sip;
|
||||||
libGLStorePath = lib.getLib libGL;
|
|
||||||
freetypeStorePath = lib.getLib freetype;
|
|
||||||
qt6baseStorePath = lib.getLib qt6.qtbase;
|
qt6baseStorePath = lib.getLib qt6.qtbase;
|
||||||
fontconfigStorePath = lib.getLib fontconfig;
|
rapidfuzzStorePath = lib.getLib rapidfuzz;
|
||||||
libxkbcommonStorePath = lib.getLib libxkbcommon;
|
qdarkstyleStorePath = lib.getLib qdarkstyle;
|
||||||
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;
|
|
||||||
in
|
in
|
||||||
stdenv.mkDerivation {
|
stdenv.mkDerivation {
|
||||||
name = "piker-qt6-uv";
|
name = "piker-qt6-poetry-shell";
|
||||||
buildInputs = [
|
buildInputs = [
|
||||||
# System requirements.
|
# System requirements.
|
||||||
glib
|
glib
|
||||||
zlib
|
|
||||||
dbus
|
|
||||||
zstd
|
|
||||||
libGL
|
|
||||||
freetype
|
|
||||||
qt6.qtbase
|
qt6.qtbase
|
||||||
libgcc.lib
|
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.
|
# Python requirements.
|
||||||
python312Full
|
python312Full
|
||||||
python312Packages.uv
|
poetry-core
|
||||||
python312Packages.qdarkstyle
|
qdarkstyle
|
||||||
python312Packages.rapidfuzz
|
rapidfuzz
|
||||||
python312Packages.pyqt6
|
pyqt6
|
||||||
python312Packages.qtpy
|
qtpy
|
||||||
];
|
];
|
||||||
src = null;
|
src = null;
|
||||||
shellHook = ''
|
shellHook = ''
|
||||||
set -e
|
set -e
|
||||||
|
|
||||||
|
export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:${libgcc.lib}/lib:${glibStorePath}/lib
|
||||||
|
|
||||||
# Set the Qt plugin path
|
# Set the Qt plugin path
|
||||||
# export QT_DEBUG_PLUGINS=1
|
# export QT_DEBUG_PLUGINS=1
|
||||||
|
|
||||||
QTBASE_PATH="${qt6baseStorePath}/lib"
|
QTBASE_PATH="${qt6baseStorePath}"
|
||||||
QT_PLUGIN_PATH="$QTBASE_PATH/qt-6/plugins"
|
echo "qtbase path: $QTBASE_PATH"
|
||||||
QT_QPA_PLATFORM_PLUGIN_PATH="$QT_PLUGIN_PATH/platforms"
|
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"
|
# Maybe create venv & install deps
|
||||||
GLIB_PATH="${glibStorePath}/lib"
|
poetry install --with uis
|
||||||
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"
|
|
||||||
|
|
||||||
XCB_UTIL_CURSOR_PATH="${xcbutilcursorStorePath}/lib"
|
# Use pyqt6 from System, patch activate script
|
||||||
XORG_LIB_X11_PATH="${xorgLibX11StorePath}/lib"
|
ACTIVATE_SCRIPT_PATH="$(poetry env info --path)/bin/activate"
|
||||||
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"
|
|
||||||
|
|
||||||
LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QTBASE_PATH"
|
export RPDFUZZ_PATH="${rapidfuzzStorePath}/lib/python3.12/site-packages"
|
||||||
LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QT_PLUGIN_PATH"
|
export QDRKSTYLE_PATH="${qdarkstyleStorePath}/lib/python3.12/site-packages"
|
||||||
LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QT_QPA_PLATFORM_PLUGIN_PATH"
|
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"
|
PATCH="export PYTHONPATH=\""
|
||||||
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"
|
|
||||||
|
|
||||||
LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XCB_UTIL_CURSOR_PATH"
|
PATCH="$PATCH\$RPDFUZZ_PATH"
|
||||||
LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_LIB_X11_PATH"
|
PATCH="$PATCH:\$QDRKSTYLE_PATH"
|
||||||
LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_LIB_XCB_PATH"
|
PATCH="$PATCH:\$QTPY_PATH"
|
||||||
LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_XCB_UTIL_IMAGE_PATH"
|
PATCH="$PATCH:\$PYQT6_PATH"
|
||||||
LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$XORG_XCB_UTIL_WM_PATH"
|
PATCH="$PATCH:\$PYQT6_SIP_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"
|
|
||||||
|
|
||||||
export LD_LIBRARY_PATH
|
PATCH="$PATCH\""
|
||||||
|
|
||||||
RPDFUZZ_PATH="${rapidfuzzStorePath}/lib/python3.12/site-packages"
|
if grep -q "$PATCH" "$ACTIVATE_SCRIPT_PATH"; then
|
||||||
QDRKSTYLE_PATH="${qdarkstyleStorePath}/lib/python3.12/site-packages"
|
echo "venv is already patched."
|
||||||
QTPY_PATH="${qtpyStorePath}/lib/python3.12/site-packages"
|
else
|
||||||
PYQT6_PATH="${pyqt6StorePath}/lib/python3.12/site-packages"
|
echo "patching $ACTIVATE_SCRIPT_PATH to use pyqt6 from nixos..."
|
||||||
PYQT6_SIP_PATH="${pyqt6SipStorePath}/lib/python3.12/site-packages"
|
sed -i "\$i$PATCH" $ACTIVATE_SCRIPT_PATH
|
||||||
|
fi
|
||||||
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
|
|
||||||
|
|
||||||
|
poetry shell
|
||||||
'';
|
'';
|
||||||
}
|
}
|
||||||
|
|
|
@ -30,8 +30,7 @@ from types import ModuleType
|
||||||
from typing import (
|
from typing import (
|
||||||
Any,
|
Any,
|
||||||
Iterator,
|
Iterator,
|
||||||
Generator,
|
Generator
|
||||||
TYPE_CHECKING,
|
|
||||||
)
|
)
|
||||||
|
|
||||||
import pendulum
|
import pendulum
|
||||||
|
@ -60,10 +59,8 @@ from ..clearing._messages import (
|
||||||
BrokerdPosition,
|
BrokerdPosition,
|
||||||
)
|
)
|
||||||
from piker.types import Struct
|
from piker.types import Struct
|
||||||
from piker.log import get_logger
|
from piker.data._symcache import SymbologyCache
|
||||||
|
from ..log import get_logger
|
||||||
if TYPE_CHECKING:
|
|
||||||
from piker.data._symcache import SymbologyCache
|
|
||||||
|
|
||||||
log = get_logger(__name__)
|
log = get_logger(__name__)
|
||||||
|
|
||||||
|
@ -496,17 +493,6 @@ class Account(Struct):
|
||||||
|
|
||||||
_mktmap_table: dict[str, MktPair] | None = None,
|
_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]:
|
) -> dict[str, Position]:
|
||||||
'''
|
'''
|
||||||
Update the internal `.pps[str, Position]` table from input
|
Update the internal `.pps[str, Position]` table from input
|
||||||
|
@ -549,32 +535,11 @@ class Account(Struct):
|
||||||
if _mktmap_table is None:
|
if _mktmap_table is None:
|
||||||
raise
|
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
|
# XXX: caller is allowed to provide a fallback
|
||||||
# mktmap table for the case where a new position is
|
# mktmap table for the case where a new position is
|
||||||
# being added and the preloaded symcache didn't
|
# being added and the preloaded symcache didn't
|
||||||
# have this entry prior (eg. with frickin IB..)
|
# have this entry prior (eg. with frickin IB..)
|
||||||
if (
|
mkt = _mktmap_table[fqme]
|
||||||
not (mkt := _mktmap_table.get(fqme))
|
|
||||||
and
|
|
||||||
required
|
|
||||||
):
|
|
||||||
raise
|
|
||||||
|
|
||||||
elif not required:
|
|
||||||
continue
|
|
||||||
|
|
||||||
else:
|
|
||||||
# should be an entry retreived somewhere
|
|
||||||
assert mkt
|
|
||||||
|
|
||||||
|
|
||||||
if not (pos := pps.get(bs_mktid)):
|
if not (pos := pps.get(bs_mktid)):
|
||||||
|
|
||||||
|
@ -691,7 +656,7 @@ class Account(Struct):
|
||||||
def write_config(self) -> None:
|
def write_config(self) -> None:
|
||||||
'''
|
'''
|
||||||
Write the current account state to the user's account TOML file, normally
|
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?
|
# TODO: show diff output?
|
||||||
|
|
|
@ -61,12 +61,13 @@ async def _setup_persistent_brokerd(
|
||||||
ctx: tractor.Context,
|
ctx: tractor.Context,
|
||||||
brokername: str,
|
brokername: str,
|
||||||
loglevel: str | None = None,
|
loglevel: str | None = None,
|
||||||
|
debug_mode: bool = False,
|
||||||
|
|
||||||
) -> None:
|
) -> None:
|
||||||
'''
|
'''
|
||||||
Allocate a actor-wide service nursery in ``brokerd``
|
Allocate a actor-wide service nursery in `brokerd` such that
|
||||||
such that feeds can be run in the background persistently by
|
feeds can be run in the background persistently by the broker
|
||||||
the broker backend as needed.
|
backend as needed.
|
||||||
|
|
||||||
'''
|
'''
|
||||||
# NOTE: we only need to setup logging once (and only) here
|
# 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
|
from piker.data import feed
|
||||||
assert not feed._bus
|
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
|
# allocate a nursery to the bus for spawning background
|
||||||
# tasks to service client IPC requests, normally
|
# tasks to service client IPC requests, normally
|
||||||
# `tractor.Context` connections to explicitly required
|
# `tractor.Context` connections to explicitly required
|
||||||
|
@ -146,18 +159,21 @@ def broker_init(
|
||||||
above.
|
above.
|
||||||
|
|
||||||
'''
|
'''
|
||||||
from ..brokers import get_brokermod
|
brokermod: ModuleType = get_brokermod(brokername)
|
||||||
brokermod = get_brokermod(brokername)
|
|
||||||
modpath: str = brokermod.__name__
|
modpath: str = brokermod.__name__
|
||||||
|
spawn_kws: dict = getattr(
|
||||||
start_actor_kwargs['name'] = f'brokerd.{brokername}'
|
brokermod,
|
||||||
start_actor_kwargs.update(
|
'_spawn_kwargs',
|
||||||
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..
|
# XXX TODO: make this not so hacky/monkeypatched..
|
||||||
# -> we need a sane way to configure the logging level for all
|
# -> 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
|
# lookup actor-enabled modules declared by the backend offering the
|
||||||
# `brokerd` endpoint(s).
|
# `brokerd` endpoint(s).
|
||||||
enabled: list[str]
|
enabled: list[str] = [
|
||||||
enabled = start_actor_kwargs['enable_modules'] = [
|
|
||||||
__name__, # so that eps from THIS mod can be invoked
|
__name__, # so that eps from THIS mod can be invoked
|
||||||
modpath,
|
modpath,
|
||||||
]
|
]
|
||||||
|
@ -180,9 +195,13 @@ def broker_init(
|
||||||
subpath: str = f'{modpath}.{submodname}'
|
subpath: str = f'{modpath}.{submodname}'
|
||||||
enabled.append(subpath)
|
enabled.append(subpath)
|
||||||
|
|
||||||
|
datad_kwargs: dict = {
|
||||||
|
'name': f'brokerd.{brokername}',
|
||||||
|
'enable_modules': enabled,
|
||||||
|
}
|
||||||
return (
|
return (
|
||||||
brokermod,
|
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)
|
# XXX see impl above; contains all (actor global)
|
||||||
# setup/teardown expected in all `brokerd` actor instances.
|
# setup/teardown expected in all `brokerd` actor instances.
|
||||||
|
@ -215,10 +234,6 @@ async def spawn_brokerd(
|
||||||
**tractor_kwargs,
|
**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
|
# ask `pikerd` to spawn a new sub-actor and manage it under its
|
||||||
# actor nursery
|
# actor nursery
|
||||||
from piker.service import (
|
from piker.service import (
|
||||||
|
@ -236,8 +251,12 @@ async def spawn_brokerd(
|
||||||
# passed to daemon_fixture_ep(**kwargs)
|
# passed to daemon_fixture_ep(**kwargs)
|
||||||
brokername=brokername,
|
brokername=brokername,
|
||||||
loglevel=loglevel,
|
loglevel=loglevel,
|
||||||
|
debug_mode=mngr.debug_mode,
|
||||||
),
|
),
|
||||||
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,
|
loglevel=loglevel,
|
||||||
enable_modules=(
|
enable_modules=(
|
||||||
_data_mods
|
_data_mods
|
||||||
|
|
|
@ -653,7 +653,6 @@ async def open_trade_dialog(
|
||||||
# in) use manually constructed table from calling
|
# in) use manually constructed table from calling
|
||||||
# the `.get_mkt_info()` provider EP above.
|
# the `.get_mkt_info()` provider EP above.
|
||||||
_mktmap_table=mkt_by_fqme,
|
_mktmap_table=mkt_by_fqme,
|
||||||
only_require=list(mkt_by_fqme),
|
|
||||||
)
|
)
|
||||||
|
|
||||||
pp_msgs: list[BrokerdPosition] = []
|
pp_msgs: list[BrokerdPosition] = []
|
||||||
|
|
|
@ -499,7 +499,7 @@ async def open_jsonrpc_session(
|
||||||
# response in original "result" msg,
|
# response in original "result" msg,
|
||||||
# THEN FINALLY set the event to signal caller
|
# THEN FINALLY set the event to signal caller
|
||||||
# to raise the error in the parent task.
|
# 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]
|
req_msg: dict = req_msgs[req_id]
|
||||||
result: dict = rpc_results[req_id]
|
result: dict = rpc_results[req_id]
|
||||||
result['error'] = error
|
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
|
# 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/>.
|
# along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||||
[build-system]
|
[build-system]
|
||||||
requires = ["hatchling"]
|
requires = ["poetry-core"]
|
||||||
build-backend = "hatchling.build"
|
build-backend = "poetry.core.masonry.api"
|
||||||
|
|
||||||
# ------ - ------
|
# ------ - ------
|
||||||
|
|
||||||
|
@ -34,114 +34,119 @@ ignore = []
|
||||||
|
|
||||||
# ------ - ------
|
# ------ - ------
|
||||||
|
|
||||||
[project]
|
[tool.poetry]
|
||||||
name = "piker"
|
name = "piker"
|
||||||
version = "0.1.0a0dev0"
|
version = "0.1.0.alpha0.dev0"
|
||||||
description = "trading gear for hackers"
|
description = "trading gear for hackers"
|
||||||
authors = [{ name = "Tyler Goodlet", email = "goodboy_foss@protonmail.com" }]
|
authors = ["Tyler Goodlet <goodboy_foss@protonmail.com>"]
|
||||||
requires-python = ">=3.12, <3.13"
|
license = "AGPLv3"
|
||||||
license = "AGPL-3.0-or-later"
|
|
||||||
readme = "README.rst"
|
readme = "README.rst"
|
||||||
keywords = [
|
|
||||||
"async",
|
# ------ - ------
|
||||||
"trading",
|
|
||||||
"finance",
|
[tool.poetry.dependencies]
|
||||||
"quant",
|
async-generator = "^1.10"
|
||||||
"charting",
|
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 = [
|
classifiers=[
|
||||||
"Development Status :: 3 - Alpha",
|
'Development Status :: 3 - Alpha',
|
||||||
"License :: OSI Approved :: GNU Affero General Public License v3 or later (AGPLv3+)",
|
"License :: OSI Approved :: GNU Affero General Public License v3 or later (AGPLv3+)",
|
||||||
"Operating System :: POSIX :: Linux",
|
'Operating System :: POSIX :: Linux',
|
||||||
"Programming Language :: Python :: Implementation :: CPython",
|
"Programming Language :: Python :: Implementation :: CPython",
|
||||||
"Programming Language :: Python :: 3 :: Only",
|
"Programming Language :: Python :: 3 :: Only",
|
||||||
"Programming Language :: Python :: 3.11",
|
"Programming Language :: Python :: 3.11",
|
||||||
"Programming Language :: Python :: 3.12",
|
"Programming Language :: Python :: 3.12",
|
||||||
"Intended Audience :: Financial and Insurance Industry",
|
'Intended Audience :: Financial and Insurance Industry',
|
||||||
"Intended Audience :: Science/Research",
|
'Intended Audience :: Science/Research',
|
||||||
"Intended Audience :: Developers",
|
'Intended Audience :: Developers',
|
||||||
"Intended Audience :: Education",
|
'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