action.h

Go to the documentation of this file.

#ifndef ACTION_H
#define ACTION_H

#include "iberbox/config.h"
#include "iberbox/ownership.h"
#include "iberbox/error.h"
#include "iberbox/node.h"
#include "iberbox/transfer.h"
#include "iberbox/payments.h"
#include "iberbox/account.h"
#include "iberbox/user.h"

#include <memory>
#include <functional>
#include <mutex>
#include <condition_variable>

#ifdef USE_SCAPIX
#include <scapix/bridge/object.h>
#endif

namespace iberbox {

class ActionData;
typedef std::shared_ptr<ActionData> Action;
typedef std::vector<Action> ActionDataList;
typedef std::shared_ptr<ActionDataList> ActionList;

class ActionData
#ifdef USE_SCAPIX
    : public scapix::bridge::object<ActionData>
#endif
{
public:
    enum ActionType
    {
        TEST,               
        ADD_CONTACT,        
        VERIFY_EMAIL,       
        FORGOT_PASSWORD,    
        CREATE_ACCOUNT,     
        CHANGE_PASSWORD,    
        RECOVERY_KEY,       
        MANAGE_2FA,         
        LOGIN,              
        GET_NODES,          
        GET_ROOT,           
        GET_CHILDREN,       
        GET_NODE,           
        GET_PATH,           
        ADD_NODES,          
        DELETE_NODE,        
        RENAME_NODE,        
        MOVE_NODE,          
        COPY_NODE,          
        CREATE_LINK,        
        GET_LINK_INFO,      
        USER_INFO,          
        ACCOUNT_INFO,       
        LOG_EVENT,          
        TEST_PROXY,         
        SET_PROXY,          
        UPLOAD,             
        DOWNLOAD,           
        DOWNLOAD_ZIP,       
        STREAM,             
        BACKUP,             
        UPLOAD_METADATA,    
        DOWNLOAD_METADATA,  
        GET_TRANSFERS,              
        CLEAR_FINISHED_TRANSFERS,   
        CANCEL_TRANSFERS,           
        SET_TRANSFER_SPEED_LIMIT,   
        GET_TRANSFER_SPEED_LIMIT,   
        REGISTER_DEVICE,            
        SELECT_DEVICE,              
        GET_CURRENT_DEVICE,         
        GET_DEVICE,                 
        GET_DEVICES,                
        RENAME_DEVICE,              
        DELETE_DEVICE,              
        GET_BACKUP,                 
        GET_BACKUPS,                
        CREATE_BACKUP,              
        MODIFY_BACKUP,              
        RENAME_BACKUP,              
        CHANGE_BACKUP_SCHEDULE,     
        CHANGE_BACKUP_PATH,         
        CHANGE_BACKUP_STATUS,       
        DELETE_BACKUP,              
        AUTHORIZE_BACKUP,           
        GET_SNAPSHOTS,                      
        GET_NEXT_SNAPSHOTS,                 
        GET_NEXT_SNAPSHOTS_BY_DEVICE,       
        GET_NEXT_SNAPSHOTS_BY_BACKUP,       
        GET_NEXT_SNAPSHOTS_BY_ACCOUNT,      
        GET_NEXT_SNAPSHOTS_BY_SCHEDULE,     
        GET_LAST_SNAPSHOTS,                 
        GET_LAST_SNAPSHOTS_BY_DEVICE,       
        GET_LAST_SNAPSHOTS_BY_BACKUP,       
        GET_LAST_SNAPSHOTS_BY_ACCOUNT,      
        CREATE_INBOX,               
        SET_INBOX_INFO,             
        GET_INBOX_INFO,             
        LOGIN_LINK,                 
        SET_RECORD_INFO,            
        UPLOAD_TO_RECORD,           
        REMOVE_FROM_RECORD,         
        GET_RECORD_INFO,            
        SET_RECORD_STATUS,          
        SUBSCRIPTION_OPTIONS,       
        PAYMENT_INFO,               
        REMOVE_PAYMENT_METHOD,      
        SET_INVOICING_ADDRESS,      
        INVOICING_INFO,             
        GET_INVOICE,                
        SESSION_INFO,               
        LOGOUT_LINK,                
        CRASH_REPORT,               
        UPDATE,                     
        LOGOUT,                     
        CURRENT_EMAIL,              
        NEW_SESSION,                
        DESTROY,                    
        REFERRALS_INFO,             
        BALANCES_INFO,              
        COUPONS,                    
        ADD_PAYMENT_METHOD,         
        JOIN_LINK,                  
        DEFAULT_ACCOUNT,            
        REVOKE_ACCOUNT_ACCESS,      
        MANAGE_SECRETS,             
        MANAGE_CONTACTS,            
        MANAGE_OUTBOXES,            
        MANAGE_SENT_RECORDS,        
        GET_NODE_TREE,              
        SET_ACCOUNT_VALUE,          
        DELETE_ACCOUNT,             
        SET_ACCESS_LEVEL,           
        MANAGE_SHARED_DRIVES,       
        DELETE_LINK,                
        MANAGE_MEETINGS,            
        MANAGE_NODE_TAG,            
        GET_COMMANDS_LOG,           
        VERIFY_HASH,                
        NOTICE_CREDENTIALS,         
        MANAGE_FOLDER_SYNC,        
        LAST,
    };

    enum Manage2faOperation
    {
        GENERATE_2FA = 1,
        ENABLE_2FA = 2,
        DISABLE_2FA = 3
    };

    static const char *getTypeName(unsigned type)
    {
        static const char *sActionNames[] =
        {
            "TEST",
            "ADD_CONTACT",
            "VERIFY_EMAIL",
            "FORGOT_PASSWORD",
            "CREATE_ACCOUNT",
            "CHANGE_PASSWORD",
            "RECOVERY_KEY",
            "MANAGE_2FA",
            "LOGIN",
            "GET_NODES",
            "GET_ROOT",
            "GET_CHILDREN",
            "GET_NODE",
            "GET_PATH",
            "ADD_NODES",
            "DELETE_NODE",
            "RENAME_NODE",
            "MOVE_NODE",
            "COPY_NODE",
            "CREATE_LINK",
            "GET_LINK_INFO",
            "USER_INFO",
            "ACCOUNT_INFO",
            "LOG_EVENT",
            "TEST_PROXY",
            "SET_PROXY",
            "UPLOAD",
            "DOWNLOAD",
            "DOWNLOAD_ZIP",
            "STREAM",
            "BACKUP",
            "UPLOAD_METADATA",
            "DOWNLOAD_METADATA",
            "GET_TRANSFERS",
            "CLEAR_FINISHED_TRANSFERS",
            "CANCEL_TRANSFERS",
            "SET_TRANSFER_SPEED_LIMIT",
            "GET_TRANSFER_SPEED_LIMIT",
            "REGISTER_DEVICE",
            "SELECT_DEVICE",
            "GET_CURRENT_DEVICE",
            "GET_DEVICE",
            "GET_DEVICES",
            "RENAME_DEVICE",
            "DELETE_DEVICE",
            "GET_BACKUP",
            "GET_BACKUPS",
            "CREATE_BACKUP",
            "MODIFY_BACKUP",
            "RENAME_BACKUP",
            "CHANGE_BACKUP_SCHEDULE",
            "CHANGE_BACKUP_PATH",
            "CHANGE_BACKUP_STATUS",
            "DELETE_BACKUP",
            "AUTHORIZE_BACKUP",
            "GET_SNAPSHOTS",
            "GET_NEXT_SNAPSHOTS",
            "GET_NEXT_SNAPSHOTS_BY_DEVICE",
            "GET_NEXT_SNAPSHOTS_BY_BACKUP",
            "GET_NEXT_SNAPSHOTS_BY_ACCOUNT",
            "GET_NEXT_SNAPSHOTS_BY_SCHEDULE",
            "GET_LAST_SNAPSHOTS",
            "GET_LAST_SNAPSHOTS_BY_DEVICE",
            "GET_LAST_SNAPSHOTS_BY_BACKUP",
            "GET_LAST_SNAPSHOTS_BY_ACCOUNT",
            "CREATE_INBOX",
            "SET_INBOX_INFO",
            "GET_INBOX_INFO",
            "LOGIN_LINK",
            "SET_RECORD_INFO",
            "UPLOAD_TO_RECORD",
            "REMOVE_FROM_RECORD",
            "GET_RECORD_INFO",
            "SET_RECORD_STATUS",
            "SUBSCRIPTION_OPTIONS",
            "PAYMENT_INFO",
            "REMOVE_PAYMENT_METHOD",
            "SET_INVOICING_ADDRESS",
            "INVOICING_INFO",
            "GET_INVOICE",
            "SESSION_INFO",
            "LOGOUT_LINK",
            "CRASH_REPORT",
            "UPDATE",
            "LOGOUT",
            "CURRENT_EMAIL",
            "NEW_SESSION",
            "DESTROY",
            "REFERRALS_INFO",
            "BALANCES_INFO",
            "COUPONS",
            "ADD_PAYMENT_METHOD",
            "JOIN_LINK",
            "DEFAULT_ACCOUNT",
            "REVOKE_ACCOUNT_ACCESS",
            "MANAGE_SECRETS",
            "MANAGE_CONTACTS",
            "MANAGE_OUTBOXES",
            "MANAGE_SENT_RECORDS",
            "GET_NODE_TREE",
            "SET_ACCOUNT_VALUE",
            "DELETE_ACCOUNT",
            "SET_ACCESS_LEVEL",
            "MANAGE_SHARED_DRIVES",
            "DELETE_LINK",
            "MANAGE_MEETINGS",
            "MANAGE_NODE_TAG",
            "GET_COMMANDS_LOG",
            "VERIFY_HASH",
            "NOTICE_CREDENTIALS",
            "MANAGE_FOLDER_SYNC",
        };
        static_assert((sizeof(sActionNames) / sizeof(sActionNames[0]) == ActionData::LAST), "Invalid number of action names");
        return type < ActionData::LAST ? sActionNames[type] : "INVALID";
    }

    static const std::string getTypeNameString(unsigned type)
    {
        return getTypeName(type);
    }

    virtual ~ActionData();

    int getLocalTag() const;
    int getType() const;
    int getTag() const;
    const char *getActionName() const;
    const std::string getActionNameString() const;
    const char *getEmail() const;
    const std::string getEmailString() const;
    const char *getPassword() const;
    const std::string getPasswordString() const;
    const char *getText() const;
    const std::string getTextString() const;
    const char *getSession() const;
    const std::string getSessionString() const;
    const char *getName() const;
    const std::string getNameString() const;
    const char *getLastName() const;
    const std::string getLastNameString() const;
    const char *getLink() const;
    const std::string getLinkString() const;
    bool isProcessed() const;
    bool isFinished() const;

    int getIntValue() const;
    int getStatus() const;
    long getLongValue() const;
    uint64_t getTotalSize() const;
    uint64_t getCompletedSize() const;
    uint64_t getAccountId() const;
    NodeHandle getAccountHandle() const;
    const std::string getAccountStringHandle() const;
    uint64_t getUserId() const;
    Node getNode() const;
    NodeList getNodeList() const;
    Transfer getTransfer() const;
    uint64_t getNodeId() const;
    NodeHandle getNodeHandle() const;
    uint64_t getParentId() const;
    NumberList getNumberList() const;
    StringList getStringList() const;
    TransferList getTransferList() const;
    ActionList getActionList() const;
    SubscriptionInfoList getSubscriptionInfoList() const;
    PaymentInfo getPaymentInfo() const;
    AccountInfo getAccountInfo() const;
    UserInfo getUserInfo() const;
    InvoicingInfo getInvoicingInfo() const;
    SessionInfoList getActiveSessions() const;
    SessionInfoList getInactiveSessions() const;
    BalancesInfo getBalancesInfo() const;
    CouponInfoList getCoupons() const;
    CouponInfo getCoupon() const;
    PermissionInfoList getAccountPermissions() const;
    PermissionInfoList getUserPermissions() const;
    CommandLogList getLog() const;
    std::vector<uint8_t> *getData();
    int getErrorType() const;
    const char *getErrorName() const;
    const std::string getErrorNameString() const;

    const std::string getCustomData() const;

#ifndef USE_SCAPIX

    Error getError() const;
#endif

#ifndef EMSCRIPTEN
protected:
#endif

    ActionData(int type);

    int mLocalTag;
    int mType;
    int mTag;
    char *mEmail;
    char *mPassword;
    char *mText;
    char *mSession;
    char *mName;
    char *mLastName;
    char *mLink;
    bool mFinished;
    bool mProcessed;
    Error mError;

    int mIntValue;
    int mStatus;
    long mLongValue;
    uint64_t mTotalSize;
    uint64_t mCompletedSize;
    uint64_t mAccountId;
    std::string mAccountHandle;
    uint64_t mUserId;
    std::string mUserHandle;

    Node mNode;
    NodeList mNodeList;
    uint64_t mNodeId;
    uint64_t mParentId;
    std::string mNodeHandle;
    std::string mParentHandle;
    Transfer mTransfer;
    std::vector<uint8_t> mData;

    NumberList mNumberList;
    StringList mStringList;
    TransferList mTransferList;
    ActionList mActionList;
    SubscriptionInfoList mSubscriptionInfoList;
    PaymentInfo mPaymentInfo;
    AccountInfo mAccountInfo;
    UserInfo mUserInfo;
    InvoicingInfo mInvoicingInfo;
    SessionInfoList mActiveSessionInfoList;
    SessionInfoList mInactiveSessionInfoList;
    BalancesInfo mBalancesInfo;
    CouponInfo mCouponInfo;
    CouponInfoList mCouponInfoList;
    PermissionInfoList mAccountPermissionInfoList;
    PermissionInfoList mUserPermissionInfoList;
    CommandLogList mCommandLogList;
    std::string mCustomData;
};

class ActionListener : public SharedOwnership
#ifdef USE_SCAPIX
    , public scapix::bridge::object<ActionListener>
#endif
{
public:
    ActionListener();
    ActionListener(std::function<void(Action)> finishCallback);
    ActionListener(std::function<void(Action)> progressCallback, std::function<void(Action)> finishCallback);
    ActionListener(std::function<void(Action)> errorCallback, std::function<void(Action)> progressCallback, std::function<void(Action)> finishCallback);
    ActionListener(std::function<void(Action)> startCallback, std::function<void(Action)> errorCallback, std::function<void(Action)> progressCallback, std::function<void(Action)> finishCallback);

    virtual ~ActionListener();

    void setStartCallback(std::function<void(Action)> startCallback);
    void setErrorCallback(std::function<void(Action)> errorCallback);
    void setProgressCallback(std::function<void(Action)> progressCallback);
    void setFinishCallback(std::function<void(Action)> finishCallback);

    virtual void onActionStart(Action action);
    virtual void onActionProcessed(Action action);
    virtual void onActionProgress(Action action);
    virtual void onActionError(Action action);
    virtual void onActionFinish(Action action);

protected:
    std::function<void(Action)> mStartCallback;
    std::function<void(Action)> mProgressCallback;
    std::function<void(Action)> mFinishCallback;
    std::function<void(Action)> mErrorCallback;
};

class BlockingActionListener : public ActionListener
{
public:
    BlockingActionListener();
    virtual ~BlockingActionListener() override;

    virtual void onActionFinish(Action action) override;
    virtual void onActionProgress(Action action) override;
    virtual void setOwnership(bool external_or_cpp) override;
    Action getResult();

protected:
    Action mAction;
    bool mOwnMemory;

#ifndef EMSCRIPTEN
    std::condition_variable mConditionVariable;
    std::mutex mMutex;
#endif
};

#ifdef USE_SCAPIX
typedef std::shared_ptr<ActionListener> ActionListenerType;
#else
typedef ActionListener* ActionListenerType;
#endif

}

#define MODIFY_ATTRIBUTES(NodeVarName) \
    mApiManager->mCloudCache->encryptNode(NodeVarName, [this, action, NodeVarName](EncryptedNode encryptedNode)         \
    {                                                                                                                   \
        action->setEncryptedAttributes(new std::vector<uint8_t>(*encryptedNode->getEncryptedAttributes()));             \
        action->setNode(NodeVarName);                                                                                   \
        action->setIntValue(NodeVarName->getExtraNumber());                                                             \
        notifyProcessed(action);                                                                                        \
        mApiManager->processApiRequest(std::make_shared<RenameNodeRequest>(action, mApiManager->getClientId()), this);  \
    });                                                                                                                 \

#endif // ACTION_H