fix: check on missing topic & test cases for payload contents

Author: TechSolomon

utility/republisher.go

@@ -71,6 +71,11 @@ func OutboundMessageFlow(server string, port int, prefix string, destination str
 
 		// TODO: Bounds checking for extracted top-level message intent.
 
+		if msg.Topic == "" {
+			fmt.Println(">> [!] Error extracting the message topic.")
+			continue
+		}
+
 		prepend := prefix + "/" + msg.Topic
 		repackaged := RepackageContents(message, prepend)
 		PublishPayload(server, port, prepend, repackaged)

utility/republisher_test.go

@@ -41,3 +41,37 @@ func TestDetectContents(t *testing.T) {
 		}
 	}
 }
+
+func TestRepackageContents(t *testing.T) {
+	testcases := []struct {
+		input  string
+		topic  string
+		output string
+	}{
+		{"{\"time\": 1234567890123456, \"topic\": \"test-topic\", \"b64payload\": \"ZGF0YS1kaW9kZQ==\"}", "test-topic", "data-diode"},
+	}
+
+	for _, test := range testcases {
+		actual := RepackageContents(test.input, test.topic)
+		expected := test.output
+
+		if actual != expected {
+			t.Errorf("Expected %s but got %s", expected, actual)
+		}
+	}
+}
+
+func TestPublishPayload(t *testing.T) {
+	testcases := []struct {
+		server  string
+		port    int
+		topic   string
+		message string
+	}{
+		{"localhost", 1883, "test-topic", "data-diode"},
+	}
+
+	for _, test := range testcases {
+		PublishPayload(test.server, test.port, test.topic, test.message)
+	}
+}