Platform Integration for Remix Apps

import { env } from "cloudflare:workers";
import { Database } from "remix/data-table";
import { database } from "pitlane/data-table-middleware";

router.use(database(env.DB));

router.get("/contacts", async ctx => {
    let db = ctx.get(Database);
    return Response.json(
        await db.findMany(Contacts),
    );
});

import { env } from "cloudflare:workers";
import { FileStorage } from "pitlane/file-storage";
import { fileStorage } from "pitlane/file-storage-middleware";

router.use(fileStorage(env.FILES));

router.post("/avatar", async ctx => {
    let files = ctx.get(FileStorage);
    await files.set(
        "avatar",
        await ctx.request.blob(),
    );
});

import { env } from "cloudflare:workers";
import { Session } from "remix/session";
import { session } from "remix/session-middleware";
import { createKvSessionStorage } from "pitlane/session-storage";

let storage = createKvSessionStorage(env.SESSIONS, {
    keyPrefix: "session:",
    ttl: 60 * 60 * 24,
});

router.use(session(cookie, storage));

router.get("/", ctx => {
    let s = ctx.get(Session);
    return Response.json({
        count: s.get("count") ?? 0,
    });
});

import { env } from "cloudflare:workers";
import * as s from "remix/data-schema";
import { createJobs, Scheduler } from "pitlane/job";
import { scheduler } from "pitlane/job-middleware";

let jobs = createJobs({
    sendEmail: {
        binding: env.TASKS,
        schema: s.object({ to: s.string() }),
        async handle({ to }) {
            await sendEmail(to);
        },
    },
});

router.use(scheduler(jobs));

router.post("/emails", async ctx => {
    let scheduler = ctx.get(Scheduler);
    await scheduler.enqueue(
        jobs.sendEmail,
        { to: "a@example.com" },
    );
});