Cloudflare Queues ​

import { Hono } from "hono";

type Environment = {
  readonly ERROR_QUEUE: Queue<Error>;
  readonly ERROR_BUCKET: R2Bucket;
};

const app = new Hono<{
  Bindings: Environment;
}>();

app.get("/", (c) => {
  if (Math.random() < 0.5) {
    return c.text("Success!");
  }
  throw new Error("Failed!");
});

app.onError(async (err, c) => {
  await c.env.ERROR_QUEUE.send(err);
  return c.text(err.message, { status: 500 });
});

export default {
  fetch: app.fetch,
  async queue(batch: MessageBatch<Error>, env: Environment) {
    let file = "";
    for (const message of batch.messages) {
      const error = message.body;
      file += error.stack || error.message || String(error);
      file += "\r\n";
    }
    await env.ERROR_BUCKET.put(`errors/${Date.now()}.log`, file);
  },
};

import { Hono } from "hono";

type Environment = {
  readonly ERROR_QUEUE: Queue<Error>;
  readonly ERROR_BUCKET: R2Bucket;
};

const app = new Hono<{
  Bindings: Environment;
}>();

app.get("/", (c) => {
  if (Math.random() < 0.5) {
    return c.text("Success!");
  }
  throw new Error("Failed!");
});

app.onError(async (err, c) => {
  await c.env.ERROR_QUEUE.send(err);
  return c.text(err.message, { status: 500 });
});

export default {
  fetch: app.fetch,
  async queue(batch: MessageBatch<Error>, env: Environment) {
    let file = "";
    for (const message of batch.messages) {
      const error = message.body;
      file += error.stack || error.message || String(error);
      file += "\r\n";
    }
    await env.ERROR_BUCKET.put(`errors/${Date.now()}.log`, file);
  },
};