ramadhan sjamsani
ed765d230c
- Add require_mitra_ping + mitra_ping_interval_seconds config keys (migration) - Add getMitraPingConfig/setMitraPingConfig to config service - Add GET/PATCH /internal/config/mitra-ping routes for control center - Update mitra status service: honor ping config in auto-offline sweep, include ping config in GET /api/mitra/status response - Enhance pairing FCM payload with action: 'open_accept' for deep-link - Add FCM fallback to closure.service (initiateEarlyEnd, completeSession) - Add FCM fallback to session-timer.service (onSessionExpired) - Add unread count queries (getActiveSessionByCustomerWithUnread, getActiveSessionsByMitraWithUnread) - Add GET /api/client/chat/session/active-with-unread route - Add GET /api/mitra/chat-requests/sessions/active-with-unread route Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
41 lines
1.4 KiB
JavaScript
41 lines
1.4 KiB
JavaScript
import 'dotenv/config'
|
|
import { buildPublicApp } from './app.public.js'
|
|
import { buildInternalApp } from './app.internal.js'
|
|
import { autoOfflineStaleMitras } from './services/mitra-status.service.js'
|
|
import { initFirebase } from './plugins/firebase.js'
|
|
import { restoreActiveTimers } from './services/session-timer.service.js'
|
|
|
|
const PUBLIC_PORT = process.env.PUBLIC_PORT || 3000
|
|
const INTERNAL_PORT = process.env.INTERNAL_PORT || 3001
|
|
const INTERNAL_HOST = process.env.INTERNAL_HOST || '127.0.0.1'
|
|
|
|
const start = async () => {
|
|
initFirebase()
|
|
const publicApp = await buildPublicApp()
|
|
const internalApp = await buildInternalApp()
|
|
|
|
await publicApp.listen({ port: PUBLIC_PORT, host: '0.0.0.0' })
|
|
console.log(`Public API listening on port ${PUBLIC_PORT}`)
|
|
|
|
await internalApp.listen({ port: INTERNAL_PORT, host: INTERNAL_HOST })
|
|
console.log(`Internal API listening on ${INTERNAL_HOST}:${INTERNAL_PORT}`)
|
|
|
|
// Restore session timers for active sessions (on server restart)
|
|
await restoreActiveTimers()
|
|
|
|
// Auto-offline mitras with stale heartbeat (every 30s)
|
|
setInterval(async () => {
|
|
try {
|
|
const count = await autoOfflineStaleMitras()
|
|
if (count > 0) console.log(`Auto-offlined ${count} stale mitra(s)`)
|
|
} catch (err) {
|
|
console.error('Auto-offline check failed:', err)
|
|
}
|
|
}, 30_000)
|
|
}
|
|
|
|
start().catch((err) => {
|
|
console.error(err)
|
|
process.exit(1)
|
|
})
|