task.hpp 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248
  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. auto index = _value.index();
  86. name = n;
  87. type = t;
  88. value = _value;
  89. }
  90. /**
  91. * Move Constructor
  92. *
  93. * @constructor
  94. * @param [in] {TaskArgument&&} a The R-value reference to a TaskArgument
  95. */
  96. TaskArgument(TaskArgument&& a) :
  97. name(std::move(a.name)), type(std::move(a.type)), value(std::move(a.value)) {}
  98. /**
  99. * text
  100. * @returns {QString} The name of the argument
  101. */
  102. virtual const QString text() override { return name; }
  103. /**
  104. * setValue
  105. * @param [in] {TypeVariant} new_value The new value for this argument
  106. */
  107. virtual void setValue(TypeVariant new_value) override { value = new_value; }
  108. /**
  109. * @brief getStringValue
  110. * @return [out] {QString}
  111. */
  112. virtual const QString getStringValue() override {
  113. if (isIndex(value.index(), VariantIndex::QSTRING)) {
  114. return std::get<VariantIndex::QSTRING>(value);
  115. } else if (isIndex(value.index(), VariantIndex::BOOLEAN)) {
  116. return QString::number(std::get<VariantIndex::BOOLEAN>(value));
  117. } else if (isIndex(value.index(), VariantIndex::INTEGER)) {
  118. return QString::number(std::get<VariantIndex::INTEGER>(value));
  119. }
  120. return "";
  121. }
  122. /**
  123. * @brief getValue
  124. * @return [out] {TypeVariant}
  125. */
  126. virtual TypeVariant getValue() override {
  127. size_t index = value.index();
  128. bool equivalence = index == VariantIndex::STRVEC;
  129. if (isIndex(value.index(), VariantIndex::QSTRING)) {
  130. return std::get<VariantIndex::QSTRING>(value);
  131. } else if (isIndex(value.index(), VariantIndex::BOOLEAN)) {
  132. return std::get<VariantIndex::BOOLEAN>(value);
  133. } else if (isIndex(value.index(), VariantIndex::INTEGER)) {
  134. return std::get<VariantIndex::INTEGER>(value);
  135. } else if (isIndex(value.index(), VariantIndex::STRVEC)) {
  136. return std::get<VariantIndex::STRVEC>(value);
  137. } else if (isIndex(value.index(), VariantIndex::FILEVEC)) {
  138. return std::get<VariantIndex::FILEVEC>(value);
  139. }
  140. }
  141. /**
  142. * @brief clear
  143. */
  144. virtual void clear() override {
  145. if (isIndex(value.index(), VariantIndex::STRVEC)) {
  146. std::get<VariantIndex::STRVEC>(value).clear();
  147. } else if (isIndex(value.index(), VariantIndex::FILEVEC)) {
  148. std::get<VariantIndex::FILEVEC>(value).clear();
  149. } else if (isIndex(value.index(), VariantIndex::QSTRING)) {
  150. std::get<VariantIndex::QSTRING>(value).clear();
  151. } else if (isIndex(value.index(), VariantIndex::INTEGER)) {
  152. std::get<VariantIndex::INTEGER>(value) = 0;
  153. } else if (isIndex(value.index(), VariantIndex::BOOLEAN)) {
  154. std::get<VariantIndex::BOOLEAN>(value) = false;
  155. }
  156. }
  157. /**
  158. * @brief isContainer
  159. * @return [out] {bool}
  160. */
  161. virtual bool isContainer() override {
  162. return (isIndex(value.index(), VariantIndex::STRVEC) || isIndex(value.index(), VariantIndex::FILEVEC));
  163. }
  164. /**
  165. * @brief insert
  166. * @param value
  167. */
  168. virtual void insert(QString string) override {
  169. if (isIndex(value.index(), VariantIndex::STRVEC)) {
  170. std::get<VariantIndex::STRVEC>(value).push_back(string);
  171. } else {
  172. // Unable to push. Throw?
  173. }
  174. }
  175. /**
  176. * @brief insert
  177. * @param file
  178. */
  179. virtual void insert(KFileData file) override {
  180. if (value.index() == VariantIndex::FILEVEC) {
  181. std::get<VariantIndex::FILEVEC>(value).push_back(file);
  182. } else {
  183. // Unable to push. Throw?
  184. }
  185. }
  186. /**
  187. * @brief getTypeIndex
  188. * @return
  189. */
  190. virtual uint8_t getTypeIndex() override {
  191. return value.index();
  192. }
  193. private:
  194. QString name;
  195. ArgumentType type;
  196. TypeVariant value;
  197. };
  198. using TaskArguments = std::vector<std::unique_ptr<TaskArgument>>;
  199. /**
  200. * The interface expected to be implemented in all Task types
  201. */
  202. class Task {
  203. public:
  204. Task(){};
  205. Task(KFileData);
  206. Task(QVector<KFileData>);
  207. virtual void setArgument(QString name, TypeVariant arg) = 0;
  208. virtual void addArgument(QString name, Scheduler::KFileData file) = 0;
  209. virtual void addArgument(QString name, QString string) = 0;
  210. virtual const TaskArguments getTaskArguments() = 0;
  211. virtual const TypeVariant getTaskArgument(QString name) = 0;
  212. virtual ArgumentValues getArgumentValues() = 0;
  213. virtual TaskType getType() = 0;
  214. virtual void defineTaskArguments() = 0;
  215. virtual void setDefaultValues() = 0;
  216. virtual const QVector<KFileData> getFiles() = 0;
  217. virtual bool hasFiles() = 0;
  218. virtual bool isReady() = 0;
  219. virtual void clear() = 0;
  220. virtual ~Task(){};
  221. };
  222. } // namespace Scheduler
  223. #endif // __TASK_HPP__