// +build !nominers

package launchers

import (
	"fmt"
	"net/rpc"
	"os"

	"github.com/p9c/p9/pkg/log"
	"github.com/p9c/p9/cmd/kopach"
	"github.com/p9c/p9/cmd/kopach/worker"
	"github.com/p9c/p9/pod/state"

	"github.com/p9c/p9/pkg/interrupt"

	"github.com/p9c/p9/pkg/chaincfg"
	"github.com/p9c/p9/pkg/fork"
)

// Kopach runs the kopach miner
func Kopach(ifc interface{}) (e error) {
	var cx *state.State
	var ok bool
	if cx, ok = ifc.(*state.State); !ok {
		return fmt.Errorf("cannot run without a state")
	}
	// log.AppColorizer = color.Bit24(255, 128, 128, false).Sprint
	// log.App = "kopach"
	I.Ln("starting up kopach standalone miner for parallelcoin")
	D.Ln(os.Args)
	// podconfig.Configure(cx, true)
	if cx.ActiveNet.Name == chaincfg.TestNet3Params.Name {
		fork.IsTestnet = true
	}
	defer cx.KillAll.Q()
	e = kopach.Run(cx)
	<-interrupt.HandlersDone
	D.Ln("kopach main finished")
	return
}

func Worker(ifc interface{}) (e error) {
	var cx *state.State
	var ok bool
	if cx, ok = ifc.(*state.State); !ok {
		return fmt.Errorf("cannot run without a state")
	}
	// I.Ln(cx.Config.ExtraArgs)
	if len(cx.Config.ExtraArgs) > 1 {
		if os.Args[3] == chaincfg.TestNet3Params.Name {
			fork.IsTestnet = true
		}
	}
	if len(os.Args) > 2 {
		log.SetLogLevel(os.Args[4])
	}
	D.Ln("miner worker starting")
	w, conn := worker.New(cx.Config.ExtraArgs[0], cx.KillAll,
		uint64(cx.Config.UUID.V()))
	e = rpc.Register(w)
	if e != nil {
		D.Ln(e)
		return e
	}
	D.Ln("starting up worker IPC")
	rpc.ServeConn(conn)
	D.Ln("stopping worker IPC")
	D.Ln("finished")
	return nil
}