spirit_smiirl/index.js

// Smiiirl Compteur - Entreprise Spirit SA 

const path = require('path');
const express = require('express');
const app = express();
const port = process.env.PORT || 3000;
const bodyParser = require('body-parser');
const validator = require('validator');
const API = require('./lib/API');
const mail =  require('./notification.js')

let info = {
    followers: 99999,
    companyID: 991997, // spirit_3 company page
    orgaName: "spirit_3",
    tokens: null,
    expire: 0,
    active: true,
    updateTime: 4000 // 25000 Api call / 24H
}

if (process.env.access_token) {
    info.tokens = process.env.access_token
    info.active = true
}
if (process.env.expire) info.expire = process.env.expire

async function watchLinkedin(){
    if (info.active){

        try {
            API.getCompanyFollowers(info).then( (followersNb) => {

                if (followersNb.firstDegreeSize) {
                    info.followers = followersNb.firstDegreeSize
                    process.env.lastFollowers = info.followers
                    // cleanUp error
                    info.error = 0
                }
            }).catch( (err)=> {
                console.log(err);
                throw new error
            })
        } catch (error) {
            console.log("[DEBUG-LOG][watchLinkedin ERROR]", err);
            info.error++
            if (info.error > 50) {
                info.active = false
                mail.notif(process.env.usermail, process.env.pswd, process.env.contact);
            }
        }

    }
}

setInterval(watchLinkedin, info.updateTime)

// --- --- --- --- --- --- EXPRESS SERVER

app.disable('x-powered-by');
app.use(bodyParser.urlencoded({ extended: true}));

app.get('/', (req, res) => {
    res.json({number: info.followers})
});

app.get('/auth', (req, res) => {
    res.redirect(API.getAuthorizationUrl());
});

app.get('/callback', async (req, res) => {
    if(!req.query.code) {
        res.redirect('/');
        return;
    }
    try {
        const data = await API.getAccessToken(req);
        if(data.access_token) {
            info.token = data.access_token;
            info.authorized = true;
            info.active = true
            process.env.access_token = info.token
            process.env.expire = data.expire ? data.expire : 0
        }
        res.redirect('/');
    } catch(err) {
        res.json(err);
    }
});

app.get('/test', async (req, res) => {
    try {
        const id = await API.getLinkedinId(info);
        console.log("[getLinkedinId]", id)
        res.json(id)
    } catch(err) {
        res.send(err);
     }
});

app.get('/company', async (req, res) => {
    try {
        await API.getCompanyFollowers(info)
        .then( (followersNb) => {
            if (followersNb.firstDegreeSize) {
                info.followers = followersNb.firstDegreeSize
                process.env.lastFollowers = info.followers
                res.json(info.followers)
            } else res.json({"error": "firstDegreeSize not available"})
        }).catch( (err) => {
            info.error++
            if (info.error > 50) mail.notif(process.env.usermail, process.env.pswd, process.env.contact);
        })

    } catch(err) {
        res.send(err);
    }
});

app.listen(process.env.PORT);