CDN Uploads

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

const device = new DeviceClient({
  agentId: process.env.LUA_AGENT_ID!,
  apiKey: process.env.LUA_API_KEY!,
  deviceName: 'lobby-kiosk',
  commands: [
    {
      name: 'take_screenshot',
      description: 'Capture a screenshot of the kiosk display and upload it',
    },
    {
      name: 'upload_logs',
      description: 'Upload the last hour of application logs',
    },
  ],
});

device.onCommand('take_screenshot', async () => {
  // Capture screenshot (Linux with scrot, macOS with screencapture)
  const tmpPath = '/tmp/kiosk-screenshot.png';
  execSync(`screencapture -x ${tmpPath}`);

  const screenshot = fs.readFileSync(tmpPath);
  const result = await device.cdn.upload(screenshot, 'kiosk-screenshot.png', 'image/png');

  return {
    message: 'Screenshot captured and uploaded',
    url: result.url,
    fileId: result.fileId,
    size: screenshot.length,
  };
});

device.onCommand('upload_logs', async () => {
  const logPath = '/var/log/kiosk/app.log';
  const logContent = fs.readFileSync(logPath);

  const result = await device.cdn.upload(
    logContent,
    `kiosk-logs-${new Date().toISOString().slice(0, 10)}.log`,
    'text/plain',
  );

  return {
    message: 'Logs uploaded',
    url: result.url,
    fileId: result.fileId,
    lines: logContent.toString().split('\n').length,
  };
});

async function main() {
  await device.connect();
  console.log('Kiosk device online');
}

main().catch(console.error);

import asyncio
import os
import subprocess
from datetime import date
from lua_device import DeviceClient, DeviceCommandDefinition

client = DeviceClient(
    agent_id=os.environ["LUA_AGENT_ID"],
    api_key=os.environ["LUA_API_KEY"],
    device_name="lobby-kiosk",
    commands=[
        DeviceCommandDefinition(
            name="take_screenshot",
            description="Capture a screenshot of the kiosk display and upload it",
        ),
        DeviceCommandDefinition(
            name="upload_logs",
            description="Upload the last hour of application logs",
        ),
    ],
)

@client.on_command("take_screenshot")
async def handle_take_screenshot(payload):
    # Capture screenshot (Linux with scrot, macOS with screencapture)
    tmp_path = "/tmp/kiosk-screenshot.png"
    subprocess.run(["screencapture", "-x", tmp_path], check=True)

    with open(tmp_path, "rb") as f:
        screenshot = f.read()

    result = await client.cdn.upload(screenshot, "kiosk-screenshot.png", "image/png")

    return {
        "message": "Screenshot captured and uploaded",
        "url": result.url,
        "fileId": result.file_id,
        "size": len(screenshot),
    }

@client.on_command("upload_logs")
async def handle_upload_logs(payload):
    log_path = "/var/log/kiosk/app.log"
    with open(log_path, "rb") as f:
        log_content = f.read()

    result = await client.cdn.upload(
        log_content,
        f"kiosk-logs-{date.today().isoformat()}.log",
        "text/plain",
    )

    return {
        "message": "Logs uploaded",
        "url": result.url,
        "fileId": result.file_id,
        "lines": log_content.decode().count("\n"),
    }

async def main():
    await client.connect()
    print("Kiosk device online")

asyncio.run(main())