feat: add resend provider (#1)

* feat: adding resend provider to deal easily with emails

* fix: pnpm lock

* fix: check if email was sent or if has some error

* fix: redis config for fly

* fix: ignore fly env

Author: iagocavalcante

.env.example

@@ -7,7 +7,7 @@ APP_SECRET=REPLACE_WITH_LONG_SECRET
 
 JWT_TOKEN_EXPIRES_IN=30d
 
-DATABASE_URL="postgresql://postgres:password@localhost:5432/docmost?schema=public"
+DATABASE_URL="postgresql://postgres:postgres@localhost:5432/docmost?schema=public"
 REDIS_URL=redis://127.0.0.1:6379
 
 # options: local | s3
@@ -24,7 +24,7 @@ AWS_S3_FORCE_PATH_STYLE=
 # default: 50mb
 FILE_UPLOAD_SIZE_LIMIT=
 
-# options: smtp | postmark
+# options: smtp | postmark | resend
 MAIL_DRIVER=smtp
 MAIL_FROM_ADDRESS=hello@example.com
 MAIL_FROM_NAME=Docmost
@@ -43,4 +43,6 @@ POSTMARK_TOKEN=
 # for custom drawio server
 DRAWIO_URL=
 
-DISABLE_TELEMETRY=false
+# Resend driver config
+RESEND_API_TOKEN=
+DISABLE_TELEMETRY=false

.env.fly

@@ -0,0 +1,36 @@
+# your domain, e.g https://example.com
+APP_URL=https://notionish.fly.dev
+PORT=3000
+
+# make sure to replace this.
+APP_SECRET=DeZy/1Zne6LA3dhWieLdidYLvepXmpSv8p4Sm7GpDBo=
+
+JWT_TOKEN_EXPIRES_IN=30d
+
+DATABASE_URL="postgres://notionish:xrXwVJ6R7PwzaJX@notionish-db.flycast:5432/notionish?sslmode=disable"
+REDIS_URL="redis://default:15ac3435cf164abfbaed717546f1e244@fly-notionish-redis.upstash.io:6379?family=6"
+
+# options: local | s3
+STORAGE_DRIVER=s3
+
+# S3 driver config
+AWS_S3_ACCESS_KEY_ID=tid_SbhaJfkRGDWlEFKIMMvaZ_JMdsOPXxPxFOmZFqSuzwbgQtkfwg
+AWS_S3_SECRET_ACCESS_KEY=tsec_FpRz6DyZOmuHhWgTWDCtesOXAkElx9xAGWzxIvTWQIZ2hwprx6C94BahROcdvK3S5UHAIs
+AWS_S3_REGION=auto
+AWS_S3_BUCKET=notionish-bucket
+AWS_S3_ENDPOINT=https://fly.storage.tigris.dev
+AWS_S3_FORCE_PATH_STYLE=
+
+# default: 50mb
+FILE_UPLOAD_SIZE_LIMIT=
+
+# options: smtp | postmark | resend
+MAIL_DRIVER=resend
+MAIL_FROM_ADDRESS=contact@iagocavalcante.com
+MAIL_FROM_NAME=Notionish
+
+# Postmark driver config
+POSTMARK_TOKEN=
+
+# Resend driver config
+RESEND_API_TOKEN=re_GZ1henng_6N8F5Hm5JqkE2gPzVe92ZfGw

.github/workflows/fly-deploy.yml

@@ -0,0 +1,18 @@
+# See https://fly.io/docs/app-guides/continuous-deployment-with-github-actions/
+
+name: Fly Deploy
+on:
+  push:
+    branches:
+      - main
+jobs:
+  deploy:
+    name: Deploy app
+    runs-on: ubuntu-latest
+    concurrency: deploy-group    # optional: ensure only one action runs at a time
+    steps:
+      - uses: actions/checkout@v4
+      - uses: superfly/flyctl-actions/setup-flyctl@master
+      - run: flyctl deploy --remote-only
+        env:
+          FLY_API_TOKEN: ${{ secrets.FLY_API_TOKEN }}

.gitignore

@@ -1,6 +1,7 @@
 .env
 .env.dev
 .env.prod
+.env.fly
 data
 # compiled output
 /dist

.tool-versions

@@ -0,0 +1 @@
+nodejs 22.6.0

apps/server/package.json

@@ -77,6 +77,7 @@
     "postmark": "^4.0.5",
     "react": "^18.3.1",
     "reflect-metadata": "^0.2.2",
+    "resend": "^4.0.1",
     "rxjs": "^7.8.1",
     "sanitize-filename-ts": "^1.0.2",
     "socket.io": "^4.8.1",

apps/server/src/integrations/environment/environment.service.ts

@@ -145,6 +145,10 @@ export class EnvironmentService {
     return this.configService.get<string>('DRAWIO_URL');
   }
 
+  getResendApiToken(): string {
+    return this.configService.get<string>('RESEND_API_TOKEN');
+  }
+
   isCloud(): boolean {
     const cloudConfig = this.configService
       .get<string>('CLOUD', 'false')

apps/server/src/integrations/environment/environment.validation.ts

@@ -43,7 +43,7 @@ export class EnvironmentVariables {
   APP_SECRET: string;
 
   @IsOptional()
-  @IsIn(['smtp', 'postmark'])
+  @IsIn(['smtp', 'postmark', 'resend'])
   MAIL_DRIVER: string;
 
   @IsOptional()

apps/server/src/integrations/health/redis.health.ts

@@ -5,6 +5,7 @@ import {
 import { Injectable, Logger } from '@nestjs/common';
 import { EnvironmentService } from '../environment/environment.service';
 import { Redis } from 'ioredis';
+import { parseRedisUrl } from 'src/common/helpers/utils';
 
 @Injectable()
 export class RedisHealthIndicator {
@@ -19,8 +20,16 @@ export class RedisHealthIndicator {
     const indicator = this.healthIndicatorService.check(key);
 
     try {
-      const redis = new Redis(this.environmentService.getRedisUrl(), {
+      const { host, port, password, db } = parseRedisUrl(
+        this.environmentService.getRedisUrl(),
+      );
+      const redis = new Redis({
+        host,
+        port,
+        password,
+        db,
         maxRetriesPerRequest: 15,
+        family: 6,
       });
 
       await redis.ping();

apps/server/src/integrations/mail/drivers/resend.driver.ts

@@ -0,0 +1,51 @@
+import { MailDriver } from './interfaces/mail-driver.interface';
+import { ResendConfig } from '../interfaces';
+import { Resend } from 'resend';
+import { MailMessage } from '../interfaces/mail.message';
+import { Logger } from '@nestjs/common';
+import { mailLogName } from '../mail.utils';
+
+export class ResendDriver implements MailDriver {
+  private readonly logger = new Logger(mailLogName(ResendDriver.name));
+  private readonly resendClient: Resend;
+
+  constructor(config: ResendConfig) {
+    this.logger.debug(`TOKEN ${config.resendApiToken}`);
+    this.resendClient = new Resend(config.resendApiToken);
+  }
+
+  private formatEmailAddress(email: string): string {
+    if (email.includes('<') && email.includes('>')) {
+      const matches = email.match(/<(.+)>/);
+      if (matches && matches[1]) {
+        return matches[1];
+      }
+    }
+    return email;
+  }
+
+  async sendMail(message: MailMessage): Promise<void> {
+    try {
+      const fromEmail = this.formatEmailAddress(message.from);
+      this.logger.debug(`Attempting to send mail from ${fromEmail}`);
+
+      const { data, error } = await this.resendClient.emails.send({
+        from: fromEmail,
+        to: message.to,
+        subject: message.subject,
+        text: message.text,
+        html: message.html,
+      });
+
+      if (error) {
+        this.logger.error(`Failed to send mail: ${error.message}`);
+        throw new Error(error.message);
+      }
+
+      this.logger.debug(`Email sent successfully. ID: ${data?.id}`);
+    } catch (err) {
+      this.logger.error(`Failed to send mail: ${err}`);
+      throw err;
+    }
+  }
+}