Build a warehouse station

import { DeviceClient } from '@lua-ai-global/device-client';

type Item = { name: string; quantity: number; threshold: number };
const inventory: Record<string, Item> = {
  'SKU-2024-0847': { name: 'Widget A', quantity: 8, threshold: 10 },
  'SKU-2024-0312': { name: 'Bracket B', quantity: 142, threshold: 20 },
};

const device = new DeviceClient({
  agentId: process.env.LUA_AGENT_ID!,
  deviceCredential: process.env.LUA_DEVICE_CREDENTIAL!,
  deviceName: 'warehouse-station-01',
  commands: [
    { name: 'scan_barcode', description: 'Activate the scanner and return the barcode it reads', timeoutMs: 10000 },
    { name: 'read_weight', description: 'Read the shipping scale in kilograms' },
    {
      name: 'check_stock_level',
      description: 'Return the stock level and reorder threshold for a SKU',
      inputSchema: { type: 'object', properties: { sku: { type: 'string' } }, required: ['sku'] },
    },
    {
      name: 'print_receipt',
      description: 'Print lines of text on the station receipt printer',
      inputSchema: {
        type: 'object',
        properties: { lines: { type: 'array', items: { type: 'string' }, maxItems: 40 } },
        required: ['lines'],
      },
      timeoutMs: 15000,
    },
    {
      name: 'open_gate',
      description: 'Open a dock gate. Ask the worker to confirm before calling this.',
      inputSchema: { type: 'object', properties: { gate: { type: 'string', enum: ['dock-a', 'dock-b'] } }, required: ['gate'] },
      timeoutMs: 15000,
    },
  ],
});

device.onCommand('scan_barcode', async () => ({ barcode: 'SKU-2024-0847', format: 'CODE128' }));
device.onCommand('read_weight', async () => ({ weight: 12.4, unit: 'kg' }));

device.onCommand('check_stock_level', async (payload) => {
  const item = inventory[String(payload.sku)];
  if (!item) return { found: false, sku: payload.sku };
  return { found: true, sku: payload.sku, ...item, low: item.quantity <= item.threshold };
});

device.onCommand('print_receipt', async (payload) => {
  const lines: string[] = payload.lines.map((line: unknown) => String(line).slice(0, 48));
  console.log(['--- RECEIPT ---', ...lines, '--- END ---'].join('\n'));
  return { printed: lines.length };
});

device.onCommand('open_gate', async (payload) => ({ gate: payload.gate, opened: true, at: new Date().toISOString() }));

async function main() {
  await device.connect();
  console.log('warehouse-station-01 connected');
  setInterval(async () => {
    for (const [sku, item] of Object.entries(inventory)) {
      if (item.quantity > item.threshold) continue;
      await device
        .trigger('low_stock_alert', { sku, name: item.name, quantity: item.quantity, threshold: item.threshold })
        .catch((err: Error) => console.error(err.message));
    }
  }, 60_000);
}

main().catch((err: Error) => {
  console.error(err.message);
  process.exit(1);
});

import { Agents, Data, defineDeviceTrigger } from 'lua-cli';
import { z } from 'zod';

// From lua.skill.yaml; env() is empty inside device-trigger handlers.
const AGENT_ID = 'agent_abc123';

export const lowStockAlert = defineDeviceTrigger({
  name: 'low_stock_alert',
  description: 'A station reports a SKU at or below its reorder threshold',
  payloadSchema: z.object({ sku: z.string(), name: z.string(), quantity: z.number(), threshold: z.number() }),
  async execute(payload, { device }) {
    await Data.create('stock-alerts', { device: device.name, ...payload, at: Date.now() });
    await Agents.invoke(
      AGENT_ID,
      `${device.name} reports ${payload.name} (${payload.sku}) at ${payload.quantity}, threshold ${payload.threshold}. Draft a reorder.`
    );
  },
});