1// The jevstrudel Worker. The static site is served by Cloudflare's asset
2// layer before this runs (`wrangler deploy --assets`), so the Worker only
3// sees paths that are not files:
4//
5//   POST /jev/v1/systemone   the Jev relay (relay.ts), everywhere
6//   POST /jev/votes          a "do you agree with Jev?" vote  } votes.ts,
7//   GET  /jev/votes/summary  the vote counts                  } everywhere
8//   …    /jev/auth/*         passkey accounts (auth.ts): register, sign
9//                            in and out, who is signed in; everywhere
10//   GET, POST /jev/me/radio  a signed-in listener's radio history (radio.ts)
11//   POST /jev/reactions      a listener's 🔥 or 😴             } listening.ts,
12//   GET  /jev/reactions      a song's tally, all listeners   } everywhere
13//   POST /jev/performances   a performance, for a replay link }
14//   GET  /jev/performances/<id>  one, to replay it            }
15//   GET  /jev/party/<room>   a listening party's WebSocket (party.ts), everywhere
16//   GET  /jev/parties[/<id>] live parties, and a listed one's room (party.ts)
17//   GET  /jev/lobby          the lobby's WebSocket: who is listening to what
18//                            (lobby.ts), everywhere
19//   GET  /jev/data[/*]       everything the site stores, for anyone to read
20//                            (data.ts): people too, never a secret; everywhere
21//   …    /jev/listeners/*    listeners' songs, covers, comments and pitches
22//                            (content.ts): public to read, signed in to
23//                            write, screened by Jev first; everywhere
24//   POST /jev/mcp            the hosted MCP, for everyone's own AI, with an
25//                            OAuth token (hosted-mcp.ts); its OAuth under
26//                            /jev/oauth/* and /.well-known/oauth-* (oauth.ts);
27//                            /jev/me/tabs, a signed-in tab joining its
28//                            user's hub, and /jev/me/apps, connected apps;
29//                            everywhere
30//   GET  /strudel/status     open MCP tabs; the page's probe  } dev only:
31//   GET  /strudel/ws         a tab's WebSocket to the hub     } they need
32//   POST /mcp                MCP over HTTP (mcp.ts)           } the HUB binding
33//
34// Its cron trigger (wrangler.json) runs the work Jev owes listeners'
35// content, screening and scoring, every minute (content-jobs.ts).
36import { auth, AUTH_PREFIX } from './auth';
37import { content, LISTENERS_PREFIX } from './content';
38import { data, DATA_PREFIX } from './data';
39import { sweep } from './content-jobs';
40import { d1Content } from './content-store';
41import type { Env } from './env';
42import { mcp } from './mcp';
43import { oauth } from './oauth';
44import { radio, RADIO_PATH } from './radio';
45import { listening, PERFORMANCES_PATH, REACTIONS_PATH } from './listening';
46import { d1Listening } from './listening-store';
47import { lobby, LOBBY_PATH } from './lobby';
48import { parties, PARTIES_PATH, party, PARTY_PREFIX } from './party';
49import { relay, RELAY_PATH } from './relay';
50import { refuseCrossOrigin } from './session';
51import { SUMMARY_PATH, votes, VOTES_PATH } from './votes';
52import { d1Votes } from './votes-store';
53
54export { JevBudget } from './budget';
55export { Hub } from './hub';
56export { LobbyRoom } from './lobby';
57export { Party, PartyDirectory } from './party';
58export { TabHub } from './tab-hub';
59
60export default {
61  async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
62    const { pathname } = new URL(request.url);
63    // writes only from this site's own pages: never another site's, nor the
64    // sandbox listeners' songs play in (session.ts)
65    const crossOrigin = refuseCrossOrigin(request);
66    if (crossOrigin) return crossOrigin;
67    if (pathname === RELAY_PATH) return relay(request, env, ctx);
68    const hosted = await oauth(request, env, ctx);
69    if (hosted) return hosted;
70    if (pathname === VOTES_PATH || pathname === SUMMARY_PATH) {
71      return votes(request, env, d1Votes(env.DB));
72    }
73    if (pathname.startsWith(AUTH_PREFIX)) return auth(request, env);
74    if (pathname === RADIO_PATH) return radio(request, env);
75    if (pathname === REACTIONS_PATH || pathname === PERFORMANCES_PATH || pathname.startsWith(`${PERFORMANCES_PATH}/`)) {
76      return listening(request, env, d1Listening(env.DB));
77    }
78    if (pathname.startsWith(PARTY_PREFIX)) return party(request, env);
79    if (pathname === PARTIES_PATH || pathname.startsWith(`${PARTIES_PATH}/`)) return parties(request, env);
80    if (pathname === LOBBY_PATH) return lobby(request, env);
81    if (pathname.startsWith(LISTENERS_PREFIX)) return content(request, env, ctx);
82    if (pathname === DATA_PREFIX || pathname.startsWith(`${DATA_PREFIX}/`)) return data(request, env);
83    if (pathname === '/mcp') return mcp(request, env);
84    if (env.HUB && pathname === '/strudel/ws') return env.HUB.get(env.HUB.idFromName('hub')).fetch(request);
85    if (env.HUB && pathname === '/strudel/status') {
86      const sessions = await env.HUB.get(env.HUB.idFromName('hub')).sessions();
87      return Response.json({ active_sessions: sessions });
88    }
89    return new Response('not found', { status: 404 });
90  },
91
92  async scheduled(_controller: ScheduledController, env: Env, ctx: ExecutionContext): Promise<void> {
93    ctx.waitUntil(sweep(env, d1Content(env.DB)).then(() => undefined));
94  },
95} satisfies ExportedHandler<Env>;