Function ParseTORReader

caliper/tor.go:79–241

ParseTORReader parses a Luciol OTDR .tor text file from a reader

(r io.Reader)

// ParseTORReader parses a Luciol OTDR .tor text file from a reader
func ParseTORReader(r io.Reader) (*TORFile, error) {
	tor := &TORFile{}
	scanner := bufio.NewScanner(r)

	// Skip header lines until we find the first section
	for scanner.Scan() {
		line := cleanLine(scanner.Text())
		if line == "[DateTime]" {
			break
		}
	}

	currentSection := "DateTime"
	for scanner.Scan() {
		line := cleanLine(scanner.Text())

		if line == "[-]" {
			currentSection = ""
			continue
		}

		if strings.HasPrefix(line, "[") && strings.HasSuffix(line, "]") {
			currentSection = line[1 : len(line)-1]
			continue
		}

		if currentSection == "" && line == "" {
			continue
		}

		switch currentSection {
		case "DateTime":
			ts, err := strconv.ParseInt(line, 10, 64)
			if err != nil {
				return nil, fmt.Errorf("parsing DateTime %q: %w", line, err)
			}
			tor.DateTime = time.Unix(ts, 0)
		case "InstrumentInfo":
			if tor.InstrumentInfo == "" {
				tor.InstrumentInfo = line
			} else if sn, ok := strings.CutPrefix(line, "OTDR module S/N:"); ok {
				tor.ModuleSerialNumber = strings.TrimSpace(sn)
			}
		case "CableID":
			tor.CableID = line
		case "FiberID":
			tor.FiberID = line
		case "FiberType":
			v, err := strconv.Atoi(line)
			if err != nil {
				return nil, fmt.Errorf("parsing FiberType %q: %w", line, err)
			}
			tor.FiberType = v
		case "Wavelength":
			v, err := strconv.Atoi(line)
			if err != nil {
				return nil, fmt.Errorf("parsing Wavelength %q: %w", line, err)
			}