Create stream
curl --request PUT \
--url https://api.moralis-streams.com/streams/evm \
--header 'Content-Type: application/json' \
--header 'x-api-key: <api-key>' \
--data '
{
"webhookUrl": "<string>",
"description": "<string>",
"chainIds": [
"<string>"
],
"tag": "<string>",
"topic0": [
"<string>"
],
"allAddresses": true,
"includeNativeTxs": true,
"includeContractLogs": true,
"includeInternalTxs": true,
"includeAllTxLogs": true,
"getNativeBalances": [
{
"selectors": [
"<string>"
]
}
],
"abi": null,
"advancedOptions": null,
"filterPossibleSpamAddresses": true,
"demo": true,
"triggers": [
{
"contractAddress": "<string>",
"functionAbi": {},
"inputs": [
"<string>"
],
"topic0": "<string>",
"callFrom": "<string>"
}
]
}
'import requests
url = "https://api.moralis-streams.com/streams/evm"
payload = {
"webhookUrl": "<string>",
"description": "<string>",
"chainIds": ["<string>"],
"tag": "<string>",
"topic0": ["<string>"],
"allAddresses": True,
"includeNativeTxs": True,
"includeContractLogs": True,
"includeInternalTxs": True,
"includeAllTxLogs": True,
"getNativeBalances": [{ "selectors": ["<string>"] }],
"abi": None,
"advancedOptions": None,
"filterPossibleSpamAddresses": True,
"demo": True,
"triggers": [
{
"contractAddress": "<string>",
"functionAbi": {},
"inputs": ["<string>"],
"topic0": "<string>",
"callFrom": "<string>"
}
]
}
headers = {
"x-api-key": "<api-key>",
"Content-Type": "application/json"
}
response = requests.put(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'PUT',
headers: {'x-api-key': '<api-key>', 'Content-Type': 'application/json'},
body: JSON.stringify({
webhookUrl: '<string>',
description: '<string>',
chainIds: ['<string>'],
tag: '<string>',
topic0: ['<string>'],
allAddresses: true,
includeNativeTxs: true,
includeContractLogs: true,
includeInternalTxs: true,
includeAllTxLogs: true,
getNativeBalances: [{selectors: ['<string>']}],
abi: null,
advancedOptions: null,
filterPossibleSpamAddresses: true,
demo: true,
triggers: [
{
contractAddress: '<string>',
functionAbi: {},
inputs: ['<string>'],
topic0: '<string>',
callFrom: '<string>'
}
]
})
};
fetch('https://api.moralis-streams.com/streams/evm', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.moralis-streams.com/streams/evm",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "PUT",
CURLOPT_POSTFIELDS => json_encode([
'webhookUrl' => '<string>',
'description' => '<string>',
'chainIds' => [
'<string>'
],
'tag' => '<string>',
'topic0' => [
'<string>'
],
'allAddresses' => true,
'includeNativeTxs' => true,
'includeContractLogs' => true,
'includeInternalTxs' => true,
'includeAllTxLogs' => true,
'getNativeBalances' => [
[
'selectors' => [
'<string>'
]
]
],
'abi' => null,
'advancedOptions' => null,
'filterPossibleSpamAddresses' => true,
'demo' => true,
'triggers' => [
[
'contractAddress' => '<string>',
'functionAbi' => [
],
'inputs' => [
'<string>'
],
'topic0' => '<string>',
'callFrom' => '<string>'
]
]
]),
CURLOPT_HTTPHEADER => [
"Content-Type: application/json",
"x-api-key: <api-key>"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://api.moralis-streams.com/streams/evm"
payload := strings.NewReader("{\n \"webhookUrl\": \"<string>\",\n \"description\": \"<string>\",\n \"chainIds\": [\n \"<string>\"\n ],\n \"tag\": \"<string>\",\n \"topic0\": [\n \"<string>\"\n ],\n \"allAddresses\": true,\n \"includeNativeTxs\": true,\n \"includeContractLogs\": true,\n \"includeInternalTxs\": true,\n \"includeAllTxLogs\": true,\n \"getNativeBalances\": [\n {\n \"selectors\": [\n \"<string>\"\n ]\n }\n ],\n \"abi\": null,\n \"advancedOptions\": null,\n \"filterPossibleSpamAddresses\": true,\n \"demo\": true,\n \"triggers\": [\n {\n \"contractAddress\": \"<string>\",\n \"functionAbi\": {},\n \"inputs\": [\n \"<string>\"\n ],\n \"topic0\": \"<string>\",\n \"callFrom\": \"<string>\"\n }\n ]\n}")
req, _ := http.NewRequest("PUT", url, payload)
req.Header.Add("x-api-key", "<api-key>")
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.put("https://api.moralis-streams.com/streams/evm")
.header("x-api-key", "<api-key>")
.header("Content-Type", "application/json")
.body("{\n \"webhookUrl\": \"<string>\",\n \"description\": \"<string>\",\n \"chainIds\": [\n \"<string>\"\n ],\n \"tag\": \"<string>\",\n \"topic0\": [\n \"<string>\"\n ],\n \"allAddresses\": true,\n \"includeNativeTxs\": true,\n \"includeContractLogs\": true,\n \"includeInternalTxs\": true,\n \"includeAllTxLogs\": true,\n \"getNativeBalances\": [\n {\n \"selectors\": [\n \"<string>\"\n ]\n }\n ],\n \"abi\": null,\n \"advancedOptions\": null,\n \"filterPossibleSpamAddresses\": true,\n \"demo\": true,\n \"triggers\": [\n {\n \"contractAddress\": \"<string>\",\n \"functionAbi\": {},\n \"inputs\": [\n \"<string>\"\n ],\n \"topic0\": \"<string>\",\n \"callFrom\": \"<string>\"\n }\n ]\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.moralis-streams.com/streams/evm")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Put.new(url)
request["x-api-key"] = '<api-key>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"webhookUrl\": \"<string>\",\n \"description\": \"<string>\",\n \"chainIds\": [\n \"<string>\"\n ],\n \"tag\": \"<string>\",\n \"topic0\": [\n \"<string>\"\n ],\n \"allAddresses\": true,\n \"includeNativeTxs\": true,\n \"includeContractLogs\": true,\n \"includeInternalTxs\": true,\n \"includeAllTxLogs\": true,\n \"getNativeBalances\": [\n {\n \"selectors\": [\n \"<string>\"\n ]\n }\n ],\n \"abi\": null,\n \"advancedOptions\": null,\n \"filterPossibleSpamAddresses\": true,\n \"demo\": true,\n \"triggers\": [\n {\n \"contractAddress\": \"<string>\",\n \"functionAbi\": {},\n \"inputs\": [\n \"<string>\"\n ],\n \"topic0\": \"<string>\",\n \"callFrom\": \"<string>\"\n }\n ]\n}"
response = http.request(request)
puts response.read_body{
"webhookUrl": "<string>",
"description": "<string>",
"chainIds": [
"<string>"
],
"id": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
"status": {},
"statusMessage": "<string>",
"updatedAt": "2023-11-07T05:31:56Z",
"amountOfAddresses": 123,
"tag": "<string>",
"topic0": [
"<string>"
],
"allAddresses": true,
"includeNativeTxs": true,
"includeContractLogs": true,
"includeInternalTxs": true,
"includeAllTxLogs": true,
"getNativeBalances": [
{
"selectors": [
"<string>"
],
"type": "tx"
}
],
"abi": null,
"advancedOptions": null,
"filterPossibleSpamAddresses": true,
"demo": true,
"triggers": [
{
"type": "tx",
"contractAddress": "<string>",
"functionAbi": {},
"inputs": [
"<string>"
],
"topic0": "<string>",
"callFrom": "<string>"
}
]
}Streams
Create Stream
Creates a new evm stream.
PUT
/
streams
/
evm
Create stream
curl --request PUT \
--url https://api.moralis-streams.com/streams/evm \
--header 'Content-Type: application/json' \
--header 'x-api-key: <api-key>' \
--data '
{
"webhookUrl": "<string>",
"description": "<string>",
"chainIds": [
"<string>"
],
"tag": "<string>",
"topic0": [
"<string>"
],
"allAddresses": true,
"includeNativeTxs": true,
"includeContractLogs": true,
"includeInternalTxs": true,
"includeAllTxLogs": true,
"getNativeBalances": [
{
"selectors": [
"<string>"
]
}
],
"abi": null,
"advancedOptions": null,
"filterPossibleSpamAddresses": true,
"demo": true,
"triggers": [
{
"contractAddress": "<string>",
"functionAbi": {},
"inputs": [
"<string>"
],
"topic0": "<string>",
"callFrom": "<string>"
}
]
}
'import requests
url = "https://api.moralis-streams.com/streams/evm"
payload = {
"webhookUrl": "<string>",
"description": "<string>",
"chainIds": ["<string>"],
"tag": "<string>",
"topic0": ["<string>"],
"allAddresses": True,
"includeNativeTxs": True,
"includeContractLogs": True,
"includeInternalTxs": True,
"includeAllTxLogs": True,
"getNativeBalances": [{ "selectors": ["<string>"] }],
"abi": None,
"advancedOptions": None,
"filterPossibleSpamAddresses": True,
"demo": True,
"triggers": [
{
"contractAddress": "<string>",
"functionAbi": {},
"inputs": ["<string>"],
"topic0": "<string>",
"callFrom": "<string>"
}
]
}
headers = {
"x-api-key": "<api-key>",
"Content-Type": "application/json"
}
response = requests.put(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'PUT',
headers: {'x-api-key': '<api-key>', 'Content-Type': 'application/json'},
body: JSON.stringify({
webhookUrl: '<string>',
description: '<string>',
chainIds: ['<string>'],
tag: '<string>',
topic0: ['<string>'],
allAddresses: true,
includeNativeTxs: true,
includeContractLogs: true,
includeInternalTxs: true,
includeAllTxLogs: true,
getNativeBalances: [{selectors: ['<string>']}],
abi: null,
advancedOptions: null,
filterPossibleSpamAddresses: true,
demo: true,
triggers: [
{
contractAddress: '<string>',
functionAbi: {},
inputs: ['<string>'],
topic0: '<string>',
callFrom: '<string>'
}
]
})
};
fetch('https://api.moralis-streams.com/streams/evm', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.moralis-streams.com/streams/evm",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "PUT",
CURLOPT_POSTFIELDS => json_encode([
'webhookUrl' => '<string>',
'description' => '<string>',
'chainIds' => [
'<string>'
],
'tag' => '<string>',
'topic0' => [
'<string>'
],
'allAddresses' => true,
'includeNativeTxs' => true,
'includeContractLogs' => true,
'includeInternalTxs' => true,
'includeAllTxLogs' => true,
'getNativeBalances' => [
[
'selectors' => [
'<string>'
]
]
],
'abi' => null,
'advancedOptions' => null,
'filterPossibleSpamAddresses' => true,
'demo' => true,
'triggers' => [
[
'contractAddress' => '<string>',
'functionAbi' => [
],
'inputs' => [
'<string>'
],
'topic0' => '<string>',
'callFrom' => '<string>'
]
]
]),
CURLOPT_HTTPHEADER => [
"Content-Type: application/json",
"x-api-key: <api-key>"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://api.moralis-streams.com/streams/evm"
payload := strings.NewReader("{\n \"webhookUrl\": \"<string>\",\n \"description\": \"<string>\",\n \"chainIds\": [\n \"<string>\"\n ],\n \"tag\": \"<string>\",\n \"topic0\": [\n \"<string>\"\n ],\n \"allAddresses\": true,\n \"includeNativeTxs\": true,\n \"includeContractLogs\": true,\n \"includeInternalTxs\": true,\n \"includeAllTxLogs\": true,\n \"getNativeBalances\": [\n {\n \"selectors\": [\n \"<string>\"\n ]\n }\n ],\n \"abi\": null,\n \"advancedOptions\": null,\n \"filterPossibleSpamAddresses\": true,\n \"demo\": true,\n \"triggers\": [\n {\n \"contractAddress\": \"<string>\",\n \"functionAbi\": {},\n \"inputs\": [\n \"<string>\"\n ],\n \"topic0\": \"<string>\",\n \"callFrom\": \"<string>\"\n }\n ]\n}")
req, _ := http.NewRequest("PUT", url, payload)
req.Header.Add("x-api-key", "<api-key>")
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.put("https://api.moralis-streams.com/streams/evm")
.header("x-api-key", "<api-key>")
.header("Content-Type", "application/json")
.body("{\n \"webhookUrl\": \"<string>\",\n \"description\": \"<string>\",\n \"chainIds\": [\n \"<string>\"\n ],\n \"tag\": \"<string>\",\n \"topic0\": [\n \"<string>\"\n ],\n \"allAddresses\": true,\n \"includeNativeTxs\": true,\n \"includeContractLogs\": true,\n \"includeInternalTxs\": true,\n \"includeAllTxLogs\": true,\n \"getNativeBalances\": [\n {\n \"selectors\": [\n \"<string>\"\n ]\n }\n ],\n \"abi\": null,\n \"advancedOptions\": null,\n \"filterPossibleSpamAddresses\": true,\n \"demo\": true,\n \"triggers\": [\n {\n \"contractAddress\": \"<string>\",\n \"functionAbi\": {},\n \"inputs\": [\n \"<string>\"\n ],\n \"topic0\": \"<string>\",\n \"callFrom\": \"<string>\"\n }\n ]\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.moralis-streams.com/streams/evm")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Put.new(url)
request["x-api-key"] = '<api-key>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"webhookUrl\": \"<string>\",\n \"description\": \"<string>\",\n \"chainIds\": [\n \"<string>\"\n ],\n \"tag\": \"<string>\",\n \"topic0\": [\n \"<string>\"\n ],\n \"allAddresses\": true,\n \"includeNativeTxs\": true,\n \"includeContractLogs\": true,\n \"includeInternalTxs\": true,\n \"includeAllTxLogs\": true,\n \"getNativeBalances\": [\n {\n \"selectors\": [\n \"<string>\"\n ]\n }\n ],\n \"abi\": null,\n \"advancedOptions\": null,\n \"filterPossibleSpamAddresses\": true,\n \"demo\": true,\n \"triggers\": [\n {\n \"contractAddress\": \"<string>\",\n \"functionAbi\": {},\n \"inputs\": [\n \"<string>\"\n ],\n \"topic0\": \"<string>\",\n \"callFrom\": \"<string>\"\n }\n ]\n}"
response = http.request(request)
puts response.read_body{
"webhookUrl": "<string>",
"description": "<string>",
"chainIds": [
"<string>"
],
"id": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
"status": {},
"statusMessage": "<string>",
"updatedAt": "2023-11-07T05:31:56Z",
"amountOfAddresses": 123,
"tag": "<string>",
"topic0": [
"<string>"
],
"allAddresses": true,
"includeNativeTxs": true,
"includeContractLogs": true,
"includeInternalTxs": true,
"includeAllTxLogs": true,
"getNativeBalances": [
{
"selectors": [
"<string>"
],
"type": "tx"
}
],
"abi": null,
"advancedOptions": null,
"filterPossibleSpamAddresses": true,
"demo": true,
"triggers": [
{
"type": "tx",
"contractAddress": "<string>",
"functionAbi": {},
"inputs": [
"<string>"
],
"topic0": "<string>",
"callFrom": "<string>"
}
]
}Authorizations
Body
application/json
Provide a Stream Model
Provide a Stream Model
Webhook URL where moralis will send the POST request.
A description for this stream
The ids of the chains for this stream in hex Ex: ["0x1","0x38"]
A user-provided tag that will be send along the webhook, the user can use this tag to identify the specific stream if multiple streams are present
An Array of topic0's in string-signature format ex: ['FunctionName(address,uint256)']
Include events for all addresses (only applied when abi and topic0 is provided)
Include or not native transactions defaults to false
Include or not logs of contract interactions defaults to false
Include or not include internal transactions defaults to false
Include all logs if atleast one value in tx or log matches stream config
Include native balances for each address in the webhook
Show child attributes
Show child attributes
Indicator if it is a demo stream
Filter possible spam addresses
triggers
Show child attributes
Show child attributes
Response
200 - application/json
Ok
Webhook URL where moralis will send the POST request.
A description for this stream
The ids of the chains for this stream in hex Ex: ["0x1","0x38"]
The unique uuid of the stream
Pattern:
[0-9A-Fa-f]{8}-[0-9A-Fa-f]{4}-4[0-9A-Fa-f]{3}-[89ABab][0-9A-Fa-f]{3}-[0-9A-Fa-f]{12}The status of the stream.
Available options:
active, paused, error, terminated Example:
{}
Description of current status of stream.
Last Updated Date.
Amount of Addresses.
A user-provided tag that will be send along the webhook, the user can use this tag to identify the specific stream if multiple streams are present
An Array of topic0's in string-signature format ex: ['FunctionName(address,uint256)']
Include events for all addresses (only applied when abi and topic0 is provided)
Include or not native transactions defaults to false
Include or not logs of contract interactions defaults to false
Include or not include internal transactions defaults to false
Include all logs if atleast one value in tx or log matches stream config
Include native balances for each address in the webhook
Show child attributes
Show child attributes
Indicator if it is a demo stream
Filter possible spam addresses
triggers
Show child attributes
Show child attributes