Healthcheck & Connectivity Monitoring
The Healthcheck system continuously monitors the availability and status of all configured database sources and storage destinations. It ensures that connection issues are detected early and can be tracked historically.
Architecture
Data Model
The system extends the Prisma schema with a dedicated log table for health checks and adds caching fields to the AdapterConfig model.
// Status states for adapters
enum HealthStatus {
ONLINE // Connection successful
DEGRADED // Transient failures (first/second attempt failed)
OFFLINE // Persistent failure (>= 3 consecutive failures)
}
// Log entry for each check cycle
model HealthCheckLog {
id String @id
adapterConfigId String
status HealthStatus
latencyMs Int // Measured latency in milliseconds
error String? // Error message if failed
createdAt DateTime
adapterConfig AdapterConfig @relation(...)
}
model AdapterConfig {
// ...existing fields
lastHealthCheck DateTime? // Timestamp of last check
lastStatus String // Cached status: "ONLINE" | "DEGRADED" | "OFFLINE"
lastError String? // Human-readable reason when lastStatus != ONLINE
consecutiveFailures Int // Counter for failure state machine
}Components Overview
┌─────────────────┐ ┌──────────────────┐ ┌─────────────────────────────┐
│ System Task │────▶│ Healthcheck │────▶│ Adapter.ping() │
│ (Scheduler) │ │ Service │ │ (falls back to .test() │
└─────────────────┘ └──────────────────┘ │ if ping() not implemented) │
│ └─────────────────────────────┘
▼
┌──────────────────┐
│ HealthCheckLog │
│ (Database) │
└──────────────────┘Backend Service
Location: src/services/system/healthcheck-service.ts
The core service that performs the actual health checks.
Constants
const ADAPTER_CHECK_TIMEOUT_MS = 15_000; // 15 second timeout per individual adapter check
const MAX_CONCURRENT_CHECKS = 5; // Max parallel checks to avoid overloading
const DEFAULT_REMINDER_COOLDOWN_MS = 24 * 60 * 60 * 1000; // 24 h: re-notify interval for persistent offlineProcess Flow
- Loads all configured adapters (database sources and storage destinations)
- Runs checks concurrently — at most
MAX_CONCURRENT_CHECKSat once - For each adapter: calls
ping()first; falls back totest()ifping()is not implemented - Each check is wrapped with a
ADAPTER_CHECK_TIMEOUT_MStimeout to prevent hangs - Evaluates status based on result and consecutive failure count
- Writes a
HealthCheckLogrecord and updates the cached fields onAdapterConfig - Sends an offline notification if the adapter just went
OFFLINE(with 24 h cooldown for persistent failures)
An air-gapped destination (isAirGapped in src/lib/core/air-gap.ts) is checked and logged like any other, but sends neither CONNECTION_OFFLINE nor CONNECTION_ONLINE, and an offline state left from before it was marked is dropped. The pages read a status other than ONLINE of one as not connected, with isNotConnected, never as offline.
ping() vs test()
ping() is a lightweight connectivity check that must not write any files to storage. test() is the full write/delete verification. The health check system always prefers ping() to avoid polluting storage with test files every minute.
State Machine
The service implements a failure state machine to avoid flapping between states:
| Condition | Result |
|---|---|
| Success | Status = ONLINE, Failures = 0 |
| Failure | Failures + 1 |
| Failures < 3 | Status = DEGRADED |
| Failures >= 3 | Status = OFFLINE |
// Simplified state logic
if (success) {
status = HealthStatus.ONLINE;
consecutiveFailures = 0;
} else {
consecutiveFailures++;
status = consecutiveFailures >= 3
? HealthStatus.OFFLINE
: HealthStatus.DEGRADED;
}Retention
Logs are automatically deleted once a day by the CLEAN_OLD_LOGS system task, not on every health check run. Default retention is 2 days, configurable as Health check history under Settings → Data retention (healthcheck.logRetentionDays).
System Task Integration
Location: src/services/system-task-service.ts
The healthcheck is integrated as a system task (system.health_check).
- Default Interval: Every minute (
*/1 * * * *) - Configuration: Settings → System tasks
- Manual Trigger: Can be run on-demand via UI
Adapter Integration
Each adapter implements the test(config) method from the adapter interface:
interface DatabaseAdapter {
test(config: DatabaseConfig): Promise<TestResult>;
// ...
}
interface StorageAdapter {
test(config: StorageConfig): Promise<TestResult>;
// ...
}What Gets Tested
The test() method performs more than just TCP connectivity:
| Adapter Type | Test Operation |
|---|---|
| MySQL/MariaDB | SELECT VERSION() |
| PostgreSQL | SELECT version() |
| MongoDB | db.admin().ping() |
| SQLite | File existence + read |
| MSSQL | SELECT @@VERSION |
| S3 | HeadBucket operation |
| SFTP | Directory listing |
| Local | Directory access check |
Frontend Components
Status Cell
The Status column of the connection tables shows a dot, the status and a short detail: the response time while online, the number of failed checks in a row while degraded.
| Status | Color |
|---|---|
| ONLINE | Green (success) |
| DEGRADED | Amber (warning) |
| OFFLINE | Red (destructive) |
| PENDING | Grey, not checked yet |
Status Popover
A click on the status opens ConnectionHealthPopover in src/components/adapter/connection-health-popover.tsx. It loads the last 60 checks and shows:
- A head tinted in the status color that says in one sentence how the connection is doing and since when, like "Online for 3 h 12 min" or "Offline for 20 min". The line under it holds the response time, the time of the last answer or the latest error.
- One bar per check, oldest on the left, and the share of checks that passed.
- Up to three changes with their time, worked out by
healthEvents()inhealth-story.ts. A degraded connection lists its failed checks, an offline one when it last answered, when the first check failed and when it went offline, and a failure that is over gets one line. - The mean and slowest response time of the passed checks, and a link to the details panel.
API Reference
Get Health History
GET /api/adapters/[id]/health-historyNeeds the read permission of the connection's kind: sources:view for databases and directory sources, destinations:read for destinations, notifications:read for notification channels.
Query Parameters:
| Parameter | Type | Default | Description |
|---|---|---|---|
limit | number | 100 | Number of entries to return, at most 10080 |
from | ISO date | Only checks at or after this time |
Response:
{
"history": [
{
"id": "clx123...",
"status": "ONLINE",
"latencyMs": 23,
"createdAt": "2026-01-31T10:00:00.000Z",
"error": null
}
],
"stats": {
"uptime": 98.5,
"avgLatency": 45,
"maxLatency": 81,
"totalChecks": 60
},
"since": "2026-01-31T07:12:00.000Z",
"lastPassedAt": "2026-01-31T10:00:00.000Z"
}historyholds the latest checks, newest first.stats.uptimeis the share of the returned checks that passed, in percent.stats.avgLatencyandstats.maxLatencyare the mean and the slowest response time of the returned checks that passed, and 0 when none did. A failed check reports how long it waited, so it is left out.sinceis when the status of the newest check began, also when that lies before the returned checks.lastPassedAtis the newest check that passed, however long ago.
Testing
Unit Tests
The state transition logic (Online → Degraded → Offline) is verified in:
tests/unit/services/healthcheck-service.test.tsManual Testing
- Go to Settings → System tasks
- Find Health checks
- Click Run now at the end of its row
- Check the terminal logs for output
- Navigate to Sources or Destinations - status badges should be updated
Configuration
The healthcheck interval can be configured per-installation:
// Default cron expression (every minute)
const HEALTHCHECK_CRON = '*/1 * * * *';For high-availability setups, consider:
- Reducing interval to 30 seconds
- Increasing
healthcheck.logRetentionDaysbeyond the default 2 days - Adding external monitoring integration