func handler()

in services/kinesis-consumer/cmd/main.go [68:97]

• 25 lines of code
• 4 McCabe index (conditional complexity)

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

		msg := &consumer.TrackingEvent{}
		if err := proto.Unmarshal(dataBytes, msg); err != nil {
			fmt.Println("Got error unmarshalling event:")
			fmt.Println(err.Error())
		}

		event := &model.Message{
			UserAgent:    msg.UserAgent,
			ProgramID:    msg.Programid,
			Checksum:     msg.Checksum,
			CustomerID:   msg.CustomerId,
			CustomerName: msg.CustomerName,
			MessageID:    msg.MessageId,
			ProgramName:  msg.ProgramName}

		msgID, err := persistence.PersistData(*svc, tableName, *event)

		fmt.Println("Message-ID:" + msgID)
		if err != nil {
			return err
		}
	}

	return nil
}