File size: 1,407 Bytes
d9399ed |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 |
require('dotenv').config();
const Redis = require('ioredis');
const { Pool } = require('pg');
const redis = new Redis(process.env.REDIS_URL);
const pool = new Pool({ connectionString: process.env.DATABASE_URL });
redis.subscribe('infra:faults:created', (err, count) => {
if (err) return console.error(err);
console.log('subscribed to infra:faults:created');
});
redis.on('message', async (chan, msg) => {
if (chan !== 'infra:faults:created') return;
try {
const ev = JSON.parse(msg);
console.log('verifying', ev.id);
// simple verification stub: random confidence
const confidence = Math.random();
const confirmed = confidence > 0.45;
const q = 'UPDATE objects SET confirmed=$1 WHERE id=$2 RETURNING *';
const r = await pool.query(q, [confirmed, ev.id]);
console.log('updated confirmed', ev.id, confirmed);
// if confirmed, create a payout row
if (confirmed) {
const base = 5000;
const total = base * (r.rows[0].severity || 1);
const insert = 'INSERT INTO payouts (fault_id, amount_minor_units, currency, payee_id, status) VALUES ($1,$2,$3,$4,\'created\') RETURNING *';
const payee = 'local-contractor-001';
const p = await pool.query(insert, [ev.id, total, 'ZAR', payee]);
redis.publish('payouts:created', JSON.stringify({ payoutId: p.rows[0].id }));
}
} catch (e) {
console.error('verify error', e);
}
});
|