Added conditional ws streams to Poloniex and Kraken.

████ ███  To request new features or in case this commit breaks something for you,
████ ███  please, create a new github issue with all possible information for me,
▓███▀█▄   but never share your API Keys!
▒▓██ ███
░▒▓█ ███  Signed-off-by: Carles Tubio <ctubio@users.noreply.github.com>
 _______________________________
/ Hello, WORLD!                 \
|                               |
\ pssst.. 1 BTC = 33043.34 EUR. /
 -------------------------------
        \   ^__^
         \  (oo)\_______
            (__)\       )\/\
                ||----w |
                ||     ||

Makefile

@@ -2,7 +2,7 @@ K         ?= K.sh
 MAJOR      = 0
 MINOR      = 6
 PATCH      = 2
-BUILD      = 6
+BUILD      = 7
 
 OBLIGATORY = DISCLAIMER: This is strict non-violent software: \n$\
              if you hurt other living creatures, please stop; \n$\

src/bin/+portfolios/+portfolios.data.h

@@ -2,17 +2,34 @@
 //! \brief Welcome user! (just a manager of portfolios).
 
 namespace analpaper {
-  class Engine {
-    private:
-      Levels levels;
+  struct Wallets {
+    map<string, Wallet> wallet;
     private_ref:
       const KryptoNinja &K;
     public:
-      Engine(const KryptoNinja &bot)
+      Wallets(const KryptoNinja &bot)
         : K(bot)
       {};
+      void read_from_gw(const Wallet &raw) {
+        wallet[raw.currency] = raw;
+      };
+      bool ready() const {
+        const bool err = wallet.empty();
+        if (err and Tspent > 21e+3)
+          K.logWar("QE", "Unable to display portfolios, missing wallet data", 3e+3);
+        return !err;
+      };
+  };
+
+  class Engine {
+    private:
+      Wallets wallet;
+    public:
+      Engine(const KryptoNinja &bot)
+        : wallet(bot)
+      {};
       void read(const Wallet &rawdata) {
-        cout << ((json)rawdata).dump() << endl;
+        wallet.read_from_gw(rawdata);
       };
   };
 }

src/lib/Krypto.ninja-apis.h

@@ -229,7 +229,7 @@ namespace ₿ {
         async.wallet.wait_for(loop, [&]() { return sync_wallet(); });
       };
       void ask_for_never_async_data(const unsigned int &tick) {
-        if (!(tick % 15)) balance();
+        if (async.wallet.write and !(tick % 15)) balance();
       };
   };
 
@@ -477,12 +477,11 @@ namespace ₿ {
         GwApiWs::connect();
         if (GwApiWs::connected()) {
           CURLcode rc;
-          if (CURLE_OK == (rc = WebSocketTwin::connect(twin(ws)))) {
+          if (CURLE_OK == (rc = WebSocketTwin::connect(twin(ws))))
             WebSocketTwin::start(GwExchangeData::loopfd, [&]() {
               wait_for_async_data();
             });
-            print("WS Streaming orders");
-          } else reconnect(string("CURL connect Error: ") + curl_easy_strerror(rc));
+          else reconnect(string("CURL connect Error: ") + curl_easy_strerror(rc));
         }
       };
       void disconnect() override {