As of May 1, 2026, this WebSocket method is billed based on metered data usage: 0.1 MB = 15 API credits. Learn more about WebSocket billing.

Parameters

program_id

string

The address encoded as a base-58 string

object

object

The configuration object with the following fields:

commitment

string

All fields are strings.

finalized

the node will query the most recent block the cluster has recognized as finalized.

confirmed

the node will query the most recent block that has been voted on by supermajority of the cluster.

processed

the node will query its most recent block. Note that the block may not be complete.

encoding

string

The encoding format for account data. It can be one of base58 (slow), base64, base64+zstd or jsonParsed

filters

string

The filter results using various filter objects; The account must meet all filter criteria to be included in results

Returns

result

integer

The result will be an RpcResponse JSON object with id equal to the subscription id (needed to unsubscribe)

Notification Format:

The notification format is the same as seen in the getProgramAccounts RPC HTTP method

Request

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const publicKey = new web3.PublicKey(
4
    "22Y43yTVxuUkoRKdm9thyRhQ3SdgQS7c7kB6UNCiaczD"
5
  );
6
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
7
    wsEndpoint: "",
8
  });
9
  solanaConnection.onProgramAccountChange(
10
    publicKey,
11
    (updatedProgramInfo, context) =>
12
      console.log("Updated program info: ", updatedProgramInfo),
13
    "finalized"
14
  );
15
})();
16

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const publicKey = new web3.PublicKey(
4
    "22Y43yTVxuUkoRKdm9thyRhQ3SdgQS7c7kB6UNCiaczD"
5
  );
6
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
7
    wsEndpoint: "",
8
  });
9
  solanaConnection.onProgramAccountChange(
10
    publicKey,
11
    (updatedProgramInfo, context) =>
12
      console.log("Updated program info: ", updatedProgramInfo),
13
    "finalized"
14
  );
15
})();
16

1
import solana
2
import asyncio
3
from asyncstdlib import enumerate
4
from solana.rpc.websocket_api import connect
5
from solana.publickey import PublicKey
6

7
async def main():
8
    async with connect("") as websocket:
9
        await websocket.program_subscribe(PublicKey('22Y43yTVxuUkoRKdm9thyRhQ3SdgQS7c7kB6UNCiaczD'))
10
        first_resp = await websocket.recv()
11
        subscription_id = first_resp.result
12
        async for idx, msg in enumerate(websocket):
13
            print(msg)
14

15
asyncio.run(main())

1
import solana
2
import asyncio
3
from asyncstdlib import enumerate
4
from solana.rpc.websocket_api import connect
5
from solana.publickey import PublicKey
6

7
async def main():
8
    async with connect("") as websocket:
9
        await websocket.program_subscribe(PublicKey('22Y43yTVxuUkoRKdm9thyRhQ3SdgQS7c7kB6UNCiaczD'))
10
        first_resp = await websocket.recv()
11
        subscription_id = first_resp.result
12
        async for idx, msg in enumerate(websocket):
13
            print(msg)
14

15
asyncio.run(main())

1
wscat -c  \ 
2
# wait for connection 
3
{
4
  "jsonrpc": "2.0",
5
  "id": 1,
6
  "method": "programSubscribe",
7
  "params": [
8
    "11111111111111111111111111111111",
9
    {
10
      "encoding": "base64",
11
      "commitment": "finalized"
12
    }
13
  ]
14
}

1
wscat -c  \ 
2
# wait for connection 
3
{
4
  "jsonrpc": "2.0",
5
  "id": 1,
6
  "method": "programSubscribe",
7
  "params": [
8
    "11111111111111111111111111111111",
9
    {
10
      "encoding": "base64",
11
      "commitment": "finalized"
12
    }
13
  ]
14
}

Response

1
{
2
  "jsonrpc": "2.0",
3
  "result": 24040,
4
  "id": 1
5
}

1
{
2
  "jsonrpc": "2.0",
3
  "result": 24040,
4
  "id": 1
5
}

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free