package main

import (
	"context"
	"fmt"
	"log"

	"github.com/rakyll/sessionlife"
	"github.com/valkey-io/valkey-go"
)

func main() {
	ctx := context.Background()

	client, err := valkey.NewClient(valkey.ClientOption{
		InitAddress: []string{"127.0.0.1:6379"},
	})
	if err != nil {
		log.Fatal(err)
	}
	defer client.Close()

	// 1. Create a global Manager
	m, err := sessionlife.NewManager(client)
	if err != nil {
		log.Fatal(err)
	}

	// 2. Queue lifecycle events across multiple sessions
	ev1, err := m.QueueResume(ctx, "session-A", "work-101")
	ev2, err := m.QueueResume(ctx, "session-B", "work-201")
	ev3, err := m.QueueSuspend(ctx, "session-A")

	// 3. Inspect currently pending events
	pending, err := m.Pending(ctx)
	for _, e := range pending {
		fmt.Printf("Pending: session=%s action=%s work=%s id=%s\n", e.SessionID, e.Action, e.WorkID, e.EntryID)
	}

	// 4. Acknowledge completed work
	if err := m.Ack(ctx, ev1.EntryID); err != nil {
		log.Fatal(err)
	}
	if err := m.Ack(ctx, ev2.EntryID); err != nil {
		log.Fatal(err)
	}

	// 5. Acknowledge suspend when processed
	_ = m.Ack(ctx, ev3.EntryID)
}

type Event struct {
	SessionID  string    `json:"session_id"`
	WorkID     string    `json:"work_id,omitempty"`
	Action     string    `json:"action"`
	EntryID    string    `json:"entry_id"`
	EnqueuedAt time.Time `json:"enqueued_at"`
}