mirror of
https://github.com/fosrl/pangolin.git
synced 2026-05-01 10:11:51 +00:00
Fix errors
This commit is contained in:
@@ -191,11 +191,19 @@ export const handleHealthcheckStatusMessage: MessageHandler = async (
|
||||
})
|
||||
.where(eq(targetHealthCheck.targetId, targetCheck.targetId));
|
||||
|
||||
const orgId = targetCheck.orgId || targetCheck.resourceOrgId; // for backwards compatibility, check both orgId fields because the target health checks dont have the orgId
|
||||
if (!orgId) {
|
||||
logger.warn(
|
||||
`No org ID found for target ${targetId}, skipping status history logging`
|
||||
);
|
||||
continue;
|
||||
}
|
||||
|
||||
// Log the state change to status history
|
||||
await db.insert(statusHistory).values({
|
||||
entityType: "healthCheck",
|
||||
entityId: targetCheck.targetHealthCheckId,
|
||||
orgId: targetCheck.orgId || targetCheck.resourceOrgId,
|
||||
orgId: orgId,
|
||||
status: healthStatus.status,
|
||||
timestamp: Math.floor(Date.now() / 1000)
|
||||
});
|
||||
@@ -235,7 +243,7 @@ export const handleHealthcheckStatusMessage: MessageHandler = async (
|
||||
await db.insert(statusHistory).values({
|
||||
entityType: "resource",
|
||||
entityId: targetCheck.resourceId,
|
||||
orgId: targetCheck.orgId || targetCheck.resourceOrgId,
|
||||
orgId: orgId,
|
||||
status: status,
|
||||
timestamp: Math.floor(Date.now() / 1000)
|
||||
});
|
||||
@@ -244,13 +252,13 @@ export const handleHealthcheckStatusMessage: MessageHandler = async (
|
||||
// because we are checking above if there was a change we can fire the alert here because it changed
|
||||
if (healthStatus.status === "unhealthy") {
|
||||
await fireHealthCheckHealthyAlert(
|
||||
targetCheck.orgId || targetCheck.resourceOrgId, // for backwards compatibility, check both orgId fields because the target health checks dont have the orgId
|
||||
orgId,
|
||||
targetCheck.targetHealthCheckId,
|
||||
targetCheck.name
|
||||
);
|
||||
} else if (healthStatus.status === "healthy") {
|
||||
await fireHealthCheckNotHealthyAlert(
|
||||
targetCheck.orgId || targetCheck.resourceOrgId, // for backwards compatibility, check both orgId fields because the target health checks dont have the orgId
|
||||
orgId,
|
||||
targetCheck.targetHealthCheckId,
|
||||
targetCheck.name
|
||||
);
|
||||
|
||||
@@ -346,10 +346,16 @@ export default function AlertRuleGraphEditor({
|
||||
useWatch({ control: form.control, name: "enabled" }) ?? true;
|
||||
const wSourceType =
|
||||
useWatch({ control: form.control, name: "sourceType" }) ?? "site";
|
||||
const wAllSites =
|
||||
useWatch({ control: form.control, name: "allSites" }) ?? true;
|
||||
const wSiteIds =
|
||||
useWatch({ control: form.control, name: "siteIds" }) ?? [];
|
||||
const wAllHealthChecks =
|
||||
useWatch({ control: form.control, name: "allHealthChecks" }) ?? true;
|
||||
const wHealthCheckIds =
|
||||
useWatch({ control: form.control, name: "healthCheckIds" }) ?? [];
|
||||
const wAllResources =
|
||||
useWatch({ control: form.control, name: "allResources" }) ?? true;
|
||||
const wResourceIds =
|
||||
useWatch({ control: form.control, name: "resourceIds" }) ?? [];
|
||||
const wTrigger =
|
||||
@@ -363,8 +369,11 @@ export default function AlertRuleGraphEditor({
|
||||
name: wName,
|
||||
enabled: wEnabled,
|
||||
sourceType: wSourceType,
|
||||
allSites: wAllSites,
|
||||
siteIds: wSiteIds,
|
||||
allHealthChecks: wAllHealthChecks,
|
||||
healthCheckIds: wHealthCheckIds,
|
||||
allResources: wAllResources,
|
||||
resourceIds: wResourceIds,
|
||||
trigger: wTrigger,
|
||||
actions: wActions
|
||||
@@ -373,8 +382,11 @@ export default function AlertRuleGraphEditor({
|
||||
wName,
|
||||
wEnabled,
|
||||
wSourceType,
|
||||
wAllSites,
|
||||
wSiteIds,
|
||||
wAllHealthChecks,
|
||||
wHealthCheckIds,
|
||||
wAllResources,
|
||||
wResourceIds,
|
||||
wTrigger,
|
||||
wActions
|
||||
|
||||
Reference in New Issue
Block a user