/streams/rest/v1/streams/test_filter REST API Endpoint

Body Parameters

network

string

REQUIRED

Loading...

dataset

string

REQUIRED

Loading...

filter_function

string<base64>

REQUIRED

Loading...

block

string

REQUIRED

Loading...

Returns

result

string

Loading...

Request

1
curl -X POST \
2
    "https://api.quicknode.com/streams/rest/v1/streams/test_filter" \
3
    -H "accept: application/json" \
4
    -H "Content-Type: application/json" \
5
    -H "x-api-key: YOUR_API_KEY" \
6
    -d $'{
7
  "network": "ethereum-mainnet",
8
  "dataset": "block",
9
  "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
10
  "block": "17811625"
11
}'
12
    

1
curl -X POST \
2
    "https://api.quicknode.com/streams/rest/v1/streams/test_filter" \
3
    -H "accept: application/json" \
4
    -H "Content-Type: application/json" \
5
    -H "x-api-key: YOUR_API_KEY" \
6
    -d $'{
7
  "network": "ethereum-mainnet",
8
  "dataset": "block",
9
  "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
10
  "block": "17811625"
11
}'
12
    

1
import { QuicknodeSdk, StreamDataset } from "@quicknode/sdk"
2

3
const qn = new QuicknodeSdk({ apiKey: "YOUR_API_KEY" })
4

5
const filterFunction = Buffer.from(`
6
function main(data) {
7
	return data
8
}
9
`).toString("base64")
10

11
const result = await qn.streams.testFilter({
12
	network: "ethereum-mainnet",
13
	dataset: StreamDataset.Block,
14
	block: "17811625",
15
	filterFunction,
16
})
17

18
console.log("logs:", result.logs)
19
console.log("result:", result.result)
20

1
import { QuicknodeSdk, StreamDataset } from "@quicknode/sdk"
2

3
const qn = new QuicknodeSdk({ apiKey: "YOUR_API_KEY" })
4

5
const filterFunction = Buffer.from(`
6
function main(data) {
7
	return data
8
}
9
`).toString("base64")
10

11
const result = await qn.streams.testFilter({
12
	network: "ethereum-mainnet",
13
	dataset: StreamDataset.Block,
14
	block: "17811625",
15
	filterFunction,
16
})
17

18
console.log("logs:", result.logs)
19
console.log("result:", result.result)
20

1
import asyncio
2
import base64
3
from quicknode_sdk import QuicknodeSdk, SdkFullConfig
4

5

6
async def main():
7
    qn = QuicknodeSdk(SdkFullConfig(api_key="YOUR_API_KEY"))
8

9
    filter_function = base64.b64encode(
10
        b"function main(data) { return data; }"
11
    ).decode()
12

13
    result = await qn.streams.test_filter(
14
        network="ethereum-mainnet",
15
        dataset="block",
16
        block="17811625",
17
        filter_function=filter_function,
18
    )
19

20
    print("logs:", result.logs)
21
    print("result:", result.result)
22

23

24
asyncio.run(main())
25

1
import asyncio
2
import base64
3
from quicknode_sdk import QuicknodeSdk, SdkFullConfig
4

5

6
async def main():
7
    qn = QuicknodeSdk(SdkFullConfig(api_key="YOUR_API_KEY"))
8

9
    filter_function = base64.b64encode(
10
        b"function main(data) { return data; }"
11
    ).decode()
12

13
    result = await qn.streams.test_filter(
14
        network="ethereum-mainnet",
15
        dataset="block",
16
        block="17811625",
17
        filter_function=filter_function,
18
    )
19

20
    print("logs:", result.logs)
21
    print("result:", result.result)
22

23

24
asyncio.run(main())
25

1
require "base64"
2
require "quicknode_sdk"
3

4
qn = QuicknodeSdk::SDK.from_config(api_key: "YOUR_API_KEY")
5

6
filter_function = Base64.strict_encode64("function main(data) { return data; }")
7

8
result = qn.streams.test_filter(
9
  network: "ethereum-mainnet",
10
  dataset: "block",
11
  block: "17811625",
12
  filter_function: filter_function,
13
)
14

15
puts "logs: #{result["logs"]}"
16
puts "result: #{result["result"]}"
17

1
require "base64"
2
require "quicknode_sdk"
3

4
qn = QuicknodeSdk::SDK.from_config(api_key: "YOUR_API_KEY")
5

6
filter_function = Base64.strict_encode64("function main(data) { return data; }")
7

8
result = qn.streams.test_filter(
9
  network: "ethereum-mainnet",
10
  dataset: "block",
11
  block: "17811625",
12
  filter_function: filter_function,
13
)
14

15
puts "logs: #{result["logs"]}"
16
puts "result: #{result["result"]}"
17

1
use quicknode_sdk::{
2
    streams::{StreamDataset, TestFilterParams},
3
    QuicknodeSdk,
4
    SdkFullConfig,
5
};
6

7
#[tokio::main]
8
async fn main() -> Result<(), Box<dyn std::error::Error>> {
9
    let qn = QuicknodeSdk::new(&SdkFullConfig::builder().api_key("YOUR_API_KEY").build())?;
10

11
    // Base64-encoded: function main(data) { return data; }
12
    let filter_function = "ZnVuY3Rpb24gbWFpbihkYXRhKSB7IHJldHVybiBkYXRhOyB9".to_string();
13

14
    let params = TestFilterParams {
15
        network: "ethereum-mainnet".to_string(),
16
        dataset: StreamDataset::Block,
17
        block: "17811625".to_string(),
18
        filter_function: Some(filter_function),
19
        filter_language: None,
20
        address_book_config: None,
21
    };
22
    let result = qn.streams.test_filter(&params).await?;
23

24
    println!("logs: {:?}", result.logs);
25
    println!("result: {}", result.result);
26
    Ok(())
27
}
28

1
use quicknode_sdk::{
2
    streams::{StreamDataset, TestFilterParams},
3
    QuicknodeSdk,
4
    SdkFullConfig,
5
};
6

7
#[tokio::main]
8
async fn main() -> Result<(), Box<dyn std::error::Error>> {
9
    let qn = QuicknodeSdk::new(&SdkFullConfig::builder().api_key("YOUR_API_KEY").build())?;
10

11
    // Base64-encoded: function main(data) { return data; }
12
    let filter_function = "ZnVuY3Rpb24gbWFpbihkYXRhKSB7IHJldHVybiBkYXRhOyB9".to_string();
13

14
    let params = TestFilterParams {
15
        network: "ethereum-mainnet".to_string(),
16
        dataset: StreamDataset::Block,
17
        block: "17811625".to_string(),
18
        filter_function: Some(filter_function),
19
        filter_language: None,
20
        address_book_config: None,
21
    };
22
    let result = qn.streams.test_filter(&params).await?;
23

24
    println!("logs: {:?}", result.logs);
25
    println!("result: {}", result.result);
26
    Ok(())
27
}
28

1
var myHeaders = new Headers();
2
myHeaders.append('accept', 'application/json');
3
myHeaders.append('Content-Type', 'application/json');
4
myHeaders.append('x-api-key', 'YOUR_API_KEY'); // Replace with your actual API key
5

6
var requestOptions = {
7
  method: 'POST',
8
  headers: myHeaders,
9
  redirect: 'follow',
10
  body: JSON.stringify({
11
    network: 'ethereum-mainnet',
12
    dataset: 'block',
13
    filter_function: 'ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==',
14
    block: '17811625'
15
  })
16
};
17

18
fetch('https://api.quicknode.com/streams/rest/v1/streams/test_filter', requestOptions)
19
  .then(response => response.text())
20
  .then(result => console.log(result))
21
  .catch(error => console.log('error', error));
22

1
var myHeaders = new Headers();
2
myHeaders.append('accept', 'application/json');
3
myHeaders.append('Content-Type', 'application/json');
4
myHeaders.append('x-api-key', 'YOUR_API_KEY'); // Replace with your actual API key
5

6
var requestOptions = {
7
  method: 'POST',
8
  headers: myHeaders,
9
  redirect: 'follow',
10
  body: JSON.stringify({
11
    network: 'ethereum-mainnet',
12
    dataset: 'block',
13
    filter_function: 'ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==',
14
    block: '17811625'
15
  })
16
};
17

18
fetch('https://api.quicknode.com/streams/rest/v1/streams/test_filter', requestOptions)
19
  .then(response => response.text())
20
  .then(result => console.log(result))
21
  .catch(error => console.log('error', error));
22

1
import requests
2

3
url = "https://api.quicknode.com/streams/rest/v1/streams/test_filter"
4

5
payload = {
6
    "network": "ethereum-mainnet",
7
    "dataset": "block",
8
    "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
9
    "block": "17811625"
10
}
11

12
headers = {
13
    "accept": "application/json",
14
    "Content-Type": "application/json",
15
    "x-api-key": "YOUR_API_KEY"  # Replace with your actual API key
16
}
17

18
response = requests.post(url, headers=headers, json=payload)
19

20
print(response.text)
21

1
import requests
2

3
url = "https://api.quicknode.com/streams/rest/v1/streams/test_filter"
4

5
payload = {
6
    "network": "ethereum-mainnet",
7
    "dataset": "block",
8
    "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
9
    "block": "17811625"
10
}
11

12
headers = {
13
    "accept": "application/json",
14
    "Content-Type": "application/json",
15
    "x-api-key": "YOUR_API_KEY"  # Replace with your actual API key
16
}
17

18
response = requests.post(url, headers=headers, json=payload)
19

20
print(response.text)
21

1
require "uri"
2
require "net/http"
3
require "json"
4

5
# Set up the URL for the request
6
url = URI("https://api.quicknode.com/streams/rest/v1/streams/test_filter")
7

8
https = Net::HTTP.new(url.host, url.port)
9
https.use_ssl = true
10

11
request = Net::HTTP::Post.new(url)
12
request["accept"] = "application/json"
13
request["Content-Type"] = "application/json"
14
request["x-api-key"] = "YOUR_API_KEY"  # Replace with your actual API key
15

16
request.body = {
17
  "network" => "ethereum-mainnet",
18
  "dataset" => "block",
19
  "filter_function" => "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
20
  "block" => "17811625"
21
}.to_json
22

23
response = https.request(request)
24
puts response.body
25

1
require "uri"
2
require "net/http"
3
require "json"
4

5
# Set up the URL for the request
6
url = URI("https://api.quicknode.com/streams/rest/v1/streams/test_filter")
7

8
https = Net::HTTP.new(url.host, url.port)
9
https.use_ssl = true
10

11
request = Net::HTTP::Post.new(url)
12
request["accept"] = "application/json"
13
request["Content-Type"] = "application/json"
14
request["x-api-key"] = "YOUR_API_KEY"  # Replace with your actual API key
15

16
request.body = {
17
  "network" => "ethereum-mainnet",
18
  "dataset" => "block",
19
  "filter_function" => "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
20
  "block" => "17811625"
21
}.to_json
22

23
response = https.request(request)
24
puts response.body
25

Try in Swagger

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free