ALDRpcUtils.h

См. документацию.

 
#ifndef ALD_RPC_UTILS
#define ALD_RPC_UTILS
 
#include "common.h"
#include <iostream>
#include <memory>
#include "ald-rpc.h"
#include "rpc-definitions.h"
 
using namespace std;
 
namespace ALD
{
 
void send_str(ostream& o, const string& s, bool checklen = true);
void read_str(istream& i, string& s, bool checklen = true);
 
void send_size(ostream& o, size_t s);
void read_size(istream& i, size_t& s);
 
class IALDRpcSession;
class CALDUser;
 
// Privileged     everybody   authenticated     authorized(CREDS)   admins     admin/admin
enum arcPrivKind{
    arckPublic,         
    arckAuthenticated,  
    arckAuthorized,     
    arckPrivileged,     
    arckSystem};        
 
class CALDRpcCommand
{
protected:
    IALDCore* m_pCore;      
    string m_strName;       
    string m_strDesc;       
    arcPrivKind m_PrivKind; 
public:
    inline const string &name() const {return m_strName;}
    inline const string &desc() const {return m_strDesc;}
    inline arcPrivKind kind() const {return m_PrivKind;}
 
    virtual void Run(ald_rpc_request &request, IALDRpcSession *session, void* extra) = 0;
 
    CALDRpcCommand(IALDCore& Core);
    virtual ~CALDRpcCommand();
};
 
typedef shared_ptr<CALDRpcCommand> CALDRpcCommandPtr;
 
typedef map<string, CALDRpcCommandPtr> ald_rpc_command_map;
 
class IALDRpcSession
{
public:
    virtual ald_rpc_request& request() = 0; 
 
    virtual bool IsAuthenticated() = 0;
    virtual bool IsAuthorized() = 0;
    virtual bool IsAdmin() = 0;
    virtual bool IsSuperuser() = 0;
    virtual bool IsService() = 0;
    virtual string userId() = 0;            
 
    virtual string localhost() = 0;
    virtual int localport() = 0;
    virtual string peerhost() = 0;
    virtual int peerport() = 0;
 
    virtual ald_rpc_command_map& commands(const string &key) = 0;
 
    virtual ~IALDRpcSession(){}
};
 
/* Actions */
#define ALD_LOAD_RPC_COMMANDS   "LoadRpcCommands"
#define ALD_RPC_KEY             "RPC"
#define ALD_LPC_KEY             "LPC"
 
struct ald_load_rpc_commands_extra {
    ald_rpc_command_map* mapRpcCmds;    
    // cppcheck-suppress unusedStructMember
    void *extra;                        
};
 
const char* rpcmsgtype2str(unsigned short message);
 
struct ald_rpc_statistics_extra {
    ald_string_map *stats;      
    // cppcheck-suppress unusedStructMember
    void *extra;                
};
 
#define MK_BROADCAST_MESSAGE(msg, arg) string(msg)+":"+arg
 
bool SendBroadcastMessage(IALDCore &Core, const string& msg, ald_string_list *responses = NULL, int timeout = 3);
 
 
} // ALD
 
#endif //ALD_RPC_UTILS