func parseJobMessage()

in awsiotjobs/awsiotjobs.go [326:337]

• 12 lines of code
• 2 McCabe index (conditional complexity)

func parseJobMessage(msg []byte) (*JobExecution, error) {
	var jobExecution JobExecution
	var doc map[string]interface{}
	json.Unmarshal(msg, &doc)
	execution, ok := doc["execution"]
	if !ok {
		return &jobExecution, JobError{"ERR_INVALID_JOB", fmt.Sprintf("missing \"execution\" from payload: %s", msg)}
	}
	executionJSON, _ := json.Marshal(execution)
	json.Unmarshal(executionJSON, &jobExecution)
	return &jobExecution, nil
}