From e100ecbeacf6bac923f4b8e416621f98668b4830 Mon Sep 17 00:00:00 2001
From: Nikolay Volf <nikvolf@gmail.com>
Date: Sat, 5 Mar 2016 23:47:28 +0300
Subject: [PATCH] exposing in lib

---
 sync/src/chain.rs |  4 ++++
 sync/src/lib.rs   | 10 ++++++++++
 2 files changed, 14 insertions(+)

diff --git a/sync/src/chain.rs b/sync/src/chain.rs
index ddf30854a..fd1771045 100644
--- a/sync/src/chain.rs
+++ b/sync/src/chain.rs
@@ -1294,6 +1294,10 @@ impl ChainSync {
 			transaction_queue.add_all(txs, |a| chain.nonce(a));
 		});
 	}
+
+	pub fn transaction_queue(&self) -> &Mutex<TransactionQueue> {
+		return &self.transaction_queue;
+	}
 }
 
 #[cfg(test)]
diff --git a/sync/src/lib.rs b/sync/src/lib.rs
index d67a09f3b..a6480b0ad 100644
--- a/sync/src/lib.rs
+++ b/sync/src/lib.rs
@@ -128,6 +128,16 @@ impl EthSync {
 	pub fn restart(&mut self, io: &mut NetworkContext<SyncMessage>) {
 		self.sync.write().unwrap().restart(&mut NetSyncIo::new(io, self.chain.deref()));
 	}
+
+	/// Insert transaction in transaction queue
+	pub fn insert_transaction(&self, transaction: SignedTransaction) {
+		use util::numbers::*;
+
+		let nonce_fn = |a: &Address| self.chain.state().nonce(a) + U256::one();
+		let sync = self.sync.write().unwrap();
+		let mut queue = sync.transaction_queue().lock().unwrap();
+		queue.add(transaction, &nonce_fn);
+	}
 }
 
 impl NetworkProtocolHandler<SyncMessage> for EthSync {