React SDK

yarn add @torquefi/react @torquefi/types
# Server BFF also needs torque-node + TORQUE_API_KEY

'use client'
import { useIntelligenceFeed } from '@torquefi/react/intelligence'
import { useAssistantChat } from '@torquefi/react/assistant'

export function Dashboard({ walletAddress }: { walletAddress: string }) {
  const { items, refresh, isLoading } = useIntelligenceFeed({
    walletAddress,
    chainId: 8453,
    includeBrief: 1,
  })

  const { send, streamText, functionResults, isStreaming } = useAssistantChat()

  return (
    <div>
      <button type="button" onClick={() => refresh()} disabled={isLoading}>
        Refresh feed
      </button>
      <ul>{items?.map((item) => <li key={item.id}>{item.title}</li>)}</ul>

      <button
        type="button"
        onClick={() =>
          send({
            content: 'What moved today?',
            context: { walletAddress, chainId: 8453 },
            stream: true,
          })
        }
        disabled={isStreaming}
      >
        Ask assistant
      </button>
      {streamText && <p>{streamText}</p>}
      {functionResults?.length ? <pre>{JSON.stringify(functionResults, null, 2)}</pre> : null}
    </div>
  )
}

import { createTorqueFromEnv } from 'torque-node'
import { NextRequest, NextResponse } from 'next/server'

export async function GET(req: NextRequest) {
  const { searchParams } = req.nextUrl
  const torque = createTorqueFromEnv()
  const feed = await torque.intelligence.feed({
    walletAddress: searchParams.get('walletAddress') ?? undefined,
    chainId: Number(searchParams.get('chainId') ?? 8453),
    includeBrief: searchParams.get('includeBrief') === '1' ? 1 : undefined,
  })
  return NextResponse.json(feed)
}

import { createTorqueFromEnv } from 'torque-node'
import { NextRequest, NextResponse } from 'next/server'

export async function POST(req: NextRequest) {
  const body = await req.json()
  const torque = createTorqueFromEnv()
  const stream = req.nextUrl.searchParams.get('stream') === 'true'

  if (stream) {
    // Return SSE from torque.assistant.chatStream — see Platform SDK streaming
    return new NextResponse(/* SSE stream */)
  }

  const response = await torque.assistant.chat(body)
  return NextResponse.json(response)
}