Hono

import { serve } from '@hono/node-server';
import { Hono } from 'hono';

import { syncServer } from './sync-server';

const app = new Hono();

app.all('/api/sync/*', (c) => syncServer.fetch(c.req.raw));

serve({ fetch: app.fetch, port: 3000 });

import { createSyncServer, memoryStore } from 'ferrysync/server';
import { Hono } from 'hono';

import { schema } from './schema';

/** The user each request was authenticated as, by the middleware. */
const users = new WeakMap<Request, string>();

const syncServer = createSyncServer({
  schema,
  store: memoryStore(),
  auth: (request) => users.get(request) ?? null,
});

const app = new Hono<{ Variables: { userId: string | null } }>();

app.use('*', async (c, next) => {
  c.set('userId', (await getSession(c.req.raw))?.userId ?? null);
  await next();
});

app.all('/api/sync/*', (c) => {
  const userId = c.get('userId');
  if (userId !== null) {
    users.set(c.req.raw, userId);
  }
  return syncServer.fetch(c.req.raw);
});

import { Hono } from 'hono';
import { cors } from 'hono/cors';

import { syncServer } from './sync-server';

export const app = new Hono();

app.use(
  '/api/sync/*',
  cors({ origin: 'https://app.example.com', allowHeaders: ['authorization', 'content-type'] }),
);
app.all('/api/sync/*', (c) => syncServer.fetch(c.req.raw));