in main/status.go [106:123]
func readStatus(ctx *log.Context, hEnv HandlerEnvironment, seqNum int) (Type, error) {
fileName := fmt.Sprintf("%d.status", seqNum)
path := filepath.Join(hEnv.HandlerEnvironment.StatusFolder, fileName)
buffer, err := ioutil.ReadFile(path)
if err != nil {
return "", fmt.Errorf("Error reading status file %s: %v", path, err)
}
var statusReport StatusReport
if err := json.Unmarshal(buffer, &statusReport); err != nil {
return "", fmt.Errorf("error parsing json: %v", err)
}
if len(statusReport) != 1 {
return "", fmt.Errorf("wrong statusReport count. expected:1, got:%d", len(statusReport))
}
return statusReport[0].Status.Status, nil
}