package ci

import (
	"os/exec"
	"path"
	"strings"

	"github.com/macports/mpbot-github/ci/logger"
)

// buildWorker receive ports from portChan
type buildWorker struct {
	worker
	portChan chan string
}

func newBuildWorker(session *Session) *buildWorker {
	return &buildWorker{
		worker:   worker{session: session, quitChan: make(chan byte)},
		portChan: make(chan string),
	}
}

func (worker *buildWorker) start() {
	returnCode := byte(0)
	for {
		select {
		case port := <-worker.portChan:
			if port == "" {
				worker.quitChan <- returnCode
				return
			}
			subports, err := ListSubports(port)
			if err != nil {
				returnCode = 1
				logger.GlobalLogger.LogChan <- &logger.LogText{"port-" + port + "-subports-fail", []byte(err.Error())}
				continue
			}
			logger.GlobalLogger.LogChan <- &logger.LogText{"port-" + port + "-subports", []byte(strings.Join(subports, "\n"))}
			for _, subport := range subports {
				statusString := "success"
				portTmpDir := path.Join(worker.session.tmpDir, subport)
				mpbbToLog("cleanup", "", portTmpDir, "cleanup.log")
				logFilename := path.Join(worker.session.tmpDir, "port-"+subport+"-dep-install.log")
				logger.GlobalLogger.LogChan <- &logger.LogText{"port-" + subport + "-dep-install-start", nil}
				err := mpbbToLog("install-dependencies", subport, portTmpDir, logFilename)
				if err != nil {
					if eerr, ok := err.(*exec.ExitError); ok {
						if !eerr.Success() {
							returnCode = 1
							statusString = "fail"
						}
					}
				}
				logger.GlobalLogger.LogChan <- &logger.LogFile{
					FieldName: "port-" + subport + "-dep-summary-" + statusString,
					Filename:  path.Join(portTmpDir, "logs/dependencies-progress.txt"),
				}
				if err != nil {
					logger.GlobalLogger.LogChan <- &logger.LogFile{
						FieldName: "port-" + subport + "-dep-install-output-" + statusString,
						Filename:  logFilename,
						Big:       true,
					}
					continue
				}

				logFilename = path.Join(worker.session.tmpDir, "port-"+subport+"-install.log")
				logger.GlobalLogger.LogChan <- &logger.LogText{"port-" + subport + "-install-start", nil}
				err = mpbbToLog("install-port", subport, portTmpDir, logFilename, "--source")
				if err != nil {
					if eerr, ok := err.(*exec.ExitError); ok {
						if !eerr.Success() {
							returnCode = 1
							statusString = "fail"
						}
					}
				}
				logger.GlobalLogger.LogChan <- &logger.LogFile{
					FieldName: "port-" + subport + "-install-summary-" + statusString,
					Filename:  path.Join(portTmpDir, "logs/ports-progress.txt"),
				}
				logger.GlobalLogger.LogChan <- &logger.LogFile{
					FieldName: "port-" + subport + "-install-output-" + statusString,
					Filename:  logFilename,
					Big:       true,
				}
			}
		}
	}
}