···

       
42
       
 
       
  }

     

       
43
       
 
       
}

     

       
44
       
 
       


     

       
45
       
-
       
export function formHandler<

     

       
46
       
-
       
  Req extends IncomingMessage = IncomingMessage,

     

       
47
       
-
       
  Res extends ServerResponse<Req & { body: unknown }> = ServerResponse<

     

       
48
       
-
       
    Req & { body: unknown }

     

       
49
       
-
       
  >,

     

       
50
       
-
       
>(fn: AsyncHandler<Req & { body: unknown }, Res>): Handler<Req, Res> {

     

       
51
       
-
       
  return handler(async (req, res, next) => {

     

       
52
       
-
       
    if (req.method !== 'POST') {

     

       
53
       
-
       
      return void res.writeHead(405).end()

     

       
54
       
-
       
    }

     

       
55
       
-
       
    if (req.headers['content-type'] !== 'application/x-www-form-urlencoded') {

     

       
56
       
-
       
      return void res.writeHead(415).end('Unsupported Media Type')

     

       
57
       
-
       
    }

     

       
58
       
-
       


     

       
59
       
-
       
    // Read the request payload

     

       
60
       
-
       
    const chunks: Uint8Array[] = []

     

       
61
       
-
       
    for await (const chunk of req) chunks.push(chunk)

     

       
62
       
-
       
    const payload = Buffer.concat(chunks).toString('utf-8')

     

       
63
       
-
       


     

       
64
       
-
       
    // Parse the Form URL-encoded payload

     

       
65
       
-
       
    const body = payload ? Object.fromEntries(new URLSearchParams(payload)) : {}

     

       
66
       
-
       


     

       
67
       
-
       
    // Define the body property on the request object

     

       
68
       
-
       
    Object.defineProperty(req, 'body', {

     

       
69
       
-
       
      value: body,

     

       
70
       
-
       
      writable: false,

     

       
71
       
-
       
      enumerable: true,

     

       
72
       
-
       
      configurable: true,

     

       
73
       
-
       
    })

     

       
74
       
-
       


     

       
75
       
-
       
    // Call the provided async handler with the modified request

     

       
76
       
-
       
    return fn(req as Req & { body: unknown }, res, next)

     

       
77
       
-
       
  })

     

       
78
       
-
       
}

     

       
79
       
-
       


     

       
80
       
 
       
export async function startServer(

     

       
81
       
 
       
  requestListener: RequestListener,

     

       
82
       
 
       
  {

     

···

       
42
       
 
       
  }

     

       
43
       
 
       
}

     

       
44
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
45
       
 
       
export async function startServer(

     

       
46
       
 
       
  requestListener: RequestListener,

     

       
47
       
 
       
  {

     

···

       
16
       
 
       
import * as Profile from '#/lexicon/types/app/bsky/actor/profile'

     

       
17
       
 
       
import * as Status from '#/lexicon/types/xyz/statusphere/status'

     

       
18
       
 
       
import { env } from '#/env'

     

       
19
       
-
       
import { formHandler, handler } from '#/lib/http'

     

       
20
       
 
       
import { page } from '#/lib/view'

     

       
21
       
 
       
import { home } from '#/pages/home'

     

       
22
       
 
       
import { login } from '#/pages/login'

     
···

       
53
       
 
       
  // OAuth metadata

     

       
54
       
 
       
  app.get(

     

       
55
       
 
       
    '/oauth-client-metadata.json',

     

       
56
       
-
       
    handler(async (req: Request, res: Response) => {

     

       
57
       
 
       
      res.json(ctx.oauthClient.clientMetadata)

     

       
58
       
 
       
    }),

     

       
59
       
 
       
  )

     
···

       
61
       
 
       
  // Public keys

     

       
62
       
 
       
  app.get(

     

       
63
       
 
       
    '/.well-known/jwks.json',

     

       
64
       
-
       
    handler(async (req: Request, res: Response) => {

     

       
65
       
 
       
      res.json(ctx.oauthClient.jwks)

     

       
66
       
 
       
    }),

     

       
67
       
 
       
  )

     
···

       
91
       
 
       
  // Login page

     

       
92
       
 
       
  app.get(

     

       
93
       
 
       
    '/login',

     

       
94
       
-
       
    handler(async (req: Request, res: Response) => {

     

       
95
       
 
       
      res.type('html').send(page(login({})))

     

       
96
       
 
       
    }),

     

       
97
       
 
       
  )

     
···

       
99
       
 
       
  // Login handler

     

       
100
       
 
       
  app.post(

     

       
101
       
 
       
    '/login',

     

       
102
       
-
       
    formHandler(async (req: Request, res: Response) => {

     

       
0
       
 
       

     

       
103
       
 
       
      // Validate

     

       
104
       
 
       
      const handle = req.body?.handle

     

       
105
       
 
       
      if (typeof handle !== 'string' || !isValidHandle(handle)) {

     
···

       
133
       
 
       
  // Logout handler

     

       
134
       
 
       
  app.post(

     

       
135
       
 
       
    '/logout',

     

       
136
       
-
       
    formHandler(async (req: Request, res: Response) => {

     

       
137
       
 
       
      const session = await getIronSession<Session>(req, res, {

     

       
138
       
 
       
        cookieName: 'sid',

     

       
139
       
 
       
        password: env.COOKIE_SECRET,

     
···

       
223
       
 
       
  // "Set status" handler

     

       
224
       
 
       
  app.post(

     

       
225
       
 
       
    '/status',

     

       
226
       
-
       
    formHandler(async (req: Request, res: Response) => {

     

       
0
       
 
       

     

       
227
       
 
       
      // If the user is signed in, get an agent which communicates with their server

     

       
228
       
 
       
      const agent = await getSessionAgent(req, res, ctx)

     

       
229
       
 
       
      if (!agent) {

     

···

       
16
       
 
       
import * as Profile from '#/lexicon/types/app/bsky/actor/profile'

     

       
17
       
 
       
import * as Status from '#/lexicon/types/xyz/statusphere/status'

     

       
18
       
 
       
import { env } from '#/env'

     

       
19
       
+
       
import { handler } from '#/lib/http'

     

       
20
       
 
       
import { page } from '#/lib/view'

     

       
21
       
 
       
import { home } from '#/pages/home'

     

       
22
       
 
       
import { login } from '#/pages/login'

     
···

       
53
       
 
       
  // OAuth metadata

     

       
54
       
 
       
  app.get(

     

       
55
       
 
       
    '/oauth-client-metadata.json',

     

       
56
       
+
       
    handler((req: Request, res: Response) => {

     

       
57
       
 
       
      res.json(ctx.oauthClient.clientMetadata)

     

       
58
       
 
       
    }),

     

       
59
       
 
       
  )

     
···

       
61
       
 
       
  // Public keys

     

       
62
       
 
       
  app.get(

     

       
63
       
 
       
    '/.well-known/jwks.json',

     

       
64
       
+
       
    handler((req: Request, res: Response) => {

     

       
65
       
 
       
      res.json(ctx.oauthClient.jwks)

     

       
66
       
 
       
    }),

     

       
67
       
 
       
  )

     
···

       
91
       
 
       
  // Login page

     

       
92
       
 
       
  app.get(

     

       
93
       
 
       
    '/login',

     

       
94
       
+
       
    handler((req: Request, res: Response) => {

     

       
95
       
 
       
      res.type('html').send(page(login({})))

     

       
96
       
 
       
    }),

     

       
97
       
 
       
  )

     
···

       
99
       
 
       
  // Login handler

     

       
100
       
 
       
  app.post(

     

       
101
       
 
       
    '/login',

     

       
102
       
+
       
    express.urlencoded({ extended: true }),

     

       
103
       
+
       
    handler(async (req: Request, res: Response) => {

     

       
104
       
 
       
      // Validate

     

       
105
       
 
       
      const handle = req.body?.handle

     

       
106
       
 
       
      if (typeof handle !== 'string' || !isValidHandle(handle)) {

     
···

       
134
       
 
       
  // Logout handler

     

       
135
       
 
       
  app.post(

     

       
136
       
 
       
    '/logout',

     

       
137
       
+
       
    handler(async (req: Request, res: Response) => {

     

       
138
       
 
       
      const session = await getIronSession<Session>(req, res, {

     

       
139
       
 
       
        cookieName: 'sid',

     

       
140
       
 
       
        password: env.COOKIE_SECRET,

     
···

       
224
       
 
       
  // "Set status" handler

     

       
225
       
 
       
  app.post(

     

       
226
       
 
       
    '/status',

     

       
227
       
+
       
    express.urlencoded({ extended: true }),

     

       
228
       
+
       
    handler(async (req: Request, res: Response) => {

     

       
229
       
 
       
      // If the user is signed in, get an agent which communicates with their server

     

       
230
       
 
       
      const agent = await getSessionAgent(req, res, ctx)

     

       
231
       
 
       
      if (!agent) {