Function getPostgresClusterHealth

App/API/AdminHealth.ts:1242–1573

()

 * never query text or row data — so this stays safe to share.
 */
async function getPostgresClusterHealth(): Promise<JSONObject> {
  const result: JSONObject = {
    connected: false,
    clusterName: null,
    serverVersion: null,
    isInRecovery: false,
    role: null,
    uptimeSeconds: null,
    replication: [],
    replicationSlots: [],
    connections: null,
    database: null,
    wraparound: null,
    topTablesByDeadTuples: [],
    databaseSizeInBytes: null,
  };

  try {
    const dataSource: ReturnType<typeof PostgresAppInstance.getDataSource> =
      PostgresAppInstance.getDataSource();

    if (!dataSource) {
      return result;
    }

    result["connected"] = true;

    // 1. Node identity & role — is this the primary or a standby, and for how long.
    try {
      const identityRows: Array<{
        cluster_name: string | null;
        server_version: string | null;
        in_recovery: boolean;
        uptime_seconds: string | null;
      }> = await dataSource.query(
        `SELECT
           current_setting('cluster_name', true) AS cluster_name,
           current_setting('server_version') AS server_version,
           pg_is_in_recovery() AS in_recovery,
           ROUND(EXTRACT(EPOCH FROM (now() - pg_postmaster_start_time()))) AS uptime_seconds`,
      );

      const identity: (typeof identityRows)[number] | undefined =
        identityRows?.[0];

      if (identity) {
        result["clusterName"] = identity.cluster_name || null;
        result["serverVersion"] = identity.server_version || null;
        result["isInRecovery"] = Boolean(identity.in_recovery);
        result["role"] = identity.in_recovery ? "standby" : "primary";
        result["uptimeSeconds"] = toNumberOrNull(identity.uptime_seconds);
      }
    } catch (err) {
      logger.debug("AdminHealth: postgres identity probe failed");
      logger.debug(err);
    }

    // 2. Streaming replication — the primary's view of every connected standby.