go__sqs_demo/handler.go

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"time"

	"github.com/google/uuid"
)

// HandleDummy is blissfully unaware of SQS, and could therefore be used as a handler for another message queue.
func HandleDummy(_ context.Context, enc *json.Encoder, msg []byte) error {
	type EventBody struct {
		EventID   uuid.UUID      `json:"event_id"`
		EventTime time.Time      `json:"event_time"`
		Data      map[string]int `json:"data,omitempty"`
	}
	evt := EventBody{}
	if err := json.Unmarshal(msg, &evt); err != nil {
		return fmt.Errorf("error parsing body as JSON: %w", err)
	}

	enc.Encode(evt)
	return nil
}