1 files changed, 283 insertions, 0 deletions
diff --git a/libccnx-transport-rta/ccnx/transport/common/test/test_transport_MetaMessage.c b/libccnx-transport-rta/ccnx/transport/common/test/test_transport_MetaMessage.c
new file mode 100644
index 00000000..3896d945
--- /dev/null
+++ b/libccnx-transport-rta/ccnx/transport/common/test/test_transport_MetaMessage.c
@@ -0,0 +1,283 @@
+/*
+ * Copyright (c) 2017 Cisco and/or its affiliates.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "../transport_MetaMessage.c"
+#include <stdio.h>
+
+#include <LongBow/unit-test.h>
+
+#include <parc/algol/parc_SafeMemory.h>
+
+#include <ccnx/common/validation/ccnxValidation_CRC32C.h>
+
+LONGBOW_TEST_RUNNER(ccnx_MetaMessage)
+{
+    parcMemory_SetInterface(&PARCSafeMemoryAsPARCMemory);
+
+    LONGBOW_RUN_TEST_FIXTURE(Global);
+    LONGBOW_RUN_TEST_FIXTURE(Local);
+}
+
+// The Test Runner calls this function once before any Test Fixtures are run.
+LONGBOW_TEST_RUNNER_SETUP(ccnx_MetaMessage)
+{
+    return LONGBOW_STATUS_SUCCEEDED;
+}
+
+// The Test Runner calls this function once after all the Test Fixtures are run.
+LONGBOW_TEST_RUNNER_TEARDOWN(ccnx_MetaMessage)
+{
+    return LONGBOW_STATUS_SUCCEEDED;
+}
+
+LONGBOW_TEST_FIXTURE(Global)
+{
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_Acquire_Release);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_CreateFromContentObject);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_CreateFromControl);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_CreateFromInterest);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_Display);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_GetContentObject);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_GetControl);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_GetInterest);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_IsContentObject);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_IsControl);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_IsInterest);
+    LONGBOW_RUN_TEST_CASE(Global, ccnxMetaMessage_EncodeDecode);
+}
+
+LONGBOW_TEST_FIXTURE_SETUP(Global)
+{
+    return LONGBOW_STATUS_SUCCEEDED;
+}
+
+LONGBOW_TEST_FIXTURE_TEARDOWN(Global)
+{
+    uint32_t outstandingAllocations = parcSafeMemory_ReportAllocation(STDERR_FILENO);
+    if (outstandingAllocations != 0) {
+        printf("%s leaks memory by %d allocations\n", longBowTestCase_GetName(testCase), outstandingAllocations);
+        return LONGBOW_STATUS_MEMORYLEAK;
+    }
+    return LONGBOW_STATUS_SUCCEEDED;
+}
+
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_Acquire_Release)
+{
+    CCNxName *name = ccnxName_CreateFromCString("lci:/foo/bar");
+    CCNxInterest *interest = ccnxInterest_CreateSimple(name);
+    CCNxMetaMessage *portalMessage = ccnxMetaMessage_CreateFromInterest(interest);
+
+    CCNxMetaMessage *ref1 = ccnxMetaMessage_Acquire(portalMessage);
+    CCNxMetaMessage *ref2 = ccnxMetaMessage_Acquire(portalMessage);
+    CCNxMetaMessage *ref3 = ccnxMetaMessage_Acquire(portalMessage);
+
+    ccnxMetaMessage_Release(&ref1);
+    assertNull(ref1, "Expected pointer to pointer to be null after Release()");
+
+    ccnxMetaMessage_Release(&ref2);
+    assertNull(ref2, "Expected pointer to pointer to be null after Release()");
+
+    ccnxMetaMessage_Release(&ref3);
+    assertNull(ref3, "Expected pointer to pointer to be null after Release()");
+
+    ccnxMetaMessage_Release(&portalMessage);
+    ccnxInterest_Release(&interest);
+    ccnxName_Release(&name);
+}
+
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_CreateFromContentObject)
+{
+    CCNxName *name = ccnxName_CreateFromCString("lci:/foo/bar");
+    PARCBuffer *payload = parcBuffer_WrapCString("This is some data. It's not good data, but it is data.");
+    CCNxContentObject *contentObject = ccnxContentObject_CreateWithNameAndPayload(name, payload);
+
+    CCNxMetaMessage *portalMessage = ccnxMetaMessage_CreateFromContentObject(contentObject);
+    assertNotNull(portalMessage, "Expected a non-null portal message");
+    ccnxMetaMessage_Release(&portalMessage);
+
+    ccnxContentObject_Release(&contentObject);
+    parcBuffer_Release(&payload);
+    ccnxName_Release(&name);
+}
+
+#ifndef BUGZID_712
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_CreateFromControl)
+{
+    testUnimplemented("");
+}
+#endif // !BUGZID_712
+
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_CreateFromInterest)
+{
+    CCNxName *name = ccnxName_CreateFromCString("lci:/foo/bar");
+    CCNxInterest *interest = ccnxInterest_CreateSimple(name);
+
+    CCNxMetaMessage *portalMessage = ccnxMetaMessage_CreateFromInterest(interest);
+    assertNotNull(portalMessage, "Expected a non-null portal message");
+    ccnxMetaMessage_Release(&portalMessage);
+
+    ccnxInterest_Release(&interest);
+    ccnxName_Release(&name);
+}
+
+#ifndef BUGZID_712
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_Display)
+{
+    testUnimplemented("");
+}
+#endif // !BUGZID_712
+
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_GetContentObject)
+{
+    CCNxName *name = ccnxName_CreateFromCString("lci:/foo/bar");
+    PARCBuffer *payload = parcBuffer_WrapCString("This is some data. It's not good data, but it is data.");
+    CCNxContentObject *contentObject = ccnxContentObject_CreateWithNameAndPayload(name, payload);
+
+    CCNxMetaMessage *portalMessage = ccnxMetaMessage_CreateFromContentObject(contentObject);
+
+    CCNxContentObject *reference = ccnxMetaMessage_GetContentObject(portalMessage);
+
+#ifndef BUGZID_712
+    // TODO: We need a ccnxContentObject_Equals()!
+    // assertTrue(ccnxContentObject_Equals(contentObject, reference), "Expected reference to equal original contentObject");
+#endif // !BUGZID_712
+    ccnxContentObject_AssertValid(reference);
+
+    ccnxMetaMessage_Release(&portalMessage);
+
+    ccnxContentObject_Release(&contentObject);
+    parcBuffer_Release(&payload);
+    ccnxName_Release(&name);
+}
+
+#ifndef BUGZID_712
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_GetControl)
+{
+    testUnimplemented("");
+}
+#endif // !BUGZID_712
+
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_GetInterest)
+{
+    CCNxName *name = ccnxName_CreateFromCString("lci:/foo/bar");
+    CCNxInterest *interest = ccnxInterest_CreateSimple(name);
+    CCNxMetaMessage *portalMessage = ccnxMetaMessage_CreateFromInterest(interest);
+    CCNxInterest *reference = ccnxMetaMessage_GetInterest(portalMessage);
+
+    assertTrue(ccnxInterest_Equals(interest, reference), "Expected reference to equal original interest");
+    ccnxInterest_AssertValid(reference);
+
+    ccnxInterest_Release(&reference);
+    ccnxMetaMessage_Release(&portalMessage);
+    ccnxName_Release(&name);
+}
+
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_IsContentObject)
+{
+    CCNxName *name = ccnxName_CreateFromCString("lci:/foo/bar");
+    PARCBuffer *payload = parcBuffer_WrapCString("This is some data. It's not good data, but it is data.");
+    CCNxContentObject *contentObject = ccnxContentObject_CreateWithNameAndPayload(name, payload);
+
+    CCNxMetaMessage *portalMessage = ccnxMetaMessage_CreateFromContentObject(contentObject);
+
+    assertTrue(ccnxMetaMessage_IsContentObject(portalMessage), "Expected portal message to be an ContentObject");
+    assertFalse(ccnxMetaMessage_IsInterest(portalMessage), "Did not expect portal message to be an Interest");
+    assertFalse(ccnxMetaMessage_IsControl(portalMessage), "Did not expect portal message to be a Control message");
+
+    ccnxMetaMessage_Release(&portalMessage);
+    ccnxContentObject_Release(&contentObject);
+    parcBuffer_Release(&payload);
+    ccnxName_Release(&name);
+}
+
+#ifndef BUGZID_712
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_IsControl)
+{
+    testUnimplemented("");
+}
+#endif // !BUGZID_712
+
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_IsInterest)
+{
+    CCNxName *name = ccnxName_CreateFromCString("lci:/foo/bar");
+    CCNxInterest *interest = ccnxInterest_CreateSimple(name);
+    CCNxMetaMessage *portalMessage = ccnxMetaMessage_CreateFromInterest(interest);
+
+    assertTrue(ccnxMetaMessage_IsInterest(portalMessage), "Expected portal message to be an Interest");
+    assertFalse(ccnxMetaMessage_IsContentObject(portalMessage), "Did not expect portal message to be a ContentObject");
+    assertFalse(ccnxMetaMessage_IsControl(portalMessage), "Did not expect portal message to be a Control message");
+
+    ccnxMetaMessage_Release(&portalMessage);
+    ccnxInterest_Release(&interest);
+    ccnxName_Release(&name);
+}
+
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_EncodeDecode)
+{
+    CCNxName *name = ccnxName_CreateFromCString("lci:/foo/bar");
+    CCNxInterest *interest = ccnxInterest_CreateSimple(name);
+    ccnxName_Release(&name);
+
+    PARCSigner *signer = ccnxValidationCRC32C_CreateSigner(); // Would really be SHA256 or something.
+
+    // Encode it to wire format.
+    PARCBuffer *wireFormatBuffer = ccnxMetaMessage_CreateWireFormatBuffer(interest, signer);
+
+    // Now decode it from wireformat.
+    CCNxMetaMessage *decodedMessage = ccnxMetaMessage_CreateFromWireFormatBuffer(wireFormatBuffer);
+
+    // At this point, the unpacked dictionary should be equivalent to the original interest.
+    assertTrue(ccnxInterest_Equals(interest, decodedMessage), "Expected an equivalent interest to be unpacked");
+
+    parcBuffer_Release(&wireFormatBuffer);
+    ccnxInterest_Release(&interest);
+    ccnxMetaMessage_Release(&decodedMessage);
+    parcSigner_Release(&signer);
+}
+
+#ifndef BUGZID_712
+LONGBOW_TEST_CASE(Global, ccnxMetaMessage_Release)
+{
+    testUnimplemented("");
+}
+#endif // !BUGZID_712
+
+LONGBOW_TEST_FIXTURE(Local)
+{
+}
+
+LONGBOW_TEST_FIXTURE_SETUP(Local)
+{
+    return LONGBOW_STATUS_SUCCEEDED;
+}
+
+LONGBOW_TEST_FIXTURE_TEARDOWN(Local)
+{
+    uint32_t outstandingAllocations = parcSafeMemory_ReportAllocation(STDERR_FILENO);
+    if (outstandingAllocations != 0) {
+        printf("%s leaks memory by %d allocations\n", longBowTestCase_GetName(testCase), outstandingAllocations);
+        return LONGBOW_STATUS_MEMORYLEAK;
+    }
+    return LONGBOW_STATUS_SUCCEEDED;
+}
+
+int
+main(int argc, char *argv[])
+{
+    LongBowRunner *testRunner = LONGBOW_TEST_RUNNER_CREATE(ccnx_MetaMessage);
+    int exitStatus = longBowMain(argc, argv, testRunner, NULL);
+    longBowTestRunner_Destroy(&testRunner);
+    exit(exitStatus);
+}