Function recordServerStatus

src/server/model/serverStatus.ts:97–152

(
  info: ServerStatusInfo,
  requestContext: ServerStatusRequestContext = {}
)

});

export async function recordServerStatus(
  info: ServerStatusInfo,
  requestContext: ServerStatusRequestContext = {}
) {
  const { workspaceId, name, hostname, timeout, payload } = info;

  if (!workspaceId || !name || !hostname) {
    console.warn(
      '[ServerStatus] lost some necessary params, request will be ignore',
      info
    );
    return;
  }

  // Get current server map from cache
  const serverMap = await getServerMapFromCache(workspaceId);

  // Update current server status
  const serverKey = name || hostname;
  serverMap[serverKey] = {
    workspaceId,
    name,
    hostname,
    timeout,
    updatedAt: Date.now(),
    payload: {
      ...requestContext,
      ...payload,
    },
  };

  // Save updated server map to cache
  await saveServerMapToCache(workspaceId, serverMap);

  // Update server history using cache
  const history = await getServerHistoryFromCache(workspaceId, serverKey);
  history.push(serverMap[serverKey]);

  // Keep only the last 20 records
  if (history.length > 20) {
    history.shift();
  }

  saveServerHistoryToCache(workspaceId, serverKey, history).catch((err) => {
    logger.error('[ServerStatus] Error saving history to cache:', err);
  });

  promServerCounter.set(
    {
      workspaceId,
    },
    Object.keys(serverMap).length
  );

  subscribeEventBus.emit('onServerStatusUpdate', workspaceId, serverMap);
}

export async function clearOfflineServerStatus(workspaceId: string) {