fixup queue to publish to

This commit is contained in:
Graham Christensen 2018-02-23 21:45:55 -05:00
parent f6289be861
commit aa562cf943
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C

View file

@ -68,39 +68,46 @@ impl worker::SimpleWorker for EvaluationFilterWorker {
_ => false, _ => false,
}; };
if interesting { if !interesting {
let repo_msg = Repo { info!("Not interesting: {}#{} to be interesting because of {:?}",
clone_url: job.repository.clone_url.clone(), job.repository.full_name, job.number, job.action
full_name: job.repository.full_name.clone(), );
owner: job.repository.owner.login.clone(),
name: job.repository.name.clone(),
};
let pr_msg = Pr {
number: job.number.clone(),
head_sha: job.pull_request.head.sha.clone(),
target_branch: Some(job.pull_request.base.git_ref.clone()),
};
let msg = massrebuildjob::MassRebuildJob {
repo: repo_msg.clone(),
pr: pr_msg.clone(),
};
return vec![ return vec![
worker::publish_serde_action(
Some("mass-rebuild-check-jobs".to_owned()),
None,
&msg
),
worker::Action::Ack worker::Action::Ack
]; ];
} }
info!("Found {}#{} to be interesting because of {:?}",
job.repository.full_name, job.number, job.action
);
let repo_msg = Repo {
clone_url: job.repository.clone_url.clone(),
full_name: job.repository.full_name.clone(),
owner: job.repository.owner.login.clone(),
name: job.repository.name.clone(),
};
let pr_msg = Pr {
number: job.number.clone(),
head_sha: job.pull_request.head.sha.clone(),
target_branch: Some(job.pull_request.base.git_ref.clone()),
};
let msg = massrebuildjob::MassRebuildJob {
repo: repo_msg.clone(),
pr: pr_msg.clone(),
};
return vec![ return vec![
worker::publish_serde_action(
None,
Some("mass-rebuild-check-jobs".to_owned()),
&msg
),
worker::Action::Ack worker::Action::Ack
]; ];
} }
} }
#[cfg(test)] #[cfg(test)]
@ -126,8 +133,8 @@ mod tests {
worker.consumer(&job), worker.consumer(&job),
vec![ vec![
worker::publish_serde_action( worker::publish_serde_action(
Some("mass-rebuild-check-jobs".to_owned()),
None, None,
Some("mass-rebuild-check-jobs".to_owned()),
&massrebuildjob::MassRebuildJob { &massrebuildjob::MassRebuildJob {
repo: Repo { repo: Repo {
clone_url: String::from("https://github.com/NixOS/nixpkgs.git"), clone_url: String::from("https://github.com/NixOS/nixpkgs.git"),