connamara.ep3.v1beta1              # Core API services
├── MarketDataSubscriptionAPI      # Market data streaming
├── OrderEntryAPI                  # Order streaming and entry
└── common.proto                   # Common message types

connamara.ep3.orders.v1beta1       # Order-specific types
└── orders.proto                   # Order enums and messages

connamara.ep3.instruments.v1beta1  # Instrument types
└── instruments.proto              # Instrument statistics

# List all services using grpcurl
grpcurl traderapi.us-east-1.privatelink.preprod.polymarketexchange.com:443 list

# Describe a specific service
grpcurl traderapi.us-east-1.privatelink.preprod.polymarketexchange.com:443 describe \
  connamara.ep3.v1beta1.MarketDataSubscriptionAPI

python -m grpc_tools.protoc \
  --python_out=. \
  --grpc_python_out=. \
  --proto_path=protos \
  protos/connamara/ep3/v1beta1/market_data.proto \
  protos/connamara/ep3/v1beta1/order_entry.proto \
  protos/connamara/ep3/orders/v1beta1/orders.proto \
  protos/connamara/ep3/instruments/v1beta1/instruments.proto \
  protos/connamara/ep3/type/v1beta1/common.proto

service MarketDataSubscriptionAPI {
    rpc CreateMarketDataSubscription(CreateMarketDataSubscriptionRequest)
        returns (stream CreateMarketDataSubscriptionResponse);
}

from connamara.ep3.v1beta1 import market_data_pb2
from connamara.ep3.v1beta1 import market_data_pb2_grpc

# Create request
request = market_data_pb2.CreateMarketDataSubscriptionRequest(
    symbols=["mlb-ari-sf-2025-09-08"],
    depth=10
)

# Use stub
stub = market_data_pb2_grpc.MarketDataSubscriptionAPIStub(channel)
response_stream = stub.CreateMarketDataSubscription(request, metadata=metadata)

# Check event type
if response.HasField('heartbeat'):
    # Heartbeat message
    pass
elif response.HasField('update'):
    # Market data update
    update = response.update

# price_scale from instrument metadata (via list_instruments API)
px = bid.px / price_scale
qty = bid.qty
symbol_sub_type = bid.symbol_sub_type

from connamara.ep3.v1beta1 import market_data_pb2

# Get state name
state_name = market_data_pb2.InstrumentState.Name(update.state)

# Check if open
if update.state == market_data_pb2.INSTRUMENT_STATE_OPEN:
    print("Market is open for trading")

# Check if stats field exists
if update.HasField('stats'):
    stats = update.stats

    # price_scale from instrument metadata
    if stats.HasField('last_trade_px'):
        last_px = stats.last_trade_px / price_scale
        print(f"Last Trade: ${last_px:.4f}")

service OrderEntryAPI {
    rpc CreateOrderSubscription(CreateOrderSubscriptionRequest)
        returns (stream CreateOrderSubscriptionResponse);
}

from connamara.ep3.v1beta1 import order_entry_pb2
from connamara.ep3.v1beta1 import order_entry_pb2_grpc
from connamara.ep3.orders.v1beta1 import orders_pb2

# Create request
request = order_entry_pb2.CreateOrderSubscriptionRequest(
    symbols=["mlb-ari-sf-2025-09-08"],
    accounts=[],
    snapshot_only=False
)

# Use stub
stub = order_entry_pb2_grpc.OrderEntryAPIStub(channel)
response_stream = stub.CreateOrderSubscription(request, metadata=metadata)

# Check event type
if response.HasField('heartbeat'):
    pass
elif response.HasField('snapshot'):
    snapshot = response.snapshot
    for order in snapshot.orders:
        # Process order
        pass
elif response.HasField('update'):
    update = response.update
    for execution in update.executions:
        # Process execution
        pass

# Access session ID
session_id = response.session_id

# Access order fields
print(f"Order ID: {order.id}")
print(f"Symbol: {order.symbol}")
print(f"Side: {orders_pb2.Side.Name(order.side)}")
print(f"State: {orders_pb2.OrderState.Name(order.state)}")

if order.price > 0:
    price = order.price / order.price_scale
    print(f"Price: ${price:.4f}")

# Process execution
exec_type = orders_pb2.ExecutionType.Name(execution.type)
print(f"Execution Type: {exec_type}")

if execution.last_shares > 0:
    fill_px = execution.last_px / execution.order.price_scale
    print(f"Fill: {execution.last_shares} @ ${fill_px:.4f}")

if execution.order_reject_reason != orders_pb2.ORD_REJECT_REASON_UNDEFINED:
    reject_reason = orders_pb2.OrdRejectReason.Name(execution.order_reject_reason)
    print(f"Rejected: {reject_reason}")

from connamara.ep3.orders.v1beta1 import orders_pb2

# Get type name
type_name = orders_pb2.OrderType.Name(order.type)

# Get side name
side_name = orders_pb2.Side.Name(order.side)

# Check side
if order.side == orders_pb2.SIDE_BUY:
    print("Buy order")

tif_name = orders_pb2.TimeInForce.Name(order.time_in_force)

state_name = orders_pb2.OrderState.Name(order.state)

if order.state == orders_pb2.ORDER_STATE_FILLED:
    print("Order completely filled")

exec_type = orders_pb2.ExecutionType.Name(execution.type)

if execution.type == orders_pb2.EXECUTION_TYPE_FILL:
    print("Order completely filled")

if execution.order_reject_reason != orders_pb2.ORD_REJECT_REASON_UNDEFINED:
    reason = orders_pb2.OrdRejectReason.Name(execution.order_reject_reason)
    print(f"Reject Reason: {reason}")

from datetime import datetime

# Check if field is set
if order.HasField('insert_time'):
    # Convert to Python datetime
    insert_dt = datetime.fromtimestamp(order.insert_time.seconds)
    print(f"Inserted at: {insert_dt}")

# Use HasField() for optional fields
if update.HasField('stats'):
    # price_scale from instrument metadata
    if update.stats.HasField('last_trade_px'):
        last_px = update.stats.last_trade_px / price_scale