Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/openstatus. 🫖 Status page with uptime monitoring & API monitoring as code 🫖 openstatus.dev
bun drizzle-orm monitoring monitoring-as-code nextjs observability on-call open-source shadcn-ui status-page statuspage synthetic-monitoring tinybird turso uptime uptime-checker uptime-monitor
Something went wrong. Try again.
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263import { db, eq } from "@openstatus/db";import { user, usersToWorkspaces, workspace } from "@openstatus/db/src/schema";import type { AdapterUser } from "next-auth/adapters";import * as randomWordSlugs from "random-word-slugs";
export async function createUser(data: AdapterUser) { const newUser = await db .insert(user) .values({ email: data.email, photoUrl: data.image, name: data.name, firstName: data.firstName, lastName: data.lastName, }) .returning() .get();
let slug: string | undefined = undefined;
while (!slug) { slug = randomWordSlugs.generateSlug(2); const slugAlreadyExists = await db .select() .from(workspace) .where(eq(workspace.slug, slug)) .get();
if (slugAlreadyExists) { console.warn(`slug already exists: '${slug} - recreating new one'`); slug = undefined; } }
const newWorkspace = await db .insert(workspace) .values({ slug, name: "" }) .returning({ id: workspace.id }) .get();
await db .insert(usersToWorkspaces) .values({ userId: newUser.id, workspaceId: newWorkspace.id, role: "owner", }) .returning() .get();
return newUser;}
export async function getUser(id: string) { const _user = await db .select() .from(user) .where(eq(user.id, Number(id))) .get();
return _user || null;}