Initial Commit

Author: gerryeng

lib/blockcypher.rb

@@ -0,0 +1,5 @@
+require 'blockcypher/api'
+require 'bitcoin'
+require 'json'
+require 'uri'
+require 'net/http'

lib/blockcypher/api.rb

@@ -0,0 +1,175 @@
+
+
+module BlockCypher
+
+	V1 = 'v1'
+
+	BTC = 'btc'
+	LTC = 'ltc'
+
+	MAIN_NET = 'main'
+	TEST_NET = 'test'
+	TEST_NET_3 = 'test3'
+
+	class Api
+
+		class Error < RuntimeError ; end
+
+		def initialize(version: V1, currency: BTC, network: MAIN_NET)
+			@version = version
+			@currency = currency
+			@network = network
+		end
+
+		##################
+		# Blockchain API
+		##################
+
+		def blockchain_transaction(transaction_hash)
+			api_http_get('/txs/' + transaction_hash)
+		end
+
+		def blockchain_block(block_index)
+			api_http_get('/blocks/' + block_index)
+		end
+
+		##################
+		# Transaction API
+		##################
+
+		def send_money(from_address, to_address, satoshi_amount, private_key)
+
+			unless to_address.kind_of? Array
+				to_address = [to_address]
+			end
+
+			tx_new = transaction_new([from_address], to_address, satoshi_amount)
+
+			transaction_sign_and_send(tx_new, private_key)
+		end
+
+		def transaction_new(input_addreses, output_addresses, satoshi_amount)
+			payload = {
+				'inputs' => [
+					{
+						addresses: input_addreses
+					}
+				],
+				'outputs' => [
+					{
+						addresses: output_addresses,
+						value: satoshi_amount
+					}
+				]
+			}
+			api_http_post('/txs/new', json_payload: payload.to_json)
+		end
+
+		def transaction_sign_and_send(new_tx, private_key)
+			key = Bitcoin::Key.new(private_key, nil, compressed = true)
+			public_key = key.pub
+			signatures = []
+			public_keys = []
+
+			new_tx['tosign'].each do |to_sign_hex|
+				public_keys << public_key
+				to_sign_binary = [to_sign_hex].pack("H*")
+				sig_binary = key.sign(to_sign_binary)
+				sig_hex = sig_binary.unpack("H*").first
+				signatures << sig_hex
+			end
+			new_tx['signatures'] = signatures
+			new_tx['pubkeys'] = public_keys
+
+			res = api_http_post('/txs/send', json_payload: new_tx.to_json)
+
+			res
+		end
+
+		##################
+		# Address APIs
+		##################
+
+		def address_generate
+			api_http_post('/addrs')
+		end
+
+		def address_details(address)
+			api_http_get('/addrs/' + address)
+		end
+
+		def address_final_balance(address)
+			details = address_details(address)
+			details['final_balance']
+
+		end
+
+		##################
+		# Events API
+		##################
+
+		def event_webhook_subscribe(url, filter, token = nil)
+			payload = {
+				url: url,
+				filter: filter,
+				token: token
+			}.to_json
+			api_http_post('/hooks', json_payload: payload)
+		end
+
+		private
+
+		def api_http_call(http_method, api_path, json_payload: nil)
+			uri = endpoint_uri(api_path)
+
+			# Build the connection
+			http    = Net::HTTP.new(uri.host, uri.port)
+			http.use_ssl = true
+
+			# Build the Request
+			if http_method == :post
+				request = Net::HTTP::Post.new(uri.request_uri)
+			elsif http_method == :get
+				request = Net::HTTP::Get.new(uri.request_uri)
+			else
+				raise 'Invalid HTTP method'
+			end
+
+			unless json_payload.nil?
+				request.content_type = 'application/json'
+				request.body = json_payload
+			end
+
+			response = http.request(request)
+
+			# Detect errors
+			if response.code == '400'
+				raise Error.new(uri.to_s + ' Response:' + response.body)
+			end
+
+			# Process the response
+			begin
+				json_response = JSON.parse(response.body)
+				return json_response
+			rescue => e
+				raise "Unable to parse JSON response #{e.inspect}, #{response.body}"
+			end
+		end
+
+		def api_http_get(api_path)
+			api_http_call :get, api_path
+		end
+
+		def api_http_post(api_path, json_payload: nil)
+			api_http_call :post, api_path, json_payload: json_payload
+		end
+
+		def endpoint_uri(api_path)
+			if api_path[0] != '/'
+				api_path += '/' + api_path
+			end
+			URI('https://api.blockcypher.com/' + @version + '/' + @currency + '/' + @network + api_path)
+		end
+
+	end
+end

spec/blockcypher/api_spec.rb

@@ -0,0 +1,52 @@
+require 'blockcypher'
+
+module BlockCypher
+
+	describe Api do
+		let(:api) { BlockCypher::Api.new(currency: BlockCypher::BTC, network: BlockCypher::TEST_NET_3, version: BlockCypher::V1) }
+
+		let(:address_1) { 'miB9s4fcYCEBxPQm8vw6UrsYc2iSiEW3Yn' }
+		let(:address_1_private_key) { 'f2a73451a726e81aec76a2bfd5a4393a89822b30cc4cddb2b4317efb2266ad47' }
+
+		let(:address_2) { 'mnTBb2Fd13pKwNjFQz9LVoy2bqmDugLM5m' }
+		let(:address_2_private_key) { '76a32c1e5b6f9e174719e7c1b555d6a55674fdc2fd99cfeee96a5de632775645' }
+
+		describe '#transaction_new' do
+
+			it 'should call the txs/new api' do
+				input_addresses = [address_1]
+				output_addresses = [address_2]
+				satoshi_value = 20000
+				res = api.transaction_new(input_addresses, output_addresses, satoshi_value)
+				expect(res["tx"]["hash"]).to be_present
+			end
+		end
+
+		describe '#transaction_sign_and_send' do
+
+			it 'should call txs/send api' do
+
+				input_addresses = [address_2]
+				output_addresses = [address_1]
+				satoshi_value = 10000
+
+				new_tx = api.transaction_new(input_addresses, output_addresses, satoshi_value)
+				res = api.transaction_sign_and_send(new_tx, address_2_private_key)
+				expect(res["tx"]["hash"]).to be_present
+			end
+
+		end
+
+		describe '#address_final_balance' do
+
+			it 'should get the balance of an address' do
+				balance = api.address_final_balance(address_1)
+				expect(balance).to be_kind_of Integer
+				expect(balance).to be > 0
+			end
+
+		end
+
+	end
+
+end