not clear how to do mutations and data fetching with server fns

Author: OliverGilan

app/database/schema.sql.ts

@@ -1,12 +1,27 @@
-import { text, pgTable, timestamp, jsonb, serial, integer, primaryKey, uuid } from "drizzle-orm/pg-core";
+import { sql } from "drizzle-orm";
+import {
+  text,
+  pgTable,
+  timestamp,
+  jsonb,
+  serial,
+  integer,
+  primaryKey,
+  uuid,
+  uniqueIndex,
+} from "drizzle-orm/pg-core";
 
-export const UserTable = pgTable("users", {
-  id: text("id").primaryKey(),
-  externalId: text("external_id").notNull().unique(),
-  email: text("email").notNull(),
-  name: text("name").notNull(),
-  avatarUrl: text("avatar_url"),
-});
+export const UserTable = pgTable(
+  "users",
+  {
+    id: text("id").primaryKey(),
+    externalId: text("external_id").notNull().unique(),
+    email: text("email").notNull(),
+    name: text("name").notNull(),
+    avatarUrl: text("avatar_url"),
+  },
+  (t) => [uniqueIndex("emailUniqueIndex").on(sql`lower(${t.email})`)],
+);
 
 export const SlackInstallationTable = pgTable("slack_installations", {
   id: serial("id").primaryKey(),

products/github.ts app/feeds/github.tsproducts/github.ts renamed to app/feeds/github.ts

@@ -1,7 +1,7 @@
 import { ProductFeed } from "@/lib/product";
 import { readdirSync } from "node:fs";
 
-export const getProducts = async (): Promise<ProductFeed[]> => {
+export const getFeeds = async (): Promise<ProductFeed[]> => {
   const products: ProductFeed[] = [];
   const path = require("path");
   for (const value of readdirSync(path.join(__dirname))) {

products/index.ts app/feeds/index.tsproducts/index.ts renamed to app/feeds/index.ts

@@ -1,7 +1,7 @@
 import { ConfigTable, SlackInstallationTable } from "@/database/schema.sql";
 import { db } from "@/database/db";
 import { eq, inArray, and, getTableColumns } from "drizzle-orm";
-import { getProducts } from "../../products";
+import { getFeeds } from "@/feeds";
 import { ClassifiedMessage } from "@/lib/interfaces";
 import { client } from "integrations/slack/client";
 
@@ -11,7 +11,7 @@ export async function handler() {
   // Fetch new messages from all services
   // Classify messages
   // Store messages in database
-  const products = await getProducts();
+  const products = await getFeeds();
   const newMessages = await products.reduce(
     async (acc, product) => {
       const messages = await product.refreshStatusMessages();
@@ -48,7 +48,7 @@ export async function handler() {
       );
       toNotify.forEach(async (installation) => {
         const response = await client.chat.postMessage({
-          token: installation.bot.token,
+          token: installation.botToken,
           channel: installation.incomingWebhook.channelId,
           text: message.content,
         });

app/functions/run.ts

@@ -5,10 +5,15 @@ import { getWebRequest } from "vinxi/http";
 import appCss from "@/app.css?url";
 import { ClerkProvider } from "@clerk/tanstack-start";
 import { getAuth } from "@clerk/tanstack-start/server";
+import { db } from "@/database/db";
+import { eq } from "drizzle-orm";
+import { UserTable } from "@/database/schema.sql";
 
 const getUser = createServerFn({ method: "GET" }).handler(async () => {
   const { userId } = await getAuth(getWebRequest());
 
+  // const [user] = userId ? await db.select().from(UserTable).where(eq(UserTable.id, userId!)) : [];
+
   return { userId };
 });
 

app/routes/__root.tsx

@@ -7,12 +7,33 @@ import { createServerFn } from "@tanstack/start";
 import { getWebRequest } from "vinxi/http";
 import { getAuth } from "@clerk/tanstack-start/server";
 import { clerkClient } from "@clerk/tanstack-start/server";
+import { Resource } from "sst";
+import { client } from "integrations/slack/client";
+import { eq } from "drizzle-orm";
+import { db } from "@/database/db";
+import { SlackInstallationTable } from "@/database/schema.sql";
+
+const getUser = createServerFn({ method: "GET" }).handler(async () => {
+  const { userId } = await getAuth(getWebRequest());
+  if (!userId) throw redirect({ to: "/sign-in/$" });
+  const clerk = await clerkClient({
+    secretKey: Resource.ClerkSecretKey.value,
+  });
+  const accessTokens = (await clerk.users.getUserOauthAccessToken(userId!, "oauth_slack")).data;
+  const token = accessTokens[0].token || "";
+  const userInfo = await client.openid.connect.userInfo({
+    token,
+  });
+  const [installation] = await db
+    .select({ id: SlackInstallationTable.id })
+    .from(SlackInstallationTable)
+    .where(eq(SlackInstallationTable.teamId, userInfo["https://slack.com/team_id"]!));
+  return { userId, teamId: userInfo["https://slack.com/team_id"]!, installationId: installation!.id };
+});
 
 export const Route = createFileRoute("/_authed")({
   component: RouteComponent,
-  loader: ({ context }) => {
-    if (!context.userId) throw redirect({ to: "/sign-in/$" });
-  },
+  beforeLoad: async () => await getUser(),
 });
 
 function RouteComponent() {