In-App Notifications (Wallet-Based)

import { OnchainSuite } from "@onchainsuite/sdk";

const os = new OnchainSuite("pk_live_yourorg_xxx", {
  apiBaseUrl: "https://api.onchainsuite.com",
});

await os.start(); // prompts window.ethereum to connect + sign

const os = new OnchainSuite("pk_live_yourorg_xxx", {
  apiBaseUrl: "https://api.onchainsuite.com",
  signMessage: async (message) => signMessageAsync({ message }),
});

await os.start(walletAddress);

// components/OnchainInApp.tsx
"use client";
import { useEffect } from "react";
import { OnchainSuite } from "@onchainsuite/sdk";
import { useSignMessage } from "wagmi";

export function OnchainInApp({ wallet }: { wallet: string | null }) {
  const { signMessageAsync } = useSignMessage();

  useEffect(() => {
    if (!wallet) return; // push needs a connected wallet

    const os = new OnchainSuite(process.env.NEXT_PUBLIC_ONCHAIN_PK!, {
      apiBaseUrl: "https://api.onchainsuite.com",
      // Bridge signing to your wallet library so WalletConnect and mobile
      // wallets work, not just injected ones.
      signMessage: (message) => signMessageAsync({ message }),
    });

    os.on("connected", () => console.log("onchain: connected"));
    os.on("notification", (n) => {/* render your toast or inbox */});
    os.start(wallet);

    return () => os.stop(); // clean up on unmount or wallet change
  }, [wallet]);

  return null;
}

const { address } = useAccount();
return <>{address && <OnchainInApp wallet={address} />}</>;

const os = new OnchainSuite(process.env.NEXT_PUBLIC_ONCHAIN_PK!, {
  apiBaseUrl: "https://api.onchainsuite.com",
  display: false, // your UI, not the built-in toast
  onNotification: (n, actions) => {
    actions.report("viewed"); // it's about to be shown
    showToast({
      title: n.title,
      body: n.body,
      cta: n.cta, // { label, url } | undefined
      onClickCta: () => actions.click(), // reports "clicked" and opens the url
      onClose: () => actions.dismiss(), // reports "dismissed"
    });
    return false; // suppress the built-in toast
  },
});

await os.start(wallet);

interface Notification {
  deliveryId: string; // stable id, use it to dedupe
  title: string;
  body: string;
  cta?: { label: string; url: string };
}

interface NotificationActions {
  report: (type: "delivered" | "viewed" | "dismissed" | "clicked") => void;
  click: () => void;   // reports "clicked" and opens cta.url
  dismiss: () => void; // reports "dismissed"
}

import messaging from "@react-native-firebase/messaging";

await client.start(walletAddress);
await messaging().requestPermission();

const token = await messaging().getToken();
await client.registerDevice(token, "android");

// Keep it fresh; tokens rotate.
messaging().onTokenRefresh((t) => client.registerDevice(t, "android"));

{
  "success": true,
  "message": "Request processed successfully",
  "data": { },
  "timestamp": "2026-07-19T12:00:00.000Z",
  "requestId": "…"
}

{
  "success": false,
  "error": { "code": "UNAUTHORIZED", "message": "Origin not allowed", "details": {} },
  "meta": { "timestamp": "…", "path": "/api/v1/inapp/challenge", "requestId": "…" }
}

{ "walletAddress": "0xabc..." }

{
  "nonceId": "f3c1…",
  "message": "OnchainSuite In-App Push\n\nWallet: 0xabc…\nNonce: …\nIssued At: …\nExpires At: …",
  "expiresAt": "2026-07-19T12:05:00.000Z"
}

import { BrowserProvider } from "ethers";

const provider = new BrowserProvider(window.ethereum);
const signer = await provider.getSigner();
const signature = await signer.signMessage(message);

import bs58 from "bs58";

const { signature } = await window.solana.signMessage(
  new TextEncoder().encode(message),
);
const signatureB58 = bs58.encode(signature);

{ "walletAddress": "0xabc...", "signature": "0x..." }

{
  "token": "<session-jwt>",
  "wsUrl": "https://api.onchainsuite.com/api/v1/inapp/register",
  "expiresAt": "2026-07-26T12:00:00.000Z"
}

import { io } from "socket.io-client";

const socket = io("https://api.onchainsuite.com", {
  path: "/api/v1/inapp/register",
  transports: ["websocket"],
  auth: { token },
});

socket.on("connect", () => {
  socket.emit("REGISTER", { walletAddress }, (ack) => {
    console.log(`connected, ${ack.pendingCount} pending`);
  });
});

socket.on("PUSH", (push) => {
  renderNotification(push);
  socket.emit("EVENT", {
    campaignRunId: push.campaignRunId,
    deliveryId: push.deliveryId,
    type: "delivered",
  });
});

{
  deliveryId: string;
  campaignRunId: string;
  walletAddress: string;
  title: string;
  body: string;
  cta?: { label: string; url: string };
  createdAt: string;
  expiresAt: string;
  deliveredAt?: string;  // present on replay
  viewedAt?: string;
}

curl -X POST https://api.onchainsuite.com/api/v1/inapp/push \
  -H "Authorization: Bearer sk_live_…" \
  -H "Content-Type: application/json" \
  -d '{
    "walletAddress": "0xabc...",
    "title": "You received tokens",
    "body": "A transfer just hit your wallet.",
    "ctaLabel": "View transaction",
    "ctaUrl": "https://app.example.com/tx/0x...",
    "automationId": "transfer_alert"
  }'

{
  "ok": true,
  "campaignRunId": "…",
  "deliveryId": "…",
  "deliveredNow": true,
  "expiresAt": "2026-07-22T12:00:00.000Z"
}