Commit History
-
Create docker compose logs -f verification docker compose logs -f billing docker compose logs -f apollo
Verified signaturee80aa1b -
Create curl -X POST http://localhost:3001/detect -H "Content-Type: application/json" -d '{"namespace":"satellite","type":"pothole-detection","location":{"lat":-29.12,"lon":26.22},"severity":2,"images":[],"provenance":{"source":"test"}}'
Verified signature978c3e1 -
Create docker exec -i $(docker ps -q -f ancestor=postgres:15) psql -U integral -d integral -f postgres/migrations/01_schema.sql
Verified signaturecfcdb09 -
Create docker compose up --build -d
Verified signature59b8e1c -
Create Readme.md
Verified signature48c2b45 -
Create README.md
Verified signature504c5da
-
Create services/dashboard/package.json
Verified signaturee587d54 -
Create services/dashboard/Dockerfile
Verified signaturecf6b929 -
Create services/billing-worker/package.json
Verified signature0fc5487 -
Create services/billing-worker/Dockerfile
Verified signaturef4205e6 -
Create services/verification-worker/index.js
Verified signatured9399ed -
Create services/verification-worker/package.json
Verified signature6b9a90d -
Create services/verification-worker/Dockerfile
Verified signature4b8e806 -
Create services/detection-service/main.py
Verified signature9901342 -
Create services/detection-service/requirements.txt
Verified signature777a515 -
Create services/detection-service/Dockerfile
Verified signature76bc2b2 -
Update services/apollo-server/package.json
Verified signature986ff7f -
Create services/apollo-server/package.json
Verified signature390e407 -
Create services/apollo-server/Dockerfile
Verified signature5c5fce1 -
Update const express = require('express'); const bodyParser = require('body-parser'); const { Pool } = require('pg'); const Redis = require('ioredis'); const fetch = require('node-fetch'); const pool = new Pool({ connectionString: process.env.DATABASE_URL || 'postgresql:/localhost/integral' }); const redis = new Redis(process.env.REDIS_URL || 'redis:/localhost:6379'); const app = express(); app.use(bodyParser.json()); redis.subscribe('payouts:created', () => console.log('listening for payouts')); redis.on('message', async (channel, msg) => { if (channel !== 'payouts:created') return; const { payoutId } = JSON.parse(msg); console.log('handle payout', payoutId); / naive: call settle endpoint try { await settlePayout(payoutId); } catch (err) { console.error(err); } }); async function settlePayout(payoutId) { / fetch payout const r = await pool.query('SELECT * FROM payouts WHERE id=$1 FOR UPDATE', [payoutId]); if (r.rowCount === 0) throw new Error('payout not found'); const payout = r.rows[0]; if (payout.status !== 'created') return; / mark queued await pool.query('UPDATE payouts SET status=$1 WHERE id=$2', ['processing', payoutId]); / Example: call external TMS / Accounting system / Payment Gateway / This is a stub — replace with real API call (e.g. TMS settlement API, or bank transfer). const remote = await fakePaymentGateway(payout); if (remote.success) { const txRef = remote.txRef; await pool.query('UPDATE payouts SET status=$1, tx_ref=$2, settled_at=now() WHERE id=$3', ['settled', txRef, payoutId]); await redis.publish('payouts:settled', JSON.stringify({ payoutId, txRef })); } else { await pool.query('UPDATE payouts SET status=$1 WHERE id=$2', ['failed', payoutId]); await redis.publish('payouts:failed', JSON.stringify({ payoutId })); } } async function fakePaymentGateway(payout) { / fake delay await new Promise(r => setTimeout(r, 600)); return { success: true, txRef: `TX-${Date.now()}-${Math.floor(Math.random()*1000)}` }; } app.post('/settle/:payoutId', async (req, res) => { try { const { payoutId } = req.params; await settlePayout(payoutId); res.json({ success: true }); } catch (err) { console.error(err); res.status(500).json({ success: false, error: err.message }); } }); app.listen(process.env.PORT || 3010, () => console.log('billing-service listening 3010'));
Verified signatureab370fc -
Update migrations/01_schema.sql
Verified signature44fe6ac -
Create ini
Verified signaturef36003a -
Create docker-compose.yml
Verified signature4bf6114 -
Create lue
Verified signature29154c6 -
Upload synthetic_pothole_dataset.zip
Verified signature0bf3ad6 -
Upload integral_ml_and_dashboard.md
Verified signature546a3df -
Upload integral_react_dashboard.jsx
Verified signature2c6638a -
Upload integral_apollo_server.js
Verified signatureaa67905 -
Create Bash
Verified signature86eab3d -
Create Bash
Verified signature7482b36 -
Create billing-service/index.js
Verified signatureb38ce6c -
Create const express = require('express'); const bodyParser = require('body-parser'); const { Pool } = require('pg'); const Redis = require('ioredis'); const fetch = require('node-fetch'); const pool = new Pool({ connectionString: process.env.DATABASE_URL || 'postgresql://localhost/integral' }); const redis = new Redis(process.env.REDIS_URL || 'redis://localhost:6379'); const app = express(); app.use(bodyParser.json()); redis.subscribe('payouts:created', () => console.log('listening for payouts')); redis.on('message', async (channel, msg) => { if (channel !== 'payouts:created') return; const { payoutId } = JSON.parse(msg); console.log('handle payout', payoutId); // naive: call settle endpoint try { await settlePayout(payoutId); } catch (err) { console.error(err); } }); async function settlePayout(payoutId) { // fetch payout const r = await pool.query('SELECT * FROM payouts WHERE id=$1 FOR UPDATE', [payoutId]); if (r.rowCount === 0) throw new Error('payout not found'); const payout = r.rows[0]; if (payout.status !== 'created') return; // mark queued await pool.query('UPDATE payouts SET status=$1 WHERE id=$2', ['processing', payoutId]); // Example: call external TMS / Accounting system / Payment Gateway // This is a stub — replace with real API call (e.g. TMS settlement API, or bank transfer). const remote = await fakePaymentGateway(payout); if (remote.success) { const txRef = remote.txRef; await pool.query('UPDATE payouts SET status=$1, tx_ref=$2, settled_at=now() WHERE id=$3', ['settled', txRef, payoutId]); await redis.publish('payouts:settled', JSON.stringify({ payoutId, txRef })); } else { await pool.query('UPDATE payouts SET status=$1 WHERE id=$2', ['failed', payoutId]); await redis.publish('payouts:failed', JSON.stringify({ payoutId })); } } async function fakePaymentGateway(payout) { // fake delay await new Promise(r => setTimeout(r, 600)); return { success: true, txRef: `TX-${Date.now()}-${Math.floor(Math.random()*1000)}` }; } app.post('/settle/:payoutId', async (req, res) => { try { const { payoutId } = req.params; await settlePayout(payoutId); res.json({ success: true }); } catch (err) { console.error(err); res.status(500).json({ success: false, error: err.message }); } }); app.listen(process.env.PORT || 3010, () => console.log('billing-service listening 3010'));
Verified signaturee7f2fbf -
Create verification-service/index.js
Verified signaturefb14b4c -
Create detection-service/index.js
Verified signature12ba915 -
Create migrations/01_schema.sql
Verified signatureac179f4 -
Create schema-potholes.graphql
Verified signaturea295b09 -
initial commit
Verified signature9abc8f4