Struct Hub 

pub struct Hub {
    pub issuer: Arc<Issuer>,
    /* private fields */
}

The host’s jobs and the page’s event stream.

Fields

issuer: Arc<Issuer>

Signs the person’s own commands this host sends, and checks them.

Implementations

impl Hub

pub fn new(root: Root, issuer: Arc<Issuer>) -> Arc<Self>

A hub for the project root is (or will be, once bound), signing with issuer.

pub fn subscribe(&self) -> Receiver<String>

Every event from now on, as JSON text.

pub fn progress(self: &Arc<Self>) -> Arc<dyn Progress>

A progress sink onto the page’s event stream, for work that is not a job (an Ask turn).

pub fn job(&self) -> Option<JobView>

The job, if one ran since the host started.

pub fn waiting(&self) -> Option<Value>

What waits for the person now (an ask or question event).

pub fn answer(&self, id: u64, reply: Reply) -> Result<(), String>

Answers what waits; Err when nothing does, or something else does.

pub fn stop(&self)

Asks the running job to stop before its next task; a call waiting for the person is answered with “stop” (it keeps waiting, resumably).

pub fn exclusive<T>(&self, f: impl FnOnce() -> T) -> Result<T, String>

Runs f while no job runs and none can start — for a short change to the checkout (a commit): the check and the change are one step.

Errors

A job is working.

pub fn start( self: &Arc<Self>, run: Runnable, input: Option<String>, feature: Option<String>, command: String, root: PathBuf, ) -> Result<u64, String>

Starts run (with input for actions that take one) for feature, in root (the bound project’s, or a folder of a host not bound yet); Err when a job is already working.

pub fn start_fix( self: &Arc<Self>, argvs: Vec<Vec<String>>, root: PathBuf, ) -> Result<u64, String>

Runs the person’s own command — argvs this host issued, checked by the caller — in root, as a job: its output lines go to the page (output events), Stop ends it, and it ends in its result.

pub fn start_speccoder( self: &Arc<Self>, args: Vec<String>, root: PathBuf, ) -> Result<u64, String>

Runs one of speccoder’s own commands that has no action of its own (speccoder run --ignore-checklists) — args issued by this host, checked by the caller — as a job of speccoder’s: no time limit, Stop asks it to stop, its run shows as any run does (the project’s live state), and its own result is the job’s.

Trait Implementations

impl Debug for Hub

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.