logsSubscribe RPC Method

Parameters

filters

string

all

string

allWithVotes

string

object

mentions

array

encoding

object

array

commitment

string

finalized

string

confirmed

string

processed

string

Returns

result

integer

Notification Format:

object

signature

string

err

object

logs

array

Request

import { createSolanaRpcSubscriptions, address } from '@solana/kit';

const rpcSubscriptions = createSolanaRpcSubscriptions('');

async function main() {
    const publicKeyString = address('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk');
    const abortController = new AbortController();

    const subscription = await rpcSubscriptions
        .logsNotifications({ mentions: [publicKeyString] })
        .subscribe(
            { abortSignal: abortController.signal }
        );

        try {
            for await (const notification of subscription) {
                console.log("Updated account info: ", notification);
            }
        } catch (e) {
            console.error("Error in logs subscription:", e);
        } finally {
            abortController.abort();
            console.log('Unsubscribed from logs');
        }
}

main();

const web3 = require("@solana/web3.js");
(async () => {
  const publicKey = new web3.PublicKey(
    "E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"
  );
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
    wsEndpoint: "",
  });
  solanaConnection.onLogs(
    publicKey,
    (logs, context) => console.log("Updated account info: ", logs),
    "confirmed"
  );
})();

import solana
import asyncio
from asyncstdlib import enumerate
from solana.rpc.websocket_api import connect

async def main():
    async with connect("") as websocket:
        await websocket.log_subscribe()
        first_resp = await websocket.recv()
        subscription_id = first_resp.result
        async for idx, msg in enumerate(websocket):
            print(msg)

asyncio.run(main())

wscat -c  \ 
# wait for connection 
{"jsonrpc": "2.0", "id": 1, "method": "logsSubscribe", "params": [{"mentions": ["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"]}, {"commitment": "finalized"}]}

Response

{
  "jsonrpc": "2.0",
  "result": 24040,
  "id": 1
}

Don't have an account yet?

Create your QuickNode endpoint in seconds and start building

Get started for free

logsSubscribe RPC Method

Loading...

Parameters

Returns