trade/trade-drift-dlob
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' into mainnet-beta

Browse Source
This commit is contained in:
wphan
2024-12-05 15:45:41 -08:00
parent 5755077161 e8feb96ee5
commit dae81b2712
1 changed files with 25 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/publishers/dlobPublisher.ts
View File

@@ -324,29 +324,34 @@ const main = async () => {
let accountSubscription: DriftClientSubscriptionConfig; let accountSubscription: DriftClientSubscriptionConfig;
let slotSource: SlotSource; let slotSource: SlotSource;
// NOTE: disable GRPC for general driftClient subscriptions until we can reliably subscribe
// to multiple streams. Currently this causes the nodes to start killing connections.
//
// USE_GRPC=true will override websocket // USE_GRPC=true will override websocket
if (useGrpc) { // if (useGrpc) {
accountSubscription = { // accountSubscription = {
type: 'grpc', // type: 'grpc',
resubTimeoutMs: 30_000, // resubTimeoutMs: 30_000,
grpcConfigs: { // grpcConfigs: {
endpoint, // endpoint,
token, // token,
channelOptions: { // channelOptions: {
'grpc.keepalive_time_ms': 10_000, // 'grpc.keepalive_time_ms': 10_000,
'grpc.keepalive_timeout_ms': 1_000, // 'grpc.keepalive_timeout_ms': 1_000,
'grpc.keepalive_permit_without_calls': 1, // 'grpc.keepalive_permit_without_calls': 1,
}, // },
}, // },
}; // };
slotSubscriber = new SlotSubscriber(connection); // slotSubscriber = new SlotSubscriber(connection);
await slotSubscriber.subscribe(); // await slotSubscriber.subscribe();
slotSource = { // slotSource = {
getSlot: () => slotSubscriber!.getSlot(), // getSlot: () => slotSubscriber!.getSlot(),
}; // };
} else if (!useWebsocket) { // }
if (!useWebsocket) {
bulkAccountLoader = new BulkAccountLoader( bulkAccountLoader = new BulkAccountLoader(
connection, connection,
stateCommitment, stateCommitment,