add cita sync module test

app/models/cita_sync/api.rb

@@ -2,7 +2,7 @@ module CitaSync
   class Api
     class << self
 
-      # New methods without prefix in CITA v0.16
+      # New methods without prefix since CITA v0.16
       METHOD_NAMES = %w(
         peerCount
         blockNumber

spec/models/cita_sync/api_spec.rb

@@ -0,0 +1,50 @@
+require 'rails_helper'
+
+RSpec.describe CitaSync::Api, type: :model do
+
+  before do
+    mock_all
+  end
+
+  def is_hex?(str)
+    !str.remove("0x")[/\H/]
+  end
+
+  context "call_rpc" do
+    it "call blockNumber in chain only method name given" do
+      resp_body = CitaSync::Api.call_rpc("blockNumber")
+      expect(is_hex?(resp_body["result"])).to be true
+    end
+
+    # it "given jsonrpc param" do
+    #   resp_body = CitaSync::Api.call_rpc("blockNumber", jsonrpc: "3.0")
+    #   expect(resp_body).to be nil
+    # end
+
+    # let(:id) { 42 }
+    # it "given id param" do
+    #   resp_body = CitaSync::Api.call_rpc("blockNumber", id: id)
+    #   expect(resp_body["id"]).to eq id
+    #   expect(is_hex?(resp_body["result"])).to be true
+    # end
+  end
+
+  context "define method" do
+    it "call block_number" do
+      resp_body = CitaSync::Api.block_number
+      expect(is_hex?(resp_body["result"])).to be true
+    end
+
+    let(:block_number) { "0x0" }
+    it "call get_block_by_number" do
+      resp_body = CitaSync::Api.get_block_by_number(block_number, true)
+      expect(resp_body["result"]).not_to be nil
+    end
+
+    # it "call get_block_by_number with wrong param length" do
+    #   resp_body = CitaSync::Api.get_block_by_number(block_number)
+    #   expect(resp_body["result"]).to be nil
+    #   expect(resp_body["error"]).not_to be nil
+    # end
+  end
+end

spec/models/cita_sync/basic_spec.rb

@@ -0,0 +1,19 @@
+require 'rails_helper'
+
+RSpec.describe CitaSync::Basic, type: :model do
+  let(:number) { 100 }
+  let(:hex_str) { "0x64" }
+
+  context "number_to_hex_str" do
+    it 'convert decimal number to hex number string' do
+      expect(CitaSync::Basic.number_to_hex_str(100)).to eq hex_str
+    end
+  end
+
+  context "hex_str_to_number" do
+    it "convert hex number string to decimal number" do
+      expect(CitaSync::Basic.hex_str_to_number(hex_str)).to eq number
+    end
+  end
+
+end

spec/models/cita_sync/persist_spec.rb

@@ -0,0 +1,91 @@
+require 'rails_helper'
+
+RSpec.describe CitaSync::Api, type: :model do
+
+  before do
+    mock_all
+  end
+
+  context "save block" do
+    it "save block with it's transaction info in body" do
+      expect {
+        CitaSync::Persist.save_block("0x0")
+      }.to change { ::Block.count }.by(1)
+    end
+  end
+
+  context "save transaction" do
+    it "save transaction" do
+      block = CitaSync::Persist.save_block("0x1")
+      transaction = CitaSync::Persist.save_transaction(transaction_hash)
+      expect(transaction.cita_hash).to eq transaction_hash
+      expect(transaction.errors.full_messages).to be_empty
+      expect(transaction.block).to eq block
+    end
+
+    it "save transaction with block param" do
+      block = CitaSync::Persist.save_block("0x1")
+      transaction = CitaSync::Persist.save_transaction(transaction_hash, block)
+      expect(transaction.cita_hash).to eq transaction_hash
+      expect(transaction.errors.full_messages).to be_empty
+      expect(transaction.block).to eq block
+    end
+
+    it "save transaction without block will be fail" do
+      transaction = CitaSync::Persist.save_transaction(transaction_hash)
+      expect(transaction.errors.full_messages).not_to be_empty
+    end
+  end
+
+  context "save meta data" do
+    it "save success" do
+      CitaSync::Persist.save_block("0x0")
+      meta_data = CitaSync::Persist.save_meta_data("0x0")
+      expect(meta_data.errors.full_messages).to be_empty
+    end
+  end
+
+  context "save balance" do
+    it "save success" do
+      balance, = CitaSync::Persist.save_balance(account_address, "0x0")
+      expect(balance.errors.full_messages).to be_empty
+    end
+  end
+
+  context "save abi" do
+    it "save abi" do
+      abi, = CitaSync::Persist.save_abi(account_address, "0x0")
+      expect(abi.errors.full_messages).to be_empty
+    end
+  end
+
+  context "save block with infos" do
+    it "save success" do
+      CitaSync::Persist.save_block_with_infos("0x1")
+      block = Block.first
+      transaction = Transaction.first
+      meta_data = MetaData.first
+      expect(Block.count).to eq 1
+      expect(Transaction.count).to eq 1
+      expect(transaction.block_number).to eq block.header["number"]
+      expect(transaction.block).to eq block
+      expect(meta_data.block).to eq block
+    end
+  end
+
+  context "save blocks with infos" do
+    it "save blocks with transactions with empty db" do
+      CitaSync::Persist.save_blocks_with_infos
+      expect(Block.count).to eq 2
+      expect(Transaction.count).to eq 1
+      expect(MetaData.count).to eq Block.count
+    end
+
+    it "save blocks with transactions with exist block" do
+      CitaSync::Persist.save_block("0x0")
+      CitaSync::Persist.save_blocks_with_infos
+      expect(Block.count).to eq 2
+      expect(Transaction.count).to eq 1
+    end
+  end
+end

spec/rails_helper.rb

@@ -9,12 +9,15 @@
 require "database_cleaner"
 require 'simplecov'
 SimpleCov.start
+require "webmock/rspec"
 
 if ENV['CI'] == 'true'
   require 'codecov'
   SimpleCov.formatter = SimpleCov::Formatter::Codecov
 end
 
+Dir[Rails.root.join('spec/supports/**/*.rb')].each { |f| require f }
+
 # Requires supporting ruby files with custom matchers and macros, etc, in
 # spec/support/ and its subdirectories. Files matching `spec/**/*_spec.rb` are
 # run as spec files by default. This means that files in spec/support that end
@@ -72,4 +75,7 @@
   end
 
   config.include FactoryBot::Syntax::Methods
+
+  # add supports
+  config.include BlockMockSupport
 end

spec/supports/block_mock_support.rb

@@ -0,0 +1,157 @@
+module BlockMockSupport
+  extend ActiveSupport::Concern
+
+  included do
+    def stub_request_wrapper(method, params, result)
+      include_hash = if params.nil?
+                       { method: method }
+                     else
+                       { method: method, params: params }
+                     end
+      stub_request(:post, ENV["CITA_URL"])
+        .with(
+          body: hash_including(include_hash),
+          headers: { "Content-Type": "application/json" }
+        )
+        .to_return(
+          status: 200,
+          body: { jsonrpc: "2.0", id: 83, result: result }.to_json
+        )
+    end
+
+    let(:block_number_result) { "0x1" }
+    let(:mock_block_number) do
+      stub_request_wrapper("blockNumber", nil, block_number_result)
+    end
+
+    let(:block_zero_hash) { "0x542ff7aeccbd2b269c36e134e3c0a1be103b389dc9ed90a55c1d506e00b77b81" }
+    let(:block_zero_result) do
+      {
+        "version": 0,
+        "hash": block_zero_hash,
+        "header": {
+          "timestamp": 1529377997246,
+          "prevHash": "0x0000000000000000000000000000000000000000000000000000000000000000",
+          "number": "0x0",
+          "stateRoot": "0x9b3609aca48d23cadcbab0d768fa0d2187807a23f4ae19742db128a9a64f3bfc",
+          "transactionsRoot": "0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421",
+          "receiptsRoot": "0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421",
+          "gasUsed": "0x0",
+          "proof": nil,
+          "proposer": "0x0000000000000000000000000000000000000000"
+        },
+        "body": {
+          "transactions": []
+        }
+      }
+    end
+    let(:mock_get_block_by_number_zero) do
+      stub_request_wrapper("getBlockByNumber", ["0x0", true], block_zero_result)
+    end
+
+    let(:block_one_hash) { "0xa18f9c384107d9a4fcd2fae656415928bd921047519fea5650cba394f6b6142b" }
+    let(:block_one_result) do
+      {
+        "version" => 0,
+        "hash" => block_one_hash,
+        "header" => {
+          "timestamp" => 1528702183591,
+          "prevHash" => "0xda8991b9cbc7f7bc56e94abbd7056dffc501603a4ab6bcaa7e2ed08b3e58e554",
+          "number" => "0x1",
+          "stateRoot" => "0x048523e8326427968d05673210cc77a8f76e60d0b9170d1bdc1d49c131da9c85",
+          "transactionsRoot" => "0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421",
+          "receiptsRoot" => "0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421",
+          "gasUsed" => "0x0",
+          "proof" => nil,
+          "proposer" => "0x91827976af27e1fd405469b00dc8d3b0ea2203f6"
+        },
+        "body" => {
+          "transactions" => [
+            {
+              "hash": "0xee969624a87a51fc4acc958a3bb83ca32539ee54ebb4215668fe1029eeab59d4",
+              "content": "0x0a1d186420e7192a14627306090abab3a6e1400e9345bc60c78a8bef57380112410422a3159ad636e779ad530dfca184ed3f88183f1be05be6dda4ad820791b0798fe1382cb0396c3563cc6d41f743722ea3918beb8fd343079c2b79eb085f699401"
+            }
+          ]
+        }
+      }
+    end
+    let(:mock_get_block_by_number_one) do
+      stub_request_wrapper("getBlockByNumber", ["0x1", true], block_one_result)
+    end
+
+    let(:transaction_hash) { "0xee969624a87a51fc4acc958a3bb83ca32539ee54ebb4215668fe1029eeab59d4" }
+    let(:transaction_result) do
+      {
+        "hash": transaction_hash,
+        "content": "0x0a1d186420e7192a14627306090abab3a6e1400e9345bc60c78a8bef57380112410422a3159ad636e779ad530dfca184ed3f88183f1be05be6dda4ad820791b0798fe1382cb0396c3563cc6d41f743722ea3918beb8fd343079c2b79eb085f699401",
+        "blockNumber": "0x1",
+        "blockHash": block_one_hash,
+        "index": "0x0"
+      }
+    end
+    let(:mock_get_transaction) do
+      stub_request_wrapper("getTransaction", ["0xee969624a87a51fc4acc958a3bb83ca32539ee54ebb4215668fe1029eeab59d4"], transaction_result)
+    end
+
+    let(:transaction_receipt_result) do
+      {
+        "contractAddress": "0x89be88054e2ee94911549be521ab1241c7700a1b",
+        "gasUsed": "0x2d483"
+      }
+    end
+    let(:mock_get_transaction_receipt) do
+      stub_request_wrapper("getTransactionReceipt", [transaction_hash], transaction_receipt_result)
+    end
+
+    let(:meta_data_result) do
+      {
+        "blockInterval": 3000,
+        "chainId": 1,
+        "chainName": "test-chain",
+        "genesisTimestamp": 1530164125967,
+        "operator": "test-operator",
+        "tokenAvatar": "https://avatars1.githubusercontent.com/u/35361817",
+        "tokenName": "Nervos",
+        "tokenSymbol": "NOS",
+        "validators": [
+          "0x365d339609728590ec0803a73b95c24fde718846",
+          "0xf1551b918a4f43c1b72d322b8f91d4caebc249de",
+          "0x6e66c49ed7cf07754cd5794a43d41704b7c1e217",
+          "0xb4061fa8e18654a7d51fef3866d45bb1dc688717"
+        ],
+        "website": "https://www.example.com"
+      }
+    end
+    let(:mock_get_meta_data) do
+      stub_request_wrapper("getMetaData", ["0x0"], meta_data_result)
+      stub_request_wrapper("getMetaData", ["0x1"], meta_data_result)
+    end
+
+    let(:account_address) { "0x0dcf740686de1fe9e9faa4b519767a872e1cf69e" }
+    let(:balance_result) do
+      "0x0"
+    end
+    let(:mock_get_balance) do
+      stub_request_wrapper("getBalance", [account_address, "0x0"], balance_result)
+    end
+
+    let(:abi_result) do
+      "0x"
+    end
+    let(:mock_get_abi) do
+      stub_request_wrapper("getAbi", [account_address, "0x0"], abi_result)
+    end
+
+    let(:mock_all) do
+      mock_block_number
+      mock_get_block_by_number_zero
+      mock_get_block_by_number_one
+      mock_get_transaction
+      mock_get_transaction
+      mock_get_transaction_receipt
+      mock_get_meta_data
+      mock_get_balance
+      mock_get_abi
+    end
+  end
+end