Hm/twiliov3

apps/api/.env.example

@@ -51,3 +51,7 @@ STUDENT_PROFILE_URL=http://localhost:3000
 # SMTP_HOST=
 # SMTP_PASSWORD=
 # SMTP_USERNAME=
+# TWILIO_ACCOUNT_SID= 
+# TWILIO_PHONE_NUMBER= 
+# TWILIO_AUTH_TOKEN= 
+

packages/core/package.json

@@ -82,6 +82,7 @@
     "nodemailer": "^6.9.13",
     "pdfjs-dist": "^4.5.136",
     "postmark": "^3.0.15",
+    "twilio": "^5.3.7",
     "ua-parser-js": "^1.0.36",
     "zod": "^3.20.2"
   },

packages/core/src/api.ts

@@ -23,6 +23,7 @@ import { onboardingSessionWorker } from './modules/onboarding-sessions/onboardin
 import { opportunityWorker } from './modules/opportunities';
 import { resumeReviewWorker } from './modules/resume-reviews';
 import { slackWorker } from './modules/slack/slack.worker';
+import { twilioWorker } from './modules/twilio/twilio.worker';
 
 export { job } from './infrastructure/bull';
 export { OAuthCodeState } from './modules/authentication/authentication.types';
@@ -53,4 +54,5 @@ export function startBullWorkers(): void {
   profileWorker.run();
   resumeReviewWorker.run();
   slackWorker.run();
+  twilioWorker.run();
 }

packages/core/src/infrastructure/bull.types.ts

@@ -41,6 +41,7 @@ export const BullQueue = {
   RESUME_REVIEW: 'resume_review',
   SLACK: 'slack',
   STUDENT: 'student',
+  TWILIO: 'twilio',
 } as const;
 
 export type BullQueue = ExtractValue<typeof BullQueue>;
@@ -647,6 +648,13 @@ export const StudentBullJob = z.discriminatedUnion('name', [
   }),
 ]);
 
+export const TwilioMessagingBullJob = z.discriminatedUnion('name', [
+  z.object({
+    data: z.object({}),
+    name: z.literal('twilio.messaging'),
+  }),
+]);
+
 // Combination
 
 export const BullJob = z.union([
@@ -666,6 +674,7 @@ export const BullJob = z.union([
   ResumeReviewBullJob,
   SlackBullJob,
   StudentBullJob,
+  TwilioMessagingBullJob,
 ]);
 
 // Types

packages/core/src/modules/gamification/gamification.types.ts

@@ -26,6 +26,7 @@ export const ActivityType = {
   UPDATE_EDUCATION_HISTORY: 'update_education_history',
   UPDATE_WORK_HISTORY: 'update_work_history',
   UPLOAD_PROFILE_PICTURE: 'upload_profile_picture',
+  TWILIO: 'twilio',
 } as const;
 
 export type ActivityType = ExtractValue<typeof ActivityType>;

packages/core/src/modules/twilio/twilio.service.ts

@@ -0,0 +1,43 @@
+import { Twilio } from 'twilio';
+
+import { db } from '@oyster/db';
+
+import type { GetBullJobData } from '@/infrastructure/bull.types';
+
+const twilioNumber = 'INSERT HERE';
+const accountSid = 'INSERT HERE';
+const authToken = 'INSERT HERE';
+const client = new Twilio(accountSid, authToken);
+
+export async function sendMessages(_: GetBullJobData<'twilio.messaging'>) {
+  try {
+    const studentsPhoneNumbers = await db
+      .selectFrom('students')
+      .select(['phoneNumber'])
+      .execute();
+
+    console.log('Fetched phone numbers:', studentsPhoneNumbers); // Log the raw data from the database
+    const numbers = studentsPhoneNumbers
+      .map(({ phoneNumber }) => phoneNumber)
+      .filter(Boolean);
+
+    const messagePromises = numbers.map((phoneNumber) =>
+      client.messages
+        .create({
+          body: 'Money Here',
+          to: `${phoneNumber}`,
+          from: twilioNumber,
+        })
+        .then((message) => console.log(`Message sent to ${message.to}`))
+        .catch((error) =>
+          console.error(`Failed to send message to ${phoneNumber}:`, error)
+        )
+    );
+
+    Promise.all(messagePromises)
+      .then(() => console.log('All messages processed'))
+      .catch((err) => console.error('Error in processing messages:', err));
+  } catch (error) {
+    console.error('Failed to send messages:', error);
+  }
+}

packages/core/src/modules/twilio/twilio.worker.ts

@@ -0,0 +1,17 @@
+import { match } from 'ts-pattern';
+
+import { registerWorker } from '@/infrastructure/bull';
+import { TwilioMessagingBullJob } from '@/infrastructure/bull.types';
+import { sendMessages } from './twilio.service';
+
+export const twilioWorker = registerWorker(
+  'twilio',
+  TwilioMessagingBullJob,
+  async (job) => {
+    return match(job)
+      .with({ name: 'twilio.messaging' }, ({ data }) => {
+        return sendMessages(data);
+      })
+      .exhaustive();
+  }
+);

turbo.json

@@ -1,6 +1,6 @@
 {
   "$schema": "https://turborepo.org/schema.json",
-  "pipeline": {
+  "tasks": {
     "build": {
       "dependsOn": ["^build"],
       "outputs": ["build/**", "dist/**"]