Firebase Integration

.github/docker-img.yml

@@ -0,0 +1,59 @@
+name: Publish Docker Images
+
+on: [push]
+# on:
+#   push:
+#     branches:
+#       - 'main'
+
+env:
+  HUSKY: 0
+
+jobs:
+  docker:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Check out code
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
+
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v3
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v3
+
+      - name: Get current date
+        id: date
+        run: echo "::set-output name=date::$(date +'%Y_%m_%d_%H_%m')"
+
+      - name: Build Express Server Image
+        run: docker build -f ./apps/express-server/Dockerfile -t ${{secrets.DOCKER_HUB_USERNAME}}/csl-express-server:${{ steps.date.outputs.date }} .
+
+      - name: Build NestJS Server Image
+        run: docker build -f ./apps/nestjs-server/Dockerfile -t ${{secrets.DOCKER_HUB_USERNAME}}/csl-nestjs-server:${{ steps.date.outputs.date }} .
+
+      - name: Build Next Client Image
+        run: docker build -f ./apps/next-client/Dockerfile -t ${{ secrets.DOCKER_HUB_USERNAME }}/csl-next-client:${{ steps.date.outputs.date }} .
+
+      - name: Build React Client Image
+        run: docker build -f ./apps/react-client/Dockerfile -t ${{ secrets.DOCKER_HUB_USERNAME }}/csl-next-client:${{ steps.date.outputs.date }} .
+
+      - name: Login to DockerHub
+        uses: docker/login-action@v3
+        with:
+          username: ${{ secrets.DOCKER_HUB_USERNAME }}
+          password: ${{ secrets.DOCKER_HUB_PASSWORD }}
+
+      - name: Push Express Server Image to Docker Hub
+        run: docker push ${{ secrets.DOCKER_HUB_USERNAME }}/csl-express-server:${{ steps.date.outputs.date }}
+
+      - name: Push NestJS Server Image to Docker Hub
+        run: docker push ${{ secrets.DOCKER_HUB_USERNAME }}/csl-nestjs-server:${{ steps.date.outputs.date }}
+
+      - name: Push Next Client Image to Docker Hub
+        run: docker push ${{ secrets.DOCKER_HUB_USERNAME }}/csl-next-client:${{ steps.date.outputs.date }}
+
+      - name: Push React Client Image to Docker Hub
+        run: docker push ${{ secrets.DOCKER_HUB_USERNAME }}/csl-react-client:${{ steps.date.outputs.date }}

.gitignore

@@ -43,9 +43,10 @@ coverage
 !.vscode/launch.json
 !.vscode/extensions.json
 
-# misc
+# express-server
 apps/express-server/public
 apps/express-server/uploads
+apps/express-server/src/firebase/service-account.json
 
 # config files for migrations
 apps/mysql-migrations/config/config.json

README.md

@@ -15,28 +15,26 @@
 
 The code for shared packages are in the `packages` folder & the applications code in the `apps` folder.
 
-Install `node_modules`
+Run the `setup.sh` script.
 
 ```bash
-yarn
+sh setup.sh
 ```
 
-Due to some issues with `express` dependencies, you also need to run
+This will perform the following tasks:
 
-```
-npm dedupe
-```
+- Install `node_modules` in workspace root
+- Build the `@csl/mongo-models`, `@csl/react-express` and `@csl/shared-fe` packages.
+- Link these packages to the respective applications in the `apps` directory. 
 
-to scan your `node_modules` and moves dependencies up in the tree if different versions can be consolidated. Delete the `package-lock.json` after running this command.
-
-Build, run, lint or test all your apps in one command thanks to [Turborepo's Pipelines](https://turborepo.org/docs/core-concepts/pipelines)
-
-To build all the shared packages,
+To apply any changes made in the shared packages, rebuild them by running the command below:
 
 ```bash
-turbo lib:build
+yarn lib
 ```
 
+Build, run, lint or test all your apps in one command thanks to [Turborepo's Pipelines](https://turborepo.org/docs/core-concepts/pipelines)
+
 Each of the applications have common scripts which can be easily executed in parallel by turborepo's pipelines. Add these in `turbo.json`.
 
 | Command | Result |

apps/express-server/.env_sample

@@ -45,4 +45,7 @@ AWS_SQS_FIFO_URL=
 AWS_SNS_TOPIC_ARN=
 
 # Stripe
-STRIPE_SECRET_KEY=
+STRIPE_SECRET_KEY=
+
+# Firebase
+FIREBASE_API_KEY=

apps/express-server/package.json

@@ -17,28 +17,28 @@
     "@aws-sdk/client-iam": "^3.787.0",
     "@aws-sdk/client-lambda": "3.787.0",
     "@aws-sdk/client-s3": "^3.787.0",
+    "@aws-sdk/client-secrets-manager": "^3.787.0",
     "@aws-sdk/client-ses": "^3.787.0",
     "@aws-sdk/client-sns": "^3.787.0",
     "@aws-sdk/client-sqs": "^3.787.0",
     "@aws-sdk/client-ssm": "^3.787.0",
-    "@aws-sdk/client-secrets-manager": "^3.787.0",
     "@aws-sdk/s3-request-presigner": "^3.787.0",
-    "@csl/mongo-models": "*",
-    "@csl/react-express": "*",
     "@sentry/cli": "^2.43.0",
     "@sentry/node": "^9.13.0",
     "@sentry/profiling-node": "^9.13.0",
+    "apn": "^2.2.0",
     "cors": "^2.8.5",
     "csv-parser": "^3.2.0",
-    "dotenv": "^16.5.0",
     "dd-trace": "^5.48.1",
-    "express": "^4.21.2",
+    "dotenv": "^16.5.0",
+    "express": "^5.1.0",
+    "firebase-admin": "^13.5.0",
     "fluent-ffmpeg": "^2.1.3",
     "ioredis": "^5.6.1",
     "mixpanel": "^0.18.1",
     "moment": "^2.30.1",
     "mongoose": "^8.13.2",
-    "multer": "^1.4.5-lts.2",
+    "multer": "^2.0.2",
     "mysql2": "^3.14.0",
     "papaparse": "^5.5.2",
     "pg": "^8.15.1",
@@ -48,6 +48,7 @@
     "socket.io": "^4.8.1",
     "stripe": "^18.0.0",
     "stytch": "^12.17.0",
+    "ua-parser-js": "^2.0.6",
     "uuid": "^11.1.0",
     "winston": "3.17.0"
   },
@@ -56,12 +57,11 @@
     "@nish1896/eslint-flat-config": "^3.0.3",
     "@sentry/cli": "^2.43.0",
     "@types/cors": "^2.8.17",
-    "@types/express": "4.17.21",
-    "@types/express-serve-static-core": "^4.17.33",
+    "@types/express": "^5.0.5",
     "@types/fluent-ffmpeg": "^2.1.27",
-    "@types/multer": "1.4.12",
+    "@types/multer": "2.0.0",
     "@types/node": "^22.14.1",
-    "@types/papaparse":"^5.3.15",
+    "@types/papaparse": "^5.3.15",
     "@types/uuid": "^10.0.0",
     "env-cmd": "^10.1.0",
     "eslint": "^9.25.1",

apps/express-server/src/app.ts

@@ -7,7 +7,8 @@ import { ENV_VARS, ServerConfig } from '@/constants';
 import { requestLogger } from '@/middleware';
 import { routesArray } from '@/routes';
 import { io } from '.';
-
+import { sendSafariNotification } from '@/firebase/apns';
+import { sendFCMNotification } from './firebase/fcm';
 const app = express();
 
 function generatePath(routeName: string): string {
@@ -62,6 +63,24 @@ app.get('/debug-sentry', function mainHandler() {
   throw new Error('My first Sentry error!');
 });
 
+// sendSafariNotification(
+//   'eQ5dYEavCKvGtvYrgJ0oLf:APA91bG1lOfYjB13MCCxVj6aZYi9mjf28h4KfUqLFxMOw_MsFzHCRqZi3ewLutwfQzcrMmmDTf4C_R4Zo87udDtnCjvcP7hrHHAEp3gTIdXglBFXTV1B1QY',
+//   'Hello from APNs',
+//   'This is a test notification sent via APNs',
+//   'https://57f50d0eb427.ngrok-free.app'
+// ).then(() => {
+//   console.log('Safari notification sent (if device token is valid)');
+// }).catch(err => {
+//   console.error('Error sending Safari notification:', err);
+// });
+
+sendFCMNotification(
+  'eQ5dYEavCKvGtvYrgJ0oLf:APA91bG1lOfYjB13MCCxVj6aZYi9mjf28h4KfUqLFxMOw_MsFzHCRqZi3ewLutwfQzcrMmmDTf4C_R4Zo87udDtnCjvcP7hrHHAEp3gTIdXglBFXTV1B1QY',
+  'Hello from FCM in safari',
+  'This is a test notification sent via FCM',
+  { customData: 'your_custom_data' }
+);
+
 /* 404 Handler */
 app.get('*', (req: Request, response: Response) => {
   const notFoundMsg = `Not Found - "${req.originalUrl}"`;

apps/express-server/src/constants/environment.ts

@@ -11,7 +11,7 @@ function defEnvVariable(varName: string, defaultValue?: string): string {
   if (defaultValue) {
     return defaultValue.trim();
   }
-  throw new Error(`Missing required environment variable: ${varName}`);
+  throw new Error(`Missing environment variable: ${varName}`);
 }
 
 export const ENV_VARS = Object.freeze({

apps/express-server/src/firebase/apns.ts

@@ -0,0 +1,36 @@
+import apn from 'apn';
+import path from 'path';
+
+// Replace with your .p12 certificate for Safari Push
+const options: apn.ProviderOptions = {
+  pfx: path.resolve(__dirname, 'ReelQA.p12'),
+  passphrase: '12345',
+  production: true, // true for production
+};
+
+const apnProvider = new apn.Provider(options);
+
+/**
+ * Send Safari push notification
+ */
+export const sendSafariNotification = async (
+  deviceToken: string,
+  title: string,
+  body: string,
+  url: string
+) => {
+  const note = new apn.Notification();
+  note.alert = { title, body };
+  note.urlArgs = [url];
+  note.topic = 'web.in.appskeeper.reelsfrontqa';
+  note.payload = { customData: 'your_custom_data' };
+  note.expiry = Math.floor(Date.now() / 1000) + 3600; // Expires in 1 hour
+  note.priority = 10; // Immediate delivery
+
+  try {
+    const result = await apnProvider.send(note, deviceToken);
+    console.log('APNs Result:', JSON.stringify(result, null, 2));
+  } catch (err) {
+    console.error('APNs Error:', err);
+  }
+};

apps/express-server/src/firebase/fcm.ts

@@ -0,0 +1,46 @@
+import admin from 'firebase-admin';
+import { type Message } from 'firebase-admin/lib/messaging';
+import path from 'path';
+
+const serviceAccount = path.resolve(__dirname, 'service-account.json');
+
+if (!admin.apps.length) {
+  admin.initializeApp({
+    credential: admin.credential.cert(serviceAccount),
+  });
+}
+
+/* Send notification to FCM token(s) */
+export const sendFCMNotification = async (
+  token: string,
+  title: string,
+  body: string,
+  data: Record<string, string> = {}
+) => {
+
+  const message = {
+    notification: { title, body },
+    tokens: [token], // send to all saved tokens
+  };
+
+  try {
+    const response = await admin.messaging().sendEachForMulticast(message);
+    console.log('response: ', response);
+    // res.json({ successCount: response.successCount, failureCount: response.failureCount });
+  } catch (err) {
+    console.error('Error sending message:', err);
+    // res.status(500).json({ error: err.message });
+  }
+  // const message: Message = {
+  //   notification: { title, body },
+  //   data,
+  //   token,
+  // };
+
+  // try {
+  //   const response = await admin.messaging().send(message);
+  //   console.log('FCM Response:', response);
+  // } catch (err) {
+  //   console.error('FCM Error:', err);
+  // }
+};