rad:zwTxygwuz5LDGBq255RA2CbNGrz8 radicle-ci-broker07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870{
"request": "trigger",
"version": 1,
"event_type": "push",
"repository": {
"id": "rad:zwTxygwuz5LDGBq255RA2CbNGrz8",
"name": "radicle-ci-broker",
"description": "Radicle CI broker",
"private": false,
"default_branch": "main",
"delegates": [
"did:key:z6MkgEMYod7Hxfy9qCvDv5hYHkZ4ciWmLFgfvm3Wn1b2w2FV",
"did:key:z6MksFqXN3Yhqk8pTJdUGLwATkRfQvwZXPqR2qMEhbS9wzpT"
]
},
"pusher": {
"id": "did:key:z6MkgEMYod7Hxfy9qCvDv5hYHkZ4ciWmLFgfvm3Wn1b2w2FV",
"alias": "liw"
},
"before": "2a40a12a9def72594cbab2ce783cae949619e5e5",
"after": "07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870",
"branch": "main",
"commits": [
"07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870"
]
}.radicle/native.yamlshell: | cargo --version rustc --version cargo fmt --check cargo clippy --all-targets --workspace -- -Dwarnings cargo build --all-targets --workspace cargo doc --workspace cargo test --workspace --no-fail-fast subplot docgen ci-broker.subplot -o doc/ci-broker.html make -C doc publish
git clone /home/_rad/.radicle/storage/zwTxygwuz5LDGBq255RA2CbNGrz8 /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/srcgit config advice.detachedHead falsegit checkout 07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870git show 07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870timeout 600 bash -c set -xeuo pipefail
cargo --version
rustc --version
cargo fmt --check
cargo clippy --all-targets --workspace -- -Dwarnings
cargo build --all-targets --workspace
cargo doc --workspace
cargo test --workspace --no-fail-fast
subplot docgen ci-broker.subplot -o doc/ci-broker.html
make -C doc publish
git clone /home/_rad/.radicle/storage/zwTxygwuz5LDGBq255RA2CbNGrz8 /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/srcCommand arguments:
"git""clone""/home/_rad/.radicle/storage/zwTxygwuz5LDGBq255RA2CbNGrz8""/srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src"In directory: /
Exit code: 0
Output (stdout and stderr):
Cloning into '/srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src'... done.
git config advice.detachedHead falseCommand arguments:
"git""config""advice.detachedHead""false"In directory: /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src
Exit code: 0
git checkout 07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870Command arguments:
"git""checkout""07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870"In directory: /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src
Exit code: 0
Output (stdout and stderr):
HEAD is now at 07b3a48 feat: add table with current event queue to front report page
git show 07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870Command arguments:
"git""show""07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870"In directory: /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src
Exit code: 0
Output (stdout and stderr):
commit 07b3a48a5e1edbfa031d6c2b77dc3c7f9aeda870
Author: Lars Wirzenius <liw@liw.fi>
Date: Wed Aug 21 11:49:48 2024 +0300
feat: add table with current event queue to front report page
Add a table of pending events in the event queue. except for ones for
private repositories.
The public queue allows people to have a idea of how long they will
have to wait for CI to run for their change.
The table leaks the event queue, commit IDs, branch names, and patch
IDs, but if that's a problem, we can make this a table configurable,
on a per node basis.
diff --git a/src/bin/cib.rs b/src/bin/cib.rs
index b21876f..f8685cb 100644
--- a/src/bin/cib.rs
+++ b/src/bin/cib.rs
@@ -209,8 +209,7 @@ impl ProcessEventsCmd {
if let Some(dirname) = &config.report_dir {
page.set_output_dir(dirname);
}
- let page_updater =
- page.update_in_thread(run_notification.rx(), db, &profile.config.node.alias, false);
+ let page_updater = page.update_in_thread(run_notification.rx(), profile, db, false);
let mut broker = Broker::new(config.db()).map_err(CibError::new_broker)?;
let spec =
diff --git a/src/bin/cibtoolcmd/report.rs b/src/bin/cibtoolcmd/report.rs
index 61a8140..a0a4039 100644
--- a/src/bin/cibtoolcmd/report.rs
+++ b/src/bin/cibtoolcmd/report.rs
@@ -23,8 +23,7 @@ impl Leaf for ReportCmd {
page.set_output_dir(&self.output_dir);
let mut run_notification = NotificationChannel::default();
- let thread =
- page.update_in_thread(run_notification.rx(), db, &profile.config.node.alias, true);
+ let thread = page.update_in_thread(run_notification.rx(), profile, db, true);
thread.join().unwrap()?;
Ok(())
diff --git a/src/pages.rs b/src/pages.rs
index 47113cc..e07058b 100644
--- a/src/pages.rs
+++ b/src/pages.rs
@@ -21,11 +21,15 @@ use log::{debug, info, trace, warn};
use serde::Serialize;
use time::{macros::format_description, OffsetDateTime};
-use radicle::prelude::RepoId;
+use radicle::{
+ prelude::RepoId,
+ storage::{ReadRepository, ReadStorage},
+ Profile,
+};
use crate::{
- db::{Db, DbError},
- event::BrokerEvent,
+ db::{Db, DbError, QueuedEvent},
+ event::{parse_ref, BrokerEvent, ParsedRef},
msg::RunId,
notif::NotificationReceiver,
run::{Run, RunState, Whence},
@@ -68,6 +72,7 @@ pub enum PageError {
pub struct PageBuilder {
node_alias: Option<String>,
runs: Vec<Run>,
+ events: Vec<QueuedEvent>,
}
impl PageBuilder {
@@ -81,6 +86,11 @@ impl PageBuilder {
self
}
+ pub fn events(mut self, events: Vec<QueuedEvent>) -> Self {
+ self.events = events;
+ self
+ }
+
pub fn build(self) -> Result<StatusPage, PageError> {
let mut runs = HashMap::new();
for run in self.runs.iter() {
@@ -103,6 +113,7 @@ struct PageData {
ci_broker_git_commit: &'static str,
node_alias: String,
runs: HashMap<RunId, Run>,
+ events: Vec<QueuedEvent>,
broker_event_counter: usize,
latest_broker_event: Option<BrokerEvent>,
latest_ci_run: Option<Run>,
@@ -175,6 +186,55 @@ impl PageData {
}
doc.push_to_body(table);
+ Self::h1(&mut doc, "Event queue");
+ let mut table = Element::new(Tag::Table)
+ .with_class("event-queue")
+ .with_child(
+ Element::new(Tag::Tr)
+ .with_child(Element::new(Tag::Th).with_text("Queue id"))
+ .with_child(Element::new(Tag::Th).with_text("Timestamp"))
+ .with_child(Element::new(Tag::Th).with_text("Event")),
+ );
+ for event in self.events.iter() {
+ table.push_child(
+ Element::new(Tag::Tr)
+ .with_child(Element::new(Tag::Td).with_text(&event.id().to_string()))
+ .with_child(Element::new(Tag::Td).with_text(event.timestamp()))
+ .with_child(
+ Element::new(Tag::Td).with_child(match event.event() {
+ BrokerEvent::Shutdown => Element::new(Tag::Span).with_text("shutdown"),
+ BrokerEvent::RefChanged {
+ rid,
+ name,
+ oid,
+ old: _,
+ } => Element::new(Tag::Span)
+ .with_child(
+ Element::new(Tag::Span)
+ .with_class("repoid")
+ .with_text(&rid.to_string()),
+ )
+ .with_child(Element::new(Tag::Br))
+ .with_child(Element::new(Tag::Span).with_class("ref").with_text(
+ &match parse_ref(name) {
+ Ok(Some(ParsedRef::Push(branch))) => branch,
+ Ok(Some(ParsedRef::Patch(patch))) => patch.to_string(),
+ Ok(None) => "unknown".into(),
+ Err(_) => "unknown".into(),
+ },
+ ))
+ .with_child(Element::new(Tag::Br))
+ .with_child(
+ Element::new(Tag::Span)
+ .with_class("commit")
+ .with_text(&oid.to_string()),
+ ),
+ }),
+ ),
+ );
+ }
+ doc.push_to_body(table);
+
Self::h1(&mut doc, "Recent status");
let status = StatusData::from(self).as_json()?;
doc.push_to_body(
@@ -461,22 +521,22 @@ impl StatusPage {
pub fn update_in_thread(
mut self,
run_rx: NotificationReceiver,
+ profile: Profile,
db: Db,
- node_alias: &str,
once: bool,
) -> JoinHandle<Result<(), PageError>> {
if self.dirname.is_none() {
warn!("not writing HTML report pages as output directory has not been set");
}
- self.node_alias = node_alias.into();
+ self.node_alias = profile.config.alias().to_string();
info!(
"wait about {} seconds to update HTML report pages again",
UPDATE_INTERVAL.as_secs()
);
spawn(move || {
'processing_loop: loop {
- self.update_and_write(&db)?;
+ self.update_and_write(&profile, &db)?;
if once {
return Ok(());
}
@@ -496,14 +556,14 @@ impl StatusPage {
// Make sure we update reports and status JSON at least once.
info!("make sure we update reports and status JSON at least once");
- self.update_and_write(&db)?;
+ self.update_and_write(&profile, &db)?;
info!("end page updater thread");
Ok(())
})
}
- fn update_and_write(&mut self, db: &Db) -> Result<(), PageError> {
+ fn update_and_write(&mut self, profile: &Profile, db: &Db) -> Result<(), PageError> {
if let Some(dirname) = &self.dirname {
info!(
"write HTML report pages and {STATUS_JSON} to {}",
@@ -512,6 +572,29 @@ impl StatusPage {
let runs = db.get_all_runs()?;
+ // Create list of events, except ones for private
+ // repositories.
+ let events: Result<Vec<QueuedEvent>, PageError> = db
+ .queued_events()?
+ .iter()
+ .filter_map(|id| match db.get_queued_event(id) {
+ Ok(Some(event)) => match event.event() {
+ BrokerEvent::Shutdown => Some(Ok(event)),
+ BrokerEvent::RefChanged { rid, .. } => {
+ if Self::is_public_repo(profile, rid) {
+ Some(Ok(event))
+ } else {
+ None
+ }
+ }
+ },
+ Ok(None) => None, // Event is (no longer?) in database.
+ Err(_) => None, // We ignore error here on purpose.
+ })
+ .collect();
+ let mut events = events?;
+ events.sort_by_cached_key(|e| e.timestamp().to_string());
+
let data = PageData {
timestamp: now()?,
ci_broker_version: env!("CARGO_PKG_VERSION"),
@@ -521,6 +604,7 @@ impl StatusPage {
runs.iter()
.map(|run| (run.broker_run_id().clone(), run.clone())),
),
+ events,
broker_event_counter: 0,
latest_broker_event: None,
latest_ci_run: None,
@@ -559,6 +643,17 @@ impl StatusPage {
Ok(())
}
+ fn is_public_repo(profile: &Profile, rid: &RepoId) -> bool {
+ if let Ok(repo) = profile.storage.repository(*rid) {
+ if let Ok(id_doc) = repo.canonical_identity_doc() {
+ if id_doc.doc.visibility.is_public() {
+ return true;
+ }
+ }
+ }
+ false
+ }
+
fn write_file(filename: &Path, text: &str) -> Result<(), PageError> {
debug!("write file {}", filename.display());
write(filename, text).map_err(|e| PageError::Write(filename.into(), e))?;
diff --git a/src/radicle-ci.css b/src/radicle-ci.css
index 2e5dbce..b6936e6 100644
--- a/src/radicle-ci.css
+++ b/src/radicle-ci.css
@@ -34,7 +34,7 @@ code.patch {
font-weight: bold;
}
-code.commit {
+code.commit, span.commit {
font-weight: bold;
}
@@ -42,7 +42,7 @@ code.revision {
font-weight: bold;
}
-code.repoid {
+code.repoid, span.repoid {
font-weight: bold;
}
@@ -70,7 +70,7 @@ span.who {
}
table {
- width: 90%;
+ width: 100%;
table-layout: fixed;
}
timeout 600 bash -c set -xeuo pipefail
cargo --version
rustc --version
cargo fmt --check
cargo clippy --all-targets --workspace -- -Dwarnings
cargo build --all-targets --workspace
cargo doc --workspace
cargo test --workspace --no-fail-fast
subplot docgen ci-broker.subplot -o doc/ci-broker.html
make -C doc publish
Command arguments:
"timeout""600""bash""-c""set -xeuo pipefail\ncargo --version\nrustc --version\n\ncargo fmt --check\ncargo clippy --all-targets --workspace -- -Dwarnings\ncargo build --all-targets --workspace\ncargo doc --workspace\ncargo test --workspace --no-fail-fast\n\nsubplot docgen ci-broker.subplot -o doc/ci-broker.html\nmake -C doc publish\n"In directory: /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src
Exit code: 101
Output (stdout and stderr):
+ cargo --version
cargo 1.77.0 (3fe68eabf 2024-02-29)
+ rustc --version
rustc 1.77.0 (aedd173a2 2024-03-17)
+ cargo fmt --check
+ cargo clippy --all-targets --workspace -- -Dwarnings
Compiling proc-macro2 v1.0.86
Compiling unicode-ident v1.0.12
Compiling version_check v0.9.5
Compiling libc v0.2.158
Compiling typenum v1.17.0
Checking cfg-if v1.0.0
Compiling serde v1.0.208
Compiling shlex v1.3.0
Compiling thiserror v1.0.63
Compiling once_cell v1.19.0
Compiling memchr v2.7.4
Compiling byteorder v1.5.0
Compiling syn v1.0.109
Checking subtle v2.6.1
Compiling bitflags v2.6.0
Compiling rustix v0.38.34
Compiling pkg-config v0.3.30
Compiling crossbeam-utils v0.8.20
Compiling itoa v1.0.11
Compiling linux-raw-sys v0.4.14
Compiling anyhow v1.0.86
Compiling allocator-api2 v0.2.18
Compiling generic-array v0.14.7
Compiling ahash v0.8.11
Compiling log v0.4.22
Checking cpufeatures v0.2.13
Compiling regex-syntax v0.8.4
Compiling same-file v1.0.6
Compiling num-conv v0.1.0
Compiling aho-corasick v1.1.3
Compiling time-core v0.1.2
Compiling walkdir v2.5.0
Compiling time-macros v0.2.18
Compiling utf8parse v0.2.2
Compiling ucd-trie v0.1.6
Compiling anstyle-parse v0.2.5
Compiling bstr v1.10.0
Compiling unic-common v0.9.0
Compiling quote v1.0.36
Compiling unic-char-range v0.9.0
Compiling anstyle-query v1.1.1
Compiling unicode-width v0.1.13
Compiling heck v0.5.0
Compiling powerfmt v0.2.0
Compiling is_terminal_polyfill v1.70.1
Compiling crossbeam-epoch v0.9.18
Compiling libm v0.2.8
Compiling syn v2.0.75
Compiling jobserver v0.1.32
Compiling getrandom v0.2.15
Compiling colorchoice v1.0.2
Compiling vcpkg v0.2.15
Compiling rand_core v0.6.4
Compiling cc v1.1.13
Compiling ryu v1.0.18
Compiling doc-comment v0.3.3
Compiling serde_json v1.0.125
Compiling anstyle v1.0.8
Compiling crossbeam-deque v0.8.5
Compiling deranged v0.3.11
Compiling unic-char-property v0.9.0
Compiling anstream v0.6.15
Compiling unic-ucd-version v0.9.0
Compiling proc-macro-error-attr v1.0.4
Compiling unicase v2.7.0
Compiling encoding_rs v0.8.34
Compiling arraydeque v0.5.1
Compiling strsim v0.11.1
Compiling fastrand v2.1.0
Checking tinyvec_macros v0.1.1
Checking crypto-common v0.1.6
Checking block-buffer v0.10.4
Checking block-padding v0.3.3
Compiling clap_lex v0.7.2
Checking digest v0.10.7
Checking inout v0.1.3
Checking universal-hash v0.5.1
Checking tinyvec v1.8.0
Checking cipher v0.4.4
Compiling clap_builder v4.5.15
Compiling unic-ucd-segment v0.9.0
Compiling proc-macro-error v1.0.4
Compiling pulldown-cmark v0.9.6
Compiling tempfile v3.12.0
Compiling equivalent v1.0.1
Compiling regex-automata v0.4.7
Compiling deunicode v1.6.0
Compiling smawk v0.3.2
Compiling time v0.3.36
Compiling amplify_syn v2.0.1
Checking opaque-debug v0.3.1
Checking signature v1.6.4
Compiling unicode-linebreak v0.1.5
Checking ed25519 v1.5.3
Compiling humansize v2.1.3
Compiling slug v0.1.6
Checking unicode-normalization v0.1.23
Compiling textwrap v0.16.1
Compiling unic-segment v0.9.0
Compiling is-terminal v0.4.13
Compiling subplot v0.10.0
Compiling getopts v0.2.21
Compiling libz-sys v1.1.19
Compiling pikchr v0.1.3
Compiling libgit2-sys v0.16.2+1.7.2
Compiling percent-encoding v2.3.1
Checking ascii v1.1.0
Checking ct-codecs v1.1.1
Checking amplify_num v0.5.3
Compiling lazy_static v1.5.0
Compiling unsafe-libyaml v0.2.11
Compiling humantime v2.1.0
Compiling termcolor v1.4.1
Compiling utf8-width v0.1.7
Checking unicode-bidi v0.3.15
Compiling html-escape v0.2.13
Checking ec25519 v0.1.0
Checking form_urlencoded v1.2.1
Checking idna v0.5.0
Compiling sqlite3-src v0.5.1
Compiling amplify_derive v4.0.1
Checking polyval v0.6.2
Checking sha2 v0.10.8
Compiling tracing-core v0.1.32
Compiling file_diff v1.0.0
Checking base64ct v1.6.0
Checking keccak v0.1.5
Compiling line-col v0.2.1
Compiling base64 v0.22.1
Compiling pin-project-lite v0.2.14
Checking url v2.5.2
Checking sha3 v0.10.8
Checking pem-rfc7468 v0.7.0
Compiling globset v0.4.14
Compiling regex v1.10.6
Checking ghash v0.5.1
Checking ctr v0.9.2
Checking aes v0.8.4
Checking aead v0.5.2
Checking base32 v0.4.0
Compiling data-encoding v2.6.0
Compiling ignore v0.4.22
Checking hashbrown v0.14.5
Compiling env_logger v0.10.2
Compiling cfg_aliases v0.2.1
Checking ssh-encoding v0.2.0
Compiling nix v0.29.0
Checking aes-gcm v0.10.3
Checking blowfish v0.9.1
Checking poly1305 v0.8.0
Checking chacha20 v0.9.1
Checking cbc v0.1.2
Checking pbkdf2 v0.12.2
Checking indexmap v2.4.0
Compiling globwalk v0.9.1
Compiling adler v1.0.2
Checking radicle-std-ext v0.1.0
Checking zeroize v1.8.1
Compiling miniz_oxide v0.7.4
Checking bcrypt-pbkdf v0.10.0
Checking ssh-cipher v0.2.0
Checking rand v0.8.5
Compiling xattr v1.3.1
Compiling data-encoding-macro-internal v0.1.13
Compiling filetime v0.2.24
Compiling crc32fast v1.4.2
Checking base-x v0.2.11
Checking signature v2.2.0
Compiling tar v0.4.41
Checking ssh-key v0.6.6
Compiling flate2 v1.0.31
Checking qcheck v1.0.0
Checking cvt v0.1.2
Compiling slog v2.7.0
Checking data-encoding-macro v0.1.15
Checking multibase v0.9.1
Compiling glob v0.3.1
Checking terminal_size v0.3.0
Checking radicle-dag v0.9.0
Checking normpath v1.3.0
Compiling serde_yml v0.0.11
Checking fs2 v0.4.3
Checking amplify v4.7.0
Checking shell-words v1.1.0
Checking base64 v0.21.7
Checking libyml v0.0.4
Checking siphasher v1.0.1
Checking crossbeam-channel v0.5.13
Checking state v0.5.3
Checking unescape v0.1.0
Compiling radicle-surf v0.18.0
Checking nonempty v0.5.0
Checking base64 v0.13.1
Compiling serde_derive v1.0.208
Compiling thiserror-impl v1.0.63
Compiling zerocopy-derive v0.7.35
Compiling clap_derive v4.5.13
Compiling git-testament-derive v0.2.0
Compiling tracing-attributes v0.1.27
Checking cyphergraphy v0.3.0
Compiling culpa-macros v1.0.2
Checking fs_at v0.2.1
Checking cypheraddr v0.4.0
Checking remove_dir_all v0.8.3
Checking html-page v0.4.0
Checking uuid v1.10.0
Checking socks5-client v0.4.1
Checking cyphernet v0.5.2
Compiling git-testament v0.2.5
Compiling zerocopy v0.7.35
Compiling pest v2.7.11
Compiling git-ref-format-core v0.3.0
Compiling tracing v0.1.40
Checking radicle-ssh v0.9.0
Compiling culpa v1.0.2
Compiling subplotlib-derive v0.10.0
Compiling ppv-lite86 v0.2.20
Compiling git-ref-format-macro v0.3.0
Checking env_filter v0.1.2
Checking env_logger v0.11.5
Compiling rand_chacha v0.3.1
Compiling clap v4.5.16
Compiling hashlink v0.8.4
Compiling hashlink v0.9.1
Compiling pest_meta v2.7.11
Compiling yaml-rust2 v0.8.1
Compiling tempfile-fast v0.3.4
Compiling pest_generator v2.7.11
Compiling pest_derive v2.7.11
Checking nonempty v0.9.0
Checking localtime v1.3.1
Checking git-ref-format v0.3.0
Compiling serde_path_to_error v0.1.16
Compiling serde_yaml v0.9.34+deprecated
Checking slog-json v2.6.1
Compiling marked-yaml v0.7.1
Compiling roadmap v0.6.1
Compiling serde-aux v4.5.0
Compiling tera v1.20.0
Checking git2 v0.18.3
Checking radicle-git-ext v0.7.0
Compiling subplot-build v0.10.0
Compiling subplotlib v0.10.0
Compiling radicle-ci-broker v0.4.0 (/srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src)
Checking sqlite3-sys v0.15.2
Checking sqlite v0.32.0
Checking radicle-crypto v0.10.0
Checking radicle-cob v0.11.0
Checking radicle v0.12.0
Finished dev [unoptimized + debuginfo] target(s) in 27.45s
+ cargo build --all-targets --workspace
Compiling cfg-if v1.0.0
Compiling memchr v2.7.4
Compiling bitflags v2.6.0
Compiling once_cell v1.19.0
Compiling log v0.4.22
Compiling itoa v1.0.11
Compiling subtle v2.6.1
Compiling regex-syntax v0.8.4
Compiling typenum v1.17.0
Compiling libc v0.2.158
Compiling percent-encoding v2.3.1
Compiling serde v1.0.208
Compiling thiserror v1.0.63
Compiling ryu v1.0.18
Compiling fastrand v2.1.0
Compiling equivalent v1.0.1
Compiling utf8parse v0.2.2
Compiling crossbeam-utils v0.8.20
Compiling cpufeatures v0.2.13
Compiling anstyle-query v1.1.1
Compiling colorchoice v1.0.2
Compiling ahash v0.8.11
Compiling anstyle v1.0.8
Compiling rustix v0.38.34
Compiling anstyle-parse v0.2.5
Compiling is_terminal_polyfill v1.70.1
Compiling anyhow v1.0.86
Compiling num-conv v0.1.0
Compiling powerfmt v0.2.0
Compiling anstream v0.6.15
Compiling time-core v0.1.2
Compiling getrandom v0.2.15
Compiling strsim v0.11.1
Compiling clap_lex v0.7.2
Compiling hashbrown v0.14.5
Compiling deranged v0.3.11
Compiling rand_core v0.6.4
Compiling encoding_rs v0.8.34
Compiling aho-corasick v1.1.3
Compiling generic-array v0.14.7
Compiling time-macros v0.2.18
Compiling crossbeam-epoch v0.9.18
Compiling bstr v1.10.0
Compiling pest v2.7.11
Compiling crossbeam-deque v0.8.5
Compiling rand_chacha v0.3.1
Compiling tinyvec_macros v0.1.1
Compiling tinyvec v1.8.0
Compiling clap_builder v4.5.15
Compiling crypto-common v0.1.6
Compiling block-padding v0.3.3
Compiling block-buffer v0.10.4
Compiling hashlink v0.8.4
Compiling inout v0.1.3
Compiling universal-hash v0.5.1
Compiling hashlink v0.9.1
Compiling rand v0.8.5
Compiling digest v0.10.7
Compiling signature v1.6.4
Compiling humantime v2.1.0
Compiling cipher v0.4.4
Compiling opaque-debug v0.3.1
Compiling utf8-width v0.1.7
Compiling yaml-rust2 v0.8.1
Compiling html-escape v0.2.13
Compiling ed25519 v1.5.3
Compiling indexmap v2.4.0
Compiling subplot v0.10.0
Compiling unicode-normalization v0.1.23
Compiling lazy_static v1.5.0
Compiling linux-raw-sys v0.4.14
Compiling amplify_num v0.5.3
Compiling regex-automata v0.4.7
Compiling tempfile v3.12.0
Compiling unicode-bidi v0.3.15
Compiling ct-codecs v1.1.1
Compiling ascii v1.1.0
Compiling tempfile-fast v0.3.4
Compiling pest_meta v2.7.11
Compiling ec25519 v0.1.0
Compiling serde_path_to_error v0.1.16
Compiling time v0.3.36
Compiling serde_json v1.0.125
Compiling idna v0.5.0
Compiling serde_yaml v0.9.34+deprecated
Compiling pulldown-cmark v0.9.6
Compiling marked-yaml v0.7.1
Compiling clap v4.5.16
Compiling polyval v0.6.2
Compiling sha2 v0.10.8
Compiling pest_generator v2.7.11
Compiling roadmap v0.6.1
Compiling amplify v4.7.0
Compiling serde-aux v4.5.0
Compiling libz-sys v1.1.19
Compiling form_urlencoded v1.2.1
Compiling tracing-core v0.1.32
Compiling git-ref-format-core v0.3.0
Compiling base64ct v1.6.0
Compiling byteorder v1.5.0
Compiling keccak v0.1.5
Compiling base64 v0.22.1
Compiling globset v0.4.14
Compiling regex v1.10.6
Compiling sha3 v0.10.8
Compiling git-ref-format-macro v0.3.0
Compiling pem-rfc7468 v0.7.0
Compiling tracing v0.1.40
Compiling cyphergraphy v0.3.0
Compiling url v2.5.2
Compiling libgit2-sys v0.16.2+1.7.2
Compiling ghash v0.5.1
Compiling ignore v0.4.22
Compiling git-testament-derive v0.2.0
Compiling env_logger v0.10.2
Compiling aes v0.8.4
Compiling pest_derive v2.7.11
Compiling ctr v0.9.2
Compiling aead v0.5.2
Compiling base32 v0.4.0
Compiling git2 v0.18.3
Compiling git-ref-format v0.3.0
Compiling cypheraddr v0.4.0
Compiling ssh-encoding v0.2.0
Compiling sqlite3-src v0.5.1
Compiling blowfish v0.9.1
Compiling chacha20 v0.9.1
Compiling globwalk v0.9.1
Compiling aes-gcm v0.10.3
Compiling cbc v0.1.2
Compiling poly1305 v0.8.0
Compiling pbkdf2 v0.12.2
Compiling zeroize v1.8.1
Compiling radicle-std-ext v0.1.0
Compiling tera v1.20.0
Compiling data-encoding v2.6.0
Compiling bcrypt-pbkdf v0.10.0
Compiling socks5-client v0.4.1
Compiling sqlite3-sys v0.15.2
Compiling ssh-cipher v0.2.0
Compiling xattr v1.3.1
Compiling filetime v0.2.24
Compiling crc32fast v1.4.2
Compiling git-testament v0.2.5
Compiling signature v2.2.0
Compiling base-x v0.2.11
Compiling data-encoding-macro v0.1.15
Compiling ssh-key v0.6.6
Compiling multibase v0.9.1
Compiling flate2 v1.0.31
Compiling tar v0.4.41
Compiling cyphernet v0.5.2
Compiling sqlite v0.32.0
Compiling nix v0.29.0
Compiling radicle-ssh v0.9.0
Compiling qcheck v1.0.0
Compiling cvt v0.1.2
Compiling culpa v1.0.2
Compiling terminal_size v0.3.0
Compiling nonempty v0.9.0
Compiling radicle-dag v0.9.0
Compiling normpath v1.3.0
Compiling subplotlib-derive v0.10.0
Compiling slog v2.7.0
Compiling localtime v1.3.1
Compiling fs2 v0.4.3
Compiling radicle-surf v0.18.0
Compiling fs_at v0.2.1
Compiling crossbeam-channel v0.5.13
Compiling base64 v0.21.7
Compiling remove_dir_all v0.8.3
Compiling shell-words v1.1.0
Compiling state v0.5.3
Compiling base64 v0.13.1
Compiling siphasher v1.0.1
Compiling radicle-git-ext v0.7.0
Compiling libyml v0.0.4
Compiling unescape v0.1.0
Compiling nonempty v0.5.0
Compiling html-page v0.4.0
Compiling uuid v1.10.0
Compiling radicle-crypto v0.10.0
Compiling slog-json v2.6.1
Compiling radicle-cob v0.11.0
Compiling serde_yml v0.0.11
Compiling radicle v0.12.0
Compiling subplot-build v0.10.0
Compiling env_filter v0.1.2
Compiling env_logger v0.11.5
Compiling subplotlib v0.10.0
Compiling radicle-ci-broker v0.4.0 (/srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src)
Finished dev [unoptimized + debuginfo] target(s) in 23.89s
+ cargo doc --workspace
Checking unicode-ident v1.0.12
Documenting unicode-ident v1.0.12
Documenting cfg-if v1.0.0
Documenting typenum v1.17.0
Documenting libc v0.2.158
Documenting subtle v2.6.1
Documenting bitflags v2.6.0
Documenting cpufeatures v0.2.13
Documenting memchr v2.7.4
Documenting tinyvec_macros v0.1.1
Documenting log v0.4.22
Documenting opaque-debug v0.3.1
Documenting ed25519 v1.5.3
Documenting percent-encoding v2.3.1
Documenting ct-codecs v1.1.1
Documenting linux-raw-sys v0.4.14
Checking proc-macro2 v1.0.86
Documenting ascii v1.1.0
Documenting amplify_num v0.5.3
Documenting tinyvec v1.8.0
Documenting unicode-bidi v0.3.15
Checking git-ref-format-core v0.3.0
Documenting proc-macro2 v1.0.86
Documenting itoa v1.0.11
Documenting fastrand v2.1.0
Checking quote v1.0.36
Documenting keccak v0.1.5
Documenting base64ct v1.6.0
Documenting byteorder v1.5.0
Documenting form_urlencoded v1.2.1
Checking syn v2.0.75
Checking syn v1.0.109
Documenting base32 v0.4.0
Documenting unicode-normalization v0.1.23
Checking data-encoding v2.6.0
Documenting quote v1.0.36
Documenting equivalent v1.0.1
Documenting rustix v0.38.34
Documenting hashbrown v0.14.5
Documenting aho-corasick v1.1.3
Documenting pem-rfc7468 v0.7.0
Documenting sqlite3-src v0.5.1
Documenting zeroize v1.8.1
Documenting once_cell v1.19.0
Checking amplify_syn v2.0.1
Checking proc-macro-error v1.0.4
Documenting data-encoding-macro-internal v0.1.13
Documenting radicle-std-ext v0.1.0
Documenting ryu v1.0.18
Documenting data-encoding v2.6.0
Documenting serde_derive v1.0.208
Documenting thiserror-impl v1.0.63
Documenting amplify_syn v2.0.1
Documenting proc-macro-error-attr v1.0.4
Documenting utf8parse v0.2.2
Documenting idna v0.5.0
Documenting regex-syntax v0.8.4
Documenting generic-array v0.14.7
Documenting anstyle-query v1.1.1
Documenting indexmap v2.4.0
Documenting is_terminal_polyfill v1.70.1
Documenting colorchoice v1.0.2
Documenting anstyle v1.0.8
Documenting anstyle-parse v0.2.5
Documenting proc-macro-error v1.0.4
Documenting powerfmt v0.2.0
Documenting data-encoding-macro v0.1.15
Documenting getrandom v0.2.15
Documenting thiserror v1.0.63
Documenting libz-sys v1.1.19
Documenting sqlite3-sys v0.15.2
Documenting amplify_derive v4.0.1
Documenting url v2.5.2
Documenting base-x v0.2.11
Documenting signature v2.2.0
Documenting crypto-common v0.1.6
Documenting block-padding v0.3.3
Documenting block-buffer v0.10.4
Documenting deranged v0.3.11
Documenting git-ref-format-macro v0.3.0
Documenting ec25519 v0.1.0
Documenting rand_core v0.6.4
Documenting radicle-ssh v0.9.0
Documenting serde v1.0.208
Documenting sqlite v0.32.0
Documenting libgit2-sys v0.16.2+1.7.2
Documenting anstream v0.6.15
Documenting inout v0.1.3
Documenting multibase v0.9.1
Documenting nix v0.29.0
Documenting regex-automata v0.4.7
Documenting tempfile v3.12.0
Documenting time-macros v0.2.18
Documenting cvt v0.1.2
Documenting num-conv v0.1.0
Documenting digest v0.10.7
Documenting universal-hash v0.5.1
Documenting amplify v4.7.0
Documenting aead v0.5.2
Documenting rand v0.8.5
Documenting cipher v0.4.4
Documenting git2 v0.18.3
Documenting time-core v0.1.2
Documenting terminal_size v0.3.0
Documenting culpa-macros v1.0.2
Documenting radicle-dag v0.9.0
Compiling radicle-ci-broker v0.4.0 (/srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src)
Documenting crossbeam-utils v0.8.20
Documenting heck v0.5.0
Documenting fs_at v0.2.1
Documenting sha2 v0.10.8
Documenting cyphergraphy v0.3.0
Documenting sha3 v0.10.8
Documenting pbkdf2 v0.12.2
Documenting regex v1.10.6
Documenting polyval v0.6.2
Documenting aes v0.8.4
Documenting ctr v0.9.2
Documenting blowfish v0.9.1
Documenting chacha20 v0.9.1
Documenting cbc v0.1.2
Documenting poly1305 v0.8.0
Documenting qcheck v1.0.0
Documenting time v0.3.36
Checking heck v0.5.0
Documenting clap_lex v0.7.2
Documenting ssh-encoding v0.2.0
Documenting git-ref-format-core v0.3.0
Documenting serde_json v1.0.125
Documenting cypheraddr v0.4.0
Documenting nonempty v0.9.0
Documenting ghash v0.5.1
Documenting strsim v0.11.1
Documenting utf8-width v0.1.7
Documenting bcrypt-pbkdf v0.10.0
Documenting normpath v1.3.0
Documenting env_filter v0.1.2
Documenting clap_derive v4.5.13
Documenting localtime v1.3.1
Documenting crossbeam-channel v0.5.13
Documenting culpa v1.0.2
Documenting html-escape v0.2.13
Documenting aes-gcm v0.10.3
Documenting git-ref-format v0.3.0
Documenting filetime v0.2.24
Documenting socks5-client v0.4.1
Documenting clap_builder v4.5.15
Documenting remove_dir_all v0.8.3
Documenting fs2 v0.4.3
Documenting subplotlib-derive v0.10.0
Documenting slog v2.7.0
Documenting humantime v2.1.0
Documenting base64 v0.22.1
Documenting shell-words v1.1.0
Documenting lazy_static v1.5.0
Documenting siphasher v1.0.1
Documenting libyml v0.0.4
Documenting ssh-cipher v0.2.0
Documenting state v0.5.3
Documenting unescape v0.1.0
Documenting html-page v0.4.0
Documenting uuid v1.10.0
Documenting radicle-git-ext v0.7.0
Documenting anyhow v1.0.86
Documenting cyphernet v0.5.2
Documenting env_logger v0.11.5
Documenting slog-json v2.6.1
Documenting subplotlib v0.10.0
Documenting clap v4.5.16
Documenting serde_yml v0.0.11
Documenting ssh-key v0.6.6
Documenting radicle-surf v0.18.0
Documenting radicle-crypto v0.10.0
Documenting radicle-cob v0.11.0
Documenting radicle v0.12.0
Documenting radicle-ci-broker v0.4.0 (/srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src)
Finished dev [unoptimized + debuginfo] target(s) in 38.75s
Generated /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src/target/doc/radicle_ci_broker/index.html
Generated /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src/target/doc/cib/index.html
Generated /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src/target/doc/cibtool/index.html
Generated /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src/target/doc/synthetic_events/index.html
+ cargo test --workspace --no-fail-fast
Finished test [unoptimized + debuginfo] target(s) in 0.11s
Running unittests src/lib.rs (target/debug/deps/radicle_ci_broker-abd222e307c66a25)
running 40 tests
test broker::test::does_not_find_unknown_repo ... ok
test broker::test::adds_adapter ... ok
test broker::test::does_not_have_a_default_adapter_initially ... ok
test adapter::test::adapter_is_killed_before_any_messages ... ok
test adapter::test::adapter_first_message_isnt_triggered ... ok
test event::test::branch_is_not_patch_update ... ok
test event::test::get_no_push_branch ... ok
test event::test::get_push_branch ... ok
test event::test::patch_branch_is_not_patch_update ... ok
test event::test::patch_update ... ok
test event::test::test_parse_invalid_ref ... ok
test event::test::test_parse_patch_ref ... ok
test event::test::test_parse_push_ref ... ok
test event::test_broker_event::name_for_branch ... ok
test event::test_broker_event::name_for_shutdown ... ok
test event::test_broker_event::nid_for_plain_branch_name ... ok
test adapter::test::adapter_outputs_too_many_messages ... ok
test event::test_broker_event::nid_for_ref_with_namespace ... ok
test event::test_broker_event::nid_for_ref_without_namespace ... ok
test adapter::test::adapter_is_killed_after_first_message ... ok
test adapter::test::adapter_has_bad_interpreter ... ok
test adapter::test::adapter_does_not_exist ... ok
test adapter::test::adapter_is_killed_after_second_message ... ok
test event::test_parse_ref::namespaced_patch ... ok
test run::test::serialize_run_state ... ok
test event::test_parse_ref::namespaced_branch ... ok
test event::test_parse_ref::namespaced_branch_with_slashes ... ok
test event::test_parse_ref::plain_branch_name_is_none ... ok
test adapter::test::adapter_exits_nonzero ... ok
test adapter::test::adapter_is_not_executable ... ok
test adapter::test::adapter_reports_success ... ok
test adapter::test::adapter_reports_failure ... ok
test adapter::test::adapter_produces_as_bad_message ... ok
test msg::tests::trigger_push ... ok
test msg::tests::trigger_patch ... ok
test broker::test::has_no_adapters_initially ... ok
test broker::test::finds_default_adapter_for_unknown_repo ... ok
test broker::test::sets_a_default_adapter_initially ... ok
test broker::test::adapter_fails ... ok
test broker::test::executes_adapter ... ok
test result: ok. 40 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.47s
Running unittests src/bin/cib.rs (target/debug/deps/cib-5a60c9704096fd8b)
running 0 tests
test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
Running unittests src/bin/cibtool.rs (target/debug/deps/cibtool-0aff0309840e6ba5)
running 0 tests
test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
Running unittests src/bin/synthetic-events.rs (target/debug/deps/synthetic_events-ae8ea6fa86fa7503)
running 0 tests
test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
Running tests/subplot.rs (target/debug/deps/subplot-26dc923a9de5696d)
running 28 tests
test dummy_adapter_runs_successfully ... ok
test adapter_with_url_runs_successfully ... ok
test event_synthesizer_terminates_after_first_connection ... ok
test can_add_shutdown_event_to_queue ... ok
test logs_termination_due_to_error ... FAILED
test gives_helpful_error_message_if_it_doesn_t_understand_its_configuration_file ... ok
test gives_helpful_error_message_if_node_socket_can_t_be_found ... ok
test add_information_about_run_that_s_running_to_database ... ok
test add_information_about_run_that_s_finished_successfully_to_database ... ok
test add_information_about_triggered_run_to_database ... ok
test add_information_about_run_that_s_finished_in_failure_to_database ... ok
test can_trigger_a_ci_run ... ok
test shows_config_as_json ... ok
test logs_start_and_successful_end ... ok
test don_t_insert_events_into_queue_when_not_allowed_by_filter ... ok
test events_can_be_queued_and_removed_from_queue ... ok
test adapter_can_provide_url_for_info_on_run ... ok
test insert_events_into_queue ... ok
test process_queued_events ... ok
test reports_it_version ... ok
test produces_a_report_page_upon_request ... ok
test stops_if_the_node_connection_breaks ... ok
test shuts_down_when_requested ... ok
test update_and_show_information_about_run_to_running ... ok
test smoke_test__runs_adapter ... ok
test count_in_a_single_process has been running for over 60 seconds
test count_in_concurrent_processes has been running for over 60 seconds
test insert_many_events_into_queue has been running for over 60 seconds
test count_in_a_single_process ... ok
test insert_many_events_into_queue ... ok
test count_in_concurrent_processes ... ok
failures:
---- logs_termination_due_to_error stdout ----
ci-broker.md:1077:1: scenario: Logs termination due to error
ci-broker.md:1090:1: step: given an installed cib
ci-broker.md:1092:1: step: given file broker.yaml
ci-broker.md:1093:1: step: when I try to run cib --config broker.yaml queued
Running `cib` with args ["--config", "broker.yaml", "queued"]
Running in /tmp/subplotZZ1GJLogs-termination-due-to-error
ENV: SHELL = /bin/sh
PATH: /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src/target/debug:/home/_rad/.cargo/bin:/bin:/usr/bin:/sbin:/usr/sbin
Exit code: 0
Stdout:
Stderr:
{"msg":"CI broker starts","level":"INFO","ts":"2024-08-21T11:18:32.726552215Z"}
[2024-08-21T11:18:32Z INFO cib] Radicle CI broker starts
[2024-08-21T11:18:32Z WARN radicle] Overwriting `seedingPolicy` configuration
[2024-08-21T11:18:32Z INFO radicle_ci_broker::queueproc] start thread to process events until a shutdown event
[2024-08-21T11:18:32Z INFO radicle_ci_broker::queueproc] Looking for an event to process
[2024-08-21T11:18:32Z INFO radicle_ci_broker::queueproc] waiting for next event from node
[2024-08-21T11:18:32Z INFO radicle_ci_broker::queueproc] got event notification
[2024-08-21T11:18:32Z INFO radicle_ci_broker::queueproc] Looking for an event to process
[2024-08-21T11:18:32Z INFO radicle_ci_broker::queueproc] waiting for next event from node
[2024-08-21T11:18:32Z INFO radicle_ci_broker::queueproc] event notification channel disconnected
[2024-08-21T11:18:32Z INFO radicle_ci_broker::queueproc] thread to process events ends
{"msg":"CI broker ends successfully","level":"INFO","ts":"2024-08-21T11:18:32.906668675Z"}
ci-broker.md:1095:1: step: then stderr contains "CI broker starts"
ci-broker.md:1096:1: step: then stderr contains "CI broker ends in unrecoverable error"
return: Failure
thread 'logs_termination_due_to_error' panicked at /srv/http/a2de3456-e73a-4ba7-8397-9e8a03653579/src/target/debug/build/radicle-ci-broker-e6fcb49fdd8ed2bd/out/ci-broker.rs:4003:20:
called `Result::unwrap()` on an `Err` value: "stderr does not contain \"CI broker ends in unrecoverable error\""
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace
failures:
logs_termination_due_to_error
test result: FAILED. 27 passed; 1 failed; 0 ignored; 0 measured; 0 filtered out; finished in 83.17s
error: test failed, to rerun pass `--test subplot`
Doc-tests radicle-ci-broker
running 2 tests
test src/msg.rs - msg::RunId (line 44) ... ok
test src/event.rs - event (line 11) ... ok
test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 1.59s
error: 1 target failed:
`--test subplot`