Add support for tenant-associated service notifications

1 files changed, 96 insertions, 0 deletions

diff --git a/mod/ci-common.hxx b/mod/ci-common.hxx
new file mode 100644
index 0000000..6f62c4b
--- /dev/null
+++ b/mod/ci-common.hxx
@@ -0,0 +1,96 @@
+// file      : mod/ci-common.hxx -*- C++ -*-
+// license   : MIT; see accompanying LICENSE file
+
+#ifndef MOD_CI_COMMON_HXX
+#define MOD_CI_COMMON_HXX
+
+#include <odb/forward.hxx> // database
+
+#include <libbrep/types.hxx>
+#include <libbrep/utility.hxx>
+
+#include <libbrep/common.hxx>
+
+#include <mod/diagnostics.hxx>
+#include <mod/module-options.hxx>
+
+namespace brep
+{
+  class ci_start
+  {
+  public:
+    void
+    init (shared_ptr<options::ci_start>);
+
+    // If the request handling has been performed normally, then return the
+    // information that corresponds to the CI result manifest (see CI Result
+    // Manifest in the manual). Otherwise (some internal has error occured),
+    // log the error and return nullopt.
+    //
+    // The arguments correspond to the CI request and overrides manifest
+    // values (see CI Request and Overrides Manifests in the manual). Note:
+    // request id and timestamp are generated by the implementation.
+    //
+    struct package
+    {
+      package_name name;
+      optional<brep::version> version;
+    };
+    // Note that the inability to generate the reference is an internal
+    // error. Thus, it is not optional.
+    //
+    struct start_result
+    {
+      uint16_t status;
+      string message;
+      string reference;
+      vector<pair<string, string>> custom_result;
+    };
+
+    // In the optional service information, if id is empty, then the generated
+    // reference is used instead.
+    //
+    optional<start_result>
+    start (const basic_mark& error,
+           const basic_mark& warn,
+           const basic_mark* trace,
+           optional<tenant_service>&&,
+           const repository_location& repository,
+           const vector<package>& packages,
+           const optional<string>& client_ip,
+           const optional<string>& user_agent,
+           const optional<string>& interactive = nullopt,
+           const optional<string>& simulate = nullopt,
+           const vector<pair<string, string>>& custom_request = {},
+           const vector<pair<string, string>>& overrides = {});
+
+    // Helpers.
+    //
+
+    // Serialize the start result as a CI result manifest.
+    //
+    static void
+    serialize_manifest (const start_result&, ostream&, bool long_lines = false);
+
+  private:
+    shared_ptr<options::ci_start> options_;
+  };
+
+  class ci_cancel
+  {
+  public:
+    void
+    init (shared_ptr<options::ci_cancel>, shared_ptr<odb::core::database>);
+
+    // @@ TODO Archive the tenant.
+    //
+    void
+    cancel (/*...*/);
+
+  private:
+    shared_ptr<options::ci_cancel> options_;
+    shared_ptr<odb::core::database> build_db_;
+  };
+}
+
+#endif // MOD_CI_COMMON_HXX