Function parseLine

tokenizer/tokenizer.go:407–481

(currentState state, line []byte, output chan<- Event)

}

func parseLine(currentState state, line []byte, output chan<- Event) state {
	jsonLine := tryParseJSONLine(line)
	if jsonLine != nil {
		if jsonLine.Output == nil {
			return currentState
		}
		line = []byte(strings.TrimRight(*jsonLine.Output, "\r\n"))
	}

	for _, stateTransition := range stateMachine {
		if stateTransition.inputState != currentState {
			continue
		}

		// Don't match the "package" action against a JSON lines - issue #52
		if jsonLine != nil && stateTransition.action == ActionPackage {
			continue
		}

		if match := stateTransition.regexp.FindSubmatch(line); len(match) != 0 {
			elapsed, err := getTimeElapsed(stateTransition.regexp, match, "Elapsed")
			if err == nil {
				coverageString := string(extract(stateTransition.regexp, match, "Coverage"))
				coverage := -1.0
				if coverageString != "" {
					coverage, err = strconv.ParseFloat(coverageString, 64)
					if err != nil {
						continue
					}
				}
				var coveragePtr *float64
				if coverage >= 0 {
					coveragePtr = &coverage
				}

				pkg := string(extract(stateTransition.regexp, match, "Package"))
				if jsonLine != nil && pkg == "" {
					pkg = jsonLine.Package
				}
				version := string(extract(stateTransition.regexp, match, "Version"))
				test := string(extract(stateTransition.regexp, match, "Test"))
				if jsonLine != nil && test == "" {
					test = jsonLine.Test
				}
				cached := string(extract(stateTransition.regexp, match, "Cached")) == "cached"
				received := time.Now()
				if jsonLine != nil && jsonLine.Time != nil {
					received = *jsonLine.Time
				}
				if jsonLine != nil && jsonLine.Elapsed != nil && *jsonLine.Elapsed > 0 {
					elapsed = time.Duration(*jsonLine.Elapsed * float64(time.Second))
				}
				evt := Event{
					Received: received,
					Action:   stateTransition.action,
					Package:  pkg,
					Version:  version,
					Test:     test,