Python

python -m pip install grpcio grpcio-tools protobuf

git clone https://github.com/anthid-labs/proto.git anthid-proto

cd anthid-proto

mkdir -p ../generated/python

python -m grpc_tools.protoc \
  -I . \
  --python_out=../generated/python \
  --grpc_python_out=../generated/python \
  $(find . -name "*.proto")

metadata = (
    ("x-api-key", "YOUR_API_KEY"),
)

import grpc

from generated import trading_pb2
from generated import trading_pb2_grpc


API_KEY = "YOUR_API_KEY"

request = trading_pb2.Subscribe(
    trading_account_id="YOUR_TRADING_ACCOUNT_ID",
    subscriptions=[
        trading_pb2.EVENT_TYPE_BROKER_ORDER,
        trading_pb2.EVENT_TYPE_BROKER_POSITION,
    ],
)

credentials = grpc.ssl_channel_credentials()

with grpc.secure_channel(
    "stream.anthid.com:443",
    credentials,
) as channel:
    stub = trading_pb2_grpc.TradingServiceStub(
        channel,
    )

    stream = stub.SubscribeEvents(
        request,
        metadata=(
            ("x-api-key", API_KEY),
        ),
    )

    for event in stream:
        if event.HasField("heartbeat"):
            print("heartbeat")

        elif event.HasField("status"):
            print(
                "status:",
                event.status.message,
            )

        elif event.HasField("error"):
            print(
                "error:",
                event.error.message,
            )

        elif event.HasField("broker_order"):
            print(
                "order:",
                event.broker_order,
            )

        elif event.HasField("broker_position"):
            print(
                "position:",
                event.broker_position,
            )

import grpc

from generated import trading_pb2
from generated import trading_pb2_grpc


def requests():
    yield trading_pb2.StreamEventsRequest(
        subscribe=trading_pb2.Subscribe(
            trading_account_id=
                "YOUR_TRADING_ACCOUNT_ID",
            subscriptions=[
                trading_pb2.EVENT_TYPE_BROKER_ORDER,
                trading_pb2.EVENT_TYPE_BROKER_POSITION,
            ],
        )
    )

    while True:
        pass


credentials = grpc.ssl_channel_credentials()

with grpc.secure_channel(
    "stream.anthid.com:443",
    credentials,
) as channel:
    stub = trading_pb2_grpc.TradingServiceStub(
        channel,
    )

    stream = stub.StreamEvents(
        requests(),
        metadata=(
            ("x-api-key", "YOUR_API_KEY"),
        ),
    )

    for event in stream:
        print(event)