1
import { eq } from "drizzle-orm";
2
 
3
import { type D1DbExecutor, tesseraIdentities } from "@/worker/db/d1";
4
 
5
export type TesseraIdentityRow = typeof tesseraIdentities.$inferSelect;
6
export type NewTesseraIdentityRow = typeof tesseraIdentities.$inferInsert;
7
 
8
export const findIdentityBySub = async (db: D1DbExecutor, sub: string): Promise<TesseraIdentityRow | undefined> => {
9
  const rows = await db.select().from(tesseraIdentities).where(eq(tesseraIdentities.sub, sub)).limit(1);
10
  return rows[0];
11
};
12
 
13
export const findIdentityByUserId = async (
14
  db: D1DbExecutor,
15
  userId: string,
16
): Promise<TesseraIdentityRow | undefined> => {
17
  const rows = await db.select().from(tesseraIdentities).where(eq(tesseraIdentities.userId, userId)).limit(1);
18
  return rows[0];
19
};
20
 
21
export const findUserIdBySub = async (db: D1DbExecutor, sub: string): Promise<string | null> => {
22
  const rows = await db
23
    .select({ userId: tesseraIdentities.userId })
24
    .from(tesseraIdentities)
25
    .where(eq(tesseraIdentities.sub, sub))
26
    .limit(1);
27
  return rows[0]?.userId ?? null;
28
};
29
 
30
export const bumpLastSeenAt = async (db: D1DbExecutor, sub: string, lastSeenAt: number): Promise<void> => {
31
  await db.update(tesseraIdentities).set({ lastSeenAt }).where(eq(tesseraIdentities.sub, sub));
32
};
33
 
34
export const insertIdentity = async (
35
  db: D1DbExecutor,
36
  row: NewTesseraIdentityRow,
37
): Promise<TesseraIdentityRow | undefined> => {
38
  const rows = await db.insert(tesseraIdentities).values(row).returning();
39
  return rows[0];
40
};