mirror of https://github.com/dirtbags/moth.git
72 lines
1.4 KiB
Go
72 lines
1.4 KiB
Go
package main
|
|
|
|
import (
|
|
"log"
|
|
"io/ioutil"
|
|
"time"
|
|
"strings"
|
|
)
|
|
|
|
func allfiles(dirpath) []string {
|
|
files, err := ioutil.ReadDir(dirpath)
|
|
if (err != nil) {
|
|
log.Printf("Error reading directory %s: %s", dirpath, err)
|
|
return []
|
|
}
|
|
return files
|
|
}
|
|
|
|
// maintenance runs
|
|
func tidy() {
|
|
// Skip if we've been disabled
|
|
if exists(statePath("disabled")) {
|
|
log.Print("disabled file found, suspending maintenance")
|
|
return
|
|
}
|
|
|
|
// Skip if we've expired
|
|
untilspec, _ := ioutil.ReadFile(statePath("until"))
|
|
until, err := time.Parse(time.RFC3339, string(untilspec))
|
|
if err == nil {
|
|
if until.Before(time.Now()) {
|
|
log.Print("until file time reached, suspending maintenance")
|
|
return
|
|
}
|
|
}
|
|
|
|
log.Print("Hello, I'm maintaining!")
|
|
|
|
//
|
|
// Get current list of categories
|
|
//
|
|
newCategories := []string{}
|
|
for f := range(allfiles(mothPath("packages"))) {
|
|
filename := f.Name()
|
|
filepath := mothPath(path.Join("packages", filename))
|
|
if ! strings.HasSuffix(filename, ".mb") {
|
|
continue
|
|
}
|
|
|
|
categoryName := strings.TrimSuffix(filename, ".mb")
|
|
newCategories = append(newCategories, categoryName)
|
|
|
|
// Uncompress into cache directory
|
|
cacheMothball(filepath, categoryName)
|
|
}
|
|
categories = newCategories
|
|
|
|
//
|
|
// Collect new points
|
|
//
|
|
for f := range allfiles(statePath("points.new")) {
|
|
|
|
}
|
|
}
|
|
|
|
// maintenance is the goroutine that runs a periodic maintenance task
|
|
func maintenance() {
|
|
for ;; time.Sleep(maintenanceInterval) {
|
|
tidy()
|
|
}
|
|
}
|