@streamr/sdk v103.0.0

The Streamr SDK allows you to interact with the Streamr Network from JavaScript-based environments, such as browsers and Node.js. This library contains convenience functions for creating and managing streams on the Streamr Network.

Checkout our documentation for the full usage instructions.

Quickstart

The SDK is available on NPM and can be installed simply by:

npm install @streamr/sdk

If using TypeScript you can import the library with:

import { StreamrClient } from '@streamr/sdk'

If using Node.js you can import the library with:

const { StreamrClient } = require('@streamr/sdk')

Environments and frameworks

The Streamr SDK is built for the browser and Node.js environments.

Node.js

• Node.js 20, NPM 10 and later versions are recommended.

Browser (Website/WebApps)

• For usage in the browser include the latest build, e.g. by including a <script> tag pointing at a CDN:
• <script src="https://unpkg.com/@streamr/sdk@latest/streamr-sdk.web.min.js"></script>
• To use within React, please see streamr-client-react

Browser extension

• Due to the stricter security rules inside browser extensions you must use the web build version of the Streamr SDK.

Usage

Full API reference

For a full API reference visit https://docs.streamr.network/usage/sdk/api/.

Identity

In Streamr, cryptographic keys establish identity. Various types of key pairs and algorithms are supported, for example Ethereum private keys. Read more about Identity. Providing a key is not required if you are subscribing to public streams on the Network.

const streamr = new StreamrClient({
    auth: {
        privateKey: 'ethereum-private-key'
    }
})

Authenticating with an Ethereum private key contained in an Ethereum (web3) provider (e.g. MetaMask):

const streamr = new StreamrClient({
    auth: {
        ethereum: window.ethereum,
    }
})

You can also create an anonymous client instance that can interact with public streams:

const streamr = new StreamrClient()

Creating a stream

// Requires POL tokens (Polygon blockchain gas token)
const stream = await streamr.createStream({
    id: '/foo/bar'
})

console.log(stream.id) // e.g. `0x12345.../foo/bar`

Subscribing

const streamId = 'streams.dimo.eth/firehose/weather'

streamr.subscribe(streamId, (message) => {
    // handle for individual messages
})

Publishing

Publishing messages requires your Ethereum account to have permission to publish. See the stream permission docs for more information.

// Requires POL tokens (Polygon blockchain gas token)
const stream = await streamr.createStream({
    id: '/foo/bar'
})

await stream.publish({ timestamp: Date.now() })

Requesting historical messages

By default subscribe will not request historical messages.

You can fetch historical messages with the resend method:

streamr.resend(streamId, { last: 10 }, (msgs) => {
  console.log("messages": msgs);
});

This Readme only scratches the surface of what's possible - be sure to checkout our documentation for the full usage instructions.