mcp-google-sheets

import { systemUsage } from '@activepieces/server-shared' import { GetSystemHealthChecksResponse } from '@activepieces/shared' import { FastifyBaseLogger } from 'fastify' import { system } from '../helper/system/system' import { machineService } from '../workers/machine/machine-service' let workerHealthStatus = false export const healthStatusService = (log: FastifyBaseLogger) => ({ markWorkerHealthy: async (): Promise<void> => { workerHealthStatus = true }, isHealthy: (): boolean => { if (system.isWorker()) { return workerHealthStatus } return true }, getSystemHealthChecks: async (): Promise<GetSystemHealthChecksResponse> => { const workers = await machineService(log).list() const allWorkersPassedHealthcheck = workers.every(worker => worker.information.totalCpuCores > 1) const allWorkersHaveEnoughRam = workers.every(worker => worker.information.totalAvailableRamInBytes > gigaBytes(4)) return { cpu: await systemUsage.getCpuCores() >= 1 && allWorkersPassedHealthcheck, disk: (await systemUsage.getDiskInfo()).total > gigaBytes(30), ram: (await systemUsage.getContainerMemoryUsage()).totalRamInBytes > gigaBytes(4) && allWorkersHaveEnoughRam, } }, }) const gigaBytes = (value: number) => value * 1024 * 1024 * 1024