Nodemailer Email Implementation

apps/antalmanac/src/components/Header/LoadSaveFunctionality.tsx

@@ -16,9 +16,11 @@ import { ChangeEvent, PureComponent, useEffect, useState } from 'react';
 
 import actionTypesStore from '$actions/ActionTypesStore';
 import { loadSchedule, saveSchedule } from '$actions/AppStoreActions';
+import trpc from '$lib/api/trpc'; // email sending
 import AppStore from '$stores/AppStore';
 import { useThemeStore } from '$stores/SettingsStore';
 
+
 interface LoadSaveButtonBaseProps {
     action: typeof saveSchedule;
     actionName: 'Save' | 'Load';
@@ -49,6 +51,10 @@ function SaveLoadIcon(props: SaveLoadIconProps) {
     );
 }
 
+const sendEmail = async () => {
+    await trpc.users.sendUserEmail.query();
+};
+
 class LoadSaveButtonBase extends PureComponent<LoadSaveButtonBaseProps, LoadSaveButtonBaseState> {
     state: LoadSaveButtonBaseState = {
         isOpen: false,
@@ -153,6 +159,9 @@ class LoadSaveButtonBase extends PureComponent<LoadSaveButtonBaseProps, LoadSave
                         <Button onClick={() => this.handleClose(false)} color={this.props.colorType}>
                             {this.props.actionName}
                         </Button>
+                        <Button onClick={sendEmail} color={this.props.colorType}>
+                            Send Email
+                        </Button>
                     </DialogActions>
                 </Dialog>
             </>

apps/backend/package.json

@@ -21,6 +21,7 @@
         "express": "^4.18.2",
         "mongodb": "^5.0.1",
         "mongoose": "^7.1.0j",
+        "nodemailer": "^6.9.13",
         "superjson": "^1.12.3",
         "websoc-api": "^3.0.0"
     },

apps/backend/src/env.ts

@@ -8,6 +8,10 @@ const Environment = type({
     AWS_REGION: 'string',
     MAPBOX_ACCESS_TOKEN: 'string',
     'PR_NUM?': 'number',
+    GOOGLE_EMAIL: 'string',
+    GOOGLE_ID: 'string',
+    GOOGLE_SECRET: 'string',
+    GOOGLE_REFRESH_TOKEN: 'string',
 });
 
 const env = Environment.assert({ ...process.env });

apps/backend/src/index.ts

@@ -14,12 +14,25 @@ const corsOptions: CorsOptions = {
 const MAPBOX_API_URL = 'https://api.mapbox.com';
 
 const PORT = 3000;
+import { createTransport } from 'nodemailer';
+const email = createTransport({
+    host: 'smtp.gmail.com',
+    port: 465,
+    secure: true,
+    auth: {
+    type: 'OAuth2',
+    user: env.GOOGLE_EMAIL,
+    clientId: env.GOOGLE_ID,
+    clientSecret: env.GOOGLE_SECRET,
+    refreshToken: env.GOOGLE_REFRESH_TOKEN,
+    },
+})
 
 export async function start(corsEnabled = false) {
-    await connectToMongoDB();
+    // await connectToMongoDB();
 
     const app = express();
-    app.use(cors(corsEnabled ? corsOptions : undefined));
+    app.use(cors({ origin: true }));
     app.use(express.json());
 
     app.use('/mapbox/directions/*', async (req, res) => {
@@ -42,6 +55,16 @@ export async function start(corsEnabled = false) {
         // res.type('image/png')
         // res.send(result)
     });
+
+    app.get('/email', async () => {
+        console.log("SENDING EMAIL")
+        const res = await email.sendMail({
+            to: '[email protected]', // presumably input.userEmail or something
+            subject: 'Reset Password',
+            text: `Reset your password`,
+        })
+        console.log('rez', res);
+    })
 
     app.use(
         '/trpc',

apps/backend/src/routers/users.ts

@@ -3,9 +3,24 @@ import { UserSchema } from '@packages/antalmanac-types';
 import { router, procedure } from '../trpc';
 import { ddbClient, VISIBILITY } from '../db/ddb';
 import { TRPCError } from '@trpc/server';
+import env from '../env';
+import { createTransport } from 'nodemailer';
 
 const userInputSchema = type([{ userId: 'string' }, '|', { googleId: 'string' }]);
 
+const email = createTransport({
+    host: 'smtp.gmail.com',
+    port: 465,
+    secure: true,
+    auth: {
+    type: 'OAuth2',
+    user: env.GOOGLE_EMAIL,
+    clientId: env.GOOGLE_ID,
+    clientSecret: env.GOOGLE_SECRET,
+    refreshToken: env.GOOGLE_REFRESH_TOKEN,
+    },
+})
+
 const viewInputSchema = type({
     /**
      * ID of the user who's requesting to view another user's schedule.
@@ -88,6 +103,16 @@ const usersRouter = router({
     viewUserData: procedure.input(viewInputSchema.assert).query(async ({ input }) => {
         return await ddbClient.viewUserData(input.requesterId, input.requesteeId);
     }),
+
+    sendUserEmail: procedure.query(async () => {
+        console.log("SENDING EMAIL")
+        const res = await email.sendMail({
+            to: '[email protected]', // presumably input.userEmail or something
+            subject: 'Reset Password',
+            text: `Reset your password`,
+        })
+        console.log('rez', res);
+    }),
 });
 
 export default usersRouter;