176 lines
5.8 KiB
TypeScript
176 lines
5.8 KiB
TypeScript
// @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<1) {
|
||
counter++;
|
||
console.log(counter,' * ', graphQLquery.variables.title);
|
||
|
||
const body = {
|
||
operationName: "createEvent",
|
||
query: graphQLquery.query,
|
||
variables: graphQLquery.variables
|
||
}
|
||
|
||
if(parserConfig.enableFetch){
|
||
fetch(parserConfig.dev_mode? parserConfig.dev_url : parserConfig.mobilizon_public_url, {
|
||
method: "post",
|
||
body: JSON.stringify(body),
|
||
headers: {
|
||
"Content-Type": "application/json",
|
||
"authorization": "Bearer "+parserConfig.bearer_token,
|
||
}
|
||
})
|
||
.then((res:any) => {
|
||
res.json()
|
||
console.log('succès');
|
||
})
|
||
.then((json:any) => console.log(json))
|
||
.catch((err:any) => console.log(err))
|
||
}else{
|
||
console.log('---- le fetch est désactivé');
|
||
}
|
||
|
||
|
||
}
|
||
|
||
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);
|