Skip to content

Commit

Permalink
Merge pull request #49 from Alokit-Innovations/akg/bug_fix_ablejobs
Browse files Browse the repository at this point in the history
added a log
  • Loading branch information
avikalpg authored Oct 30, 2023
2 parents 8d7801e + 5bafec5 commit 5d634ba
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion vibi-dpu/src/pubsub/listener.rs
Original file line number Diff line number Diff line change
@@ -59,6 +59,7 @@ async fn process_message(attributes: &HashMap<String, String>, data_bytes: &Vec<
if event_type == "pullrequest:approved" {
todo!("Process approved event");
}
println!("[process_message|webhook_callback] is_reviewable: {}; event_type: {}", is_reviewable, &event_type);
if is_reviewable && (event_type == "pullrequest:created" || event_type == "pullrequest:updated" ) {
task::spawn(async move {
process_review(&data_bytes_async).await;
@@ -73,7 +74,7 @@ async fn process_message(attributes: &HashMap<String, String>, data_bytes: &Vec<
}


async fn prcoess_install_callback(data_bytes: &[u8]) {
async fn process_install_callback(data_bytes: &[u8]) {
println!("Processing install callback message");
let msg_data_res = serde_json::from_slice::<InstallCallback>(data_bytes);
if msg_data_res.is_err() {

0 comments on commit 5d634ba

Please sign in to comment.