From 9befefb89cfa0dc81eb461284c179540f808e8b2 Mon Sep 17 00:00:00 2001
From: Bel LaPointe <breel@qualtrics.com>
Date: Mon, 6 Feb 2023 08:03:05 -0700
Subject: [PATCH] now the rems stuff is labelled rems

---
 main.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/main.go b/main.go
index 512d030..f8354fa 100644
--- a/main.go
+++ b/main.go
@@ -29,7 +29,7 @@ type Config struct {
 	AWSR      string
 	Topic     string
 	Message   string
-	Wrap      bool
+	REMSWrap  bool
 	MessageID string
 	Ack       bool
 	Pub       bool
@@ -85,12 +85,12 @@ func getConfig() (Config, error) {
 	flag.StringVar(&c.Topic, "topic", "rems-queue-prod-fra1-priority-low", "sns topic/sqs queue")
 	flag.StringVar(&c.Message, "message", `{"messageType": "NoOpMessage"}`, "published message")
 	flag.StringVar(&c.MessageID, "message-id", "", "sqs message id to ack")
-	flag.BoolVar(&c.Wrap, "wrap", true, "rems wrap message")
+	flag.BoolVar(&c.REMSWrap, "rems-wrap", true, "rems wrap message")
 	flag.BoolVar(&c.Ack, "ack", true, "ack message matching message-id")
 	flag.BoolVar(&c.Pub, "pub", false, "publish message")
 	flag.Parse()
 
-	if c.Wrap {
+	if c.REMSWrap {
 		wrap.Ciphertext = cter{}
 		var v interface{}
 		if err := json.Unmarshal([]byte(c.Message), &v); err != nil {
@@ -144,7 +144,9 @@ func (c Config) Consume(ctx context.Context) error {
 	}
 	for _, message := range messages.Messages {
 		var v interface{}
-		wrap.Unwrap([]byte(*message.Body), &v, isoc{})
+		if c.REMSWrap {
+			wrap.Unwrap([]byte(*message.Body), &v, isoc{})
+		}
 		log.Printf("message in queue: %s: %s: %+v", *message.MessageId, *message.Body, v)
 		if *message.MessageId != c.MessageID {
 			if err := c.unack(ctx, message); err != nil {