61 lines
1.6 KiB
TypeScript
61 lines
1.6 KiB
TypeScript
import { v } from "convex/values";
|
|
|
|
import { mutation, query } from "./_generated/server";
|
|
|
|
const now = () => Date.now();
|
|
|
|
export const upsert = mutation({
|
|
args: {
|
|
daemonId: v.string(),
|
|
name: v.string(),
|
|
desiredState: v.union(v.literal("online"), v.literal("offline")),
|
|
agentOsConfig: v.any(),
|
|
},
|
|
handler: async (ctx, args) => {
|
|
const existing = await ctx.db
|
|
.query("daemonDefinitions")
|
|
.withIndex("by_daemonId", (q) => q.eq("daemonId", args.daemonId))
|
|
.unique();
|
|
const timestamp = now();
|
|
if (existing) {
|
|
await ctx.db.patch("daemonDefinitions", existing._id, {
|
|
name: args.name,
|
|
desiredState: args.desiredState,
|
|
agentOsConfig: args.agentOsConfig,
|
|
configVersion: existing.configVersion + 1,
|
|
updatedAt: timestamp,
|
|
});
|
|
return existing._id;
|
|
}
|
|
return await ctx.db.insert("daemonDefinitions", {
|
|
...args,
|
|
configVersion: 1,
|
|
createdAt: timestamp,
|
|
updatedAt: timestamp,
|
|
});
|
|
},
|
|
});
|
|
|
|
export const get = query({
|
|
args: { daemonId: v.string() },
|
|
handler: async (ctx, args) => {
|
|
const definition = await ctx.db
|
|
.query("daemonDefinitions")
|
|
.withIndex("by_daemonId", (q) => q.eq("daemonId", args.daemonId))
|
|
.unique();
|
|
const presence = await ctx.db
|
|
.query("daemonPresence")
|
|
.withIndex("by_daemonId", (q) => q.eq("daemonId", args.daemonId))
|
|
.order("desc")
|
|
.first();
|
|
return { definition, presence };
|
|
},
|
|
});
|
|
|
|
export const list = query({
|
|
args: {},
|
|
handler: async (ctx) => {
|
|
return await ctx.db.query("daemonDefinitions").order("desc").collect();
|
|
},
|
|
});
|