// Copyright 2015-2017 Parity Technologies (UK) Ltd. // This file is part of Parity. // Parity is free software: you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // Parity is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // You should have received a copy of the GNU General Public License // along with Parity. If not, see . //! Sends HTTP notifications to a list of URLs every time new work is available. extern crate ethash; extern crate hyper; use self::hyper::header::ContentType; use self::hyper::method::Method; use self::hyper::client::{Request, Response, Client}; use self::hyper::{Next, Url}; use self::hyper::net::HttpStream; use self::ethash::SeedHashCompute; use std::io::Write; use ethereum_types::{H256, U256}; use parking_lot::Mutex; /// Trait for notifying about new mining work pub trait NotifyWork : Send + Sync { /// Fired when new mining job available fn notify(&self, pow_hash: H256, difficulty: U256, number: u64); } /// POSTs info about new work to given urls. pub struct WorkPoster { urls: Vec, client: Mutex>, seed_compute: Mutex, } impl WorkPoster { /// Create new `WorkPoster`. pub fn new(urls: &[String]) -> Self { let urls = urls.into_iter().filter_map(|u| { match Url::parse(u) { Ok(url) => Some(url), Err(e) => { warn!("Error parsing URL {} : {}", u, e); None } } }).collect(); let client = WorkPoster::create_client(); WorkPoster { client: Mutex::new(client), urls: urls, seed_compute: Mutex::new(SeedHashCompute::new()), } } fn create_client() -> Client { Client::::configure() .keep_alive(true) .build() .expect("Error creating HTTP client") } } /// Convert an Ethash difficulty to the target boundary. Basically just `f(x) = 2^256 / x`. fn difficulty_to_boundary(difficulty: &U256) -> H256 { if *difficulty <= U256::one() { U256::max_value().into() } else { (((U256::one() << 255) / *difficulty) << 1).into() } } impl NotifyWork for WorkPoster { fn notify(&self, pow_hash: H256, difficulty: U256, number: u64) { // TODO: move this to engine let target = difficulty_to_boundary(&difficulty); let seed_hash = &self.seed_compute.lock().hash_block_number(number); let seed_hash = H256::from_slice(&seed_hash[..]); let body = format!( r#"{{ "result": ["0x{}","0x{}","0x{}","0x{:x}"] }}"#, pow_hash.hex(), seed_hash.hex(), target.hex(), number ); let mut client = self.client.lock(); for u in &self.urls { if let Err(e) = client.request(u.clone(), PostHandler { body: body.clone() }) { warn!("Error sending HTTP notification to {} : {}, retrying", u, e); // TODO: remove this once https://github.com/hyperium/hyper/issues/848 is fixed *client = WorkPoster::create_client(); if let Err(e) = client.request(u.clone(), PostHandler { body: body.clone() }) { warn!("Error sending HTTP notification to {} : {}", u, e); } } } } } struct PostHandler { body: String, } impl hyper::client::Handler for PostHandler { fn on_request(&mut self, request: &mut Request) -> Next { request.set_method(Method::Post); request.headers_mut().set(ContentType::json()); Next::write() } fn on_request_writable(&mut self, encoder: &mut hyper::Encoder) -> Next { if let Err(e) = encoder.write_all(self.body.as_bytes()) { trace!("Error posting work data: {}", e); } encoder.close(); Next::read() } fn on_response(&mut self, _response: Response) -> Next { Next::end() } fn on_response_readable(&mut self, _decoder: &mut hyper::Decoder) -> Next { Next::end() } fn on_error(&mut self, err: hyper::Error) -> Next { trace!("Error posting work data: {}", err); Next::end() } }