Function parse

parser/parse.go:36–183

(
	evts <-chan tokenizer.Event,
	prefixChannel chan string,
	downloadsChannel chan *Downloads,
	downloadsFailureReason chan string,
	packagesChannel chan *Package,
)

}

func parse(
	evts <-chan tokenizer.Event,
	prefixChannel chan string,
	downloadsChannel chan *Downloads,
	downloadsFailureReason chan string,
	packagesChannel chan *Package,
) {
	outputStarted := false
	downloadTracker := &downloadsTracker{
		prefixChannel:          prefixChannel,
		downloadResultsList:    nil,
		downloadsByPackage:     map[string]*Download{},
		downloadsFinished:      false,
		downloadsFailureReason: downloadsFailureReason,
		target:                 downloadsChannel,
	}
	pkgTracker := &packageTracker{
		packagesByName: map[string]*Package{},
		target:         packagesChannel,
	}

	defer func() {
		downloadTracker.Write()
		pkgTracker.Write()
		close(packagesChannel)
	}()

	var prevErroredDownload string
	var prevErroredPkg string
	for {
		evt, ok := <-evts
		if !ok {
			return
		}

		if evt.Action != tokenizer.ActionStdout {
			outputStarted = true
		}
		if evt.Action != tokenizer.ActionDownload && evt.Action != tokenizer.ActionDownloadFailed && evt.Package != "" {
			pkgTracker.SetTestStartTime(evt.Package, evt.Test, evt.Received)
			if evt.Elapsed != 0 {
				pkgTracker.SetTestElapsed(evt.Package, evt.Test, evt.Elapsed)
			}
			if evt.Coverage != nil {
				pkgTracker.SetCoverage(evt.Package, evt.Test, *evt.Coverage)
			}
			if evt.Cached {
				pkgTracker.SetCached(evt.Package, evt.Test)
			}
		}

		switch evt.Action {
		case tokenizer.ActionFailFinal:
			pkgTracker.SetResult(evt.Package, evt.Test, ResultFail)
			if len(evt.Output) > 0 {
				pkgTracker.AddReason(evt.Package, string(evt.Output))
			}
		case tokenizer.ActionSkipFinal: