task.hpp 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247
  1. #ifndef __TASK_HPP__
  2. #define __TASK_HPP__
  3. #include <QQueue>
  4. #include <QString>
  5. #include <QVector>
  6. #include <memory>
  7. #include <variant>
  8. #include <vector>
  9. namespace Scheduler {
  10. enum TaskType { INSTAGRAM = 1, OTHER = 2 };
  11. /**
  12. * Files
  13. */
  14. enum FileType { VIDEO = 1, IMAGE = 2 };
  15. /**
  16. * KFileData
  17. *
  18. * Structure for holding file bytes and metadata
  19. */
  20. struct KFileData {
  21. QString name;
  22. FileType type;
  23. QString path;
  24. QByteArray bytes;
  25. };
  26. /**
  27. * Type namespace
  28. *
  29. * Describes the types of task arguments available for use
  30. */
  31. namespace Type {
  32. static constexpr const char* TEXT = "Text";
  33. static constexpr const char* FILE = "File";
  34. static constexpr const char* STRINGVECTOR = "StringVector";
  35. static constexpr const char* FILEVECTOR = "FileVector";
  36. static constexpr const char* DATETIME = "DateTime";
  37. static constexpr const char* BOOLEAN = "Boolean";
  38. static constexpr const char* INTEGER = "Integer";
  39. } // namespace Type
  40. namespace VariantIndex {
  41. static const uint8_t BOOLEAN = 0;
  42. static const uint8_t INTEGER = 1;
  43. static const uint8_t STRVEC = 2;
  44. static const uint8_t QSTRING = 3;
  45. static const uint8_t FILEVEC = 4;
  46. } // namespace VariantIndex
  47. inline bool isIndex(uint8_t v, uint8_t i) { return v == i; }
  48. /**
  49. * Forward Declarations
  50. */
  51. class TaskArgumentBase;
  52. class Task;
  53. /**
  54. * Aliases
  55. */
  56. using TaskQueue = QQueue<Task*>;
  57. using ArgumentType = const char*;
  58. using ArgumentValues = QVector<QString>;
  59. using TypeVariant = std::variant<bool, int, QVector<QString>, QString, QVector<KFileData>>;
  60. using TaskIterator = std::vector<std::unique_ptr<TaskArgumentBase>>::iterator;
  61. /**
  62. * The interface expected on our Task Arguments
  63. */
  64. class TaskArgumentBase {
  65. public:
  66. virtual const QString text() = 0;
  67. virtual const QString getStringValue() = 0;
  68. virtual uint8_t getTypeIndex() = 0;
  69. virtual TypeVariant getValue() = 0;
  70. virtual void insert(QString value) = 0;
  71. virtual void insert(KFileData file) = 0;
  72. virtual void setValue(TypeVariant v) = 0;
  73. virtual bool isContainer() = 0;
  74. virtual void clear() = 0;
  75. };
  76. /**
  77. * TaskArgument
  78. *
  79. * A templated class providing a generic way for handling arguments whose types can be one from the set defined
  80. * by our TypeVariant alias
  81. */
  82. class TaskArgument : TaskArgumentBase {
  83. public:
  84. TaskArgument(QString n, ArgumentType t, TypeVariant _value) {
  85. name = n;
  86. type = t;
  87. value = _value;
  88. }
  89. /**
  90. * Move Constructor
  91. *
  92. * @constructor
  93. * @param [in] {TaskArgument&&} a The R-value reference to a TaskArgument
  94. */
  95. TaskArgument(TaskArgument&& a) :
  96. name(std::move(a.name)), type(std::move(a.type)), value(std::move(a.value)) {}
  97. /**
  98. * text
  99. * @returns {QString} The name of the argument
  100. */
  101. virtual const QString text() override { return name; }
  102. /**
  103. * setValue
  104. * @param [in] {TypeVariant} new_value The new value for this argument
  105. */
  106. virtual void setValue(TypeVariant new_value) override { value = new_value; }
  107. /**
  108. * @brief getStringValue
  109. * @return [out] {QString}
  110. */
  111. virtual const QString getStringValue() override {
  112. if (isIndex(value.index(), VariantIndex::QSTRING)) {
  113. return std::get<VariantIndex::QSTRING>(value);
  114. } else if (isIndex(value.index(), VariantIndex::BOOLEAN)) {
  115. return QString::number(std::get<VariantIndex::BOOLEAN>(value));
  116. } else if (isIndex(value.index(), VariantIndex::INTEGER)) {
  117. return QString::number(std::get<VariantIndex::INTEGER>(value));
  118. }
  119. return ""; // Throw?
  120. }
  121. /**
  122. * @brief getValue
  123. * @return [out] {TypeVariant}
  124. */
  125. virtual TypeVariant getValue() override {
  126. if (isIndex(value.index(), VariantIndex::QSTRING)) {
  127. return std::get<VariantIndex::QSTRING>(value);
  128. } else if (isIndex(value.index(), VariantIndex::BOOLEAN)) {
  129. return std::get<VariantIndex::BOOLEAN>(value);
  130. } else if (isIndex(value.index(), VariantIndex::INTEGER)) {
  131. return std::get<VariantIndex::INTEGER>(value);
  132. } else if (isIndex(value.index(), VariantIndex::STRVEC)) {
  133. return std::get<VariantIndex::STRVEC>(value);
  134. } else if (isIndex(value.index(), VariantIndex::FILEVEC)) {
  135. return std::get<VariantIndex::FILEVEC>(value);
  136. }
  137. return ""; // Throw?
  138. }
  139. /**
  140. * @brief clear
  141. */
  142. virtual void clear() override {
  143. if (isIndex(value.index(), VariantIndex::STRVEC)) {
  144. std::get<VariantIndex::STRVEC>(value).clear();
  145. } else if (isIndex(value.index(), VariantIndex::FILEVEC)) {
  146. std::get<VariantIndex::FILEVEC>(value).clear();
  147. } else if (isIndex(value.index(), VariantIndex::QSTRING)) {
  148. std::get<VariantIndex::QSTRING>(value).clear();
  149. } else if (isIndex(value.index(), VariantIndex::INTEGER)) {
  150. std::get<VariantIndex::INTEGER>(value) = 0;
  151. } else if (isIndex(value.index(), VariantIndex::BOOLEAN)) {
  152. std::get<VariantIndex::BOOLEAN>(value) = false;
  153. }
  154. }
  155. /**
  156. * @brief isContainer
  157. * @return [out] {bool}
  158. */
  159. virtual bool isContainer() override {
  160. return (isIndex(value.index(), VariantIndex::STRVEC) || isIndex(value.index(), VariantIndex::FILEVEC));
  161. }
  162. /**
  163. * @brief insert
  164. * @param value
  165. */
  166. virtual void insert(QString string) override {
  167. if (isIndex(value.index(), VariantIndex::STRVEC)) {
  168. std::get<VariantIndex::STRVEC>(value).push_back(string);
  169. } else {
  170. // Unable to push. Throw?
  171. }
  172. }
  173. /**
  174. * @brief insert
  175. * @param file
  176. */
  177. virtual void insert(KFileData file) override {
  178. if (value.index() == VariantIndex::FILEVEC) {
  179. std::get<VariantIndex::FILEVEC>(value).push_back(file);
  180. } else {
  181. // Unable to push. Throw?
  182. }
  183. }
  184. /**
  185. * @brief getTypeIndex
  186. * @return
  187. */
  188. virtual uint8_t getTypeIndex() override {
  189. return value.index();
  190. }
  191. private:
  192. QString name;
  193. ArgumentType type;
  194. TypeVariant value;
  195. };
  196. using TaskArguments = std::vector<std::unique_ptr<TaskArgument>>;
  197. /**
  198. * The interface expected to be implemented in all Task types
  199. */
  200. class Task {
  201. public:
  202. Task(){};
  203. Task(KFileData);
  204. Task(QVector<KFileData>);
  205. virtual void setArgument(QString name, TypeVariant arg) = 0;
  206. virtual void addArgument(QString name, Scheduler::KFileData file) = 0;
  207. virtual void addArgument(QString name, QString string) = 0;
  208. virtual const TaskArguments&& getTaskArguments() = 0;
  209. virtual const TypeVariant getTaskArgument(QString name) = 0;
  210. virtual ArgumentValues getArgumentValues() = 0;
  211. virtual QVector<QString> getArgumentNames() = 0;
  212. virtual TaskType getType() = 0;
  213. virtual void defineTaskArguments() = 0;
  214. virtual void setDefaultValues() = 0;
  215. virtual const QVector<KFileData> getFiles() = 0;
  216. virtual bool hasFiles() = 0;
  217. virtual bool isReady() = 0;
  218. virtual void clear() = 0;
  219. virtual ~Task(){};
  220. };
  221. } // namespace Scheduler
  222. #endif // __TASK_HPP__