76 lines
2.7 KiB
JavaScript
76 lines
2.7 KiB
JavaScript
'use strict';
|
|
|
|
const { getSetting, setSetting } = require('../db/database');
|
|
|
|
const SYNC_DAYS_MAX = 45; // SimpleFIN Bridge hard limit — requests beyond this return an error
|
|
const SYNC_DAYS_EFFECTIVE = 44; // 1-day buffer so request latency never tips over the hard limit
|
|
const SYNC_DAYS_DEFAULT = 30; // routine sync window (initial seed always uses SYNC_DAYS_EFFECTIVE)
|
|
const SYNC_INTERVAL_DEFAULT = 4; // hours
|
|
|
|
function getBankSyncConfig() {
|
|
const dbValue = getSetting('bank_sync_enabled');
|
|
const envValue = process.env.BANK_SYNC_ENABLED;
|
|
|
|
let enabled;
|
|
if (dbValue !== null && dbValue !== undefined && dbValue !== '') {
|
|
enabled = dbValue === 'true';
|
|
} else if (envValue !== undefined && envValue !== '') {
|
|
enabled = envValue === 'true';
|
|
} else {
|
|
enabled = false;
|
|
}
|
|
|
|
const syncDaysDb = parseInt(getSetting('simplefin_sync_days') || '', 10);
|
|
const syncDaysEnv = parseInt(process.env.SIMPLEFIN_SYNC_DAYS || '', 10);
|
|
const rawSyncDays = Number.isFinite(syncDaysDb) && syncDaysDb > 0
|
|
? syncDaysDb
|
|
: Number.isFinite(syncDaysEnv) && syncDaysEnv > 0
|
|
? syncDaysEnv
|
|
: SYNC_DAYS_DEFAULT;
|
|
const syncDays = Math.min(rawSyncDays, SYNC_DAYS_EFFECTIVE);
|
|
|
|
const intervalDb = parseFloat(getSetting('simplefin_sync_interval_hours') || '');
|
|
const intervalEnv = parseFloat(process.env.SIMPLEFIN_SYNC_INTERVAL_HOURS || '');
|
|
const syncIntervalHours = Number.isFinite(intervalDb) && intervalDb >= 0.5
|
|
? intervalDb
|
|
: Number.isFinite(intervalEnv) && intervalEnv >= 0.5
|
|
? intervalEnv
|
|
: SYNC_INTERVAL_DEFAULT;
|
|
|
|
return {
|
|
enabled,
|
|
sync_days: syncDays,
|
|
seed_days: SYNC_DAYS_EFFECTIVE, // initial connect / explicit backfill window
|
|
sync_days_max: SYNC_DAYS_MAX, // SimpleFIN Bridge hard limit
|
|
sync_interval_hours: syncIntervalHours,
|
|
};
|
|
}
|
|
|
|
function setBankSyncEnabled(enabled) {
|
|
setSetting('bank_sync_enabled', enabled ? 'true' : 'false');
|
|
return getBankSyncConfig();
|
|
}
|
|
|
|
function setSyncIntervalHours(hours) {
|
|
const n = parseFloat(hours);
|
|
if (!Number.isFinite(n) || n < 0.5 || n > 168) {
|
|
throw Object.assign(new Error('sync_interval_hours must be between 0.5 and 168'), { status: 400 });
|
|
}
|
|
setSetting('simplefin_sync_interval_hours', String(Math.round(n * 10) / 10));
|
|
return getBankSyncConfig();
|
|
}
|
|
|
|
function setSyncDays(days) {
|
|
const n = parseInt(days, 10);
|
|
if (!Number.isFinite(n) || n < 1 || n > SYNC_DAYS_MAX) {
|
|
throw Object.assign(new Error(`sync_days must be between 1 and ${SYNC_DAYS_MAX} (SimpleFIN Bridge hard limit)`), { status: 400 });
|
|
}
|
|
setSetting('simplefin_sync_days', String(n));
|
|
return getBankSyncConfig();
|
|
}
|
|
|
|
module.exports = {
|
|
getBankSyncConfig, setBankSyncEnabled, setSyncIntervalHours, setSyncDays,
|
|
SYNC_DAYS_MAX, SYNC_DAYS_EFFECTIVE, SYNC_DAYS_DEFAULT,
|
|
};
|