Agent-first
Solana SDK

Raw schema-validated JSON payload streaming via WebSocket.

{
  "id": {
    "round_id": 0,
    "round_address": ""
  },
  "state": {
    "motherlode": 0,
    "total_deployed": 0,
    "total_miners": 0,
    "expires_at": 0,
    "estimated_expires_at_unix": 0,
    "deployed_per_square_ui": [
      0, 0, 0, 0, 0,
      0, 0, 0, 0, 0,
      0, 0, 0, 0, 0,
      0, 0, 0, 0, 0,
      0, 0, 0, 0, 0
    ],
    "count_per_square": [
      0, 0, 0, 0, 0,
      0, 0, 0, 0, 0,
      0, 0, 0, 0, 0,
      0, 0, 0, 0, 0,
      0, 0, 0, 0, 0
    ]
  },
  "metrics": {
    "deploy_count": 0,
    "checkpoint_count": 0
  },
  "results": {
    "did_hit_motherlode": false,
    "pre_reveal_winning_square": null,
    "winning_square": null,
    "top_miner": "11111111111111111111111111111111",
    "top_miner_reward": 0
  }
}

Generate once, then subscribe to the latest round with the stack definition baked in.

import { Arete } from '@usearete/sdk';
import { ORE_STREAM_STACK } from './generated/ore-stack';

const a4 = await Arete.connect(ORE_STREAM_STACK, {
  auth: { publishableKey: import.meta.env.PUBLIC_ARETE_PUBLISHABLE_KEY },
});

for await (const round of a4.views.OreRound.latest.use({ take: 1 })) {
  console.log(round.id?.round_id, round.state?.total_deployed);
}

The same stream shape drops into hooks, ready for a dashboard or product surface.

import { AreteProvider, useArete } from '@usearete/react';
import { ORE_STREAM_STACK } from './generated/ore-stack';

function OreRoundPanel() {
  const { views, isConnected } = useArete(ORE_STREAM_STACK);
  const { data: round } = views.OreRound.latest.useOne({ take: 1 });

  return <RoundCard isConnected={isConnected} round={round} />;
}

Backend services can listen to the same hosted stream without re-building the data layer.

use arete_sdk::prelude::*;
use arete_stacks::ore::OreStreamStack;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let a4 = Arete::<OreStreamStack>::builder()
        .api_key(std::env::var("ARETE_API_KEY")?)
        .connect()
        .await?;

    let mut stream = a4.views.ore_round.latest().listen().take(1);
    while let Some(round) = stream.next().await {
        println!("{:?}", round.state.total_deployed);
    }

    Ok(())
}