- {children} ;
+};
diff --git a/apps/web/src/server/api/root.ts b/apps/web/src/server/api/root.ts
index b341fc4..81d2142 100644
--- a/apps/web/src/server/api/root.ts
+++ b/apps/web/src/server/api/root.ts
@@ -1,5 +1,7 @@
-import { postRouter } from "~/server/api/routers/post";
+import { domainRouter } from "~/server/api/routers/domain";
import { createCallerFactory, createTRPCRouter } from "~/server/api/trpc";
+import { apiRouter } from "./routers/api";
+import { emailRouter } from "./routers/email";
/**
* This is the primary router for your server.
@@ -7,7 +9,9 @@ import { createCallerFactory, createTRPCRouter } from "~/server/api/trpc";
* All routers added in /api/routers should be manually added here.
*/
export const appRouter = createTRPCRouter({
- post: postRouter,
+ domain: domainRouter,
+ apiKey: apiRouter,
+ email: emailRouter,
});
// export type definition of API
diff --git a/apps/web/src/server/api/routers/api.ts b/apps/web/src/server/api/routers/api.ts
new file mode 100644
index 0000000..5145d16
--- /dev/null
+++ b/apps/web/src/server/api/routers/api.ts
@@ -0,0 +1,42 @@
+import { z } from "zod";
+
+import {
+ createTRPCRouter,
+ protectedProcedure,
+ publicProcedure,
+ teamProcedure,
+} from "~/server/api/trpc";
+import { db } from "~/server/db";
+import { addApiKey } from "~/server/service/api-service";
+import { createDomain, getDomain } from "~/server/service/domain-service";
+
+export const apiRouter = createTRPCRouter({
+ createToken: teamProcedure
+ .input(
+ z.object({ name: z.string(), permission: z.enum(["FULL", "SENDING"]) })
+ )
+ .mutation(async ({ ctx, input }) => {
+ return addApiKey({
+ name: input.name,
+ permission: input.permission,
+ teamId: ctx.team.id,
+ });
+ }),
+
+ getApiKeys: teamProcedure.query(async ({ ctx }) => {
+ const keys = await ctx.db.apiKey.findMany({
+ where: {
+ teamId: ctx.team.id,
+ },
+ select: {
+ id: true,
+ name: true,
+ permission: true,
+ partialToken: true,
+ lastUsed: true,
+ },
+ });
+
+ return keys;
+ }),
+});
diff --git a/apps/web/src/server/api/routers/domain.ts b/apps/web/src/server/api/routers/domain.ts
new file mode 100644
index 0000000..4a09465
--- /dev/null
+++ b/apps/web/src/server/api/routers/domain.ts
@@ -0,0 +1,34 @@
+import { z } from "zod";
+
+import {
+ createTRPCRouter,
+ protectedProcedure,
+ publicProcedure,
+ teamProcedure,
+} from "~/server/api/trpc";
+import { db } from "~/server/db";
+import { createDomain, getDomain } from "~/server/service/domain-service";
+
+export const domainRouter = createTRPCRouter({
+ createDomain: teamProcedure
+ .input(z.object({ name: z.string() }))
+ .mutation(async ({ ctx, input }) => {
+ return createDomain(ctx.team.id, input.name);
+ }),
+
+ domains: teamProcedure.query(async ({ ctx }) => {
+ const domains = await db.domain.findMany({
+ where: {
+ teamId: ctx.team.id,
+ },
+ });
+
+ return domains;
+ }),
+
+ getDomain: teamProcedure
+ .input(z.object({ id: z.number() }))
+ .query(async ({ ctx, input }) => {
+ return getDomain(input.id);
+ }),
+});
diff --git a/apps/web/src/server/api/routers/email.ts b/apps/web/src/server/api/routers/email.ts
new file mode 100644
index 0000000..a7d4dca
--- /dev/null
+++ b/apps/web/src/server/api/routers/email.ts
@@ -0,0 +1,41 @@
+import { z } from "zod";
+
+import {
+ createTRPCRouter,
+ protectedProcedure,
+ publicProcedure,
+ teamProcedure,
+} from "~/server/api/trpc";
+import { db } from "~/server/db";
+import { createDomain, getDomain } from "~/server/service/domain-service";
+
+export const emailRouter = createTRPCRouter({
+ emails: teamProcedure.query(async ({ ctx }) => {
+ const emails = await db.email.findMany({
+ where: {
+ teamId: ctx.team.id,
+ },
+ });
+
+ return emails;
+ }),
+
+ getEmail: teamProcedure
+ .input(z.object({ id: z.string() }))
+ .query(async ({ ctx, input }) => {
+ const email = await db.email.findUnique({
+ where: {
+ id: input.id,
+ },
+ include: {
+ emailEvents: {
+ orderBy: {
+ createdAt: "desc",
+ },
+ },
+ },
+ });
+
+ return email;
+ }),
+});
diff --git a/apps/web/src/server/api/routers/post.ts b/apps/web/src/server/api/routers/post.ts
deleted file mode 100644
index 3994691..0000000
--- a/apps/web/src/server/api/routers/post.ts
+++ /dev/null
@@ -1,42 +0,0 @@
-import { z } from "zod";
-
-import {
- createTRPCRouter,
- protectedProcedure,
- publicProcedure,
-} from "~/server/api/trpc";
-
-export const postRouter = createTRPCRouter({
- hello: publicProcedure
- .input(z.object({ text: z.string() }))
- .query(({ input }) => {
- return {
- greeting: `Hello ${input.text}`,
- };
- }),
-
- create: protectedProcedure
- .input(z.object({ name: z.string().min(1) }))
- .mutation(async ({ ctx, input }) => {
- // simulate a slow db call
- await new Promise((resolve) => setTimeout(resolve, 1000));
-
- return ctx.db.post.create({
- data: {
- name: input.name,
- createdBy: { connect: { id: ctx.session.user.id } },
- },
- });
- }),
-
- getLatest: protectedProcedure.query(({ ctx }) => {
- return ctx.db.post.findFirst({
- orderBy: { createdAt: "desc" },
- where: { createdBy: { id: ctx.session.user.id } },
- });
- }),
-
- getSecretMessage: protectedProcedure.query(() => {
- return "you can now see this secret message!";
- }),
-});
diff --git a/apps/web/src/server/api/trpc.ts b/apps/web/src/server/api/trpc.ts
index 486a816..43054b8 100644
--- a/apps/web/src/server/api/trpc.ts
+++ b/apps/web/src/server/api/trpc.ts
@@ -9,7 +9,7 @@
import { initTRPC, TRPCError } from "@trpc/server";
import superjson from "superjson";
-import { ZodError } from "zod";
+import { z, ZodError } from "zod";
import { getServerAuthSession } from "~/server/auth";
import { db } from "~/server/db";
@@ -106,3 +106,21 @@ export const protectedProcedure = t.procedure.use(({ ctx, next }) => {
},
});
});
+
+export const teamProcedure = protectedProcedure.use(
+ async ({ ctx, next, input }) => {
+ const teamUser = await db.teamUser.findFirst({
+ where: { userId: ctx.session.user.id },
+ include: { team: true },
+ });
+ if (!teamUser) {
+ throw new TRPCError({ code: "NOT_FOUND", message: "Team not found" });
+ }
+ return next({
+ ctx: {
+ team: teamUser.team,
+ session: { ...ctx.session, user: ctx.session.user },
+ },
+ });
+ }
+);
diff --git a/apps/web/src/server/auth.ts b/apps/web/src/server/auth.ts
index 3f792c7..6acc15d 100644
--- a/apps/web/src/server/auth.ts
+++ b/apps/web/src/server/auth.ts
@@ -5,7 +5,7 @@ import {
type NextAuthOptions,
} from "next-auth";
import { type Adapter } from "next-auth/adapters";
-import DiscordProvider from "next-auth/providers/discord";
+import GitHubProvider from "next-auth/providers/github";
import { env } from "~/env";
import { db } from "~/server/db";
@@ -19,16 +19,15 @@ import { db } from "~/server/db";
declare module "next-auth" {
interface Session extends DefaultSession {
user: {
- id: string;
+ id: number;
// ...other properties
// role: UserRole;
} & DefaultSession["user"];
}
- // interface User {
- // // ...other properties
- // // role: UserRole;
- // }
+ interface User {
+ id: number;
+ }
}
/**
@@ -57,6 +56,10 @@ export const authOptions: NextAuthOptions = {
*
* @see https://next-auth.js.org/providers/github
*/
+ GitHubProvider({
+ clientId: env.GITHUB_ID,
+ clientSecret: env.GITHUB_SECRET,
+ }),
],
};
@@ -66,3 +69,15 @@ export const authOptions: NextAuthOptions = {
* @see https://next-auth.js.org/configuration/nextjs
*/
export const getServerAuthSession = () => getServerSession(authOptions);
+
+import { createHash } from "crypto";
+
+/**
+ * Hashes a token using SHA-256.
+ *
+ * @param {string} token - The token to be hashed.
+ * @returns {string} The hashed token.
+ */
+export function hashToken(token: string) {
+ return createHash("sha256").update(token).digest("hex");
+}
diff --git a/apps/web/src/server/aws/setup.ts b/apps/web/src/server/aws/setup.ts
new file mode 100644
index 0000000..bebbc0b
--- /dev/null
+++ b/apps/web/src/server/aws/setup.ts
@@ -0,0 +1,95 @@
+import { JsonValue } from "@prisma/client/runtime/library";
+import { db } from "../db";
+import { APP_SETTINGS } from "~/utils/constants";
+import { createTopic, subscribeEndpoint } from "./sns";
+import { env } from "~/env";
+import { AppSettingsService } from "~/server/service/app-settings-service";
+import { addWebhookConfiguration } from "../ses";
+import { EventType } from "@aws-sdk/client-sesv2";
+
+const GENERAL_EVENTS: EventType[] = [
+ "BOUNCE",
+ "COMPLAINT",
+ "DELIVERY",
+ "DELIVERY_DELAY",
+ "REJECT",
+ "RENDERING_FAILURE",
+ "SEND",
+ "SUBSCRIPTION",
+];
+
+export async function setupAws() {
+ AppSettingsService.initializeCache();
+ let snsTopicArn = await AppSettingsService.getSetting(
+ APP_SETTINGS.SNS_TOPIC_ARN
+ );
+ console.log("Setting up AWS");
+
+ if (!snsTopicArn) {
+ console.log("SNS topic not present, creating...");
+ snsTopicArn = await createUnsendSNSTopic();
+ }
+
+ await setupSESConfiguration();
+}
+
+async function createUnsendSNSTopic() {
+ const topicArn = await createTopic(env.SNS_TOPIC);
+ if (!topicArn) {
+ console.error("Failed to create SNS topic");
+ return;
+ }
+
+ await subscribeEndpoint(
+ topicArn,
+ `${env.APP_URL ?? env.NEXTAUTH_URL}/api/ses_callback`
+ );
+
+ return await AppSettingsService.setSetting(
+ APP_SETTINGS.SNS_TOPIC_ARN,
+ topicArn
+ );
+}
+
+async function setupSESConfiguration() {
+ const topicArn = (
+ await AppSettingsService.getSetting(APP_SETTINGS.SNS_TOPIC_ARN)
+ )?.toString();
+
+ if (!topicArn) {
+ return;
+ }
+ console.log("Setting up SES webhook configuration");
+
+ await setWebhookConfiguration(
+ APP_SETTINGS.SES_CONFIGURATION_GENERAL,
+ topicArn,
+ GENERAL_EVENTS
+ );
+
+ await setWebhookConfiguration(
+ APP_SETTINGS.SES_CONFIGURATION_CLICK_TRACKING,
+ topicArn,
+ [...GENERAL_EVENTS, "CLICK"]
+ );
+
+ await setWebhookConfiguration(
+ APP_SETTINGS.SES_CONFIGURATION_OPEN_TRACKING,
+ topicArn,
+ [...GENERAL_EVENTS, "OPEN"]
+ );
+}
+
+async function setWebhookConfiguration(
+ setting: string,
+ topicArn: string,
+ eventTypes: EventType[]
+) {
+ const sesConfigurationGeneral = await AppSettingsService.getSetting(setting);
+
+ if (!sesConfigurationGeneral) {
+ console.log(`Setting up SES webhook configuration for ${setting}`);
+ const status = await addWebhookConfiguration(setting, topicArn, eventTypes);
+ await AppSettingsService.setSetting(setting, status.toString());
+ }
+}
diff --git a/apps/web/src/server/aws/sns.ts b/apps/web/src/server/aws/sns.ts
new file mode 100644
index 0000000..ebd8959
--- /dev/null
+++ b/apps/web/src/server/aws/sns.ts
@@ -0,0 +1,39 @@
+import {
+ SNSClient,
+ CreateTopicCommand,
+ SubscribeCommand,
+} from "@aws-sdk/client-sns";
+import { env } from "~/env";
+
+function getSnsClient(region = "us-east-1") {
+ return new SNSClient({
+ region: region,
+ credentials: {
+ accessKeyId: env.AWS_ACCESS_KEY,
+ secretAccessKey: env.AWS_SECRET_KEY,
+ },
+ });
+}
+
+export async function createTopic(topic: string) {
+ const client = getSnsClient();
+ const command = new CreateTopicCommand({
+ Name: topic,
+ });
+
+ const data = await client.send(command);
+ return data.TopicArn;
+}
+
+export async function subscribeEndpoint(topicArn: string, endpointUrl: string) {
+ const subscribeCommand = new SubscribeCommand({
+ Protocol: "https",
+ TopicArn: topicArn,
+ Endpoint: endpointUrl,
+ });
+ const client = getSnsClient();
+
+ const data = await client.send(subscribeCommand);
+ console.log(data.SubscriptionArn);
+ return data.SubscriptionArn;
+}
diff --git a/apps/web/src/server/service/api-service.ts b/apps/web/src/server/service/api-service.ts
new file mode 100644
index 0000000..f87dcf4
--- /dev/null
+++ b/apps/web/src/server/service/api-service.ts
@@ -0,0 +1,59 @@
+import { ApiPermission } from "@prisma/client";
+import { db } from "../db";
+import { randomBytes } from "crypto";
+import { hashToken } from "../auth";
+
+export async function addApiKey({
+ name,
+ permission,
+ teamId,
+}: {
+ name: string;
+ permission: ApiPermission;
+ teamId: number;
+}) {
+ try {
+ const token = `us_${randomBytes(20).toString("hex")}`;
+ const hashedToken = hashToken(token);
+
+ await db.apiKey.create({
+ data: {
+ name,
+ permission: permission,
+ teamId,
+ tokenHash: hashedToken,
+ partialToken: `${token.slice(0, 8)}...${token.slice(-5)}`,
+ },
+ });
+ return token;
+ } catch (error) {
+ console.error("Error adding API key:", error);
+ throw error;
+ }
+}
+
+export async function retrieveApiKey(token: string) {
+ const hashedToken = hashToken(token);
+
+ try {
+ const apiKey = await db.apiKey.findUnique({
+ where: {
+ tokenHash: hashedToken,
+ },
+ select: {
+ id: true,
+ name: true,
+ permission: true,
+ teamId: true,
+ partialToken: true,
+ },
+ });
+ if (!apiKey) {
+ throw new Error("API Key not found");
+ }
+ return apiKey;
+ } catch (error) {
+ console.error("Error retrieving API key:", error);
+ throw error;
+ }
+}
diff --git a/apps/web/src/server/service/app-settings-service.ts b/apps/web/src/server/service/app-settings-service.ts
new file mode 100644
index 0000000..5d8ac64
--- /dev/null
+++ b/apps/web/src/server/service/app-settings-service.ts
@@ -0,0 +1,38 @@
+import { db } from "../db";
+import { JsonValue } from "@prisma/client/runtime/library";
+
+export class AppSettingsService {
+ private static cache: Record = {};
+
+ public static async getSetting(key: string) {
+ if (!this.cache[key]) {
+ const setting = await db.appSetting.findUnique({
+ where: { key },
+ });
+ if (setting) {
+ this.cache[key] = setting.value;
+ } else {
+ return null;
+ }
+ }
+ return this.cache[key];
+ }
+
+ public static async setSetting(key: string, value: string) {
+ await db.appSetting.upsert({
+ where: { key },
+ update: { value },
+ create: { key, value },
+ });
+ this.cache[key] = value;
+
+ return value;
+ }
+
+ public static async initializeCache(): Promise {
+ const settings = await db.appSetting.findMany();
+ settings.forEach((setting) => {
+ this.cache[setting.key] = setting.value;
+ });
+ }
+}
diff --git a/apps/web/src/server/service/domain-service.ts b/apps/web/src/server/service/domain-service.ts
new file mode 100644
index 0000000..044a859
--- /dev/null
+++ b/apps/web/src/server/service/domain-service.ts
@@ -0,0 +1,69 @@
+import { addDomain, getDomainIdentity } from "~/server/ses";
+import { db } from "~/server/db";
+
+export async function createDomain(teamId: number, name: string) {
+ console.log("Creating domain:", name);
+ const publicKey = await addDomain(name);
+
+ const domain = await db.domain.create({
+ data: {
+ name,
+ publicKey,
+ teamId,
+ },
+ });
+
+ return domain;
+}
+
+export async function getDomain(id: number) {
+ let domain = await db.domain.findUnique({
+ where: {
+ id,
+ },
+ });
+
+ if (!domain) {
+ throw new Error("Domain not found");
+ }
+
+ if (domain.status !== "SUCCESS") {
+ const domainIdentity = await getDomainIdentity(domain.name, domain.region);
+
+ const dkimStatus = domainIdentity.DkimAttributes?.Status;
+ const spfDetails = domainIdentity.MailFromAttributes?.MailFromDomainStatus;
+ const verificationError = domainIdentity.VerificationInfo?.ErrorType;
+ const verificationStatus = domainIdentity.VerificationStatus;
+ const lastCheckedTime =
+ domainIdentity.VerificationInfo?.LastCheckedTimestamp;
+
+ console.log(domainIdentity);
+
+ if (
+ domain.dkimStatus !== dkimStatus ||
+ domain.spfDetails !== spfDetails ||
+ domain.status !== verificationStatus
+ ) {
+ domain = await db.domain.update({
+ where: {
+ id,
+ },
+ data: {
+ dkimStatus,
+ spfDetails,
+ status: verificationStatus ?? "NOT_STARTED",
+ },
+ });
+ }
+
+ return {
+ ...domain,
+ dkimStatus,
+ spfDetails,
+ verificationError,
+ lastCheckedTime,
+ };
+ }
+
+ return domain;
+}
diff --git a/apps/web/src/server/service/email-service.ts b/apps/web/src/server/service/email-service.ts
new file mode 100644
index 0000000..8883e5b
--- /dev/null
+++ b/apps/web/src/server/service/email-service.ts
@@ -0,0 +1,49 @@
+import { EmailContent } from "~/types";
+import { db } from "../db";
+import { sendEmailThroughSes } from "../ses";
+
+export async function sendEmail(
+ emailContent: EmailContent & { teamId: number }
+) {
+ const { to, from, subject, text, html, teamId } = emailContent;
+
+ const domains = await db.domain.findMany({ where: { teamId } });
+
+ const fromDomain = from.split("@")[1];
+ if (!fromDomain) {
+ throw new Error("From email is not valid");
+ }
+
+ const domain = domains.find((domain) => domain.name === fromDomain);
+ if (!domain) {
+ throw new Error("Domain not found. Add domain to unsend first");
+ }
+
+ if (domain.status !== "SUCCESS") {
+ throw new Error("Domain is not verified");
+ }
+
+ const messageId = await sendEmailThroughSes({
+ to,
+ from,
+ subject,
+ text,
+ html,
+ region: domain.region,
+ });
+
+ if (messageId) {
+ return await db.email.create({
+ data: {
+ to,
+ from,
+ subject,
+ text,
+ html,
+ id: messageId,
+ teamId,
+ domainId: domain.id,
+ },
+ });
+ }
+}
diff --git a/apps/web/src/server/ses.ts b/apps/web/src/server/ses.ts
new file mode 100644
index 0000000..818d0eb
--- /dev/null
+++ b/apps/web/src/server/ses.ts
@@ -0,0 +1,176 @@
+import {
+ SESv2Client,
+ CreateEmailIdentityCommand,
+ DeleteEmailIdentityCommand,
+ GetEmailIdentityCommand,
+ PutEmailIdentityMailFromAttributesCommand,
+ SendEmailCommand,
+ CreateConfigurationSetEventDestinationCommand,
+ CreateConfigurationSetCommand,
+ EventType,
+} from "@aws-sdk/client-sesv2";
+import { generateKeyPairSync } from "crypto";
+import { env } from "~/env";
+import { EmailContent } from "~/types";
+import { APP_SETTINGS } from "~/utils/constants";
+
+function getSesClient(region = "us-east-1") {
+ return new SESv2Client({
+ region: region,
+ credentials: {
+ accessKeyId: env.AWS_ACCESS_KEY,
+ secretAccessKey: env.AWS_SECRET_KEY,
+ },
+ });
+}
+
+function generateKeyPair() {
+ const { privateKey, publicKey } = generateKeyPairSync("rsa", {
+ modulusLength: 2048, // Length of your key in bits
+ publicKeyEncoding: {
+ type: "spki", // Recommended to be 'spki' by the Node.js docs
+ format: "pem",
+ },
+ privateKeyEncoding: {
+ type: "pkcs8", // Recommended to be 'pkcs8' by the Node.js docs
+ format: "pem",
+ },
+ });
+
+ const base64PrivateKey = privateKey
+ .replace("-----BEGIN PRIVATE KEY-----", "")
+ .replace("-----END PRIVATE KEY-----", "")
+ .replace(/\n/g, "");
+
+ const base64PublicKey = publicKey
+ .replace("-----BEGIN PUBLIC KEY-----", "")
+ .replace("-----END PUBLIC KEY-----", "")
+ .replace(/\n/g, "");
+
+ return { privateKey: base64PrivateKey, publicKey: base64PublicKey };
+}
+
+export async function addDomain(domain: string, region = "us-east-1") {
+ const sesClient = getSesClient(region);
+
+ const { privateKey, publicKey } = generateKeyPair();
+ const command = new CreateEmailIdentityCommand({
+ EmailIdentity: domain,
+ DkimSigningAttributes: {
+ DomainSigningSelector: "unsend",
+ DomainSigningPrivateKey: privateKey,
+ },
+ ConfigurationSetName: APP_SETTINGS.SES_CONFIGURATION_GENERAL,
+ });
+ const response = await sesClient.send(command);
+
+ const emailIdentityCommand = new PutEmailIdentityMailFromAttributesCommand({
+ EmailIdentity: domain,
+ MailFromDomain: `send.${domain}`,
+ });
+
+ const emailIdentityResponse = await sesClient.send(emailIdentityCommand);
+
+ if (
+ response.$metadata.httpStatusCode !== 200 ||
+ emailIdentityResponse.$metadata.httpStatusCode !== 200
+ ) {
+ throw new Error("Failed to create email identity");
+ }
+
+ return publicKey;
+}
+
+export async function getDomainIdentity(domain: string, region = "us-east-1") {
+ const sesClient = getSesClient(region);
+ const command = new GetEmailIdentityCommand({
+ EmailIdentity: domain,
+ });
+ const response = await sesClient.send(command);
+ return response;
+}
+
+export async function sendEmailThroughSes({
+ to,
+ from,
+ subject,
+ text,
+ html,
+ region = "us-east-1",
+}: EmailContent & {
+ region?: string;
+}) {
+ const sesClient = getSesClient(region);
+ const command = new SendEmailCommand({
+ FromEmailAddress: from,
+ Destination: {
+ ToAddresses: [to],
+ },
+ Content: {
+ // EmailContent
+ Simple: {
+ // Message
+ Subject: {
+ // Content
+ Data: subject, // required
+ Charset: "UTF-8",
+ },
+ Body: {
+ // Body
+ Text: {
+ Data: text, // required
+ Charset: "UTF-8",
+ },
+ Html: {
+ Data: html, // required
+ Charset: "UTF-8",
+ },
+ },
+ },
+ },
+ });
+
+ try {
+ const response = await sesClient.send(command);
+ console.log("Email sent! Message ID:", response.MessageId);
+ return response.MessageId;
+ } catch (error) {
+ console.error("Failed to send email", error);
+ throw new Error("Failed to send email");
+ }
+}
+
+export async function addWebhookConfiguration(
+ configName: string,
+ topicArn: string,
+ eventTypes: EventType[],
+ region = "us-east-1"
+) {
+ const sesClient = getSesClient(region);
+
+ const configSetCommand = new CreateConfigurationSetCommand({
+ ConfigurationSetName: configName,
+ });
+
+ const configSetResponse = await sesClient.send(configSetCommand);
+
+ if (configSetResponse.$metadata.httpStatusCode !== 200) {
+ throw new Error("Failed to create configuration set");
+ }
+
+ const command = new CreateConfigurationSetEventDestinationCommand({
+ ConfigurationSetName: configName, // required
+ EventDestinationName: "unsend_destination", // required
+ EventDestination: {
+ // EventDestinationDefinition
+ Enabled: true,
+ MatchingEventTypes: eventTypes,
+ SnsDestination: {
+ TopicArn: topicArn,
+ },
+ },
+ });
+
+ const response = await sesClient.send(command);
+ return response.$metadata.httpStatusCode === 200;
+}
diff --git a/apps/web/src/types/index.ts b/apps/web/src/types/index.ts
new file mode 100644
index 0000000..b84cf73
--- /dev/null
+++ b/apps/web/src/types/index.ts
@@ -0,0 +1,7 @@
+export type EmailContent = {
+ to: string;
+ from: string;
+ subject: string;
+ text: string;
+ html: string;
+};
diff --git a/apps/web/src/utils/constants.ts b/apps/web/src/utils/constants.ts
new file mode 100644
index 0000000..33d6c44
--- /dev/null
+++ b/apps/web/src/utils/constants.ts
@@ -0,0 +1,8 @@
+import { env } from "~/env";
+
+export const APP_SETTINGS = {
+ SNS_TOPIC_ARN: "SNS_TOPIC_ARN",
+ SES_CONFIGURATION_GENERAL: `SES_CONFIGURATION_GENERAL_${env.NODE_ENV}`,
+ SES_CONFIGURATION_CLICK_TRACKING: `SES_CONFIGURATION_CLICK_TRACKING_${env.NODE_ENV}`,
+ SES_CONFIGURATION_OPEN_TRACKING: `SES_CONFIGURATION_OPEN_TRACKING_${env.NODE_ENV}`,
+};
diff --git a/apps/web/tsconfig.json b/apps/web/tsconfig.json
index 81209be..88a706a 100644
--- a/apps/web/tsconfig.json
+++ b/apps/web/tsconfig.json
@@ -3,15 +3,17 @@
"compilerOptions": {
"baseUrl": ".",
"paths": {
- "~/*": ["./src/*"]
+ "~/*": [
+ "./src/*"
+ ]
},
"plugins": [
{
"name": "next"
}
- ]
+ ],
+ "strictNullChecks": true
},
-
"include": [
"next-env.d.ts",
"**/*.ts",
@@ -20,5 +22,7 @@
"**/*.js",
".next/types/**/*.ts"
],
- "exclude": ["node_modules"]
+ "exclude": [
+ "node_modules"
+ ]
}
diff --git a/package.json b/package.json
index 27735a7..c0d06d9 100644
--- a/package.json
+++ b/package.json
@@ -3,15 +3,15 @@
"private": true,
"scripts": {
"build": "turbo build",
- "dev": "turbo dev --filter=web",
+ "dev": "pnpm load-env -- turbo dev --filter=web",
"lint": "turbo lint",
"format": "prettier --write \"**/*.{ts,tsx,md}\"",
- "db:generate": "pnpm db generate",
- "db:push": "pnpm db push",
- "db:migrate-dev": "pnpm db migrate-dev",
- "db:migrate-deploy": "pnpm db migrate-deploy",
- "db:studio": "pnpm db studio",
- "db": "pnpm load-env -- pnpm --filter @unsend/db",
+ "db:generate": "pnpm db db:generate",
+ "db:push": "pnpm db db:push",
+ "db:migrate-dev": "pnpm db db:migrate-dev",
+ "db:migrate-deploy": "pnpm db db:migrate-deploy",
+ "db:studio": "pnpm db db:studio",
+ "db": "pnpm load-env -- pnpm --filter=web",
"load-env": "dotenv -e .env"
},
"devDependencies": {
diff --git a/packages/db/.gitignore b/packages/db/.gitignore
deleted file mode 100644
index 11ddd8d..0000000
--- a/packages/db/.gitignore
+++ /dev/null
@@ -1,3 +0,0 @@
-node_modules
-# Keep environment variables out of version control
-.env
diff --git a/packages/db/client.ts b/packages/db/client.ts
deleted file mode 100644
index fcab163..0000000
--- a/packages/db/client.ts
+++ /dev/null
@@ -1 +0,0 @@
-export * from "@prisma/client";
diff --git a/packages/db/index.ts b/packages/db/index.ts
deleted file mode 100644
index 19bb95e..0000000
--- a/packages/db/index.ts
+++ /dev/null
@@ -1,21 +0,0 @@
-import { PrismaClient } from "@prisma/client";
-
-declare global {
- // We need `var` to declare a global variable in TypeScript
- // eslint-disable-next-line no-var
- var prisma: PrismaClient | undefined;
-}
-
-if (!globalThis.prisma) {
- globalThis.prisma = new PrismaClient({
- datasourceUrl: process.env.DATABASE_URL,
- });
-}
-
-export const prisma =
- globalThis.prisma ||
- new PrismaClient({
- datasourceUrl: process.env.DATABASE_URL,
- });
-
-export const getPrismaClient = () => prisma;
diff --git a/packages/db/package.json b/packages/db/package.json
deleted file mode 100644
index 32b8c51..0000000
--- a/packages/db/package.json
+++ /dev/null
@@ -1,18 +0,0 @@
-{
- "name": "@unsend/db",
- "version": "0.0.0",
- "main": "./index.ts",
- "types": "./index.ts",
- "dependencies": {
- "@prisma/client": "^5.11.0",
- "prisma": "^5.11.0"
- },
- "scripts": {
- "post-install": "prisma generate",
- "generate": "prisma generate",
- "push": "prisma db push --skip-generate",
- "migrate-dev": "prisma migrate dev",
- "migrate-deploy": "prisma migrate deploy",
- "studio": "prisma studio"
- }
-}
\ No newline at end of file
diff --git a/packages/db/prisma/schema.prisma b/packages/db/prisma/schema.prisma
deleted file mode 100644
index 81d10e7..0000000
--- a/packages/db/prisma/schema.prisma
+++ /dev/null
@@ -1,73 +0,0 @@
-// This is your Prisma schema file,
-// learn more about it in the docs: https://pris.ly/d/prisma-schema
-
-generator client {
- provider = "prisma-client-js"
-}
-
-datasource db {
- provider = "postgresql"
- // NOTE: When using mysql or sqlserver, uncomment the @db.Text annotations in model Account below
- // Further reading:
- // https://next-auth.js.org/adapters/prisma#create-the-prisma-schema
- // https://www.prisma.io/docs/reference/api-reference/prisma-schema-reference#string
- url = env("DATABASE_URL")
-}
-
-model Post {
- id Int @id @default(autoincrement())
- name String
- createdAt DateTime @default(now())
- updatedAt DateTime @updatedAt
-
- createdBy User @relation(fields: [createdById], references: [id])
- createdById String
-
- @@index([name])
-}
-
-// Necessary for Next auth
-model Account {
- id String @id @default(cuid())
- userId String
- type String
- provider String
- providerAccountId String
- refresh_token String? // @db.Text
- access_token String? // @db.Text
- expires_at Int?
- token_type String?
- scope String?
- id_token String? // @db.Text
- session_state String?
- user User @relation(fields: [userId], references: [id], onDelete: Cascade)
-
- @@unique([provider, providerAccountId])
-}
-
-model Session {
- id String @id @default(cuid())
- sessionToken String @unique
- userId String
- expires DateTime
- user User @relation(fields: [userId], references: [id], onDelete: Cascade)
-}
-
-model User {
- id String @id @default(cuid())
- name String?
- email String? @unique
- emailVerified DateTime?
- image String?
- accounts Account[]
- sessions Session[]
- posts Post[]
-}
-
-model VerificationToken {
- identifier String
- token String @unique
- expires DateTime
-
- @@unique([identifier, token])
-}
diff --git a/packages/ui/package.json b/packages/ui/package.json
index 219955c..790316c 100644
--- a/packages/ui/package.json
+++ b/packages/ui/package.json
@@ -27,6 +27,8 @@
"typescript": "^5.3.3"
},
"dependencies": {
+ "@radix-ui/react-dialog": "^1.0.5",
+ "@radix-ui/react-label": "^2.0.2",
"@radix-ui/react-slot": "^1.0.2",
"add": "^2.0.6",
"class-variance-authority": "^0.7.0",
diff --git a/packages/ui/src/dialog.tsx b/packages/ui/src/dialog.tsx
new file mode 100644
index 0000000..01dace8
--- /dev/null
+++ b/packages/ui/src/dialog.tsx
@@ -0,0 +1,122 @@
+"use client";
+
+import * as React from "react";
+import * as DialogPrimitive from "@radix-ui/react-dialog";
+import { X } from "lucide-react";
+
+import { cn } from "../lib/utils";
+
+const Dialog = DialogPrimitive.Root;
+
+const DialogTrigger = DialogPrimitive.Trigger;
+
+const DialogPortal = DialogPrimitive.Portal;
+
+const DialogClose = DialogPrimitive.Close;
+
+const DialogOverlay = React.forwardRef<
+ React.ElementRef,
+ React.ComponentPropsWithoutRef
+>(({ className, ...props }, ref) => (
+ ,
+ React.ComponentPropsWithoutRef
+>(({ className, children, ...props }, ref) => (
+
+
+ {children}
+
+
+
+
+));
+DialogContent.displayName = DialogPrimitive.Content.displayName;
+
+const DialogHeader = ({
+ className,
+ ...props
+}: React.HTMLAttributes) => (
+
+);
+DialogHeader.displayName = "DialogHeader";
+
+const DialogFooter = ({
+ className,
+ ...props
+}: React.HTMLAttributes) => (
+
+);
+DialogFooter.displayName = "DialogFooter";
+
+const DialogTitle = React.forwardRef<
+ React.ElementRef,
+ React.ComponentPropsWithoutRef
+>(({ className, ...props }, ref) => (
+ ,
+ React.ComponentPropsWithoutRef
+>(({ className, ...props }, ref) => (
+ {}
+
+const Input = React.forwardRef(
+ ({ className, type, ...props }, ref) => {
+ return (
+
+ );
+ }
+);
+Input.displayName = "Input";
+
+export { Input };
diff --git a/packages/ui/src/label.tsx b/packages/ui/src/label.tsx
new file mode 100644
index 0000000..c27686d
--- /dev/null
+++ b/packages/ui/src/label.tsx
@@ -0,0 +1,26 @@
+"use client";
+
+import * as React from "react";
+import * as LabelPrimitive from "@radix-ui/react-label";
+import { cva, type VariantProps } from "class-variance-authority";
+
+import { cn } from "../lib/utils";
+
+const labelVariants = cva(
+ "text-sm font-medium leading-none peer-disabled:cursor-not-allowed peer-disabled:opacity-70"
+);
+
+const Label = React.forwardRef<
+ React.ElementRef,
+ React.ComponentPropsWithoutRef &
+ VariantProps
+>(({ className, ...props }, ref) => (
+
- Create T3 App -
-
-
-
-
- First Steps →
-
- Just the basics - Everything you need to know to set up your
- database and authentication.
-
-
-
- Documentation →
-
- Learn more about Create T3 App, the libraries it uses, and how to
- deploy it.
-
-
-
-
);
}
-
-async function CrudShowcase() {
- const session = await getServerAuthSession();
- if (!session?.user) return null;
-
- const latestPost = await api.post.getLatest();
-
- return (
- - {hello ? hello.greeting : "Loading tRPC query..."} -
- -
-
+
+
+
-
- - {session && Logged in as {session.user?.name}} -
- - {session ? "Sign out" : "Sign in"} +
+
+
+ {session?.user ? (
+
-
- {latestPost ? (
-
- );
-}
diff --git a/apps/web/src/env.js b/apps/web/src/env.js
index f642243..d1867c0 100644
--- a/apps/web/src/env.js
+++ b/apps/web/src/env.js
@@ -28,6 +28,12 @@ export const env = createEnv({
// VERCEL_URL doesn't include `https` so it cant be validated as a URL
process.env.VERCEL ? z.string() : z.string().url()
),
+ GITHUB_ID: z.string(),
+ GITHUB_SECRET: z.string(),
+ AWS_ACCESS_KEY: z.string(),
+ AWS_SECRET_KEY: z.string(),
+ APP_URL: z.string().optional(),
+ SNS_TOPIC: z.string(),
},
/**
@@ -48,6 +54,12 @@ export const env = createEnv({
NODE_ENV: process.env.NODE_ENV,
NEXTAUTH_SECRET: process.env.NEXTAUTH_SECRET,
NEXTAUTH_URL: process.env.NEXTAUTH_URL,
+ GITHUB_ID: process.env.GITHUB_ID,
+ GITHUB_SECRET: process.env.GITHUB_SECRET,
+ AWS_ACCESS_KEY: process.env.AWS_ACCESS_KEY,
+ AWS_SECRET_KEY: process.env.AWS_SECRET_KEY,
+ APP_URL: process.env.APP_URL,
+ SNS_TOPIC: process.env.SNS_TOPIC,
},
/**
* Run `build` or `dev` with `SKIP_ENV_VALIDATION` to skip env validation. This is especially
diff --git a/apps/web/src/providers/next-auth.tsx b/apps/web/src/providers/next-auth.tsx
new file mode 100644
index 0000000..4ee71a6
--- /dev/null
+++ b/apps/web/src/providers/next-auth.tsx
@@ -0,0 +1,18 @@
+"use client";
+
+import React from "react";
+
+import type { Session } from "next-auth";
+import { SessionProvider } from "next-auth/react";
+
+export type NextAuthProviderProps = {
+ session?: Session | null;
+ children: React.ReactNode;
+};
+
+export const NextAuthProvider = ({
+ session,
+ children,
+}: NextAuthProviderProps) => {
+ return Your most recent post: {latestPost.name}
- ) : ( -You have no posts yet.
- )} - -