retireve args parsing

Signed-off-by: elestrias <[email protected]>

Author: Elestrias

core/cli/cli.hpp

@@ -0,0 +1,62 @@
+/**
+ * Copyright Soramitsu Co., Ltd. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#pragma once
+
+#include <boost/optional.hpp>
+#include <boost/program_options/options_description.hpp>
+#include <map>
+#include <memory>
+#include <typeindex>
+
+#define CLI_TRY(valueName, maybeResult)                                \
+  auto valueName##OUTCOME_TRY = maybeResult;                               \
+  if (valueName##OUTCOME_TRY.has_error()) throw std::invalid_argument(""); \
+  auto valueName = valueName##OUTCOME_TRY.value();
+
+#define CLI_TRY_TEXT(valueName, maybeResult, textError)                                \
+  auto valueName##OUTCOME_TRY = maybeResult;                               \
+  if (valueName##OUTCOME_TRY.has_error()) throw std::invalid_argument(textError); \
+  auto valueName = valueName##OUTCOME_TRY.value();
+
+#define CLI_OPTS() ::fc::cli::Opts opts()
+#define CLI_RUN()                                                 \
+  static ::fc::cli::RunResult run(const ::fc::cli::ArgsMap &argm, \
+                                  const Args &args,               \
+                                  const ::fc::cli::Argv &argv)
+#define CLI_NO_RUN() constexpr static nullptr_t run{nullptr};
+
+namespace fc::cli {
+  namespace po = boost::program_options;
+  using Opts = po::options_description;
+
+  using RunResult = void;
+  struct ArgsMap {
+    std::map<std::type_index, std::shared_ptr<void>> _;
+    template <typename Args>
+    void add(Args &&v) {
+      _.emplace(typeid(Args), std::make_shared<Args>(std::forward<Args>(v)));
+    }
+    template <typename Cmd>
+    const typename Cmd::Args &of() const {
+      return *reinterpret_cast<const typename Cmd::Args *>(
+          _.at(typeid(typename Cmd::Args)).get());
+    }
+  };
+  // note: Args is defined inside command
+  using Argv = std::vector<std::string>;
+
+  struct Empty {
+    struct Args {
+      CLI_OPTS() {
+        return {};
+      }
+    };
+    CLI_NO_RUN();
+  };
+  using Group = Empty;
+
+  struct ShowHelp {};
+}  // namespace fc::cli

core/cli/node/_tree.hpp

@@ -17,7 +17,7 @@ namespace fc::cli::_node {
        })},
       {"client",
        tree<Group>({
-                       {"retrieve", tree<clientRetrive>()},
+                       {"retrieve", tree<clientRetrieve>()},
        })},
   })};
 }  // namespace fc::cli::_node

core/cli/node/client.hpp

@@ -4,33 +4,56 @@
 #pragma once
 #include "cli/node/node.hpp"
 
-namespace fc::cli::_node{
-
-
-  struct clientRetrive{
-    struct Args{
-      bool car{};
-      bool export_merkle_root{};
-      std::string data_selector;
-
-      CLI_OPTS(){
-        Opts  opts;
+namespace fc::cli::_node {
+  using api::RetrievalOrder;
+  using primitives::BigInt;
+  using primitives::address::Address;
+  using primitives::address::decodeFromString;
+
+  struct clientRetrieve {
+    struct Args {
+      std::string from;
+      std::string piece_cid;
+      BigInt max_funds;
+      boost::filesystem::path path;
+      std::string provider;
+
+      CLI_OPTS() {
+        Opts opts;
         auto option{opts.add_options()};
-        option("car", po::bool_switch(&car), "Export to a car file instead of a regular file");
-        option("data-selector", po::value(&data_selector), "IPLD datamodel text-path selector, or IPLD json selector");
-        option("car-export-merkle-proof", po::bool_switch(&export_merkle_root), "(requires --data-selector and --car) Export data-selector merkle proof");
+        option("from", po::value(&from), "transaction from");
+        option("pieceCID", po::value(&piece_cid), "cid of piece to retrieve");
+        option(
+            "maxPrice",
+            po::value(&max_funds),
+            "specifies the maximum token amount that  client ready to spend");
+        option("path",
+               po::value(&path)->required(),
+               "specifies the path to retrieve");
+        option("provider",
+               po::value(&provider)->required(),
+               "specifies retrieval provider to perform a deal");
         return opts;
       }
     };
 
-
-    CLI_RUN(){
-      std::cout<<args.data_selector<<"\n";
+    CLI_RUN() {
+      Node::Api api{argm};
+      CLI_TRY_TEXT(cid,
+                   CID::fromString(args.piece_cid),
+                   "Invalid piece CID: " + args.piece_cid)
+      if (!args.provider.empty()) {
+        CLI_TRY_TEXT(miner,
+                     decodeFromString(args.provider),
+                     "Invalid Provider Address: " + args.provider)
+      }
+      if (!args.from.empty()) {
+        CLI_TRY_TEXT(client,
+                     decodeFromString(args.from),
+                     "Invalid Client Address: " + args.from)
+      }
+      // TODO: continue function
     }
   };
 
-
-
-
-
-} //fc::cli::node
+}  // namespace fc::cli::_node