func PersistData()

in services/redis-updater/services/persistence/store_data.go [28:50]

• 17 lines of code
• 3 McCabe index (conditional complexity)

func PersistData(msg model.Message, client redis.Client) error {

	values := structs.Map(msg)
	status := client.HMSet(msg.ProgramID, values)
	if status.Err() != nil {
		fmt.Println("Error writing data:")
		fmt.Println(status.Err().Error())

		return status.Err()
	}

	msgBytes, err := json.Marshal(msg)

	if err != nil {
		fmt.Println("Error marshalling data:")
		fmt.Println(err.Error())
	}

	msgString := string(msgBytes)
	fmt.Println("Persisting data: " + msgString)

	return err
}