Asset Compliance Workflow

type AssetStatus = "active" | "maintenance" | "retired" | "disposed";

type ComplianceScheduleStatus = 
  | "scheduled"    // Upcoming
  | "in_progress"  // Job created, work underway
  | "completed"    // Inspection passed
  | "overdue"      // Past due date
  | "cancelled";   // No longer required

interface ComplianceRule {
  id: string;
  code: string;           // e.g., "AS1851-MONTHLY"
  name: string;           // e.g., "AS 1851 Monthly Inspection"
  description: string;
  
  // Applicability
  assetTypes: string[];   // Which asset types
  jurisdictions: string[]; // State/national
  
  // Frequency
  frequency: "daily" | "weekly" | "monthly" | "quarterly" | "semi-annually" | "annually";
  frequencyValue: number; // For custom frequencies
  
  // Timing
  leadTimeDays: number;   // Days before due to create job
  gracePeriodDays: number; // Days after due before overdue
  
  // Classification
  complianceType: "regulatory" | "manufacturer" | "custom";
  severity: "critical" | "high" | "medium" | "low";
  
  // Tasks
  inspectionTasks: InspectionTask[];
}

interface InspectionTask {
  id: string;
  description: string;
  required: boolean;
  passFailCriteria?: string;
  photosRequired: boolean;
}

const AS1851_MONTHLY: ComplianceRule = {
  id: "as1851-monthly",
  code: "AS1851-MONTHLY",
  name: "AS 1851 Monthly Inspection",
  description: "Monthly visual inspection per AS 1851",
  assetTypes: ["fire-extinguisher", "fire-hose-reel", "fire-blanket"],
  jurisdictions: ["AU-NSW", "AU-VIC", "AU-QLD", "AU-SA", "AU-WA", "AU-TAS", "AU-NT", "AU-ACT"],
  frequency: "monthly",
  frequencyValue: 1,
  leadTimeDays: 7,
  gracePeriodDays: 0,
  complianceType: "regulatory",
  severity: "high",
  inspectionTasks: [
    { id: "1", description: "Check pressure gauge in green zone", required: true, photosRequired: true },
    { id: "2", description: "Inspect for physical damage", required: true, photosRequired: false },
    { id: "3", description: "Verify seal intact", required: true, photosRequired: true },
    { id: "4", description: "Check signage visible", required: true, photosRequired: false }
  ]
};

interface OverdueMetrics {
  totalAssets: number;
  compliantAssets: number;
  overdueAssets: number;
  upcomingDue: number;  // Due within 30 days
  complianceRate: number; // Percentage
}

async function calculateOverdueMetrics(teamId: string): Promise<OverdueMetrics> {
  const now = new Date();
  
  const schedules = await db.select()
    .from(complianceSchedules)
    .where(eq(complianceSchedules.teamId, teamId));
  
  const overdue = schedules.filter(s => 
    new Date(s.dueDate) < now && s.status !== "completed"
  );
  
  const upcoming = schedules.filter(s => {
    const due = new Date(s.dueDate);
    const thirtyDaysFromNow = new Date(now.getTime() + 30 * 24 * 60 * 60 * 1000);
    return due >= now && due <= thirtyDaysFromNow;
  });
  
  return {
    totalAssets: uniqueAssets.length,
    compliantAssets: compliant.length,
    overdueAssets: overdue.length,
    upcomingDue: upcoming.length,
    complianceRate: (compliant.length / totalAssets.length) * 100
  };
}

// Priority based on overdue status and rule severity
function calculateRiskLevel(
  schedule: ComplianceSchedule,
  rule: ComplianceRule
): "critical" | "high" | "medium" | "low" {
  const daysOverdue = getDaysOverdue(schedule.dueDate);
  
  if (daysOverdue > 30 && rule.severity === "critical") return "critical";
  if (daysOverdue > 14 && rule.severity === "high") return "critical";
  if (daysOverdue > 7 && rule.severity === "critical") return "high";
  if (daysOverdue > 0) return "high";
  if (getDaysUntilDue(schedule.dueDate) <= 7) return "medium";
  
  return "low";
}

// Get compliance summary
complianceWorkflow.getSummary({ teamId: string })

// Get overdue items
complianceWorkflow.getOverdue({ teamId: string, severity?: string })

// Get upcoming due
complianceWorkflow.getUpcoming({ teamId: string, days: number })

// Apply rules to asset
complianceWorkflow.applyRules({ assetId: string, ruleIds: string[] })

// Generate schedule
complianceWorkflow.generateSchedule({ assetId: string, ruleId: string })

// Get asset maintenance history
maintenanceWorkflow.getHistory({ assetId: string })

// Schedule maintenance
maintenanceWorkflow.schedule({
  assetId: string,
  type: "preventive" | "corrective",
  scheduledDate: string
})

// Complete maintenance
maintenanceWorkflow.complete({
  scheduleId: string,
  result: "pass" | "fail" | "conditional",
  notes: string,
  photos: string[]
})

cd apps/workbooks-api
bun test src/__tests__/integration/compliance-workflow.test.ts
bun test src/__tests__/integration/maintenance-workflow.test.ts