Support Board

output_file_name = f"datas/{product}_OKX.scid"
record_struct = struct.Struct('Q f f f f I I I I')
record_length = struct.calcsize('Q f f f f I I I I')

with open(output_file_name, 'rb') as scid_file:
scid_file.seek(-record_length, os.SEEK_END)
record_data = scid_file.read(record_length)
timestamp, _, _, _, _, _, _, _, _ = struct.unpack('Q f f f f I I I I', record_data)
scid_last_timestamp = int((timestamp / 1000) + int((dt(1899, 12, 30) - dt(1970, 1, 1)).total_seconds() * 1000))
print(f"SCID LAST TIMESTAMP: {scid_last_timestamp}")

async def send_security_definitions(writer):
with open(QUOTE_BOARD_FILE_LOCATION, 'w') as file:
for product in PRICES_DICT:
file.write(f"{product}_OKX\n")

total_products = len(PRICES_DICT)

for index, product in enumerate(PRICES_DICT):
instrument_data = INSTRUMENTS_DICT.get(product, {})
multiplier = PRODUCT_MULTIPLIERS.get(product, 1)
tick_size = str((Decimal(instrument_data.get('tick_size', 0)) * multiplier).normalize())
tick_value = str((Decimal(instrument_data.get('tick_size', 0)) * (Decimal(instrument_data.get('ct_value', 0)))).normalize())
decimal_places = len(tick_size.split('.')[1]) if '.' in tick_size else 0
price_display_format = decimal_places if decimal_places <= 9 else -1

product_prefix = product.split('-')[0]
description = await get_product_descriptions(product_prefix)

format_string = '2Hi64s16si64sfifB2f32sBfBIi3fIfBf64si2f8sfIB'
security_definition_data = struct.pack(
format_string,
struct.calcsize(format_string), # Size (uint16)
dtc["SECURITY_DEFINITION_RESPONSE"], # Type (uint16)
0, # RequestID (int32)
product.encode('ascii'), # Symbol (char, 64 bytes)
b"OKX", # Exchange (char, 16 bytes)
0, # SecurityType (int32)
description.encode('ascii'), # Description (char, 64 bytes)
float(tick_size), # MinPriceIncrement (float)
price_display_format, # PriceDisplayFormat (int32)
float(tick_value), # CurrencyValuePerIncrement (float)
1 if index == total_products - 1 else 0, # IsFinalMessage (uint8)
1.0, # FloatToIntPriceMultiplier (float)
1.0, # IntegerToFloatPriceDivisor (float)
b"", # UnderlyingSymbol (char, 32 bytes)
0, # UpdatesBidAskOnly (uint8)
0.0, # StrikePrice (float)
0, # PutOrCall (uint8)
0, # ShortInterest (uint32)
0, # SecurityExpirationDate (int32)
0.0, # BuyRolloverInterest (float)
0.0, # SellRolloverInterest (float)
0.0, # EarningsPerShare (float)
0, # SharesOutstanding (uint32)
0.0, # IntToFloatQuantityDivisor (float)
0, # HasMarketDepthData (uint8)
1.0, # DisplayPriceMultiplier (float)
b"", # ExchangeSymbol (char, 64 bytes)
0, # RolloverDate (int32)
0.0, # InitialMarginRequirement (float)
0.0, # MaintenanceMarginRequirement (float)
b"USDT", # Currency (char, 8 bytes)
0.0, # ContractSize (float)
0, # OpenInterest (uint32)
0 # IsDelayed (uint8)
)

writer.write(security_definition_data)
await writer.drain()

cat dtc.h | grep pragma
#pragma once
// not beneficial. So this could be changed to #pragma pack(1). It is
#pragma pack(push, 8)
#pragma pack(push, 1)
#pragma pack(pop)
#pragma pack(push, 1)
#pragma pack(pop)
#pragma pack(push, 1)
#pragma pack(pop)
#pragma pack(push, 1)
#pragma pack(pop)
#pragma pack(push, 1)
#pragma pack(pop)
#pragma pack(pop)

Side = trade['side']
Side = dtc_pb2.AtBidOrAskEnum.AT_BID if Side.upper() == "SELL" else dtc_pb2.AtBidOrAskEnum.AT_ASK
Price = float(trade['px']) * multiplier
Volume = int(trade['sz']) / 1.0
DateTime = int(trade['ts']) / 1000.0
LastTradeId = int(trade['tradeId'])

MarketDataUpdateTrade = dtc_pb2.MarketDataUpdateTrade()
MarketDataUpdateTrade.SymbolID = SymbolID
MarketDataUpdateTrade.AtBidOrAsk = Side
MarketDataUpdateTrade.Price = Price
MarketDataUpdateTrade.Volume = Volume
MarketDataUpdateTrade.DateTime = DateTime

SerializedMarketDataUpdateTrade = MarketDataUpdateTrade.SerializeToString()

DeserializedMarketDataUpdateTrade = dtc_pb2.MarketDataUpdateTrade()
DeserializedMarketDataUpdateTrade.ParseFromString(SerializedMarketDataUpdateTrade)
print("Deserialized DateTime: ", DeserializedMarketDataUpdateTrade.DateTime)

SerializedMarketDataUpdateTradeSize = len(SerializedMarketDataUpdateTrade) + 4
Header = struct.pack('<HH', SerializedMarketDataUpdateTradeSize, dtc_pb2.DTCMessageType.MARKET_DATA_UPDATE_TRADE)
FullSerializedMarketDataUpdateTrade = Header + SerializedMarketDataUpdateTrade

writer.write(FullSerializedMarketDataUpdateTrade)
await writer.drain()