b73ab44 refactor(src/broker.rs): add accessors, drop unnecessary mut — radicle-ci-broker

Radicle CI broker

refactor(src/broker.rs): add accessors, drop unnecessary mut

Lars Wirzenius committed 1 year ago

commit b73ab44962134073624f51e93e165b6bde4fe4d7
parent 0cf160d3d1aee6e7942c61ca42d89322e77421b1

2 files changed +12 -4

modified src/broker.rs

@@ -42,9 +42,17 @@ impl Broker {

         })
     }
     pub fn max_run_time(&self) -> Duration {
         self.max_run_time
     }
     pub fn db(&self) -> &Db {
         &self.db
     }
     #[allow(clippy::result_large_err)]
     pub fn execute_ci(
         &mut self,
         &self,
         adapter: &Adapter,
         trigger: &Request,
         run_notification: &NotificationSender,

@@ -204,7 +212,7 @@ echo '{"response":"finished","result":"success"}'

         let tmp = tempdir()?;
         let db = tmp.path().join("db.db");
         let mut broker = broker(&db)?;
         let broker = broker(&db)?;
         let trigger = trigger_request()?;

@@ -236,7 +244,7 @@ exit 1

         let tmp = tempdir()?;
         let db = tmp.path().join("db.db");
         let mut broker = broker(&db)?;
         let broker = broker(&db)?;
         let trigger = trigger_request()?;

modified src/queueproc.rs

@@ -58,7 +58,7 @@ impl QueueProcessorBuilder {

         let mut descs = vec![];
         for _ in 0..concurrent_adapters {
             let broker = Broker::new(broker.db.filename(), broker.max_run_time)
             let broker = Broker::new(broker.db().filename(), broker.max_run_time())
                 .map_err(QueueError::NewBroker)?;
             let event_procssor = EventProcessor::new(
                 profile.clone(),