aboutsummaryrefslogtreecommitdiff
path: root/mod/ci-common.cxx
diff options
context:
space:
mode:
authorKaren Arutyunov <karen@codesynthesis.com>2024-05-22 19:34:06 +0300
committerKaren Arutyunov <karen@codesynthesis.com>2024-05-23 15:40:29 +0300
commit1dfc20c02d3b1076570a7146581799eab0773d6d (patch)
tree3d08ca9a4ccb69393dc365b0e96563f8d42b93be /mod/ci-common.cxx
parent3d7f248ee7aa7e5b470cb9bc2fcf76852e798db5 (diff)
Replace ci_start::abandon() with ci_start::cancel()
Diffstat (limited to 'mod/ci-common.cxx')
-rw-r--r--mod/ci-common.cxx50
1 files changed, 18 insertions, 32 deletions
diff --git a/mod/ci-common.cxx b/mod/ci-common.cxx
index 6ce47f2..7c41a7b 100644
--- a/mod/ci-common.cxx
+++ b/mod/ci-common.cxx
@@ -685,12 +685,13 @@ namespace brep
return r;
}
- void ci_start::
- abandon (const basic_mark& error,
- const basic_mark&,
- const basic_mark* trace,
- odb::core::database& db,
- tenant_service&& service) const
+ optional<tenant_service> ci_start::
+ cancel (const basic_mark&,
+ const basic_mark&,
+ const basic_mark* trace,
+ odb::core::database& db,
+ const string& type,
+ const string& id) const
{
using namespace odb::core;
@@ -701,37 +702,22 @@ namespace brep
using query = query<build_tenant>;
shared_ptr<build_tenant> t (
- db.query_one<build_tenant> (query::service.id == service.id &&
- query::service.type == service.type));
-
+ db.query_one<build_tenant> (query::service.id == id &&
+ query::service.type == type));
if (t == nullptr)
- {
- error << "unable to find tenant for service " << service.id << ' '
- << service.type;
-
- return;
- }
- else if (!t->unloaded_timestamp)
- {
- error << "tenant " << t->id << " for service " << service.id << ' '
- << service.type << " is already loaded";
+ return nullopt;
- return;
- }
-
- // We could probably remove the tenant from the database, but let's just
- // archive it and keep for troubleshooting.
- //
- if (!t->archived)
- {
- t->archived = true;
- db.update (t);
- }
+ optional<tenant_service> r (move (t->service));
+ t->service = nullopt;
+ t->archived = true;
+ db.update (t);
tr.commit ();
if (trace != nullptr)
- *trace << "unloaded CI request " << t->id << " for service "
- << service.id << ' ' << service.type << " is abandoned";
+ *trace << "CI request " << t->id << " for service " << id << ' ' << type
+ << " is canceled";
+
+ return r;
}
}