123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140 |
- // Smiiirl Compteur - Entreprise Spirit SA
- // https://git.heroku.com/smiiile-spirit.git
- // https://smiiile-spirit.herokuapp.com
- 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')
- const jsonfile = require('jsonfile')
- const tokenFile = './token.json'
- let info = {
- followers: 99999,
- companyID: 991997, // spirit_3 company page
- orgaName: "spirit_3",
- token: {},
- expire: 0,
- active: true,
- updateTime: 4000, // 25000 Api call / 24H,
- error: 0
- }
- jsonfile.readFile(tokenFile, function (err, obj) {
- if (err) console.error(err)
- else {
- console.dir(obj)
- info.token = obj
- obj = process.env.access_token
- }
- })
- function updateTokenEnv(data){
- let reqObj = data
- console.log("[updateTokenEnv] :");
- console.log(data);
- jsonfile.writeFile(tokenFile, reqObj, function (err) {
- if (err) console.error(err)
- else console.log("Token File updated")
- })
- }
- async function watchLinkedin(){
-
- if (info.active){
- const getFollowers = API.getCompanyFollowers(info)
-
- getFollowers.then( (followersNb) => {
- if (followersNb.firstDegreeSize) {
- info.followers = followersNb.firstDegreeSize
- info.error = 0 // cleanUp error
- }
- }).catch( (err) => {
- console.log("[DEBUG-LOG][watchLinkedin ERROR]", info.error, err);
- info.error++
- if (info.error > 50) {
- info.active = false
- // try refresh token
- const data = await API.getAccessToken(info.token)
- if(data.access_token) {
- 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.query.code);
- 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
- updateTokenEnv(data)
- }
- 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(8111);
|