rifling 0.4.0

A library for creating Github/Gitlab webhook listener
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

//! Simple example of Rifling with Hyper

#[cfg(feature = "logging")]
#[macro_use]
extern crate log;
extern crate hyper;
extern crate pretty_env_logger;

#[macro_use]
extern crate rifling;

use hyper::rt::Future;
use hyper::Server;

use rifling::{Constructor, Delivery, DeliveryType, Hook};

use std::env;

fn main() {
    if let Err(_) = env::var("RIFLING_LOG") {
        env::set_var("RIFLING_LOG", "info")
    }
    pretty_env_logger::init_custom_env("RIFLING_LOG");
    let mut cons = Constructor::new();
    let hook = Hook::new("*", Some(String::from("secret")), |delivery: &Delivery| {
        #[cfg(feature = "parse")]
        {
            if let Some(payload) = &delivery.payload {
                info!(
                    "Bazinga! Received \"{}\" action!",
                    match delivery.delivery_type {
                        DeliveryType::GitHub => payload["action"].as_str().unwrap(),
                        DeliveryType::GitLab => payload["event_name"].as_str().unwrap(),
                    }
                );
            }
        }
        #[cfg(not(feature = "parse"))]
        {
            if let Some(event) = &delivery.event {
                info!("Received \"{}\" action!", event);
            }
        }
    });
    let another_hook = Hook::new("push", Some(String::from("secret")), |_: &Delivery| {
        info!("Pushed!");
    });
    let gitlab_push_hook = Hook::new("push_hook", Some(String::from("secret")), |_: &Delivery| {
        info!("GitLab pushed");
    });
    cons.register(hook);
    cons.register(another_hook);
    cons.register(gitlab_push_hook);
    let addr = "0.0.0.0:4567".parse().unwrap();
    let server = Server::bind(&addr)
        .serve(cons)
        .map_err(|e| println!("Error: {:?}", e));
    info!("Starting up...");
    hyper::rt::run(server);
}