1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
/** \file CopyListener.h
\brief Define the class to load the plugin and lunch it
\author alpha_one_x86
\licence GPL3, see the file COPYING */
#ifndef COPYLISTENER_H
#define COPYLISTENER_H
#include <QObject>
#include <QList>
#ifndef ULTRACOPIER_PLUGIN_ALL_IN_ONE_DIRECT
#include <QPluginLoader>
#endif
#include "interface/PluginInterface_Listener.h"
#include "Environment.h"
#include "PluginLoaderCore.h"
#include "OptionDialog.h"
/** \brief to load all the listener and parse all event */
class CopyListener : public QObject
{
Q_OBJECT
public:
explicit CopyListener(OptionDialog *optionDialog);
~CopyListener();
/** \brief send of one listener is loaded */
bool oneListenerIsLoaded();
/** \brief to resend the state */
void resendState();
private slots:
//void newPlugin();
void newPluginCopyWithoutDestination(const uint32_t &orderId,const std::vector<std::string> &sources);
void newPluginCopy(const uint32_t &orderId,const std::vector<std::string> &sources,const std::string &destination);
void newPluginMoveWithoutDestination(const uint32_t &orderId,const std::vector<std::string> &sources);
void newPluginMove(const uint32_t &orderId,const std::vector<std::string> &sources,const std::string &destination);
void onePluginAdded(const PluginsAvailable &plugin);
#ifndef ULTRACOPIER_PLUGIN_ALL_IN_ONE
void onePluginWillBeRemoved(const PluginsAvailable &plugin);
#endif
void newState(const Ultracopier::ListeningState &state);
#ifdef ULTRACOPIER_DEBUG
void debugInformation(const Ultracopier::DebugLevel &level,const std::string& fonction,const std::string& text,const std::string& file,const int& ligne);
#endif // ULTRACOPIER_DEBUG
void error(const std::string &error);
void allPluginIsloaded();
void reloadClientList();
public slots:
/** \brief the copy is finished
\param orderId id used when it have send the copy
\param withError true if it have found error
\see newCopy()
\see newMove()
*/
void copyFinished(const uint32_t & orderId,const bool &withError);
/** \brief the copy is canceled by the user
\param orderId id used when it have send the copy
\see newCopy()
\see newMove()
*/
void copyCanceled(const uint32_t & orderId);
/** \brief try listen, to get copy/move from external source (mainly the file manager)
\see close()
*/
void listen();
/** \brief stop listen, to get copy/move from external source (mainly the file manager)
\see listen()
*/
void close();
/** new copy without destination have been pased by the CLI */
void copyWithoutDestination(std::vector<std::string> sources);
/** new copy with destination have been pased by the CLI */
void copy(std::vector<std::string> sources,std::string destination);
/** new move without destination have been pased by the CLI */
void moveWithoutDestination(std::vector<std::string> sources);
/** new move with destination have been pased by the CLI */
void move(std::vector<std::string> sources,std::string destination);
signals:
void newCopyWithoutDestination(const uint32_t &orderId,const std::vector<std::string> &protocolsUsedForTheSources,const std::vector<std::string> &sources) const;
void newCopy(const uint32_t &orderId,const std::vector<std::string> &protocolsUsedForTheSources,const std::vector<std::string> &sources,const std::string &protocolsUsedForTheDestination,const std::string &destination) const;
void newMoveWithoutDestination(const uint32_t &orderId,const std::vector<std::string> &protocolsUsedForTheSources,const std::vector<std::string> &sources) const;
void newMove(const uint32_t &orderId,const std::vector<std::string> &protocolsUsedForTheSources,const std::vector<std::string> &sources,const std::string &protocolsUsedForTheDestination,const std::string &destination) const;
void listenerReady(const Ultracopier::ListeningState &state,const bool &havePlugin,const bool &someAreInWaitOfReply) const;
void pluginLoaderReady(const Ultracopier::CatchState &state,const bool &havePlugin,const bool &someAreInWaitOfReply) const;
void previouslyPluginAdded(const PluginsAvailable &) const;
void newClientList(const std::vector<std::string> &clientsList) const;
private:
struct PluginListener
{
PluginInterface_Listener *listenInterface;
#ifndef ULTRACOPIER_PLUGIN_ALL_IN_ONE_DIRECT
QPluginLoader *pluginLoader;
#endif
std::string path;
Ultracopier::ListeningState state;
bool inWaitOfReply;
LocalPluginOptions *options;
};
std::vector<PluginListener> pluginList;
//for the options
uint32_t nextOrderId;
std::vector<uint32_t> orderList;
//for the copy as suspend
struct CopyRunning
{
PluginInterface_Listener *listenInterface;
uint32_t pluginOrderId;
uint32_t orderId;
};
std::vector<CopyRunning> copyRunningList;
uint32_t incrementOrderId();
bool tryListen;
PluginLoaderCore *pluginLoader;
Ultracopier::ListeningState last_state;
bool last_have_plugin,last_inWaitOfReply;
void sendState(bool force=false);
std::vector<std::string> stripSeparator(std::vector<std::string> sources);
OptionDialog *optionDialog;
bool stopIt;
std::regex stripSeparatorRegex;
};
#endif // COPYLISTENER_H
|
