our-sejahtera-backend/index.js

const express = require('express');
const cors = require('cors')
const { Sequelize, DataTypes, STRING } = require('sequelize');
const session = require('express-session');
const bcrypt = require('bcrypt');
const QRCode = require('qrcode');
const { createSecureServer } = require('http2');
require("dotenv").config();

const sequelize = new Sequelize('sqlite::memory:')

const COOKIE_EXPIRY_DURATION = 60 * 60 * 3 * 1000; // 3 hours in milliseconds

const Contact = sequelize.define('Contact', {
    user: {
        type: DataTypes.INTEGER,
        allowNull: false,
    },
    with: {
        type: DataTypes.INTEGER,
        allowNull: false,
    },
});
Contact.sync();

const User = sequelize.define('User', {
    email: {
        type: DataTypes.STRING,
        allowNull: false,
        unique: true,
    },
    name: {
        type: DataTypes.STRING,
    },
    hash: {
        type: STRING,
    },
    phoneNumber: {
        type: DataTypes.STRING,
    },
    verification: {
        type: DataTypes.STRING,
    },
    org: {
        type: DataTypes.STRING,
    },
});

User.sync().then(() => {
    User.create({
        email: "admin@msolidariti.org",
        name: "Demo",
        hash: bcrypt.hashSync("test", 10),
        phoneNumber: "123",
    });
});


function authUser(email, password, done) {
    User.findOne({
        where: {
            email: email
        }
    }).then(user => {
        if (!user) {
            done(false, "User not found")
        } else {
            const auth = bcrypt.compareSync(password, user.hash);
            done(auth, auth ? "Authorized" : "Wrong password");
        }
    });
}

function refreshVerification(user, done) {
    let newVerification = bcrypt.hashSync(`${new Date().getTime()}-${user.hash}`, 5).replace(/[^a-zA-Z0-9]+/g, "");
    newVerification = newVerification.substr(0, newVerification.length / 2);
    console.log(`Verification: ${newVerification}`)

    user.verification = newVerification;
    user.save().then(result => {
        done(result)
    });
}

function createQRCode(email, done) {

    User.findOne({
        where: {
            email: email
        }
    }).then(user => {
        refreshVerification(user, result => {
            const verifyURL = `${process.env.SERVER_API_URL}/verify/${encodeURIComponent(result.verification)}`;
            QRCode.toDataURL(verifyURL, { width: 300, height: 300 }, (err, url) => {
                done(err, url);
            })
        });
    });
}

function checkVerification(id, done) {
    User.findOne({
        where: {
            verification: decodeURIComponent(id),
        }
    }).then(user => {
        if (user) {
            console.log(user);
            done(true, "User verified", user.id);
        } else {
            done(false, "No such verification");
        }
    });
}

function createUser(email, password, name, phoneNumber, done) {
    hash = bcrypt.hashSync(password, 10);
    User.create({
        email: email,
        name: name,
        hash: hash,
        phoneNumber: phoneNumber,
    }).then(user => {
        if (!user) {
            done(false, "Could not create user");
        } else {
            done(true, "Success");
        }
    }).catch(reason => {
        if (reason.name == "SequelizeUniqueConstraintError") {
            done(false, "User already exists");
        } else {
            done(false, "Unknown error");
        }
    });
}

function addContact(userEmail, withUserID, done) {
    User.findOne({ where: { email: userEmail } }).then(user => {
        Contact.create({ user: user.id, with: withUserID })
            .then(res => {
                done(true, "Successfully added contact");
            })
            .catch(e => {
                done(false, e);
            });
    })
}

function getCookieExpiry() {
    return new Date(Date.now() + COOKIE_EXPIRY_DURATION);
}

const app = express();
app.set('trust proxy', 1)
app.use(session({
    secret: process.env.SERVER_SESSION_SECRET,
    resave: false,
    saveUninitialized: false,
}))
app.use(cors({ credentials: true, origin: process.env.WEBSITE_URL }))
app.use(express.json())

app.post('/login', (req, res) => {
    reqEmail = req.body.email.toLowerCase();
    const auth = authUser(reqEmail, req.body.password, (success, msg) => {
        req.session.regenerate(() => {
            cookieExpiry = getCookieExpiry();
            req.session.cookie.expires = cookieExpiry;
            req.session.user = reqEmail;
            res.cookie("authorized", success, { domain: process.env.COOKIE_DOMAIN.split(","), sameSite: "none", secure: true, expires: cookieExpiry });
            res.send({ authorized: success, message: msg })
        });
    });
});

app.post('/create', (req, res) => {
    reqEmail = req.body.email.toLowerCase();
    if (req.session.verified) {
        createUser(reqEmail, req.body.password, req.body.name, req.body.phoneNumber, (success, msg) => {
            cookieExpiry = getCookieExpiry();
            req.session.cookie.expires = cookieExpiry;
            req.session.user = reqEmail;
            res.cookie("authorized", success, { domain: process.env.COOKIE_DOMAIN.split(","), sameSite: "none", secure: true, expires: cookieExpiry });
            if(success){
                addContact(req.session.user, req.session.verifiedBy, (sucesss, msg)=>{
                    res.send({ success: success, message: msg });    
                });
            }else{
                res.send({ success: success, message: msg });
            }
        });
    } else {
        res.status(401).send("Not verified");
    }
})

app.get('/code', (req, res) => {
    if (!req.session.user) {
        res.status(401).send("Not logged in");
        return;
    }
    createQRCode(req.session.user, (err, url) => {
        res.send({ error: err, data: url });
    });
})

app.get("/verify/:id", (req, res) => {
    checkVerification(req.params.id, (success, msg, withUserID) => {
        cookieExpiry = getCookieExpiry();
        req.session.cookie.expires = cookieExpiry;
        req.session.verified = success;
        req.session.verifiedBy = withUserID;

        if (success) {
            if (req.session.user) { // If Logged In
                addContact(req.session.user, withUserID, (success, msg) => {
                    if (success) {
                        res.redirect(`${process.env.WEBSITE_URL}/#/success`)
                    } else {
                        res.status(400).send(msg);
                    }
                });
            } else { // If Not Logged In
                res.cookie("verified", success, { domain: process.env.COOKIE_DOMAIN.split(","), sameSite: "none", secure: true, expires: cookieExpiry });
                if (success) {
                    res.redirect(`${process.env.WEBSITE_URL}/#/create`)
                } else {
                    res.status(400).send(msg);
                }
            }
        } else {
            res.status(400).send(msg);
        }
    });
});

const port = process.env.SERVER_PORT;

app.listen(port, () => {
    console.log(`Listening on port ${port}`);
})