Client service

src/service.rs

@@ -0,0 +1,61 @@
+//! Client service.
+//!
+//!
+//!
+//!
+//!
+
+use util::*;
+use sync::*;
+use spec::Spec;
+use error::*;
+use std::env;
+use client::Client;
+
+pub struct ClientService {
+	_net_service: NetworkService<SyncMessage>,
+}
+
+impl ClientService {
+	pub fn start(spec: Spec) -> Result<ClientService, Error> {
+		let mut net_service = try!(NetworkService::start());
+		let mut dir = env::temp_dir();
+		dir.push(H32::random().hex());
+		let client = Arc::new(Client::new(spec, &dir, net_service.io().channel()).unwrap());
+		EthSync::register(&mut net_service, client.clone());
+		let client_io = Box::new(ClientIoHandler {
+			client: client
+		});
+		try!(net_service.io().register_handler(client_io));
+
+		Ok(ClientService {
+			_net_service: net_service,
+		})
+	}
+}
+
+struct ClientIoHandler {
+	client: Arc<Client>
+}
+
+impl IoHandler<NetSyncMessage> for ClientIoHandler {
+	fn initialize<'s>(&'s mut self, _io: &mut IoContext<'s, NetSyncMessage>) {
+	}
+
+	fn message<'s>(&'s mut self, _io: &mut IoContext<'s, NetSyncMessage>, net_message: &'s mut NetSyncMessage) {
+		match net_message {
+			&mut UserMessage(ref mut message) =>  {
+				match message {
+					&mut SyncMessage::BlockVerified(ref mut bytes) => {
+						Arc::get_mut(&mut self.client).unwrap().import_verified_block(mem::replace(bytes, Bytes::new()));
+					},
+					_ => {},
+				}
+
+			}
+			_ => {},
+		}
+
+	}
+}
+