Function readRequestBody

apps/realtime/src/routes/http.ts:33–42

(req: IncomingMessage)

}

function readRequestBody(req: IncomingMessage): Promise<string> {
  return new Promise((resolve, reject) => {
    let body = ''
    req.on('data', (chunk) => {
      body += chunk.toString()
    })
    req.on('end', () => resolve(body))
    req.on('error', reject)
  })
}

function sendSuccess(res: ServerResponse): void {
  res.writeHead(200, { 'Content-Type': 'application/json' })