app.js

const express = require('express');
var logger = require('morgan');
const formData = require('form-data');
const Mailgun = require('mailgun.js');
const { Client } = require('pg');

require('dotenv').config();

const client = new Client({
    user: process.env.DB_USER,
    host: process.env.DB_HOST,
    database: process.env.DB_NAME,
    password: process.env.DB_PASSWORD,
    port: process.env.DB_PORT,
    ssl: {
        rejectUnauthorized: false,
    }
});

const mailgun = new Mailgun(formData);
const mg = mailgun.client({
    username: 'api',
    key: process.env.MAILGUN_API_KEY,
    url: process.env.MAILGUN_URL
});

client.connect()
    .then(() => { })
    .catch(err => console.error('Connection error', err.stack));

var app = express();
app.set('trust proxy', true);

app.use(logger('dev'));
app.use(express.json());
app.use(express.urlencoded({ extended: false }));

app.use('/api/v1', function (req, res, next) {
    const apiKey = process.env.API_KEY;

    const authHeader = req.headers.authorization;
    if (authHeader && authHeader.startsWith('Basic ')) {
        const basicCredentials = authHeader.split(' ')[1];
        if (basicCredentials === apiKey) {
            return next();
        }
    }

    const authBody = req.body.token;
    if (authBody === apiKey) {
        return next();
    }

    res.status(401).end();
});

app.post('/api/v1/telemetry_host', async (req, res) => {
    const remoteAddress = req.ip;
    const data = req.body;

    if (!data.instance) {
        return res.status(400).json({ error: 'instance is required' });
    }

    await client.query('INSERT INTO public.telemetry_host("instance", remote_address, "data") VALUES($1, $2, $3)', [
        data.instance,
        remoteAddress,
        data
    ])

    res.status(202).end();
});

app.post('/api/v1/telemetry_gps', async (req, res) => {
    const remoteAddress = req.ip;
    const data = req.body;

    if (!data.instance) {
        return res.status(400).json({ error: 'instance is required' });
    }

    await client.query('INSERT INTO public.telemetry_gps("instance", remote_address, location, "data") VALUES($1, $2, POINT($3, $4), $5)', [
        data.instance,
        remoteAddress,
        data.lat || 0,
        data.lon || 0,
        data
    ])

    res.status(202).end();
});

app.post('/api/v1/gateway_sms', async (req, res) => {
    const message = req.body.message;
    const sender = req.body.sender;

    if (!message) {
        return res.status(400).send({ error: 'message is required' });
    }

    await mg.messages.create(process.env.MAILGUN_DOMAIN, {
        from: "Laixer Equipment <postmaster@laixer.equipment>",
        to: process.env.MAILGUN_RECIPIENT,
        subject: "SMS Gateway",
        text: `Message from ${sender}\n\n${message}`
    });

    res.status(202).end();
});

app.post('/api/v1/notify', async (req, res) => {
    const topic = req.body.topic;
    const message = req.body.message;

    if (!topic || !message) {
        return res.status(400).json({ error: 'type and message are required' });
    }

    console.log(`NOTIFY ${topic}: ${message}`);

    res.status(202).end();
});

app.get('/api/v1/ip', async (req, res) => {
    const remoteAddress = req.ip;

    res.json({ ip: remoteAddress });
});

// error handler
app.use(function (err, req, res, next) {
    console.error(err.message);

    res.status(err.status || 500).end();
});

// catch 404 and forward to error handler
app.use(function (req, res) {
    res.status(404).end();
});

module.exports = app;