123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120 |
- // 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 {
- const getFollowers = API.getCompanyFollowers(info)
-
- getFollowers.then( (followersNb) => {
- if (followersNb.firstDegreeSize) {
- info.followers = followersNb.firstDegreeSize
- process.env.lastFollowers = info.followers
- // cleanUp error
- info.error = 0
- }
- }).catch( err => new Error(err));
-
- } 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);
|