SafeScan (HSE)

const project = await tenant.hseProjects.create({
code: 'PRJ-2026-BXL',
name: 'Brussels Terminal Expansion',
region: 'EMEA',
businessUnit: 'Logistics',
});

console.log(project.id);     // "hpr_abc123"
console.log(project.status); // "active"

const shipment = await tenant.hseProjects.createShipment({
projectId: project.id,
code: 'SHP-BXL-001',
name: 'Antwerp → Brussels — Road Leg 1',
});

// List all shipments for the project
const shipments = await tenant.hseProjects.listShipments(project.id);

const event = await tenant.hseEvents.upsert({
clientId: 'a3f1c2e4-0001-4d2a-b9f3-112233445566',
kind: 'incident',
severity: 'high',
description: 'Forklift struck rack in aisle 7, two pallets fell.',
occurredAt: '2026-07-23T08:15:00Z',
latitude: 51.2194,
longitude: 4.4025,
projectId: project.id,
shipmentId: shipment.id,
transportMode: 'yard',
stopWork: true,
});

console.log(event.id);       // "hev_xyz789"
console.log(event.status);   // "open"
console.log(event.stopWork); // true

// Filter by status and project
const page = await tenant.hseEvents.list({
status: 'open',
projectId: project.id,
limit: 50,
});

console.log(page.data);            // HseEvent[]
console.log(page.pagination.hasMore); // true | false

// Date-range filter
const weekEvents = await tenant.hseEvents.list({
dateFrom: '2026-07-01T00:00:00Z',
dateTo:   '2026-07-31T23:59:59Z',
kind:     'incident',
severity: 'high',
});

// Stream every open event in the project — no manual cursor handling
for await (const e of tenant.hseEvents.listAll({
status: 'open',
projectId: project.id,
})) {
console.log(e.id, e.kind, e.severity);
}

// Open → under investigation
await tenant.hseEvents.transition(event.id, {
to: 'under_investigation',
assigneeId: 'usr_safety_officer_01',
reason: 'Root-cause analysis started',
});

// Under investigation → closed
await tenant.hseEvents.transition(event.id, {
to: 'closed',
reason: 'All corrective actions verified, area cleared.',
});

// Issue a stop-work order
await tenant.hseEvents.stopWork(event.id, {
stopWork: true,
reason: 'Area unsafe — rack integrity unverified.',
});

// Clear once the area is safe
await tenant.hseEvents.stopWork(event.id, {
stopWork: false,
reason: 'Structural inspection passed, work resumed.',
});

// Create an action
const action = await tenant.hseActions.create(event.id, {
assigneeId: 'usr_maintenance_02',
description: 'Inspect all racking in aisles 6–8 and replace damaged uprights.',
dueDate: '2026-07-30T17:00:00Z',
priority: 'high',
});

console.log(action.id);     // "hac_aaa111"
console.log(action.status); // "open"

// Update action — mark in progress
await tenant.hseActions.update(action.id, {
status: 'in_progress',
});

// Close the action when remediation is done
await tenant.hseActions.update(action.id, {
status: 'closed',
dueDate: '2026-07-28T14:00:00Z',
});

// List all actions for the event
const actionsPage = await tenant.hseActions.list(event.id, { limit: 20 });

await tenant.hseRca.upsert(event.id, {
method: '5-whys',
summary: 'Root cause: inadequate aisle width markings led to forklift path conflict.',
nodes: [
  {
    id: 'node_1',
    question: 'Why did the forklift strike the rack?',
    answer: 'The aisle width markings were worn and invisible.',
    factorType: 'environment',
    sortOrder: 1,
  },
  {
    id: 'node_2',
    parentId: 'node_1',
    question: 'Why were the markings worn?',
    answer: 'Floor repainting was overdue by 3 months.',
    factorType: 'management',
    sortOrder: 2,
  },
  {
    id: 'node_3',
    parentId: 'node_2',
    question: 'Why was repainting overdue?',
    answer: 'No scheduled maintenance reminder was in place.',
    factorType: 'process',
    sortOrder: 3,
  },
],
});

// Read back the RCA
const rca = await tenant.hseRca.get(event.id);
console.log(rca.method); // "5-whys"
console.log(rca.nodes.length); // 3

// Create an alert from the event
const alert = await tenant.hseAlerts.createFromEvent(event.id, {
title: 'Forklift aisle collision — floor marking hazard',
body: 'An incident occurred in aisle 7 due to worn floor markings. All sites must audit aisle markings this week.',
audienceFilter: {
  regions: ['EMEA'],
  businessUnits: ['Logistics'],
},
});

// Publish to the filtered audience
await tenant.hseAlerts.publish(alert.id);

// Record a lesson learned
await tenant.hseAlerts.createLesson({
alertId: alert.id,
category: 'floor-safety',
summary: 'Worn aisle markings are a leading indicator of forklift collision risk. Add quarterly floor audit to site checklist.',
tags: ['forklift', 'floor-marking', 'aisle-safety'],
});

// 1. Request a signed upload URL
const { uploadUrl, storageRef, expiresAt } = await tenant.hseMedia.getSignedUrl({
eventId: event.id,
mediaId: 'med_local_uuid_001',
mediaKind: 'photo',
contentType: 'image/jpeg',
fileName: 'aisle7-damage.jpg',
});

// 2. PUT the file directly to cloud storage
await fetch(uploadUrl, {
method: 'PUT',
body: imageBuffer,
headers: { 'Content-Type': 'image/jpeg' },
});

// 3. Commit the upload
const media = await tenant.hseMedia.completeUpload('med_local_uuid_001', {
storageRef,
fileSize: imageBuffer.byteLength,
});

console.log(media.uploadState); // "uploaded"

// First pull: since=0 returns everything
const pullResult = await tenant.hseSync.pull({
since: 0,
clientDeviceId: 'device_field_unit_07',
limit: 200,
});

console.log(pullResult.events);   // HseEventDetail[] — full event graphs
console.log(pullResult.cursor);   // e.g. 1048576 — new sequence number
console.log(pullResult.hasMore);  // true if more pages to pull

// Subsequent pull: pass the last cursor
const delta = await tenant.hseSync.pull({
since: pullResult.cursor,
clientDeviceId: 'device_field_unit_07',
});

const pushResult = await tenant.hseSync.push({
clientDeviceId: 'device_field_unit_07',
ops: [
  {
    opId: 'op_uuid_001',
    entity: 'event',
    id: 'a3f1c2e4-0001-4d2a-b9f3-112233445566',
    type: 'upsert',
    seq: 1,
    payload: {
      clientId: 'a3f1c2e4-0001-4d2a-b9f3-112233445566',
      kind: 'near_miss',
      severity: 'medium',
      description: 'Near-miss at loading bay 3.',
      occurredAt: '2026-07-23T10:00:00Z',
    },
  },
],
});

for (const result of pushResult.results) {
console.log(result.opId, result.status);
// e.g. "op_uuid_001" "applied"
}

// 1. Report the incident (offline-safe via clientId)
const event = await tenant.hseEvents.upsert({
clientId: 'c0ffee00-beef-4a1b-8bad-000000000001',
kind: 'incident',
severity: 'high',
description: 'Chemical spill in bay 4 — drum punctured during unloading.',
occurredAt: new Date().toISOString(),
projectId: 'hpr_terminal_01',
transportMode: 'road',
stopWork: true,
});

// 2. Issue the stop-work order explicitly
await tenant.hseEvents.stopWork(event.id, {
stopWork: true,
reason: 'Hazmat spill — bay 4 cordoned off.',
});

// 3. Start investigation
await tenant.hseEvents.transition(event.id, {
to: 'under_investigation',
assigneeId: 'usr_ehs_lead',
reason: 'EHS team on site.',
});

// 4. Create corrective actions
await tenant.hseActions.create(event.id, {
assigneeId: 'usr_hazmat_team',
description: 'Contain and neutralise spill; dispose of contaminated materials.',
dueDate: new Date(Date.now() + 4 * 60 * 60 * 1000).toISOString(),
priority: 'critical',
});

// 5. RCA
await tenant.hseRca.upsert(event.id, {
method: '5-whys',
summary: 'Drum was over-pressurised during road transport; valve failed on impact.',
nodes: [
  {
    id: 'n1',
    question: 'Why did the drum puncture?',
    answer: 'Internal pressure exceeded rated limit.',
    factorType: 'equipment',
    sortOrder: 1,
  },
  {
    id: 'n2',
    parentId: 'n1',
    question: 'Why was pressure excessive?',
    answer: 'Temperature relief valve was not inspected before shipment.',
    factorType: 'process',
    sortOrder: 2,
  },
],
});

// 6. Alert the organisation
const alert = await tenant.hseAlerts.createFromEvent(event.id, {
title: 'Chemical drum spill — Bay 4 — Antwerp terminal',
body: 'Drum over-pressurisation caused a spill. All sites must verify valve inspections before loading.',
audienceFilter: { businessUnits: ['Logistics', 'QHSE'] },
});
await tenant.hseAlerts.publish(alert.id);

// 7. Iterate all open high-severity events to check scope
for await (const e of tenant.hseEvents.listAll({ status: 'open', severity: 'high' })) {
console.log(e.id, e.kind, e.occurredAt);
}

// 8. Close after remediation
await tenant.hseEvents.transition(event.id, {
to: 'closed',
reason: 'Spill contained, bay cleared, corrective actions verified.',
});
await tenant.hseEvents.stopWork(event.id, { stopWork: false });