package main import ( "fmt" "github.com/aerogo/nano" "github.com/animenotifier/arn" "github.com/fatih/color" ) func main() { color.Yellow("Deleting old sessions") defer color.Green("Finished.") defer arn.Node.Close() // threshold := time.Now().Add(-6 * 30 * 24 * time.Hour).Format(time.RFC3339) count := 0 total := 0 for session := range streamSessions() { data := *session // created := data["created"].(string) if data["userId"] == nil { // created < threshold arn.DB.Delete("Session", data["sid"].(string)) count++ } total++ } fmt.Printf("Deleted %d / %d sessions.\n", count, total) } func streamSessions() chan *arn.Session { channel := make(chan *arn.Session, nano.ChannelBufferSize) go func() { for obj := range arn.DB.All("Session") { channel <- obj.(*arn.Session) } close(channel) }() return channel }