Function proxyElectricShape

examples/react-native/shopping-list/server/index.ts:121–170

(
  req: express.Request,
  res: express.Response,
  table: string,
)

}

async function proxyElectricShape(
  req: express.Request,
  res: express.Response,
  table: string,
) {
  const requestUrl = `${req.protocol}://${req.get(`host`)}${req.originalUrl}`
  const originUrl = buildElectricShapeUrl(requestUrl, table)
  const forwardHeaders = buildForwardHeaders(req)
  const body =
    req.method === `POST` && req.body !== undefined
      ? JSON.stringify(req.body)
      : undefined

  if (body && !forwardHeaders.has(`content-type`)) {
    forwardHeaders.set(`content-type`, `application/json`)
  }

  const response = await fetch(originUrl, {
    method: req.method,
    headers: forwardHeaders,
    body,
  })

  response.headers.forEach((value, key) => {
    const lower = key.toLowerCase()
    if (
      lower === `content-encoding` ||
      lower === `content-length` ||
      lower === `transfer-encoding`
    ) {
      return
    }
    res.setHeader(key, value)
  })
  const varyHeader = response.headers.get(`vary`)
  res.setHeader(
    `Vary`,
    varyHeader ? `${varyHeader}, Authorization` : `Authorization`,
  )
  res.status(response.status)

  if (!response.body) {
    res.end()
    return
  }

  const nodeStream = Readable.fromWeb(response.body as any)
  res.on(`close`, () => nodeStream.destroy())
  await pipeline(nodeStream, res)
}

async function ensureDb() {
  await sql`