webhook-gateway 2.17.2

A service to ingress github event
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use crate::backend;
use crate::github::event::GithubEvent;
use crate::message;
use crate::queue;
use crate::constants;
use anyhow::Result;
use tracing::{info, error};

pub fn produce_message_from(event: &GithubEvent) -> Result<()> {
    let action = event.get_action();
    if action == "deleted" {
        return Ok(());
    }
    let comment = event.get_comment();
    if !constants::contains_keywords_we_focus(&comment) {
        return Ok(());
    }
    match backend::get_backend_task_from_str(
        &comment,
        &event.get_repo_name(),
        event.get_pr_number(),
        event.get_user_name(),
    ) {
        Ok(backend) => {
            let s = queue::get_sender();
            let guard = s.lock();
            let sender = guard.expect("get sender fail."); // crash here if the channel is malfunc
            if sender.send(message::Message { backend }).is_err() {
                error!("Fail to send a task to channel.");
            }
        }
        Err(e) => {
            error!("Cannot get backend task from body.{:?}", e);
        }
    }
    Ok(())
}