GameCult/ModelConnector
Watch
9
0
Fork
You've already forked ModelConnector
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

lease-persona-callers: model-connector lease callers take the turn

Browse source 
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
Meta Vens 2026-10-31 01:58:12 +01:00
commit 47a4dcc6b4
1 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

12
crates/model-connector/src/service/lease.rs
View file

@ -263,10 +263,10 @@ impl TransportService {
caller_runtime_id: caller_runtime_id.to_string(), caller_runtime_id: caller_runtime_id.to_string(),
request_id: lease_id.to_string(), request_id: lease_id.to_string(),
}; };
if !self if self
.live .live
.get(&identity) .get(&identity)
.is_some_and(|request| request.lease.is_some()) .is_none_or(|request| request.lease.is_none())
{ {
return Err(ServiceError::NoActiveRequest); return Err(ServiceError::NoActiveRequest);
} }
@ -378,7 +378,7 @@ mod tests {
fn lease(service: &mut TransportService, run: &str, cost: u64) -> LeaseAdmission { fn lease(service: &mut TransportService, run: &str, cost: u64) -> LeaseAdmission {
service service
.begin_lease(CALLER, run, cost, NOW + 60_000, NOW) .begin_lease(CALLER, LeaseTurn::SelfRun, run, cost, NOW + 60_000, NOW)
.unwrap() .unwrap()
} }
@ -473,7 +473,7 @@ mod tests {
let mut service = open(&store, 1_000); let mut service = open(&store, 1_000);
assert_eq!( assert_eq!(
service service
.begin_lease("stranger", "run-1", 100, NOW + 1, NOW) .begin_lease("stranger", LeaseTurn::SelfRun, "run-1", 100, NOW + 1, NOW)
.unwrap(), .unwrap(),
LeaseAdmission::Refused(LeaseRefusal::UnknownCaller) LeaseAdmission::Refused(LeaseRefusal::UnknownCaller)
); );
@ -648,7 +648,7 @@ mod tests {
allowance.store(0, Ordering::SeqCst); allowance.store(0, Ordering::SeqCst);
assert!( assert!(
service service
.begin_lease(CALLER, "run-1", 100, NOW + 1, NOW) .begin_lease(CALLER, LeaseTurn::SelfRun, "run-1", 100, NOW + 1, NOW)
.is_err() .is_err()
); );
assert_eq!(held(&service), 0); assert_eq!(held(&service), 0);
@ -724,7 +724,7 @@ mod tests {
.unwrap(); .unwrap();
assert!( assert!(
service service
.begin_lease(CALLER, &format!("{longest}r"), 100, NOW + 1, NOW) .begin_lease(CALLER, LeaseTurn::SelfRun, &format!("{longest}r"), 100, NOW + 1, NOW)
.is_err() .is_err()
); );
} }