22613. 22613 let slot = chrono::Local::now() - chrono::Duration::minutes(5);
22614. 22614 let marker = |state: &AppState| state.next_fire.lock().unwrap().get("nightly").copied();
22615. 22615 state
22616. 22616 .next_fire
22617. 22617 .lock()
22618. 22618 .unwrap()
22619. 22619 .insert("nightly".into(), slot);
22620. 22620
22621. 22621 scheduler_tick(&state).await;
22622. 22622 assert_eq!(
22623. 22623 marker(&state),
22624. 22624 Some(slot),
22625. 22625 "a refused run leaves its slot to be tried again"
22626. 22626 );
22627. 22627
22628. 22628 make_repo(&ws);
22629. 22629 scheduler_tick(&state).await;
22630. 22630 assert!(
22631. 22631 marker(&state).is_some_and(|next| next > chrono::Local::now()),
22632. 22632 "the slot is spent once a run starts"
22633. 22633 );
22634. 22634 }
22635. 22635
22636. 22636 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
22637. 22637 async fn child_core_home_is_not_nested() {
22638. 22638 let dir = tempfile::tempdir().unwrap();
22639. 22639 let (ws, home) = (dir.path().join("ws"), dir.path().join("home"));
22640. 22640 std::fs::create_dir_all(&ws).unwrap();
22641. 22641 make_repo(&ws);
22642. 22642 let writer = agents::builtin_templates()
22643. 22643 .into_iter()
22644. 22644 .find(|template| template.template_id == "writer")
22645. 22645 .unwrap()
22646. 22646 .to_agent_definition("writer", None);
22647. 22647 agents::save(&ws, &[writer], true).unwrap();
22648. 22648 let vak = vak_session::types::AgentIdentity {
22649. 22649 id: "vak".into(),
22650. 22650 revision: 1,
22651. 22651 name: "Vakyartha".into(),
22652. 22652 character: String::new(),
22653. 22653 personality: String::new(),
22654. 22654 animation: "spark".into(),
22655. 22655 voice: "calm".into(),
22656. 22656 behaviour: String::new(),
22657. 22657 responsibilities: String::new(),
22658. 22658 instructions: String::new(),
22659. 22659 };
22660. 22660 let state = state_with(
22661. 22661 &ws,
22662. 22662 &home,
22663. 22663 vec![cron_task("for-writer", &ws, Some("writer"))],
22664. 22664 Some(vak),
22665. 22665 );
22666. 22666 load_tasks(&state);
22667. 22667 let session = fire_task(&state, "for-writer")
22668. 22668 .await
22669. 22669 .unwrap_or_else(|_| panic!("the routine starts"));
22670. 22670
22671. 22671 let ledger = std::fs::read_dir(home.join("agents").join("writer").join("sessions"))
22672. 22672 .unwrap()
22673. 22673 .flatten()
22674. 22674 .any(|project| project.path().join(format!("{session}.jsonl")).is_file());
22675. 22675 assert!(ledger, "the run's ledger is under the writer's own home");
22676. 22676 assert!(
22677. 22677 !home.join("agents").join("vak").join("agents").exists(),
22678. 22678 "no Agent home nested inside another's"
22679. 22679 );
22680. 22680 }
22681. 22681}
22682. 22682