Merge pull request #298 from drift-labs/grpc-extned
use grpc for drift client for dlob publishers
This commit is contained in:
@@ -324,7 +324,24 @@ const main = async () => {
|
|||||||
let accountSubscription: DriftClientSubscriptionConfig;
|
let accountSubscription: DriftClientSubscriptionConfig;
|
||||||
let slotSource: SlotSource;
|
let slotSource: SlotSource;
|
||||||
|
|
||||||
if (!useWebsocket) {
|
// USE_GRPC=true will override websocket
|
||||||
|
if (useGrpc) {
|
||||||
|
accountSubscription = {
|
||||||
|
type: 'grpc',
|
||||||
|
resubTimeoutMs: 30_000,
|
||||||
|
grpcConfigs: {
|
||||||
|
endpoint,
|
||||||
|
token,
|
||||||
|
},
|
||||||
|
};
|
||||||
|
|
||||||
|
slotSubscriber = new SlotSubscriber(connection);
|
||||||
|
await slotSubscriber.subscribe();
|
||||||
|
|
||||||
|
slotSource = {
|
||||||
|
getSlot: () => slotSubscriber!.getSlot(),
|
||||||
|
};
|
||||||
|
} else if (!useWebsocket) {
|
||||||
bulkAccountLoader = new BulkAccountLoader(
|
bulkAccountLoader = new BulkAccountLoader(
|
||||||
connection,
|
connection,
|
||||||
stateCommitment,
|
stateCommitment,
|
||||||
|
|||||||
Reference in New Issue
Block a user