hmi.h

Go to the documentation of this file.

/*
-------------------------------------------------------------------------------
                            PLEBBLE
-------------------------------------------------------------------------------
 Copyright (C) 2019-2020 KATLAS Technology. (http://katlastechnology.com)
 Copyright (C) 2017-2020 Marcos Mayorga. (mm@mm-studios.com)
 
 This file is part of our Plebble(R) Platform.
 
 The code below cannot be copied, used for any purpose other than the one
 agreed and/or distributed without the express permission of
 KATLAS Technology.
-------------------------------------------------------------------------------
 
 
*/
#ifndef USGOV_7e8968a1ad23f4f0e2b0aade0a18023d9c2c364de17a7de4ecbcf6f83d7b11e6
#define USGOV_7e8968a1ad23f4f0e2b0aade0a18023d9c2c364de17a7de4ecbcf6f83d7b11e6
 
#include <us/gov/config.h>
#include <us/gov/io/shell_args.h>
#include <us/gov/io/screen.h>
#include <us/gov/io/params.h>
#include <us/gov/io/cfg.h>
#include <us/gov/io/cfg1.h>
#include <us/gov/config.h>
#include <us/gov/socket/datagram.h>
#include "rpc_api.h"
 
namespace us{ namespace gov {
 
namespace engine {
    struct daemon;
}
 
namespace cli {
using namespace std;
 
struct hmi {
 
    typedef us::gov::io::params params;
    typedef us::gov::io::shell_args shell_args;
    typedef us::gov::io::cfg_daemon cfg_daemon;
    typedef us::gov::io::cfg1 cfg1;
    typedef us::gov::io::screen screen;
    typedef us::gov::socket::datagram datagram;
 
    static const char* KO_10100;
    static const char* KO_20195;
 
    struct rpc_api: us::gov::cli::rpc_api {
        typedef us::gov::cli::rpc_api b;
        using b::rpc_api;
        void on_peer_disconnected(const string& reason) override {
            b::on_peer_disconnected(reason);
//            disconnect_reason=reason;
            ret=(ko)KO_20195;
            parent->scr.os << "Peer disconnected. Given reason: " << reason << '\n';
        }
 
        void on_connect(ko err) override {
            b::on_connect(err);
            ret=err;
        }
//        string disconnect_reason;
        ko ret{ok};
        hmi* parent{nullptr};
    };
 
    hmi(ostream&);
    hmi(int argc, char** argv, ostream&);
    hmi(const shell_args&, ostream&);
    hmi(const params&, ostream&);
    virtual ~hmi();
 
    static string parse_options(shell_args& args, params& p);
    static void help(const params& p, ostream& os);
    void write_rpc_client_key();
    void dump_diff(const string& diff_file) const;
    void dump_db(const string& snapshot_block, int detail) const;
    void print_id() const;
    virtual void setup_signals(bool on) {}
    bool run_online();
    bool run_offline();
    void interactive_shell();
    ko exec(const string& cmd);
    ko start();
    ko start(datagram::dispatcher_t*);
    void stop();
    void join();
    ko run();
    static void banner(const params&, ostream&);
    ko wait_connected();
 
    bool interactive{false};
    gov::engine::daemon* demon{nullptr};
    rpc_api* rpc_demon{nullptr};
    cfg_daemon* cfg{nullptr};
    cfg1* cfgcli{nullptr};
    params p;
    screen scr;
    string home;
    ko ret{ok};
    #if CFG_LOGS==1
        string logdir;
    #endif
};
 
}
}}
 
#endif