main.go

package main

import (
	"fmt"

	"github.com/ninjasphere/app-scheduler/model"
	"github.com/ninjasphere/app-scheduler/rest"
	"github.com/ninjasphere/app-scheduler/service"
	"github.com/ninjasphere/app-scheduler/ui"
	"github.com/ninjasphere/go-ninja/api"
	nmodel "github.com/ninjasphere/go-ninja/model"
	"github.com/ninjasphere/go-ninja/support"
)

var (
	info = ninja.LoadModuleInfo("./package.json")
)

type postConstructable interface {
	PostConstruct() error
}

//SchedulerApp describes the scheduler application.
type SchedulerApp struct {
	support.AppSupport
	service       *service.SchedulerService
	restServer    rest.RestServer
	configService *ui.ConfigService
}

// Start is called after the ExportApp call is complete.
func (a *SchedulerApp) Start(m *model.Schedule) error {
	if a.service != nil {
		return fmt.Errorf("illegal state: scheduler is already running")
	}
	m = m.Migrate()
	m.Version = Version
	a.SendEvent("config", m)
	a.service = &service.SchedulerService{
		Log:   a.Log,
		Conn:  a.Conn,
		Model: m,
		ConfigStore: func(m *model.Schedule) {
			a.SendEvent("config", m)
		},
	}
	err := a.service.Init(a.Info.ID)
	if err != nil {
		return err
	}

	a.restServer.Scheduler = a.service
	go a.restServer.Start()

	a.configService = ui.NewConfigService(a.service, a.Conn)
	a.Conn.MustExportService(a.configService, "$app/"+a.GetModuleInfo().ID+"/configure", &nmodel.ServiceAnnouncement{
		Schema: "/protocol/configuration",
	})

	return nil
}

// Stop the scheduler module.
func (a *SchedulerApp) Stop() error {
	var err error

	// TODO: stop the REST server
	if a.service != nil {
		tmp := a.service
		a.service = nil
		a.restServer.Stop()
		err = tmp.Scheduler.Stop()
	}
	return err
}

func main() {
	app := &SchedulerApp{}
	err := app.Init(info)
	if err != nil {
		app.Log.Fatalf("failed to initialize app: %v", err)
	}

	err = app.Export(app)
	if err != nil {
		app.Log.Fatalf("failed to export app: %v", err)
	}

	support.WaitUntilSignal()
}