daemon.go

package main

import (
	"fmt"
	"os"
	"runtime"

	"github.com/dedis/drand/core"
	"github.com/dedis/drand/key"
	"github.com/urfave/cli"
)

func startCmd(c *cli.Context) error {
	conf := contextToConfig(c)
	fs := key.NewFileStore(conf.ConfigFolder())
	var drand *core.Drand

	// determine if we already ran a DKG or not
	_, errG := fs.LoadGroup()
	_, errS := fs.LoadShare()
	_, errD := fs.LoadDistPublic()
	// XXX place that logic inside core/ directly with only one method
	freshRun := errG != nil || errS != nil || errD != nil
	var err error
	if freshRun {
		if exit := resetBeaconDB(conf); exit {
			os.Exit(0)
		}
		fmt.Println("drand: will run as fresh install -> expect to run DKG.")
		drand, err = core.NewDrand(fs, conf)
		if err != nil {
			fatal("drand: can't instantiate drand instance %s", err)
		}
	} else {
		fmt.Print("drand: will already start running randomness beacon")
		drand, err = core.LoadDrand(fs, conf)
		if err != nil {
			fatal("drand: can't load drand instance %s", err)
		}
		// XXX make it configurable so that new share holder can still start if
		// nobody started.
		if err := drand.StartBeacon(!c.Bool(pushFlag.Name)); err != nil {
			fatal("drand: starting beacon failed: %s", err)
		}
	}
	// wait indefinitely  - XXX analyzes goroutine graphs to see if it actually
	// makes sense
	runtime.Goexit()

	return nil
}

func stopDaemon(c *cli.Context) error {
	// TODO
	panic("not implemented yet")
}