moth/maintenance.go

package main

import (
	"log"
	"io/ioutil"
	"time"
	"os"
	"strings"
)

func cacheMothball(filepath string, categoryName string) {
	log.Printf("I'm exploding a mothball %s %s", filepath, categoryName)
}

// maintenance runs
func tidy() {
	// Skip if we've been disabled
	if _, err := os.Stat(statePath("disabled")); err == nil {
		log.Print("disabled file found, suspending maintenance")
		return
	}
	
	// Skip if we've expired
	untilspec, err := ioutil.ReadFile(statePath("until"))
	if err == nil {
		until, err := time.Parse(time.RFC3339, string(untilspec))
		if err != nil {
			log.Print("Unparseable date in until file: %s", until)
		} else {
			if until.Before(time.Now()) {
				log.Print("until file time reached, suspending maintenance")
				return
			}
		}
	}
	
	// Get current list of categories
	newCategories := []string{}
	files, err := ioutil.ReadDir(modulesPath())
	if err != nil {
		log.Printf("Error reading packages: %s", err)
	}
	for _, f := range files {
		filename := f.Name()
		filepath := modulesPath(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
	
	collectPoints()
}

// maintenance is the goroutine that runs a periodic maintenance task
func maintenance(maintenanceInterval time.Duration) {
	for ;; time.Sleep(maintenanceInterval) {
		tidy()
	}
}