WorkerBee Reactive. Typed. Real-time.

Production-grade framework for Hive blockchain. Type-safe APIs, reactive state, real-time data streaming.

Start Observing in Minutes

Install WorkerBee and write your first observer in 5 lines of code.

$ pnpm add @hiveio/workerbee

import WorkerBee from "@hiveio/workerbee";

const bot = new WorkerBee();
await bot.start();

bot.observe.onBlock().subscribe({
  next: (data) => console.log("Block:", data.block.number),
  error: console.error
});

Built for Serious Bots

Everything you need to build production-grade blockchain observers. From reactive streams to type-safe filters — all in one framework.

Observable API

Reactive, RxJS-style event streams. No polling loops, no callbacks hell. Subscribe to blockchain events and process them with familiar Observable patterns.

bee.observe
  .onTransfer()
  .subscribe(tx => console.log(tx));

Filter Composition

Combine filters with .or and .and operators for complex conditions. Build precise event matchers from simple, reusable building blocks.

const combined = filter1
  .or(filter2)
  .and(filter3);

Historical + Live

Process past operations, then seamlessly switch to real-time. Replay history from any block, then continue with live data — no gaps, no duplicates.

bee
  .providePastOperations(fromBlock)
  .subscribe(op => process(op));

Shared Evaluation Context

Multiple observers share data providers. Zero duplicate queries. Ten observers watching different events still make just one query per block.

// 10 observers, 1 query per block
const ctx = bee.sharedContext;
ctx.providers.length; // 7 — shared across all

Type-Safe Filters

25+ built-in filters, fully typed with TypeScript. Custom filters via plugin API. Every event payload is strongly typed — autocomplete everywhere.

bee.observe
  .onAccountFullManabar<{ account: string }>();
// ^? Observable<AccountManabarData>

Transaction Broadcasting

Build and broadcast transactions directly from your bot. Complete lifecycle — observe events, react, and push transactions back to the chain.

const tx = bee.chain.createTransaction();
tx.pushOperation(transfer);
await bee.broadcast(tx);

Real-World Use Cases

From whale tracking to custom bots — see how WorkerBee handles common blockchain monitoring scenarios in just a few lines of code.

Whale Alert

Monitor large transfers on Hive blockchain in real-time. Get notified when transfers exceed your threshold.

import { WorkerBee } from "@hiveio/workerbee";

const bee = new WorkerBee();
bee.start();

bee.observe
  .onTransfer()
  .filter(tx => tx.amount.gte("100000.000 HIVE"))
  .subscribe(tx => {
    notify(`${tx.from} > ${tx.to}: ${tx.amount}`);
  });

Account Monitor

Watch all operations affecting specific accounts. Track votes, transfers, and delegations in one stream.

import { WorkerBee } from "@hiveio/workerbee";

const bee = new WorkerBee();
bee.start();

bee.observe
  .onImpactedAccounts(["alice", "bob"])
  .subscribe(op => {
    log(`${op.type} on ${op.account}`);
  });

Historical Analysis

Process past blockchain operations, then seamlessly transition to real-time monitoring without missing a single block.

import { WorkerBee } from "@hiveio/workerbee";

const bee = new WorkerBee();
bee.start();

bee.observe
  .providePastOperations(startBlock)
  .onTransfer()
  .subscribe(tx => {
    // Processes historical, then switches to live
    db.insert(tx);
  });

Custom Bot

Build automated bots that react to events and broadcast transactions back to the blockchain.

import { WorkerBee } from "@hiveio/workerbee";

const bee = new WorkerBee();
bee.start();

bee.observe
  .onPost()
  .filter(post => post.tags.includes("hive"))
  .subscribe(async (post) => {
    await bee.broadcast(
      vote("mybot", post.author, post.permlink)
    );
  });