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)']

No items in the array

allAddressesboolean

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

falsetrue

includeNativeTxsboolean

Include or not native transactions defaults to false

falsetrue

includeContractLogsboolean

Include or not logs of contract interactions defaults to false

falsetrue

includeInternalTxsboolean

Include or not include internal transactions defaults to false

falsetrue

includeAllTxLogsboolean

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

falsetrue

getNativeBalancesobject

Include native balances for each address in the webhook

selectorsarray

No items in the array

typestring

abiobject

anonymousboolean

falsetrue

constantboolean

falsetrue

inputsobject

namestring

typestring

indexedboolean

falsetrue

componentsjson

internalTypestring

namestring

outputsobject

namestring

typestring

componentsjson

internalTypestring

payableboolean

falsetrue

stateMutabilitystring

typestring

gasnumber

advancedOptionsobject

topic0string

filterjson

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

[object Object]

includeNativeTxsboolean

falsetrue

chainIdsarrayrequired

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

No items in the array

demoboolean

Indicator if it is a demo stream

falsetrue

triggersobject

triggers

typestring

contractAddressstring

inputsarray

No items in the array

functionAbiobject

The abi to parse the log object of the contract

anonymousboolean

falsetrue

constantboolean

falsetrue

inputsarray

No items in the array

namestring

outputsarray

No items in the array

payableboolean

falsetrue

stateMutabilitystring

typestringrequired

gasnumber

topic0string

callFromstring

Responses

API KEY

Node.js

import Moralis from 'moralis';

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

  const response = Moralis.Streams.createStream({});

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

Python

from moralis import streams

api_key = "YOUR_API_KEY"

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

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

print(result)

cURL

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

Go

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

<?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

200 Ok

{
  "webhookUrl": "",
  "description": "",
  "tag": "",
  "topic0": [
    ""
  ],
  "allAddresses": "",
  "includeNativeTxs": "",
  "includeContractLogs": "",
  "includeInternalTxs": "",
  "includeAllTxLogs": "",
  "getNativeBalances": {
    "selectors": [
      ""
    ],
    "type": ""
  },
  "abi": {
    "anonymous": "",
    "constant": "",
    "inputs": {
      "name": "",
      "type": "",
      "indexed": "",
      "components": "",
      "internalType": ""
    },
    "name": "",
    "outputs": {
      "name": "",
      "type": "",
      "components": "",
      "internalType": ""
    },
    "payable": "",
    "stateMutability": "",
    "type": "",
    "gas": ""
  },
  "advancedOptions": {
    "topic0": "",
    "includeNativeTxs": ""
  },
  "chainIds": [
    ""
  ],
  "demo": "",
  "triggers": {
    "type": "",
    "contractAddress": "",
    "inputs": [
      ""
    ],
    "functionAbi": {
      "anonymous": "",
      "constant": "",
      "inputs": [
        ""
      ],
      "name": "",
      "outputs": [
        ""
      ],
      "payable": "",
      "stateMutability": "",
      "type": "",
      "gas": ""
    },
    "topic0": "",
    "callFrom": ""
  },
  "id": "",
  "status": "",
  "statusMessage": ""
}