123 lines
3.8 KiB
JavaScript
123 lines
3.8 KiB
JavaScript
// @author tykayn contact@cipherbliss.com www.cipherbliss.com
|
||
// imports
|
||
import utils from './utils.ts';
|
||
import parserConfig from './config.ts';
|
||
import { htmlEscape } from 'escape-goat';
|
||
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;
|
||
|
||
(async () => {
|
||
console.log('⌛ interroger la BDD mobilizon postgresql');
|
||
|
||
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!
|
||
|
||
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) => {
|
||
console.log('xml rss_feed_url count', 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) => res.json())
|
||
.then((arrayOfEvents) => {
|
||
console.log('json osmcal count', arrayOfEvents.length);
|
||
|
||
utilsTools.writeFile('osmcal.json', arrayOfEvents, 'json');
|
||
|
||
console.log('arrayOfEvents[0]', arrayOfEvents[1])
|
||
utilsTools.osmcal.doesEventExists(arrayOfEvents[1])
|
||
|
||
// arrayOfEvents.forEach((eventFound) => {
|
||
// utilsTools.osmcal.doesEventExists(eventFound);
|
||
// });
|
||
});
|
||
}
|
||
|
||
if (parserConfig.runAddQueriesToMobilizon) {
|
||
// @ts-ignore
|
||
console.log(
|
||
'➕ rajouter les évènements manquants à la base mobilizon'.blue,
|
||
);
|
||
|
||
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');
|
||
await utilsTools.client.end();
|
||
console.log('✅ ça c\'est fait '.green);
|
||
}
|
||
|
||
})();
|
||
|
||
exports = () => {
|
||
console.log('✅ hey ho', this);
|
||
};
|