package main

import (
    "fmt"
    "time"

    "github.com/nekomeowww/timecapsule"
)

func main() {
    // initialize redis dataloader
    redisDataloder := NewRedisDataloader[string]("some/task/key", redis.NewClient(&redis.Options{
        Addr: net.JoinHostPort("localhost", "6379"),
        Password: "123456",
    }))

    // create a time capsule digger, pass 250*time.Millisecond into parameter as the interval
    digger := NewDigger[string](redisDataloder, 250*time.Millisecond)

    // set task handler function
    digger.SetHandler(func(capsule *TimeCapsule[string]) {
        fmt.Println("task", capsule.Payload, "is due") // print a message
    })

    // start digging in a seperated goroutine
    go digger.Start()
    // defer stop digging
    defer digger.Stop()

    // Bury a time capsule
    err = digger.BuryFor("this is a time capsule", time.Second)
    if err != nil {
        logger.Error(err)
    }

    err = digger.BuryUntil("this is a time capsule", time.Now().UTC().Add(time.Second).UnixMilli())
    if err != nil {
        logger.Error(err)
    }
}