{"header":{"message":"Second update","description":null,"timestamp":"2023-08-27T04:29:52.141602Z","authors":[{}]},"hash":"WJECS5UEYKERBGCBZROJLHR7LKA2UJOCEIXXCMZWRJXCZM5E7GYAC","authors":[{"key":"EDe4uae8Qq8PE9CSEr1tKCsAFQ2XmsskNU3CkZx76JUS"}],"deps":{"hashes":[["WJECS5UEYKERBGCBZROJLHR7LKA2UJOCEIXXCMZWRJXCZM5E7GYAC","Second update"],["AA",null],["C56DKOEPHH4TMIFTWDWYTHCIR2FVGOS2A5J5LQYKWJGQ5TK6OJ6AC","Initial commit"]],"deps":["C56DKOEPHH4TMIFTWDWYTHCIR2FVGOS2A5J5LQYKWJGQ5TK6OJ6AC"],"known":[]},"hunks":[{"Edit":{"inode":{"change":2,"pos":116},"path":"test/message_test.exs","line":16,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":432},"to":{"change":2,"start":432,"end":433},"introduced_by":2}],"inode":{"change":2,"pos":116}}},"contents":[{"Del":"\n"}]}},{"Replacement":{"inode":{"change":2,"pos":116},"path":"test/message_test.exs","line":26,"ins":{"up_context":[{"change":2,"pos":734}],"down_context":[{"change":2,"pos":811}],"flag":"BLOCK","start":0,"end":75,"inode":{"change":2,"pos":116}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":734},"to":{"change":2,"start":734,"end":811},"introduced_by":2}],"inode":{"change":2,"pos":116}},"ins_contents":[{"Add":" msg = <>"}],"del_contents":[{"Del":" msg = << msg_code::binary, version::binary, uhh::binary, last::binary >>\n"}]}},{"Replacement":{"inode":{"change":2,"pos":116},"path":"test/message_test.exs","line":29,"ins":{"up_context":[{"change":2,"pos":897}],"down_context":[{"change":2,"pos":964}],"flag":"BLOCK","start":76,"end":143,"inode":{"change":2,"pos":116}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":897},"to":{"change":2,"start":897,"end":964},"introduced_by":2}],"inode":{"change":2,"pos":116}},"ins_contents":[{"Add":" assert(made_msg == <<0, 0, 0, 9, 71, 0, 2, 0, 2, 0, 0, 0, 0>>)"}],"del_contents":[{"Del":" assert(made_msg == <<0, 0, 0, 8, 71, 0, 2, 0, 2, 0, 0, 0, 0>>)\n"}]}},{"Replacement":{"inode":{"change":2,"pos":116},"path":"test/message_test.exs","line":33,"ins":{"up_context":[{"change":2,"pos":1008}],"down_context":[{"change":2,"pos":1056}],"flag":"BLOCK","start":144,"end":193,"inode":{"change":2,"pos":116}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1008},"to":{"change":2,"start":1008,"end":1056},"introduced_by":2}],"inode":{"change":2,"pos":116}},"ins_contents":[{"Add":" test_msg = Ibex.Messages.Outbound.ReqIds.t()"}],"del_contents":[{"Del":" test_msg = Ibex.Messages.Inbound.ReqIds.t()\n"}]}},{"Edit":{"inode":{"change":2,"pos":116},"path":"test/message_test.exs","line":37,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":1163}],"down_context":[{"change":2,"pos":1163}],"flag":"BLOCK","start":194,"end":498,"inode":{"change":2,"pos":116}}},"contents":[{"Add":""},{"Add":" test \"request contract details\" do"},{"Add":" test_msg = Ibex.Messages.Outbound.ReqContractDetails.t(\"1001\", \"AAPL\", \"STK\")"},{"Add":" converted = IBMessage.to_ib_api(test_msg)"},{"Add":""},{"Add":" assert("},{"Add":" converted =="},{"Add":" <<0, 0, 0, 19, 49, 48, 48, 49, 0, 56, 0, 57, 0, 65, 65, 80, 76, 0, 83, 84, 75, 0, 0>>"},{"Add":" )"},{"Add":" end"}]}},{"Edit":{"inode":{"change":2,"pos":1206},"path":"test/ibex_test.exs","line":4,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1262},"to":{"change":2,"start":1262,"end":1332},"introduced_by":2}],"inode":{"change":2,"pos":1206}}},"contents":[{"Del":"\n test \"greets the world\" do\n assert Ibex.hello() == :world\n end\n"}]}},{"Replacement":{"inode":{"change":2,"pos":1369},"path":"mix.exs","line":17,"ins":{"up_context":[{"change":2,"pos":1670}],"down_context":[{"change":2,"pos":1706}],"flag":"BLOCK","start":499,"end":570,"inode":{"change":2,"pos":1369}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1670},"to":{"change":2,"start":1670,"end":1706},"introduced_by":2}],"inode":{"change":2,"pos":1369}},"ins_contents":[{"Add":" extra_applications: [:logger],"},{"Add":" mod: {Ibex.Application, []}"}],"del_contents":[{"Del":" extra_applications: [:logger]\n"}]}},{"FileDel":{"deleted_names":[{"basename":"historical.ex","metadata":0}],"del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":2,"pos":1974},"to":{"change":2,"start":9070,"end":9107},"introduced_by":2},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":2,"pos":9107},"to":{"change":2,"start":9108,"end":9108},"introduced_by":2}],"inode":{"change":2,"pos":9108}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":9108},"to":{"change":2,"start":9109,"end":9273},"introduced_by":2}],"inode":{"change":2,"pos":9108}},"content":[{"Del":"defmodule Ibex.Messages.Historical do\n\n defmodule EarliestAvailableData do\n defstruct [:instrument, :contract, :what_to_show, :use_rth, :format_date]\n end\nend\n"}]}},{"Replacement":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":19,"ins":{"up_context":[{"change":2,"pos":8084}],"down_context":[{"change":2,"pos":8085}],"flag":"BLOCK","start":571,"end":575,"inode":{"change":2,"pos":7817}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":8084},"to":{"change":2,"start":8084,"end":8085},"introduced_by":2}],"inode":{"change":2,"pos":7817}},"ins_contents":[{"Add":"end"}],"del_contents":[{"Del":"\n"}]}},{"Edit":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":21,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":8086},"to":{"change":2,"start":8086,"end":8090},"introduced_by":2}],"inode":{"change":2,"pos":7817}}},"contents":[{"Del":"end\n"}]}},{"Edit":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":27,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":8190}],"down_context":[{"change":2,"pos":8190}],"flag":"BLOCK","start":576,"end":577,"inode":{"change":2,"pos":7817}}},"contents":[{"Add":""}]}},{"Edit":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":34,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":8323}],"down_context":[{"change":2,"pos":8323}],"flag":"BLOCK","start":578,"end":624,"inode":{"change":2,"pos":7817}}},"contents":[{"Add":" Logger.debug(\"Print: #{inspect(fields)}\")"}]}},{"Edit":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":39,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":8435}],"down_context":[{"change":2,"pos":8435}],"flag":"BLOCK","start":625,"end":626,"inode":{"change":2,"pos":7817}}},"contents":[{"Add":""}]}},{"Replacement":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":47,"ins":{"up_context":[{"change":2,"pos":8613}],"down_context":[{"change":2,"pos":8692}],"flag":"BLOCK","start":627,"end":719,"inode":{"change":2,"pos":7817}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":8613},"to":{"change":2,"start":8613,"end":8692},"introduced_by":2}],"inode":{"change":2,"pos":7817}},"ins_contents":[{"Add":" code = Ibex.Messages.Types.Inbound.parse(String.to_integer(code))"},{"Add":" {l, code, fields}"}],"del_contents":[{"Del":" Ibex.Messages.Types.Inbound.parse(String.to_integer(code))\n {l, fields}\n"}]}},{"Edit":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":57,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":8832},"to":{"change":2,"start":8832,"end":8884},"introduced_by":2}],"inode":{"change":2,"pos":7817}}},"contents":[{"Del":" import Ibex.Message, only: [message_version: 0]\n"}]}},{"Replacement":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":60,"ins":{"up_context":[{"change":2,"pos":8949}],"down_context":[{"change":2,"pos":8988}],"flag":"BLOCK","start":720,"end":721,"inode":{"change":2,"pos":7817}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":8949},"to":{"change":2,"start":8949,"end":8988},"introduced_by":2}],"inode":{"change":2,"pos":7817}},"ins_contents":[{"Add":""}],"del_contents":[{"Del":" Logger.debug(\"Code is: #{code}\")\n"}]}},{"Edit":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":65,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":9043}],"down_context":[{"change":2,"pos":9043}],"flag":"BLOCK","start":722,"end":1020,"inode":{"change":2,"pos":7817}}},"contents":[{"Add":" ]"},{"Add":" end"},{"Add":" end"},{"Add":""},{"Add":" defmodule ReqContractDetails do"},{"Add":" alias Ibex.Messages.Types.Outbound, as: Outbound"},{"Add":""},{"Add":" def t(req_id, symbol, sec_type) do"},{"Add":" code = to_string(Outbound.parse(:req_contract_data))"},{"Add":""},{"Add":" ["},{"Add":" code,"},{"Add":" <<\"8\">>,"},{"Add":" req_id,"},{"Add":" symbol,"},{"Add":" sec_type"}]}},{"Edit":{"inode":{"change":2,"pos":7817},"path":"lib/messages/message.ex","line":84,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":9065}],"down_context":[{"change":2,"pos":9065}],"flag":"BLOCK","start":1021,"end":1844,"inode":{"change":2,"pos":7817}}},"contents":[{"Add":""},{"Add":" defmodule ReqMatchingSymbols do"},{"Add":" alias Ibex.Messages.Types.Outbound, as: Outbound"},{"Add":""},{"Add":" def t(reqId, symbol) do"},{"Add":" code = to_string(Outbound.parse(:req_matching_symbols))"},{"Add":""},{"Add":" ["},{"Add":" code,"},{"Add":" reqId,"},{"Add":" symbol"},{"Add":" ]"},{"Add":" end"},{"Add":" end"},{"Add":""},{"Add":" defmodule ReqHistoricalData do"},{"Add":" alias Ibex.Messages.Types.Outbound, as: Outbound"},{"Add":" @version <<\"6\">>"},{"Add":""},{"Add":" def t("},{"Add":" req_id,"},{"Add":" contract,"},{"Add":" end_date_time,"},{"Add":" duration_str,"},{"Add":" bar_size_setting,"},{"Add":" what_to_show,"},{"Add":" useRTH,"},{"Add":" formatDate,"},{"Add":" keepUpToDate,"},{"Add":" chartOption"},{"Add":" ) do"},{"Add":" code = to_string(Outbound.parse(:req_historical_data))"},{"Add":" contract_fields = contract.to_fields()"},{"Add":""},{"Add":" ["},{"Add":" code,"},{"Add":" @version,"},{"Add":" req_id,"},{"Add":" contract[:con_id]"},{"Add":" ]"},{"Add":" end"},{"Add":" end"}]}},{"Replacement":{"inode":{"change":2,"pos":9306},"path":"lib/ibex.ex","line":5,"ins":{"up_context":[{"change":2,"pos":9376}],"down_context":[{"change":2,"pos":9418}],"flag":"BLOCK","start":1845,"end":1849,"inode":{"change":2,"pos":9306}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":9376},"to":{"change":2,"start":9376,"end":9418},"introduced_by":2}],"inode":{"change":2,"pos":9306}},"ins_contents":[{"Add":"end"}],"del_contents":[{"Del":"\n @doc \"\"\"\n Hello world.\n\n ## Examples\n"}]}},{"Replacement":{"inode":{"change":2,"pos":9306},"path":"lib/ibex.ex","line":7,"ins":{"up_context":[{"change":2,"pos":9419}],"down_context":[{"change":2,"pos":9495}],"flag":"BLOCK","start":1850,"end":2206,"inode":{"change":2,"pos":9306}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":9419},"to":{"change":2,"start":9419,"end":9495},"introduced_by":2}],"inode":{"change":2,"pos":9306}},"ins_contents":[{"Add":"defmodule Ibex.Types do"},{"Add":" @type contract_symbol :: String.t()"},{"Add":" @type contract_currency :: String.t()"},{"Add":" @type contract_sec_type ::"},{"Add":" :STK"},{"Add":" | :ETF"},{"Add":" | :OPT"},{"Add":" | :FUT"},{"Add":" | :IND"},{"Add":" | :FOP"},{"Add":" | :CASH"},{"Add":" | :BAG"},{"Add":" | :WAR"},{"Add":" | :BOND"},{"Add":" | :CMDTY"},{"Add":" | :NEWS"},{"Add":" | :FUND"}],"del_contents":[{"Del":" iex> Ibex.hello()\n :world\n\n \"\"\"\n def hello do\n :world\n end\n"}]}},{"FileAdd":{"meta":{"basename":"ibex","metadata":576},"context":[{"change":2,"pos":1952}],"contents":[]}},{"FileAdd":{"meta":{"basename":"application.ex","metadata":0},"context":[{"change":0,"pos":2223}],"contents":[{"Add":"defmodule Ibex.Application do"},{"Add":" # See https://hexdocs.pm/elixir/Application.html"},{"Add":" # for more information on OTP Applications"},{"Add":" @moduledoc false"},{"Add":""},{"Add":" use Application"},{"Add":" require Logger"},{"Add":" @impl true"},{"Add":" def start(_type, _args) do"},{"Add":" Logger.info(\"Starting Ibex.Application...\")"},{"Add":""},{"Add":" children = ["},{"Add":" IBClient,"},{"Add":" Ibex.Inbound.Handler,"},{"Add":" Ibex.Contracts.Storage,"},{"Add":" ]"},{"Add":""},{"Add":" opts = [strategy: :one_for_one, name: Ibex.Supervisor]"},{"Add":" Supervisor.start_link(children, opts)"},{"Add":" end"},{"Add":"end"}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":9,"ins":{"up_context":[{"change":2,"pos":9699}],"down_context":[{"change":2,"pos":9700}],"flag":"BLOCK","start":2747,"end":2911,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":9699},"to":{"change":2,"start":9699,"end":9700},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" @initial_state %{"},{"Add":" socket: nil,"},{"Add":" conn_state: :disconnected,"},{"Add":" server_api: nil,"},{"Add":" server_connect_time: nil,"},{"Add":" next_id: 0,"},{"Add":" inbound_handler: nil"},{"Add":" }"}],"del_contents":[{"Del":"\n"}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":23,"ins":{"up_context":[{"change":2,"pos":9844}],"down_context":[{"change":2,"pos":10012}],"flag":"BLOCK","start":2912,"end":2960,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":9844},"to":{"change":2,"start":9844,"end":10012},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" GenServer.start(__MODULE__, @initial_state)"}],"del_contents":[{"Del":" GenServer.start(__MODULE__, %{\n socket: nil,\n conn_state: :disconnected,\n server_api: nil,\n server_connect_time: nil,\n next_id: 0\n })\n"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":26,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":10019}],"down_context":[{"change":2,"pos":10019}],"flag":"BLOCK","start":2961,"end":3128,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":" def start_link(opt) do"},{"Add":" Logger.info(\"Starting IBClient as a supervised process...\")"},{"Add":" GenServer.start_link(__MODULE__, @initial_state, name: __MODULE__)"},{"Add":" end"},{"Add":""}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":38,"ins":{"up_context":[{"change":2,"pos":10135}],"down_context":[{"change":2,"pos":10604}],"flag":"BLOCK","start":3129,"end":3637,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":10135},"to":{"change":2,"start":10135,"end":10604},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" case state[:conn_state] do"},{"Add":" :disconnected ->"},{"Add":" connect_to_server(state)"},{"Add":""},{"Add":" :send_api_version ->"},{"Add":" send_version(state)"},{"Add":""},{"Add":" :waiting_on_version_resp ->"},{"Add":" wait_for_api_version_response(state)"},{"Add":""},{"Add":" :sending_start_api ->"},{"Add":" start_api(state)"},{"Add":""},{"Add":" :waiting_on_start_api_resp ->"},{"Add":" wait_for_start_api_resp(state)"},{"Add":""},{"Add":" :transition_to_non_blocking ->"},{"Add":" transition_to_nonblocking(state)"},{"Add":""},{"Add":" :connected ->"},{"Add":" state"},{"Add":" end"},{"Add":""}],"del_contents":[{"Del":" case state[:conn_state] do\n :disconnected ->\n connect_to_server(state)\n :send_api_version ->\n send_version(state)\n :waiting_on_version_resp ->\n wait_for_api_version_response(state)\n :sending_start_api ->\n start_api(state)\n :waiting_on_start_api_resp ->\n wait_for_start_api_resp(state)\n :transition_to_non_blocking ->\n transition_to_nonblocking(state)\n :connected ->\n state\n end\n"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":75,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":10923},"to":{"change":2,"start":10923,"end":10970},"introduced_by":2}],"inode":{"change":2,"pos":9536}}},"contents":[{"Del":" Logger.debug(\"Requesting account summary\")\n"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":81,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":11137},"to":{"change":2,"start":11137,"end":11185},"introduced_by":2}],"inode":{"change":2,"pos":9536}}},"contents":[{"Del":" Logger.info(\"Requesting next valid IDs...\")\n"}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":84,"ins":{"up_context":[{"change":2,"pos":11266}],"down_context":[{"change":2,"pos":11311}],"flag":"BLOCK","start":3638,"end":3639,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":11266},"to":{"change":2,"start":11266,"end":11311},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":""}],"del_contents":[{"Del":" Logger.debug(\"Sending: #{inspect(msg)}\")\n"}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":86,"ins":{"up_context":[{"change":2,"pos":11356}],"down_context":[{"change":2,"pos":11380}],"flag":"BLOCK","start":3640,"end":3662,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":11356},"to":{"change":2,"start":11356,"end":11380},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" {:noreply, state}"}],"del_contents":[{"Del":" {:noreply, state}\n"}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":90,"ins":{"up_context":[{"change":2,"pos":11432}],"down_context":[{"change":2,"pos":11479}],"flag":"BLOCK","start":3663,"end":3867,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":11432},"to":{"change":2,"start":11432,"end":11479},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" <> = data"},{"Add":" Logger.debug(\"Data is: #{inspect(data)}. Length is: #{inspect(l)}\")"},{"Add":" fields = String.split(rest, <<0>>)"},{"Add":" send(Ibex.Inbound.Handler, {:dispatch, fields})"}],"del_contents":[{"Del":" Logger.debug(\"Received: #{inspect(data)}\")\n"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":99,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":11651}],"down_context":[{"change":2,"pos":11651}],"flag":"BLOCK","start":3868,"end":4265,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":""},{"Add":" def handle_info({:req_stock_contract_details, ticker}, state) do"},{"Add":" {req_id, state} = next_id(state)"},{"Add":""},{"Add":" msg ="},{"Add":" Ibex.Messages.Outbound.ReqContractDetails.t(to_string(req_id), ticker, \"STK\")"},{"Add":" |> IBMessage.to_ib_api()"},{"Add":""},{"Add":" :ok = :gen_tcp.send(state[:socket], msg)"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info({:symbol_search, symbol}, state) do"},{"Add":" {req_id, state} = next_id(state)"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":114,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":11652}],"down_context":[{"change":2,"pos":11652}],"flag":"BLOCK","start":4266,"end":4505,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":" msg ="},{"Add":" Ibex.Messages.Outbound.ReqMatchingSymbols.t(to_string(req_id), symbol)"},{"Add":" |> IBMessage.to_ib_api()"},{"Add":""},{"Add":" :ok = :gen_tcp.send(state[:socket], msg)"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" @doc \"\"\""},{"Add":" Catch-call for handle_info"},{"Add":" \"\"\""}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":135,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":11907}],"down_context":[{"change":2,"pos":11907}],"flag":"BLOCK","start":4506,"end":4565,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":" @spec handle({:disconnect, any}, any) :: {:noreply, any}"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":150,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":12319}],"down_context":[{"change":2,"pos":12319}],"flag":"BLOCK","start":4566,"end":4567,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":""}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":159,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":12528}],"down_context":[{"change":2,"pos":12528}],"flag":"BLOCK","start":4568,"end":4569,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":""}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":163,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":12678}],"down_context":[{"change":2,"pos":12678}],"flag":"BLOCK","start":4570,"end":4571,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":""}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":172,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":12896}],"down_context":[{"change":2,"pos":12896}],"flag":"BLOCK","start":4572,"end":4573,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":""}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":176,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":13053}],"down_context":[{"change":2,"pos":13053}],"flag":"BLOCK","start":4574,"end":4575,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":""}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":185,"ins":{"up_context":[{"change":2,"pos":13286}],"down_context":[{"change":2,"pos":13329}],"flag":"BLOCK","start":4576,"end":4625,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":13286},"to":{"change":2,"start":13286,"end":13329},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" {length, code, data} = wait_for_data(state)"},{"Add":""}],"del_contents":[{"Del":" {_length, data} = wait_for_data(state)\n"}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":190,"ins":{"up_context":[{"change":2,"pos":13381}],"down_context":[{"change":2,"pos":13624}],"flag":"BLOCK","start":4626,"end":4893,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":13381},"to":{"change":2,"start":13381,"end":13624},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" Logger.info("},{"Add":" \"Extracting Server API version from fields. Version: #{Enum.at(data, 0)}. Time: #{Enum.at(data, 1)}\""},{"Add":" )"},{"Add":""},{"Add":" state = %{state | server_api: Enum.at(data, 0)}"},{"Add":" %{state | server_connect_time: Enum.at(data, 1)}"},{"Add":""}],"del_contents":[{"Del":" Logger.info(\"Extracting Server API version from fields. Version: #{Enum.at(data, 0)}. Time: #{Enum.at(data, 1)}\")\n state = %{ state | server_api: Enum.at(data, 0)}\n %{ state | server_connect_time: Enum.at(data, 1)}\n"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":198,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":13637}],"down_context":[{"change":2,"pos":13637}],"flag":"BLOCK","start":4894,"end":4982,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":" Logger.info(\"Resposne from API Version Request was longer: #{inspect(data)}\")"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":201,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":13663}],"down_context":[{"change":2,"pos":13663}],"flag":"BLOCK","start":4983,"end":4984,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":""}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":207,"ins":{"up_context":[{"change":2,"pos":13810}],"down_context":[{"change":2,"pos":13835}],"flag":"BLOCK","start":4985,"end":5368,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":13810},"to":{"change":2,"start":13810,"end":13835},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" {:ok, data} = :gen_tcp.recv(state[:socket], 0)"},{"Add":" <> = data"},{"Add":" <<_::binary-size(l), rest::binary>> = rest"},{"Add":" <> = rest"},{"Add":""},{"Add":" stripped = String.split(msg2, <<0>>)"},{"Add":" Logger.debug(\"Next valid order ID is #{Enum.at(stripped, 1)}\")"},{"Add":" state = %{state | next_id: String.to_integer(Enum.at(stripped, 1))}"}],"del_contents":[{"Del":" wait_for_data(state)\n"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":219,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":13928}],"down_context":[{"change":2,"pos":13928}],"flag":"BLOCK","start":5369,"end":5422,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":" Logger.info(\"Waiting synchronously for data...\")"}]}},{"Replacement":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":227,"ins":{"up_context":[{"change":2,"pos":14172}],"down_context":[{"change":2,"pos":14212}],"flag":"BLOCK","start":5423,"end":5461,"inode":{"change":2,"pos":9536}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":14172},"to":{"change":2,"start":14172,"end":14212},"introduced_by":2}],"inode":{"change":2,"pos":9536}},"ins_contents":[{"Add":" %{state | conn_state: :connected}"}],"del_contents":[{"Del":" %{ state | conn_state: :connected }\n"}]}},{"Edit":{"inode":{"change":2,"pos":9536},"path":"lib/ibclient.ex","line":230,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":14219}],"down_context":[{"change":2,"pos":14219}],"flag":"BLOCK","start":5462,"end":5588,"inode":{"change":2,"pos":9536}}},"contents":[{"Add":" defp next_id(state) do"},{"Add":" next_id = state[:next_id]"},{"Add":" state = %{state | next_id: next_id + 1}"},{"Add":" {next_id, state}"},{"Add":" end"}]}},{"FileAdd":{"meta":{"basename":"handlers","metadata":576},"context":[{"change":2,"pos":1952}],"contents":[]}},{"FileAdd":{"meta":{"basename":"inbound.ex","metadata":0},"context":[{"change":0,"pos":5609}],"contents":[{"Add":"defmodule Ibex.Inbound.Handler do"},{"Add":" use GenServer"},{"Add":" require Logger"},{"Add":" @initial_state %{}"},{"Add":" def start do"},{"Add":" Logger.debug(\"Starting Inbound...\")"},{"Add":" GenServer.start(__MODULE__, @initial_state)"},{"Add":" end"},{"Add":""},{"Add":" def start_link(_opt) do"},{"Add":" Logger.info(\"Starting Inbound as a supervised process...\")"},{"Add":" GenServer.start_link(__MODULE__, @initial_state, name: __MODULE__)"},{"Add":" end"},{"Add":""},{"Add":" def init(state) do"},{"Add":" {:ok, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info({:dispatch, fields}, state) do"},{"Add":" msg_code = String.to_integer(Enum.at(fields, 0))"},{"Add":" msg_code = Ibex.Messages.Types.Inbound.parse(msg_code)"},{"Add":" req_id = Enum.at(fields, 1)"},{"Add":" msg_body = Enum.slice(fields, 2..-1)"},{"Add":""},{"Add":" case msg_code do"},{"Add":" :contract_data ->"},{"Add":" Logger.info(\"Received contact data: #{inspect(msg_body)}\")"},{"Add":""},{"Add":" :symbol_samples ->"},{"Add":" process_symbol_samples(Enum.slice(fields, 1..-1))"},{"Add":""},{"Add":" _ ->"},{"Add":" Logger.info(\"Received unhandled message type #{msg_code}. Body was: #{inspect(msg_body)}\")"},{"Add":" end"},{"Add":""},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" defp process_symbol_samples(fields) do"},{"Add":" {req_id, fields} = chomp(fields)"},{"Add":" {num_descriptions, fields} = chomp(fields)"},{"Add":""},{"Add":" nd = Enum.at(num_descriptions, 0)"},{"Add":" nd = String.to_integer(nd)"},{"Add":" contracts = Ibex.Contracts.Inbound.SymbolSamples.extract_contracts(fields, [])"},{"Add":" Enum.each(contracts, fn contract ->"},{"Add":""},{"Add":" Logger.info(\"Sending #{inspect(contract.contract.con_id)} to storage\")"},{"Add":" if contract.contract.con_id == \"\" do"},{"Add":" nil"},{"Add":" else"},{"Add":" send(Ibex.Contracts.Storage, {:add_contract, contract})"},{"Add":" end"},{"Add":""},{"Add":" end)"},{"Add":" end"},{"Add":""},{"Add":" defp chomp(fields) do"},{"Add":" Enum.split(fields, 1)"},{"Add":" end"},{"Add":"end"},{"Add":""},{"Add":"defmodule Ibex.Contracts.Inbound.SymbolSamples do"},{"Add":" require Logger"},{"Add":" alias Ibex.Contracts.ContractDescription, as: CD"},{"Add":" def extract_contracts(fields, con_descs) do"},{"Add":""},{"Add":" {fields, con_descs} = extract_contract(fields, con_descs)"},{"Add":" case length(fields) > 0 do"},{"Add":" true ->"},{"Add":" extract_contracts(fields, con_descs)"},{"Add":" false ->"},{"Add":" con_descs"},{"Add":" end"},{"Add":""},{"Add":""},{"Add":" end"},{"Add":""},{"Add":" def extract_contract(fields, con_descs) do"},{"Add":" ncdesc = Ibex.Contracts.ContractDescription.t()"},{"Add":""},{"Add":" {con_id, fields} = chomp(fields)"},{"Add":" {symbol, fields} = chomp(fields)"},{"Add":" {sec_type, fields} = chomp(fields)"},{"Add":" {primary_exchange, fields} = chomp(fields)"},{"Add":" {currency, fields} = chomp(fields)"},{"Add":" {nDerivativeSecTypes, fields} = chomp(fields)"},{"Add":" nt = Enum.at(nDerivativeSecTypes, 0)"},{"Add":""},{"Add":" {fields, ncdesc} ="},{"Add":" if nt == nil do"},{"Add":" {fields, CD.insert_derivative_types(ncdesc, [])}"},{"Add":" else"},{"Add":" nt = String.to_integer(nt)"},{"Add":" {derivs, fields} = Enum.split(fields, nt)"},{"Add":" {fields, CD.insert_derivative_types(ncdesc, derivs)}"},{"Add":" end"},{"Add":""},{"Add":" {description, fields} = chomp(fields)"},{"Add":" {issuer_id, fields} = chomp(fields)"},{"Add":""},{"Add":" ncdesc ="},{"Add":" CD.insert_into_contract(ncdesc, :con_id, to_string(con_id))"},{"Add":" |> CD.insert_into_contract(:symbol, to_string(symbol))"},{"Add":" |> CD.insert_into_contract(:sec_type, sec_type)"},{"Add":" |> CD.insert_into_contract(:primary_exchange, primary_exchange)"},{"Add":" |> CD.insert_into_contract(:currency, currency)"},{"Add":" |> CD.insert_into_contract(:description, description)"},{"Add":" |> CD.insert_into_contract(:issuer_id, issuer_id)"},{"Add":""},{"Add":" {fields, con_descs ++ [ncdesc]}"},{"Add":" end"},{"Add":""},{"Add":" defp chomp(fields) do"},{"Add":" result = Enum.split(fields, 1)"},{"Add":" result"},{"Add":" end"},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"contracts","metadata":576},"context":[{"change":2,"pos":1952}],"contents":[]}},{"FileAdd":{"meta":{"basename":"storage.ex","metadata":0},"context":[{"change":0,"pos":8928}],"contents":[{"Add":"defmodule Ibex.Contracts.Storage do"},{"Add":" use GenServer"},{"Add":" require Logger"},{"Add":" @initial_state %{contracts: %{}}"},{"Add":" def start_link(_) do"},{"Add":" Logger.info(\"Starting Inbound as a supervised process...\")"},{"Add":" GenServer.start_link(__MODULE__, @initial_state, name: __MODULE__)"},{"Add":" end"},{"Add":""},{"Add":" def init(state) do"},{"Add":" {:ok, table_name} = :dets.open_file(:disk_storage, [type: :set])"},{"Add":" state = Map.put(state, :dets_table, table_name)"},{"Add":" {:ok, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info({:add_contract, contract_description}, state) do"},{"Add":" symbol = contract_description.contract.symbol"},{"Add":" case :dets.lookup(state[:dets_table], symbol) do"},{"Add":" [{^symbol, value}] ->"},{"Add":" Logger.info(\"Appending contract to symbol #{symbol}\")"},{"Add":" value = Map.put(value, contract_description.contract.con_id, contract_description)"},{"Add":" :dets.insert(state[:dets_table], {symbol, value})"},{"Add":" [] ->"},{"Add":" Logger.info(\"First contract for symbol #{contract_description.contract.symbol}\")"},{"Add":" :dets.insert(state[:dets_table], {contract_description.contract.symbol, %{}})"},{"Add":" end"},{"Add":""},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_call({:get_table_name}, _from, state) do"},{"Add":" {:reply, state[:dets_table], state}"},{"Add":" end"},{"Add":""},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"contract.ex","metadata":0},"context":[{"change":0,"pos":8928}],"contents":[{"Add":"defmodule Ibex.Contracts.Contract do"},{"Add":" defstruct ["},{"Add":" :con_id,"},{"Add":" :symbol,"},{"Add":" :sec_type,"},{"Add":" :last_trade_date_or_contract_month,"},{"Add":" :strike,"},{"Add":" :right,"},{"Add":" :multiplier,"},{"Add":" :exchange,"},{"Add":" :primary_exchange,"},{"Add":" :currency,"},{"Add":" :localSYmbol,"},{"Add":" :trading_class,"},{"Add":" :include_expired,"},{"Add":" :sec_id_type,"},{"Add":" :sec_id,"},{"Add":" :description,"},{"Add":" :issuer_id,"},{"Add":" :combo_legs_descrip,"},{"Add":" :combo_legs,"},{"Add":" :delta_neutral_contract"},{"Add":" ]"},{"Add":""},{"Add":" def t() do"},{"Add":" %__MODULE__{}"},{"Add":" end"},{"Add":"end"},{"Add":""},{"Add":"defmodule Ibex.Contracts.ContractDescription do"},{"Add":" defstruct [:contract, :derivative_sec_types]"},{"Add":""},{"Add":" def t() do"},{"Add":" %__MODULE__{"},{"Add":" contract: Ibex.Contracts.Contract.t(),"},{"Add":" derivative_sec_types: []"},{"Add":" }"},{"Add":" end"},{"Add":""},{"Add":" def insert_derivative_types(cd, derivs) do"},{"Add":" Map.put(cd, :derivative_sec_types, derivs)"},{"Add":" end"},{"Add":""},{"Add":" def insert_into_contract(cd, field, value) do"},{"Add":" contract = Map.get(cd, :contract)"},{"Add":" contract = Map.put(contract, field, value)"},{"Add":" Map.put(cd, :contract, contract)"},{"Add":" end"},{"Add":"end"}]}}],"owner":"kurosknight","repo":"ibex","token":"SUnpvD66KdbwQZYsMICekbzx7HA/Am8OKnA5txmRySM=","login":null}

…

Dependencies

Change contents