1 files changed, 159 insertions, 0 deletions
diff --git a/libccnx-portal/ccnx/api/ccnx_Portal/command-line/ccnx-client.c b/libccnx-portal/ccnx/api/ccnx_Portal/command-line/ccnx-client.c
new file mode 100755
index 00000000..dfd5d5ba
--- /dev/null
+++ b/libccnx-portal/ccnx/api/ccnx_Portal/command-line/ccnx-client.c
@@ -0,0 +1,159 @@
+/*
+ * 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 <config.h>
+
+#include <stdio.h>
+#include <unistd.h>
+#include <getopt.h>
+
+#include <LongBow/runtime.h>
+
+#include "ccnxPortalClient_About.h"
+
+#include <ccnx/api/ccnx_Portal/ccnx_Portal.h>
+#include <ccnx/api/ccnx_Portal/ccnx_PortalRTA.h>
+
+#include <parc/security/parc_Security.h>
+#include <parc/security/parc_IdentityFile.h>
+#include <parc/security/parc_PublicKeySigner.h>
+
+#include <parc/algol/parc_Memory.h>
+
+#include <parc/algol/parc_InputStream.h>
+#include <parc/algol/parc_OutputStream.h>
+
+int
+ccnGet(PARCIdentity *identity, CCNxName *name)
+{
+    CCNxPortalFactory *factory = ccnxPortalFactory_Create(identity);
+
+    CCNxPortal *portal = ccnxPortalFactory_CreatePortal(factory, ccnxPortalRTA_Message);
+
+    assertNotNull(portal, "Expected a non-null CCNxPortal pointer.");
+
+    CCNxInterest *interest = ccnxInterest_CreateSimple(name);
+    ccnxName_Release(&name);
+
+    CCNxMetaMessage *message = ccnxMetaMessage_CreateFromInterest(interest);
+
+    if (ccnxPortal_Send(portal, message, CCNxStackTimeout_Never)) {
+        while (ccnxPortal_IsError(portal) == false) {
+            CCNxMetaMessage *response = ccnxPortal_Receive(portal, CCNxStackTimeout_Never);
+            if (response != NULL) {
+                if (ccnxMetaMessage_IsContentObject(response)) {
+                    CCNxContentObject *contentObject = ccnxMetaMessage_GetContentObject(response);
+
+                    PARCBuffer *payload = ccnxContentObject_GetPayload(contentObject);
+
+                    size_t length = parcBuffer_Remaining(payload);
+                    ssize_t nwritten = write(1, parcBuffer_Overlay(payload, length), length);
+                    assertTrue(nwritten == length, "Did not write whole buffer, got %zd expected %zu", nwritten, length);
+
+                    break;
+                }
+                ccnxMetaMessage_Release(&response);
+            }
+        }
+    }
+
+    ccnxPortal_Release(&portal);
+
+    ccnxPortalFactory_Release(&factory);
+
+    return 0;
+}
+
+void
+usage(void)
+{
+    printf("%s\n", ccnxPortalClientAbout_About());
+    printf("ccn-client --identity <file> --password <password> <objectName>\n");
+    printf("ccn-client [-h | --help]\n");
+    printf("ccn-client [-v | --version]\n");
+    printf("\n");
+    printf("    --identity  The file name containing a PKCS12 keystore\n");
+    printf("    --password  The password to unlock the keystore\n");
+    printf("    <objectName> The LCI name of the object to fetch\n");
+}
+
+int
+main(int argc, char *argv[argc])
+{
+    char *keystoreFile = NULL;
+    char *keystorePassword = NULL;
+
+    /* options descriptor */
+    static struct option longopts[] = {
+        { "identity", required_argument, NULL, 'f' },
+        { "password", required_argument, NULL, 'p' },
+        { "version",  no_argument,       NULL, 'v' },
+        { "help",     no_argument,       NULL, 'h' },
+        { NULL,       0,                 NULL, 0   }
+    };
+
+    int ch;
+    while ((ch = getopt_long(argc, argv, "fphv", longopts, NULL)) != -1) {
+        switch (ch) {
+            case 'f':
+                keystoreFile = optarg;
+                break;
+
+            case 'p':
+                keystorePassword = optarg;
+                break;
+
+            case 'v':
+                printf("%s\n", ccnxPortalClientAbout_Version());
+                return 0;
+
+            case 'h':
+                usage();
+                return 0;
+
+            default:
+                usage();
+                return -1;
+        }
+    }
+
+    argc -= optind;
+    argv += optind;
+    if (argv[0] == NULL || keystoreFile == NULL || keystorePassword == NULL) {
+        usage();
+        return -1;
+    }
+
+    char *objectName = argv[0];
+
+    PARCIdentityFile *identityFile = parcIdentityFile_Create(keystoreFile, keystorePassword);
+    if (parcIdentityFile_Exists(identityFile) == false) {
+        printf("Inaccessible keystore file '%s'.\n", keystoreFile);
+        exit(1);
+    }
+    PARCIdentity *identity = parcIdentity_Create(identityFile, PARCIdentityFileAsPARCIdentity);
+    parcIdentityFile_Release(&identityFile);
+
+    CCNxName *name = ccnxName_CreateFromCString(objectName);
+
+    int result = ccnGet(identity, name);
+
+    parcIdentity_Release(&identity);
+    ccnxName_Release(&name);
+
+    return result;
+}