⚡ Quick Start Guide¶

-- Create state-demo.sloth
local setup_state = task("setup_state")
    :description("Initialize application state")
    :command(function(this, params)
        -- Initialize configuration
        state.set("app_config", {
            version = "1.0.0",
            environment = "development",
            debug = true
        })

        -- Set TTL for session data (5 minutes)
        state.set("session_token", "abc123xyz", 300)

        -- Initialize counters
        state.set("api_calls", 0)
        state.set("errors", 0)

        log.info("✅ Application state initialized")
        return true, "State setup completed"
    end)
    :build()

local simulate_usage = task("simulate_usage")
    :description("Simulate application usage")
    :depends_on({"setup_state"})
    :command(function(this, params)
        -- Simulate API calls
        for i = 1, 10 do
            local calls = state.increment("api_calls", 1)

            -- Simulate occasional error
            if math.random(1, 10) > 8 then
                state.increment("errors", 1)
                log.warn("Simulated error occurred")
            end

            -- Add to processing queue
            state.list_push("processing_queue", {
                id = "req_" .. i,
                timestamp = os.time(),
                status = "pending"
            })

            exec.run("sleep 0.1") -- Small delay
        end

        local total_calls = state.get("api_calls")
        local total_errors = state.get("errors")
        local queue_size = state.list_length("processing_queue")

        log.info("📊 Usage Summary:")
        log.info("  API Calls: " .. total_calls)
        log.info("  Errors: " .. total_errors)
        log.info("  Queue Size: " .. queue_size)

        return true, "Usage simulation completed"
    end)
    :build()

local process_queue = task("process_queue")
    :description("Process items in queue with locking")
    :depends_on({"simulate_usage"})
    :command(function(this, params)
        -- Process queue with distributed lock
        state.with_lock("queue_processing", function()
            log.info("🔒 Processing queue with exclusive lock...")

            local processed = 0
            while state.list_length("processing_queue") > 0 do
                local item = state.list_pop("processing_queue")
                log.info("Processing item: " .. item.id)
                processed = processed + 1
            end

            log.info("✅ Processed " .. processed .. " items")
            state.set("last_processing_time", os.time())

        end, 30) -- 30 second timeout

        return true, "Queue processing completed"
    end)
    :build()

-- Define workflow
workflow
    .define("state_demo")
    :description("Demonstrate state management capabilities")
    :version("1.0.0")
    :tasks({setup_state, simulate_usage, process_queue})

-- Create metrics-demo.sloth
local collect_metrics = task("collect_metrics")
    :description("Collect system and custom metrics")
    :command(function(this, params)
        log.info("📊 Collecting system metrics...")

        -- System metrics
        local cpu = metrics.system_cpu()
        local memory = metrics.system_memory()
        local disk = metrics.system_disk()

        log.info("System Status:")
        log.info("  CPU: " .. string.format("%.1f%%", cpu))
        log.info("  Memory: " .. string.format("%.1f%%", memory.percent))
        log.info("  Disk: " .. string.format("%.1f%%", disk.percent))

        -- Custom metrics
        metrics.gauge("demo_cpu_usage", cpu)
        metrics.counter("demo_executions", 1)

        -- Performance timer
        local processing_time = metrics.timer("data_processing", function()
            -- Simulate data processing
            local sum = 0
            for i = 1, 1000000 do
                sum = sum + math.sqrt(i)
            end
            return sum
        end)

        log.info("⏱️ Processing took: " .. string.format("%.2f ms", processing_time))

        -- Health check
        local health = metrics.health_status()
        log.info("🏥 Overall health: " .. health.overall)

        -- Alert if CPU is high
        if cpu > 50 then
            metrics.alert("high_cpu_demo", {
                level = "warning",
                message = "CPU usage is elevated: " .. string.format("%.1f%%", cpu),
                value = cpu
            })
        end

        return true, "Metrics collection completed"
    end)
    :build()

-- Define workflow
workflow
    .define("metrics_demo")
    :description("Demonstrate metrics and monitoring")
    :version("1.0.0")
    :tasks({collect_metrics})