Initial Commit

Author: nooobcoder

.env

@@ -0,0 +1,2 @@
+USER_EMAIL = [email protected]
+USER_PASSWORD = suryashi@1234

Dockerfile

@@ -0,0 +1,11 @@
+FROM node:14
+
+WORKDIR /usr/src/app
+
+COPY package*.json ./
+
+RUN npm install
+
+COPY . .
+
+CMD [ "nodemon", "app.js" ]

app.js

@@ -0,0 +1,59 @@
+"use strict";
+
+
+const CronJob = require('cron').CronJob;
+const fs = require('fs');
+require('dotenv').config()
+const nodemailer = require("nodemailer");
+const dataPrepare = require('./dataPrepare');
+
+const mailSender = async () => {
+    let transporter = nodemailer.createTransport({
+        host: 'smtp.gmail.com',
+        port: 587,
+        secure: false,
+        requireTLS: true,
+        auth: {
+            user: process.env.USER_EMAIL,
+            pass: process.env.USER_PASSWORD,
+        }
+    });
+
+    const mailBody = dataPrepare.masterRecord;
+    console.log(mailBody);
+
+    if (Object.keys(mailBody).length === 0) {
+        return;
+    }
+
+    const data = fs.readFileSync('./recipients.txt', 'utf8');
+    if (data === '') {
+        console.error('NO EMAILS SPECIFIED, please specify email addresses in recipients.txt\nWith emails like, [email protected], [email protected]')
+        process.exit(0);
+    }
+    // send mail with defined transport object
+    let d = new Date()
+    let currentTime = d.toLocaleString('en-US', {timeZone: 'Asia/Kolkata'});
+    let info = await transporter.sendMail({
+        from: '"Ankur Paul 👻" <[email protected]>', // sender address
+        to: `${data.toString()}`, // list of receivers
+        subject: `💉 CoWin Vaccines Available - ${currentTime}`, // Subject line
+        text: JSON.stringify(mailBody, null, '\t'), // plain text body
+
+        // html: "<h1>Hi!</h1>", // html body
+    });
+
+    console.log("Message sent: %s", info.messageId);
+    // Message sent: <[email protected]>
+
+    // Preview only available when sending through an Ethereal account
+    console.log("Preview URL: %s", nodemailer.getTestMessageUrl(info));
+    // Preview URL: https://ethereal.email/message/WaQKMgKddxQDoou...
+}
+
+var job = new CronJob('* * * * *', async () => {
+    console.log('------- JOB STARTED (ITERATING IN 1 MINUTE) 🚀 ------- ')
+    mailSender().catch(console.error);
+}, null, true, 'Asia/Kolkata');
+
+job.start();

csvparser.js

@@ -0,0 +1,7 @@
+// First I want to read the file
+const fs = require('fs')
+
+const text = fs.readFileSync('./pincodes.csv', 'utf8')
+const pincodes = text.split(",");
+
+module.exports= pincodes;

dataPrepare.js

@@ -0,0 +1,38 @@
+const csvparsed = require('./csvparser');
+
+const axios = require('axios')
+
+const masterRecord = {};
+
+const apiFetch = async () => {
+    try {
+        for (const pin of csvparsed) {
+            const apiEndpoint = `https://cdn-api.co-vin.in/api/v2/appointment/sessions/public/calendarByPin?pincode=${pin}&date=03-05-2021`
+            const {data} = await axios.get(apiEndpoint);
+            // console.log(data)
+            const dataHolder = [];
+            for (const [index, {name, center_id, sessions}] of data.centers.entries()) {
+                const info = [];
+
+                for (const {available_capacity, date} of sessions) {
+                    if (available_capacity > 0) {
+                        info.push({name, date, available_capacity});
+                        // masterRecord.push({name, info: {date, available_capacity}});
+                    }
+                    // console.log(`AVAILABLE `, available_capacity, ' ON ', date)
+                }
+                if (info.length > 0)
+                    dataHolder.push({name, info})
+            }
+            if (dataHolder.length > 0)
+                masterRecord[pin] = dataHolder
+        }
+        return masterRecord;
+        // console.log(masterRecord)
+    } catch (e) {
+        console.error(e)
+    }
+}
+apiFetch().then(r => {
+});
+module.exports = {masterRecord};