Method Start

pkg/buildercontroller/buildercontroller.go:159–191

(ctx context.Context, appId string, builderEnv map[string]string)

}

func (bc *BuilderController) Start(ctx context.Context, appId string, builderEnv map[string]string) error {
	if err := bc.waitForBuildDone(ctx); err != nil {
		return err
	}
	bc.lock.Lock()
	defer bc.lock.Unlock()

	if bc.appId != appId && bc.process != nil {
		log.Printf("BuilderController: stopping previous app %s for builder %s", bc.appId, bc.builderId)
		bc.stopProcess_nolock()
	}

	bc.appId = appId
	bc.outputBuffer = utilds.MakeMultiReaderLineBuffer(1000)
	bc.setStatus_nolock(BuilderStatus_Building, 0, 0, "")

	bc.publishOutputLine("", true)

	bc.outputBuffer.SetLineCallback(func(line string) {
		bc.publishOutputLine(line, false)
	})

	buildCtx, cancel := context.WithTimeout(context.Background(), 60*time.Second)
	go func() {
		defer cancel()
		defer func() {
			panichandler.PanicHandler(fmt.Sprintf("buildercontroller[%s].buildAndRun", bc.builderId), recover())
		}()
		bc.buildAndRun(buildCtx, appId, builderEnv, nil)
	}()

	return nil
}

func (bc *BuilderController) buildAndRun(ctx context.Context, appId string, builderEnv map[string]string, resultCh chan<- *BuildResult) {
	appNS, _, err := waveappstore.ParseAppId(appId)