Skip to main content

SolanaChainEvents

Defined in: atomiq-chain-solana/src/solana/events/SolanaChainEvents.ts:13

Event handler for backend Node.js systems with access to fs, uses HTTP polling in combination with WS to not miss any events

Extends​

Constructors​

Constructor​

new SolanaChainEvents(
directory,
connection,
solanaSwapProgram,
logFetchInterval?): SolanaChainEvents;

Defined in: atomiq-chain-solana/src/solana/events/SolanaChainEvents.ts:21

Parameters​

ParameterType
directorystring
connectionConnection
solanaSwapProgramSolanaSwapProgram
logFetchInterval?number

Returns​

SolanaChainEvents

Overrides​

SolanaChainEventsBrowser.constructor

Methods​

init()​

init(noAutomaticPoll?): Promise<void>;

Defined in: atomiq-chain-solana/src/solana/events/SolanaChainEvents.ts:97

Initializes the chains event listener, by default this initiates a websocket events subscription or HTTP polling for new events.

Parameters​

ParameterTypeDescription
noAutomaticPoll?booleanWhen this flag is passed the listener doesn't initiate the websocket events subscription or HTTP polling, instead it relies on the implementor calling the ChainEvents.poll to fetch new events

Returns​

Promise<void>

Overrides​

SolanaChainEventsBrowser.init


poll()​

poll(lastSignature?): Promise<SolanaEventListenerState>;

Defined in: atomiq-chain-solana/src/solana/events/SolanaChainEventsBrowser.ts:404

Triggers a single poll on the events instance, usually ran automatically, but should be called manually when initiated with noAutomaticPoll=true

Parameters​

ParameterTypeDescription
lastSignature?SolanaEventListenerStateThe current state of the chain events

Returns​

Promise<SolanaEventListenerState>

The new state that should be saved, persisted and passed to the subsequent poll() call

Inherited from​

SolanaChainEventsBrowser.poll


registerListener()​

registerListener(cbk): void;

Defined in: atomiq-chain-solana/src/solana/events/SolanaChainEventsBrowser.ts:437

Registers a new listener to listen for on-chain events

Parameters​

ParameterTypeDescription
cbkEventListener<SolanaSwapData>

Returns​

void

Inherited from​

SolanaChainEventsBrowser.registerListener


stop()​

stop(): Promise<void>;

Defined in: atomiq-chain-solana/src/solana/events/SolanaChainEvents.ts:110

Stops the event listener's polling and websocket subscription

Returns​

Promise<void>

Overrides​

SolanaChainEventsBrowser.stop


unregisterListener()​

unregisterListener(cbk): boolean;

Defined in: atomiq-chain-solana/src/solana/events/SolanaChainEventsBrowser.ts:444

Unregisters a previously registered events listener, returning true if success, false if failed

Parameters​

ParameterTypeDescription
cbkEventListener<SolanaSwapData>

Returns​

boolean

Inherited from​

SolanaChainEventsBrowser.unregisterListener