Convex

import { defineApp } from "convex/server";
import { v } from "convex/values";
import boxd from "@boxd-sh/convex/convex.config.js";

const app = defineApp({
  env: { BOXD_API_KEY: v.string() },
});

app.use(boxd, { env: { BOXD_API_KEY: app.env.BOXD_API_KEY } });

export default app;

import { Boxd } from "@boxd-sh/convex";
import { v } from "convex/values";
import { components } from "./_generated/api";
import {
  action,
  query,
  type ActionCtx,
  type QueryCtx,
} from "./_generated/server";

const boxd = new Boxd(components.boxd);

// Derive the owner from your auth, never from a client argument.
async function ownerId(ctx: QueryCtx | ActionCtx) {
  const identity = await ctx.auth.getUserIdentity();
  if (!identity) throw new Error("Unauthenticated");
  return identity.subject;
}

export const createMachine = action({
  args: {},
  handler: async (ctx) => {
    return await boxd.create(ctx, {
      ownerId: await ownerId(ctx),
      vcpu: 1,
      autoSuspendSeconds: 300,
    });
  },
});

export const run = action({
  args: { machineId: v.string(), command: v.string() },
  handler: async (ctx, { machineId, command }) => {
    return await boxd.exec(ctx, {
      ownerId: await ownerId(ctx),
      machineId,
      command,
    });
  },
});

// Reactive. Re-runs whenever one of this user's machine rows changes.
export const myMachines = query({
  args: {},
  handler: async (ctx) => boxd.list(ctx, { ownerId: await ownerId(ctx) }),
});

// Reactive. Every command's status and output, newest first.
export const history = query({
  args: { machineId: v.string() },
  handler: async (ctx, { machineId }) =>
    boxd.listExecutions(ctx, { machineId, ownerId: await ownerId(ctx) }),
});