Next.js

pnpm add @hookfish/api @hookfish/database @hookfish/providers @hookfish/sdk

import path from 'node:path'
import { HookfishServer } from '@hookfish/api'
import { pglite } from '@hookfish/database/pglite'
import config from '../../../hookfish.config'

export const runtime = 'nodejs'
export const dynamic = 'force-dynamic'

const db = pglite(
  process.env.PGLITE_DATA_DIR ?? path.resolve(process.cwd(), 'hookfish-data'),
)
const hookfishPromise = HookfishServer.init({ ...config, db })

async function handle(request: Request) {
  const hookfish = await hookfishPromise
  return hookfish.fetch(request, process.env)
}

export {
  handle as DELETE,
  handle as GET,
  handle as HEAD,
  handle as OPTIONS,
  handle as PATCH,
  handle as POST,
  handle as PUT,
}

import { Hookfish, HookfishError } from '@hookfish/sdk'

export async function GET(request: Request) {
  const session = await authenticateNextRequest(request)
  if (!session) {
    return Response.json({ error: 'Sign in required.' }, { status: 401 })
  }

  const brokerToken = await scopedBrokerTokenFor(session.organizationId)
  const hookfish = new Hookfish({
    apiKey: brokerToken,
    baseUrl: `${process.env.HOOKFISH_URL}/api`,
  })

  try {
    const connections = await hookfish.connections.list({
      namespace: `organizations/${session.organizationId}`,
    })
    return Response.json(connections)
  } catch (error) {
    if (error instanceof HookfishError) return error.getResponse()
    throw error
  }
}