122 lines
4.1 KiB
JavaScript
122 lines
4.1 KiB
JavaScript
/* eslint-disable import/no-absolute-path */
|
|
|
|
import { Meteor } from 'meteor/meteor';
|
|
import Subscriptions from '/imports/api/Subscriptions/Subscriptions';
|
|
import SiteSettings from '/imports/api/SiteSettings/SiteSettings';
|
|
import Perlin from 'loms.perlin';
|
|
import L from 'leaflet-headless';
|
|
import calcUnion from '/imports/ui/components/Maps/SubsUnion/Unify';
|
|
import { isMailServerMaster } from '/imports/startup/server/email';
|
|
|
|
// sudo apt-get install libcairo2-dev libjpeg-dev libgif-dev
|
|
|
|
Meteor.startup(() => {
|
|
if (!isMailServerMaster) {
|
|
console.log('We only process subsUnion in master');
|
|
return;
|
|
}
|
|
const debug = true; // Meteor.isDevelopment;
|
|
Perlin.seed(Math.random());
|
|
|
|
const addNoisy = (osub) => {
|
|
const sub = osub;
|
|
let lat = Math.round(sub.location.lat * 10) / 10;
|
|
let lon = Math.round(sub.location.lon * 10) / 10;
|
|
const noiseBase = Perlin.perlin2(lat, lon);
|
|
const noise = Math.abs(noiseBase / 3);
|
|
lat += noise;
|
|
lon += noise;
|
|
sub.location.lat = lat;
|
|
sub.location.lon = lon;
|
|
sub.distance += noiseBase;
|
|
return sub;
|
|
};
|
|
|
|
const noNoisy = sub => sub;
|
|
|
|
const process = (isPublic) => {
|
|
const subscribers = Subscriptions.find().fetch();
|
|
const result = calcUnion(L, subscribers, isPublic ? addNoisy : noNoisy, true);
|
|
const union = result[0];
|
|
const bounds = result[1];
|
|
|
|
const publicl = isPublic ? 'public' : 'private';
|
|
const Publicl = publicl.replace(/\b\w/g, l => l.toUpperCase());
|
|
|
|
if (typeof union === 'object') {
|
|
const unionSet = {
|
|
$set: {
|
|
name: `subs-${publicl}-union`,
|
|
value: JSON.stringify(union),
|
|
isPublic,
|
|
description: `${Publicl} subscriptions union`,
|
|
type: 'string'
|
|
}
|
|
};
|
|
const boundsSet = {
|
|
$set: {
|
|
name: `subs-${publicl}-union-bounds`,
|
|
value: JSON.stringify(bounds),
|
|
isPublic,
|
|
description: `${Publicl} subscriptions union bounds`,
|
|
type: 'string'
|
|
}
|
|
};
|
|
const sizeSet = {
|
|
$set: {
|
|
name: 'subs-union-count',
|
|
value: subscribers.length,
|
|
isPublic: false,
|
|
description: 'Subscriptions count',
|
|
type: 'number'
|
|
}
|
|
};
|
|
// FIXME, take care of object size:
|
|
// https://stackoverflow.com/questions/10827812/what-is-the-length-maximum-for-a-string-data-type-in-mongodb-used-with-ruby
|
|
SiteSettings.upsert({ name: `subs-${publicl}-union` }, unionSet, { multi: false });
|
|
SiteSettings.upsert({ name: `subs-${publicl}-union-bounds` }, boundsSet, { multi: false });
|
|
SiteSettings.upsert({ name: 'subs-union-count' }, sizeSet, { multi: false });
|
|
if (debug) console.log(`${Publicl} subscription union calculated`);
|
|
} else {
|
|
console.log('Subscription union failed!');
|
|
}
|
|
};
|
|
|
|
// At startup, we check if it's necessary to calc subscriptions union again
|
|
const currentUnion = SiteSettings.findOne({ name: 'subs-public-union' });
|
|
const lastSubs = Subscriptions.findOne({}, { sort: { updatedAt: -1 } });
|
|
const countUnionSubs = SiteSettings.findOne({ name: 'subs-union-count' });
|
|
const countSubs = Subscriptions.find({}).count();
|
|
if (currentUnion && lastSubs) {
|
|
const lastUnionUpdated = currentUnion.updatedAt;
|
|
const lastSubsUpdated = lastSubs.updatedAt;
|
|
if (lastUnionUpdated > lastSubsUpdated || !countUnionSubs || countSubs !== countUnionSubs.value) {
|
|
console.log('Subs union outdated');
|
|
process(true);
|
|
process(false);
|
|
} else {
|
|
console.log('Subs union up-to-date');
|
|
}
|
|
}
|
|
|
|
Subscriptions.find({ createdAt: { $gt: new Date() } }).observe({
|
|
added: function newSubAdded() { // doc) {
|
|
if (debug) console.log('Subs added so recreate union');
|
|
process(true);
|
|
process(false);
|
|
}
|
|
});
|
|
|
|
Subscriptions.find().observe({
|
|
changed: function subsChanged() { // updatedDoc, oldDoc) {
|
|
if (debug) console.log('Subs changed so recreate union');
|
|
process(true);
|
|
process(false);
|
|
},
|
|
removed: function subsRemoved() { // oldDoc) {
|
|
if (debug) console.log('Subs removed so recreate union');
|
|
process(true);
|
|
process(false);
|
|
}
|
|
});
|
|
});
|