rss-feeder-mobilizon/index.ts

// @author tykayn contact@cipherbliss.com www.cipherbliss.com
// imports
import utils from './utils';
import parserConfig from './config';

// @ts-ignore
import Parser from 'rss-parser';

const fetch = require('node-fetch');
let parser = new Parser();

// @ts-ignore
console.log(' ==============================================='.blue);
// @ts-ignore
console.log(' ====  Rss Feeder for mobilizon - by tykayn ===='.blue);
// @ts-ignore
console.log(' ==============================================='.blue);
if (parserConfig.debug) {
    // @ts-ignore
    console.log('configMobilizon'.blue, config);
}
const utilsTools = new utils();


// trouver si un évènement existe déjà par son titre

let createEventQueries = '';
let counterOfEventsToAdd = 0;
const addEventQuery = utilsTools.agendadulibre.addQuery;
const runCreationQuery = utilsTools.runCreationQuery;

console.log('⌛ interroger la BDD mobilizon postgresql');

async function init() {

    utilsTools.setupClientPostgresql();

    await utilsTools.client.connect();
    console.log('✅ OK connecté à postgresql');
    console.log(' ');
    const res = await utilsTools.client.query('SELECT * from events');
    console.log('💾 évènements enregistrés dans mobilizon : ', res.rows.length); // Hello world!
    // console.log('res', res);
    utilsTools.localMobilizonEventsByTitle = res.rows;

    if (parserConfig.askAgendaDuLibre) {
        // @ts-ignore
        console.log(' ===================================================='.blue);
        // @ts-ignore
        console.log(' ====  demander à l\'agenda du libre son flux RSS ===='.blue);
        // @ts-ignore
        console.log(' ===================================================='.blue);

        console.log('⌛ lecture du flux rss : ' + parserConfig.rss_feed_url);
        fetch(parserConfig.rss_feed_url, {method: 'GET'})

            .then((arrayOfEvents: any) => {
                console.log('xml rss_feed_url count', Object.keys(arrayOfEvents).length);

            });

        let feed = await parser.parseURL(parserConfig.rss_feed_url);
        console.log('✅ flux rss obtenu');
        console.log(feed.title);

        console.log('⚙️ interprétation des évènements');
        console.log(
            '⌛ trouver les évènements qui ne font pas partie de la BDD mobilizon postgresql',
        );
        feed.items.forEach((eventFound) => {
            console.log(eventFound.title);
            // console.log('item', item)
            utilsTools.agendadulibre.doesEventExists(eventFound);
        });
    }
    if (parserConfig.askOsmCal) {
        // @ts-ignore
        console.log(' ===================================================='.blue);
        // @ts-ignore
        console.log(' ====  demander à OSM cal ===='.blue);
        // @ts-ignore
        console.log(' ===================================================='.blue);

        fetch(parserConfig.osmcal_url, {method: 'GET'})
            .then((res: any) => res.json())
            .then((arrayOfEvents: any) => {
                console.log('json osmcal count', arrayOfEvents.length);

                // utilsTools.writeFile('osmcal.json', arrayOfEvents, 'json');

                let EventsToCreate: any = [];

                arrayOfEvents.forEach((eventFound: any) => {
                    if (!utilsTools.osmcal.doesEventExists(eventFound)) {
                        EventsToCreate.push(eventFound);
                    }
                    ;
                });
                utilsTools.createEventQueriesForApi(EventsToCreate)

            });
    }

    if (parserConfig.runAddQueriesToMobilizonAPI) {
        console.log(
            '➕ rajouter les évènements manquants par l\'API GraphQL',
            utilsTools.agendadulibre.queryToAdd.length
        );
        let limiter = true;
        let counter = 0;

      utilsTools.agendadulibre.queryToAdd.forEach((graphQLquery: any) => {


            if (limiter && !counter) {
                counter++;
                console.log('graphQLquery.variables.title', graphQLquery.variables.title);

                const body = {
                    operationName: "createEvent",
                    query: graphQLquery.query,
                    variables: graphQLquery.variables
                }
                // fetch(parserConfig.dev_url, {
                //     method: "post",
                //     body: JSON.stringify(body),
                //     headers: {"Content-Type": "application/json"}
                // })
                //     .then(res => {
                //         res.json()
                //         console.log('succès');
                //     })
                //     .then(json => console.log(json))
                //     .catch(err => console.log(err))

            }

            if (parserConfig.runAddQueriesToMobilizonBDD) {
                // @ts-ignore
                console.log(
                    '➕ rajouter les évènements manquants à la base mobilizon',
                );

                utilsTools.makeQuery();
                utilsTools.runCreationQuery();

            }

        });

    }
// @ts-ignore
    console.log(' ---------- '.green);
    // @ts-ignore
    console.log(counterOfEventsToAdd, ' évènements ajoutés '.green);
    // @ts-ignore
    console.log(' ---------- '.green);
    // @ts-ignore
    console.log('✅ fermer la connec postgresql');
    utilsTools.client.end();
    console.log('✅ ça c\'est fait ');
    console.log(' ');
}

(init)();
console.log('✅ hey ho', this);