Create stream

PUThttps://api.moralis-streams.com/streams/evm

Creates a new evm stream.

BODY PARAM

webhookUrlstringrequired

Webhook URL where moralis will send the POST request.

descriptionstringrequired

A description for this stream

tagstringrequired

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

topic0array

An Array of topic0's in string-signature format ex: ['FunctionName(address,uint256)']

allAddressesboolean

Include events for all addresses (only applied when abi and topic0 is provided)

includeNativeTxsboolean

Include or not native transactions defaults to false

includeContractLogsboolean

Include or not logs of contract interactions defaults to false

includeInternalTxsboolean

Include or not include internal transactions defaults to false

includeAllTxLogsboolean

Include all logs if atleast one value in tx or log matches stream config

getNativeBalancesobject

Include native balances for each address in the webhook

selectorsarray

typestring

abiobject

anonymousboolean

constantboolean

inputsobject

namestring

typestring

indexedboolean

componentsjson

internalTypestring

namestring

outputsobject

namestring

typestring

componentsjson

internalTypestring

payableboolean

stateMutabilitystring

typestring

gasnumber

advancedOptionsobject

topic0string

filterjson

The filter object for the topic0 https://docs.moralis.io/docs/filter-streams

includeNativeTxsboolean

chainIdsarrayrequired

The ids of the chains for this stream in hex Ex: ["0x1","0x38"]

demoboolean

Indicator if it is a demo stream

triggersobject

triggers

typestring

contractAddressstring

inputsarray

functionAbiobject

The abi to parse the log object of the contract

anonymousboolean

constantboolean

inputsarray

namestring

outputsarray

payableboolean

stateMutabilitystring

typestringrequired

gasnumber

topic0string

callFromstring

Responses

API KEY

Node.js
Python
cURL
Go
PHP

import Moralis from 'moralis';

try {
  await Moralis.start({
    apiKey: "YOUR_API_KEY"
  });

  const response = Moralis.Streams.createStream({
    "getNativeBalances": {},
    "abi": {
      "inputs": {},
      "outputs": {}
    },
    "advancedOptions": {},
    "triggers": {
      "functionAbi": {}
    }
  });

  console.log(response.raw);
} catch (e) {
  console.error(e);
}

from moralis import streams

api_key = "YOUR_API_KEY"

body = {
  "topic0": [],
  "abi": {
    "inputs": {},
    "outputs": {}
  },
  "triggers": {
    "functionAbi": {}
  },
  "get_native-balances": {},
  "advanced_options": {},
  "chain_ids": []
}

result = streams.evm_streams.create_stream(
  api_key=api_key,
  body=body,
)

print(result)

curl --request PUT \
     --url 'https://api.moralis-streams.com/streams/evm' \
     --header 'accept: application/json' \
     --header 'X-API-Key: YOUR_API_KEY' 

package main

import (
  "fmt"
  "net/http"
  "io/ioutil"
)

func main() {

  url := "https://api.moralis-streams.com/streams/evm"

  req, _ := http.NewRequest("PUT", url, payload)

  req.Header.Add("Accept", "application/json")
  req.Header.Add("X-API-Key", "YOUR_API_KEY")

  res, _ := http.DefaultClient.Do(req)

  defer res.Body.Close()
  body, _ := ioutil.ReadAll(res.Body)

  fmt.Println(res)
  fmt.Println(string(body))

}

<?php
// Dependencies to install:
// $ composer require guzzlehttp/guzzle

require_once('vendor/autoload.php');

$client = new \GuzzleHttp\Client();

$response = $client->request('PUT', 'https://api.moralis-streams.com/streams/evm', [
  'headers' => [
    'Accept' => 'application/json',
    'X-API-Key' => 'YOUR_API_KEY',
  ],
]);

echo $response->getBody();

Response Example

{
  "triggers": {
    "inputs": [
      ""
    ]
  }
}