init.ts•1.69 kB
import { api } from "./_generated/api";
import { internalMutation, type MutationCtx } from "./_generated/server";
if (!process.env.TOGETHER_API_KEY) {
const deploymentName = process.env.CONVEX_CLOUD_URL?.slice(8).replace(
".convex.cloud",
"",
);
throw new Error(
"\n Missing TOGETHER_API_KEY in environment variables.\n\n" +
" Get one at https://together.ai/\n\n" +
" Paste it on the Convex dashboard:\n" +
" https://dashboard.convex.dev/d/" +
deploymentName +
"/settings?var=TOGETHER_API_KEY",
);
}
const seedMessages = [
["Omar", "Hey there!", 0],
["Arya", "What's up? Have a good weekend?", 1000],
["Omar", "Yeah! I spent most of it reading about AI :)", 1500],
["Arya", "Oh cool, I need to learn more about that!", 1700],
[
"Omar",
"It would be great if we could chat here with an AI assistant",
3000,
],
["Evelyn", "Hey folks! Ooh I like that idea", 2000],
["Arya", "Hi :) Yeah me too!", 1000],
[
"Evelyn",
"I was playing with AI this weekend and I think we could hook it up to this app!",
600,
],
["Omar", "Sounds like a plan", 5000],
] as const;
export default internalMutation({
handler: async (ctx: MutationCtx) => {
// If this project already has a populated database, do nothing
const anyMessage = await ctx.db.query("messages").first();
if (anyMessage) return;
// If not, post each of the seed messages with the given delay
let totalDelay = 0;
for (const [author, body, delay] of seedMessages) {
totalDelay += delay;
await ctx.scheduler.runAfter(totalDelay, api.messages.send, {
author,
body,
});
}
},
});