func handler()

in services/redis-updater/cmd/main.go [56:83]

• 21 lines of code
• 5 McCabe index (conditional complexity)

func handler(ctx context.Context, kinesisEvent events.KinesisEvent) error {
	for _, record := range kinesisEvent.Records {
		kinesisRecord := record.Kinesis
		dataBytes := kinesisRecord.Data
		dataText := string(dataBytes)

		event := model.Message{}

		if err := json.Unmarshal([]byte(dataText), &event); err != nil {
			fmt.Println("Error unmarshalling data:")
			fmt.Println(err.Error())
		}

		err := persistence.PersistData(event, *redisClient)

		if err != nil {
			return err
		}

		err = persistence.NotifySubscribers(event, *redisClient, redisChannel)
	
		if err != nil {
			return err
		}
	}

	return nil
}