expire.go

package command

import (
	"github.com/deweysasser/locksmith/data"
	"github.com/deweysasser/locksmith/lib"
	"github.com/deweysasser/locksmith/output"
	"github.com/urfave/cli"
)

func CmdExpire(c *cli.Context) error {
	outputLevel(c)
	ml := lib.MainLibrary{Path: datadir(c)}

	filter := buildFilterFromContext(c)

	keys := make(chan data.Key)

	library := ml.Keys()
	go func() {
		for i := range library.List() {
			if filter(keyString(i, "")) {
				if k, ok := i.(data.Key); ok {
					k.Expire()
					keys <- k
				} else {
					output.Error(i, "is not a key")
				}
			}
		}
		close(keys)
	}()

	for k := range keys {
		library.Store(k)
	}

	return nil
}