Next.js

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

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 type { AppType as HookfishAppType } from '@hookfish/api'
import { hc } from 'hono/client'

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 = hc<HookfishAppType>(`${process.env.HOOKFISH_URL}/api`, {
    headers: {
      Authorization: `Bearer ${brokerToken}`,
    },
  })

  return hookfish.oauth.connections.$get({
    query: {
      connection_id_prefix: session.organizationId,
    },
  })
}