feat: log confirm topic messages

Heavily inspired by the verify reject command
this command now prints the messages from
confirm-topic.

cmd/verify/confirm/confirm.go

@@ -1,11 +1,15 @@
 package confirm
 
 import (
+	"context"
 	"fmt"
+	"github.com/segmentio/kafka-go"
 	"github.com/spf13/cobra"
 	"hermetic/internal/common_flags"
 	"hermetic/internal/teams"
 	confirmImplementation "hermetic/internal/verify/confirm"
+	"os"
+	"os/signal"
 )
 
 func NewCommand() *cobra.Command {
@@ -29,7 +33,16 @@ func parseArgumentsAndCallVerify(cmd *cobra.Command, args []string) error {
 		return fmt.Errorf("failed to get confirm-topic flag, cause: `%w`", err)
 	}
 
-	err = confirmImplementation.Verify(confirmTopicName)
+	ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt)
+	defer cancel()
+
+	reader := kafka.NewReader(kafka.ReaderConfig{
+		Brokers: common_flags.KafkaEndpoints,
+		Topic:   confirmTopicName,
+		GroupID: "nettarkivet-hermetic-verify",
+	})
+
+	err = confirmImplementation.ReadConfirmTopic(ctx, reader)
 	if err != nil {
 		err = fmt.Errorf("verification error, cause: `%w`", err)
 		fmt.Printf("Sending error message to Teams\n")

internal/verify/confirm/confirm.go

@@ -1,12 +1,28 @@
 package confirmImplmentation
 
 import (
+	"context"
 	"fmt"
+	"github.com/segmentio/kafka-go"
+	"hermetic/internal/dps"
 )
 
-func Verify(confirmTopicName string) error {
-	fmt.Printf("Reading messages from topic '%s'\n", confirmTopicName)
-	fmt.Printf("This command is not implemented yet\n" +
-		"Aims to solve issue https://github.com/nlnwa/hermetic/issues/3 ")
+func ReadConfirmTopic(ctx context.Context, reader *kafka.Reader) error {
+	err := dps.ReadMessages(ctx, reader, ProcessMessagesFromConfirmTopic)
+	if err != nil {
+		return fmt.Errorf("failed to read confirm-topic: `%w`", err)
+	}
+
 	return nil
 }
+
+func ProcessMessagesFromConfirmTopic(response *dps.KafkaResponse, err error) {
+	if err != nil {
+		fmt.Errorf("failed to read message, cause: `%w`", err)
+	}
+	if response == nil {
+		fmt.Println("No response found")
+	} else {
+		fmt.Printf("SIP successfully perserved: %+v\n", response)
+	}
+}