Merge remote-tracking branch 'origin/ben/get-emails' into integration/all-prs

# Conflicts:
#	apps/dashboard/convex/_shared/adminToken.ts
#	apps/dashboard/convex/crons.ts
#	apps/dashboard/convex/gmailConnection.ts
#	apps/dashboard/convex/gmailOAuth.ts
#	apps/dashboard/convex/ingestion.ts
#	apps/dashboard/convex/listservAdmin.ts
#	apps/dashboard/convex/parser.ts
#	apps/dashboard/convex/sourceAdmin.ts
#	apps/dashboard/eslint.config.js
#	apps/dashboard/src/pages/Admin.tsx
#	src/App.tsx

Author: benkoppe

apps/dashboard/convex/_generated/api.d.ts

@@ -8,17 +8,25 @@
  * @module
  */
 
+import type * as _shared_adminToken from "../_shared/adminToken.js";
 import type * as auth from "../auth.js";
 import type * as bookmarks from "../bookmarks.js";
 import type * as dev from "../dev.js";
 import type * as events from "../events.js";
 import type * as follows from "../follows.js";
+import type * as crons from "../crons.js";
+import type * as gmailConnection from "../gmailConnection.js";
+import type * as gmailOAuth from "../gmailOAuth.js";
 import type * as http from "../http.js";
 import type * as orgs from "../orgs.js";
 import type * as rsvps from "../rsvps.js";
 import type * as seed from "../seed.js";
 import type * as seedData from "../seedData.js";
 import type * as users from "../users.js";
+import type * as ingestion from "../ingestion.js";
+import type * as listservAdmin from "../listservAdmin.js";
+import type * as parser from "../parser.js";
+import type * as sourceAdmin from "../sourceAdmin.js";
 
 import type {
   ApiFromModules,
@@ -27,17 +35,25 @@ import type {
 } from "convex/server";
 
 declare const fullApi: ApiFromModules<{
+  "_shared/adminToken": typeof _shared_adminToken;
   auth: typeof auth;
   bookmarks: typeof bookmarks;
   dev: typeof dev;
   events: typeof events;
   follows: typeof follows;
+  crons: typeof crons;
+  gmailConnection: typeof gmailConnection;
+  gmailOAuth: typeof gmailOAuth;
   http: typeof http;
   orgs: typeof orgs;
   rsvps: typeof rsvps;
   seed: typeof seed;
   seedData: typeof seedData;
   users: typeof users;
+  ingestion: typeof ingestion;
+  listservAdmin: typeof listservAdmin;
+  parser: typeof parser;
+  sourceAdmin: typeof sourceAdmin;
 }>;
 
 /**

apps/dashboard/convex/_shared/adminToken.ts

@@ -0,0 +1,13 @@
+declare const process: { env: Record<string, string | undefined> };
+
+export function requireAdminToken(token: string) {
+  const expected = process.env.ADMIN_TOKEN;
+
+  if (!expected) {
+    throw new Error("ADMIN_TOKEN is not configured.");
+  }
+
+  if (token !== expected) {
+    throw new Error("Invalid admin token.");
+  }
+}

apps/dashboard/convex/crons.ts

@@ -0,0 +1,13 @@
+import { cronJobs } from "convex/server";
+import { internal } from "./_generated/api";
+
+const crons = cronJobs();
+
+crons.interval(
+  "poll listserv inbox",
+  { minutes: 10 },
+  internal.ingestion.pollListservInbox,
+  { trigger: "cron" },
+);
+
+export default crons;

apps/dashboard/convex/gmailConnection.ts

@@ -0,0 +1,38 @@
+import { v } from "convex/values";
+import { internalMutation, internalQuery } from "./_generated/server";
+
+const CONNECTION_KEY = "primary";
+
+export const getConnection = internalQuery({
+  args: {},
+  handler: async (ctx) => {
+    const connection = await ctx.db
+      .query("gmailConnections")
+      .withIndex("by_key", (q) => q.eq("key", CONNECTION_KEY))
+      .unique();
+
+    if (!connection || connection.status !== "connected") return null;
+    return {
+      email: connection.email,
+      refreshToken: connection.refreshToken,
+    };
+  },
+});
+
+export const markInvalid = internalMutation({
+  args: { error: v.string() },
+  handler: async (ctx, args) => {
+    const connection = await ctx.db
+      .query("gmailConnections")
+      .withIndex("by_key", (q) => q.eq("key", CONNECTION_KEY))
+      .unique();
+
+    if (!connection) return;
+
+    await ctx.db.patch(connection._id, {
+      status: "invalid",
+      lastError: args.error,
+      updatedAt: Date.now(),
+    });
+  },
+});