boxdot’s gists

boxdot / gitlab_hook.rs

Created March 12, 2020 20:29

	use gitlab::webhooks::WebHook;
	use hyper::service::{make_service_fn, service_fn};
	use hyper::{Body, Request, Response, Server};
	use log::{log_enabled, Level};

	async fn gitlab_webhook(req: Request<Body>) -> Result<Response<Body>, hyper::Error> {
	log::debug!("< {:?}", req);
	let body = hyper::body::to_bytes(req.into_body()).await?;
	let event: Result<WebHook, _> = serde_json::from_slice(&body);
	match event {

boxdot / num-stable-crates.rs

Created November 7, 2019 20:09

Calculate number of stable crates on crates.io

	use std::cmp::Reverse;
	use std::collections::HashMap;
	use std::fs::File;
	use std::io::BufRead;
	use std::io::BufReader;
	use walkdir::WalkDir;

	fn get_version(entry: walkdir::Result<walkdir::DirEntry>) -> Option<String> {
	let entry = entry.ok()?;
	let path = entry.path();

boxdot / leaked_thread.rs

Created April 2, 2019 14:10

	use actix::prelude::*;
	use actix_web::{middleware, web, App, HttpResponse, HttpServer};
	use log::info;

	use std::io;
	use std::thread;
	use std::time::Duration;

	fn my_handler() -> HttpResponse {
	"Hello".into()

boxdot / test.rs

Created February 18, 2019 16:30

	fn some_test -> Result<(), Error> {
	let mut rt = tokio::runtime::Runtime::new().unwrap();

	rt.spawn(microservice_1.map_err(\|e\| panic!(e)));
	rt.spawn(microservice_2.map_err(\|e\| panic!(e)));
	rt.spawn(microservice_3.map_err(\|e\| panic!(e)));
	rt.spawn(microservice_4.map_err(\|e\| panic!(e)));

	// do testing and do not touch rt anymore
	}

boxdot / nom_error.rs

Created October 12, 2018 17:21

	#[macro_use]
	extern crate nom;

	use nom::alpha;
	use nom::types::CompleteStr;
	use nom::ErrorKind;

	named!(block<CompleteStr, Vec<(CompleteStr, CompleteStr)>>,
	do_parse!(
	tag!("BEGIN") >>

boxdot / Cargo.toml

Last active October 9, 2018 09:20

Example of a hyper service/server with rate limiting of requests

boxdot / elm-time.rs

Created February 26, 2018 09:45

	#![allow(dead_code)]

	extern crate futures;
	extern crate time;

	use futures::prelude::*;
	use futures::sync::mpsc::{channel, Receiver};
	use time::{Tm, now_utc};

	use std::{thread};

boxdot / client.rs

Last active February 2, 2018 16:46

	impl Client {
	pub fn connect(
	handle: &Handle,
	uri: hyper::Uri,
	framework_info: mesos::FrameworkInfo,
	) -> Box<Future<Item = Self, Error = failure::Error>> {
	// Mesos subscribe essage
	let mut call = scheduler::Call::new();
	let mut subscribe = scheduler::Call_Subscribe::new();
	subscribe.set_framework_info(framework_info);

boxdot / csv.rs

Created November 4, 2017 22:18

boxdot / before_after.rs

Created April 26, 2017 20:19

	// before
	fn parse_args<Iter>(mut args: Iter) -> Result<Args, &'static str>
	where Iter: Iterator<Item = String>
	{
	let hostname = match args.next() {
	Some(s) => s,
	None => return Err("argument 'hostname' missing"),
	};

	let port: u16 = match args.next() {

	fn some_test -> Result<(), Error> {
	let mut rt = tokio::runtime::Runtime::new().unwrap();

	rt.spawn(microservice_1.map_err(\|e\| panic!(e)));
	rt.spawn(microservice_2.map_err(\|e\| panic!(e)));
	rt.spawn(microservice_3.map_err(\|e\| panic!(e)));
	rt.spawn(microservice_4.map_err(\|e\| panic!(e)));

	// do testing and do not touch rt anymore
	}