feat: add early_access_invitees table (#143)

* feat: add early_access_invitees table schema

* feat: add getEarlyAccessInviteeByEmail repo

* feat: add user when early access invitee exists

app/(server)/_features/early-access-invitee/repository.ts

@@ -0,0 +1,9 @@
+import { db } from '@/(server)/_shared/database/database';
+
+export const getEarlyAccessInviteeByEmail = async (email: string) => {
+  return db.query.earlyAccessInvitees.findFirst({
+    where(fields, operators) {
+      return operators.eq(fields.email, email);
+    },
+  });
+};

app/(server)/_features/early-access-invitee/schema.ts

@@ -0,0 +1,15 @@
+import { serial, text, pgTable, timestamp } from 'drizzle-orm/pg-core';
+import { type InferSelectModel, sql } from 'drizzle-orm';
+
+export const earlyAccessInvitees = pgTable('early_access_invitees', {
+  id: serial('id').primaryKey(),
+  email: text('email').notNull().unique(),
+  name: text('name').notNull(),
+  whitelistFeature: text('whitelist_feature')
+    .array()
+    .notNull()
+    .default(sql`array[]::text[]`),
+  createdAt: timestamp('created_at').notNull().defaultNow(),
+});
+
+export type EarlyAccessInvitee = InferSelectModel<typeof earlyAccessInvitees>;

app/(server)/_schema/index.ts

@@ -5,6 +5,7 @@ import {
   participant,
   eventHasParticipant,
 } from '../_features/event/schema';
+import { earlyAccessInvitees } from '@/(server)/_features/early-access-invitee/schema';
 
 // export all schema here so we can utilize using the drizzle query
 const models = {
@@ -13,6 +14,7 @@ const models = {
   events,
   eventHasParticipant,
   participant,
+  earlyAccessInvitees,
 };
 
 export default models;

app/(server)/api/auth/[provider]/authenticate/route.ts

@@ -2,6 +2,7 @@ import { NextResponse, type NextRequest } from 'next/server';
 import * as Sentry from '@sentry/nextjs';
 import { InliveApiFetcher } from '@/_shared/utils/fetcher';
 import { getUserByEmail, addUser } from '@/(server)/_features/user/repository';
+import { getEarlyAccessInviteeByEmail } from '@/(server)/_features/early-access-invitee/repository';
 import type { AuthType } from '@/_shared/types/auth';
 
 const APP_ORIGIN = process.env.NEXT_PUBLIC_APP_ORIGIN || '';
@@ -114,13 +115,24 @@ export async function GET(
           const existingUser = await getUserByEmail(currentAuth.data.email);
 
           if (!existingUser) {
-            await addUser({
+            const userData = {
               email: currentAuth.data.email,
               name: currentAuth.data.name,
               accountId: currentAuth.data.id,
               pictureUrl: currentAuth.data.picture_url,
-              whitelistFeature: [],
-            });
+              whitelistFeature: [] as string[],
+            };
+
+            const existingEarlyAccessInvitee =
+              await getEarlyAccessInviteeByEmail(userData.email);
+
+            if (existingEarlyAccessInvitee) {
+              userData.whitelistFeature =
+                existingEarlyAccessInvitee.whitelistFeature;
+              await addUser(userData);
+            } else {
+              await addUser(userData);
+            }
           }
         }
 

migrations/0012_add_early_access_invitees_table.sql

@@ -0,0 +1,8 @@
+CREATE TABLE IF NOT EXISTS "early_access_invitees" (
+	"id" serial PRIMARY KEY NOT NULL,
+	"email" text NOT NULL,
+	"name" text NOT NULL,
+	"whitelist_feature" text[] DEFAULT array[]::text[] NOT NULL,
+	"created_at" timestamp DEFAULT now() NOT NULL,
+	CONSTRAINT "early_access_invitees_email_unique" UNIQUE("email")
+);