{"header":{"message":"Initial commit","description":null,"timestamp":"2023-08-20T06:42:47.185139Z","authors":[{}]},"hash":"C56DKOEPHH4TMIFTWDWYTHCIR2FVGOS2A5J5LQYKWJGQ5TK6OJ6AC","authors":[{"key":"EDe4uae8Qq8PE9CSEr1tKCsAFQ2XmsskNU3CkZx76JUS"}],"deps":{"hashes":[["C56DKOEPHH4TMIFTWDWYTHCIR2FVGOS2A5J5LQYKWJGQ5TK6OJ6AC","Initial commit"],["AA",null],["EGXZWUT7TZXPTW5TPNJ5GD3QCT2UOKUF7FXRFZVPLXWQQDGGQ2IQC",""]],"deps":["EGXZWUT7TZXPTW5TPNJ5GD3QCT2UOKUF7FXRFZVPLXWQQDGGQ2IQC"],"known":[]},"hunks":[{"FileAdd":{"meta":{"basename":"test","metadata":576},"context":[{"change":2,"pos":1}],"contents":[]}},{"FileAdd":{"meta":{"basename":"test_helper.exs","metadata":0},"context":[{"change":0,"pos":16}],"contents":[{"Add":"ExUnit.start()"}]}},{"FileAdd":{"meta":{"basename":"message_test.exs","metadata":0},"context":[{"change":0,"pos":16}],"contents":[{"Add":"defmodule Ibex.MessageTest do"},{"Add":" use ExUnit.Case"},{"Add":" doctest Ibex"},{"Add":" require Ibex.Message"},{"Add":""},{"Add":" test \"adds nul to field\" do"},{"Add":" result = Ibex.Message.make_field(<<71>>)"},{"Add":" assert(result == <<71, 0>>)"},{"Add":" end"},{"Add":""},{"Add":" test \"prefixes length to message\" do"},{"Add":" msg_code = <<71>>"},{"Add":" version = <<2>>"},{"Add":" uhh = <<2>>"},{"Add":" last = <<0>>"},{"Add":""},{"Add":""},{"Add":" msg_code = Ibex.Message.make_field(msg_code)"},{"Add":" assert(msg_code == <<71, 0>>)"},{"Add":" version = Ibex.Message.make_field(version)"},{"Add":" assert(version == <<2, 0>>)"},{"Add":" uhh = Ibex.Message.make_field(uhh)"},{"Add":" assert(uhh == <<2, 0>>)"},{"Add":" last = Ibex.Message.make_field(last)"},{"Add":" assert(last == <<0, 0>>)"},{"Add":""},{"Add":" msg = << msg_code::binary, version::binary, uhh::binary, last::binary >>"},{"Add":" l = Ibex.Message.get_msg_length(msg)"},{"Add":" made_msg = Ibex.Message.make_msg(msg, l)"},{"Add":" assert(made_msg == <<0, 0, 0, 8, 71, 0, 2, 0, 2, 0, 0, 0, 0>>)"},{"Add":" end"},{"Add":""},{"Add":" test \"convert to IB API format\" do"},{"Add":" test_msg = Ibex.Messages.Inbound.ReqIds.t()"},{"Add":" converted = IBMessage.to_ib_api(test_msg)"},{"Add":" assert(converted = <<0, 0, 0, 4, 8, 0, 50, 0, 0>>)"},{"Add":" end"},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"ibex_test.exs","metadata":0},"context":[{"change":0,"pos":16}],"contents":[{"Add":"defmodule IbexTest do"},{"Add":" use ExUnit.Case"},{"Add":" doctest Ibex"},{"Add":""},{"Add":" test \"greets the world\" do"},{"Add":" assert Ibex.hello() == :world"},{"Add":" end"},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"mix.exs","metadata":0},"context":[{"change":2,"pos":1}],"contents":[{"Add":"defmodule Ibex.MixProject do"},{"Add":" use Mix.Project"},{"Add":""},{"Add":" def project do"},{"Add":" ["},{"Add":" app: :ibex,"},{"Add":" version: \"0.1.0\","},{"Add":" elixir: \"~> 1.15\","},{"Add":" start_permanent: Mix.env() == :prod,"},{"Add":" deps: deps()"},{"Add":" ]"},{"Add":" end"},{"Add":""},{"Add":" # Run \"mix help compile.app\" to learn about applications."},{"Add":" def application do"},{"Add":" ["},{"Add":" extra_applications: [:logger]"},{"Add":" ]"},{"Add":" end"},{"Add":""},{"Add":" # Run \"mix help deps\" to learn about dependencies."},{"Add":" defp deps do"},{"Add":" ["},{"Add":" # {:dep_from_hexpm, \"~> 0.3.0\"},"},{"Add":" # {:dep_from_git, git: \"https://github.com/elixir-lang/my_dep.git\", tag: \"0.1.0\"}"},{"Add":" ]"},{"Add":" end"},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"lib","metadata":576},"context":[{"change":2,"pos":1}],"contents":[]}},{"FileAdd":{"meta":{"basename":"messages","metadata":576},"context":[{"change":0,"pos":1952}],"contents":[]}},{"FileAdd":{"meta":{"basename":"types.ex","metadata":0},"context":[{"change":0,"pos":1974}],"contents":[{"Add":"defmodule Ibex.Messages.Types do"},{"Add":" @type message_type :: atom()"},{"Add":" @type code_map :: map()"},{"Add":" @type market_data_type :: :bid | :ask | :trades"},{"Add":" @type ticker_id :: integer()"},{"Add":""},{"Add":" defmodule Inbound do"},{"Add":" @type message_type :: Ibex.Messages.Types.message_type()"},{"Add":" @codes %{"},{"Add":" 1 => :tick_price,"},{"Add":" 2 => :tick_size,"},{"Add":" 3 => :order_status,"},{"Add":" 4 => :err_msg,"},{"Add":" 5 => :open_order,"},{"Add":" 6 => :acct_value,"},{"Add":" 7 => :portfolio_value,"},{"Add":" 8 => :acct_update,"},{"Add":" 9 => :next_valid,"},{"Add":" 10 => :contract_data,"},{"Add":" 11 => :execution_data,"},{"Add":" 12 => :market_depth,"},{"Add":" 13 => :market_depth,"},{"Add":" 14 => :news_bulletins,"},{"Add":" 15 => :managed_accts,"},{"Add":" 16 => :receive_fa,"},{"Add":" 17 => :historical_data,"},{"Add":" 18 => :bond_contract,"},{"Add":" 19 => :scanner_parameters,"},{"Add":" 20 => :scanner_data,"},{"Add":" 21 => :tick_option,"},{"Add":" 45 => :tick_generic,"},{"Add":" 46 => :tick_string,"},{"Add":" 47 => :tick_efp,"},{"Add":" 49 => :current_time,"},{"Add":" 50 => :real_time_bars,"},{"Add":" 51 => :fundamental_data,"},{"Add":" 52 => :contract_data_end,"},{"Add":" 53 => :open_order_end,"},{"Add":" 54 => :acct_download_end,"},{"Add":" 55 => :execution_data_end,"},{"Add":" 56 => :delta_neutral_validation,"},{"Add":" 57 => :tick_snapshot_end,"},{"Add":" 58 => :market_data_type,"},{"Add":" 59 => :commission_report,"},{"Add":" 61 => :position_data,"},{"Add":" 62 => :position_end,"},{"Add":" 63 => :account_summary,"},{"Add":" 64 => :account_summary_end,"},{"Add":" 65 => :verify_message_api,"},{"Add":" 66 => :verify_completed,"},{"Add":" 67 => :display_group_list,"},{"Add":" 68 => :display_group_updated,"},{"Add":" 69 => :verify_and_auth_message_api,"},{"Add":" 70 => :verify_and_auth_completed,"},{"Add":" 71 => :position_multi,"},{"Add":" 72 => :position_multi_end,"},{"Add":" 73 => :account_update_multi,"},{"Add":" 74 => :account_update_multi_end,"},{"Add":" 75 => :security_definition_option_parameter,"},{"Add":" 76 => :security_definition_option_parameter_end,"},{"Add":" 77 => :soft_dollar_tiers,"},{"Add":" 78 => :family_codes,"},{"Add":" 79 => :symbol_samples,"},{"Add":" 80 => :mkt_depth_exchanges,"},{"Add":" 81 => :tick_req_params,"},{"Add":" 82 => :smart_components,"},{"Add":" 83 => :news_article,"},{"Add":" 84 => :tick_news,"},{"Add":" 85 => :news_providers,"},{"Add":" 86 => :historical_news,"},{"Add":" 87 => :historical_news_end,"},{"Add":" 88 => :head_timestamp,"},{"Add":" 89 => :histogram_data,"},{"Add":" 90 => :historical_data_update,"},{"Add":" 91 => :reroute_mkt_data_req,"},{"Add":" 92 => :reroute_mkt_depth_req,"},{"Add":" 93 => :market_rule,"},{"Add":" 94 => :pnl,"},{"Add":" 95 => :pnl_single,"},{"Add":" 96 => :historical_ticks,"},{"Add":" 97 => :historical_ticks_bid_ask,"},{"Add":" 98 => :historical_ticks_last,"},{"Add":" 99 => :tick_by_tick,"},{"Add":" 100 => :order_bound,"},{"Add":" 101 => :completed_order,"},{"Add":" 102 => :completed_orders_end,"},{"Add":" 103 => :replace_fa_end,"},{"Add":" 104 => :wsh_meta_data,"},{"Add":" 105 => :wsh_event_data,"},{"Add":" 106 => :historical_schedule,"},{"Add":" 107 => :user_info"},{"Add":" }"},{"Add":""},{"Add":" @spec parse(integer()) :: message_type()"},{"Add":" def parse(code) do"},{"Add":" Map.get(@codes, code, nil)"},{"Add":" end"},{"Add":" end"},{"Add":""},{"Add":" defmodule Outbound do"},{"Add":" @type message_type :: Ibex.Messages.Types.message_type()"},{"Add":" @codes %{"},{"Add":" :req_mkt_data => 1,"},{"Add":" :cancel_mkt_data => 2,"},{"Add":" :place_order => 3,"},{"Add":" :cancel_order => 4,"},{"Add":" :req_open_orders => 5,"},{"Add":" :req_acct_data => 6,"},{"Add":" :req_executions => 7,"},{"Add":" :req_ids => 8,"},{"Add":" :req_contract_data => 9,"},{"Add":" :req_mkt_depth => 10,"},{"Add":" :cancel_mkt_depth => 11,"},{"Add":" :req_news_bulletins => 12,"},{"Add":" :cancel_news_bulletins => 13,"},{"Add":" :set_server_loglevel => 14,"},{"Add":" :req_auto_open_orders => 15,"},{"Add":" :req_all_open_orders => 16,"},{"Add":" :req_managed_accts => 17,"},{"Add":" :req_fa => 18,"},{"Add":" :replace_fa => 19,"},{"Add":" :req_historical_data => 20,"},{"Add":" :exercise_options => 21,"},{"Add":" :req_scanner_subscription => 22,"},{"Add":" :cancel_scanner_subscription => 23,"},{"Add":" :req_scanner_parameters => 24,"},{"Add":" :cancel_historical_data => 25,"},{"Add":" :req_current_time => 49,"},{"Add":" :req_real_time_bars => 50,"},{"Add":" :cancel_real_time_bars => 51,"},{"Add":" :req_fundamental_data => 52,"},{"Add":" :cancel_fundamental_data => 53,"},{"Add":" :req_calc_implied_volat => 54,"},{"Add":" :req_calc_option_price => 55,"},{"Add":" :cancel_calc_implied_volat => 56,"},{"Add":" :cancel_calc_option_price => 57,"},{"Add":" :req_global_cancel => 58,"},{"Add":" :req_market_data_type => 59,"},{"Add":" :req_positions => 61,"},{"Add":" :req_account_summary => 62,"},{"Add":" :cancel_account_summary => 63,"},{"Add":" :cancel_positions => 64,"},{"Add":" :verify_request => 65,"},{"Add":" :verify_message => 66,"},{"Add":" :query_display_groups => 67,"},{"Add":" :subscribe_to_group_events => 68,"},{"Add":" :update_display_group => 69,"},{"Add":" :unsubscribe_from_group_events => 70,"},{"Add":" :start_api => 71,"},{"Add":" :verify_and_auth_request => 72,"},{"Add":" :verify_and_auth_message => 73,"},{"Add":" :req_positions_multi => 74,"},{"Add":" :cancel_positions_multi => 75,"},{"Add":" :req_account_updates_multi => 76,"},{"Add":" :cancel_account_updates_multi => 77,"},{"Add":" :req_sec_def_opt_params => 78,"},{"Add":" :req_soft_dollar_tiers => 79,"},{"Add":" :req_family_codes => 80,"},{"Add":" :req_matching_symbols => 81,"},{"Add":" :req_mkt_depth_exchanges => 82,"},{"Add":" :req_smart_components => 83,"},{"Add":" :req_news_article => 84,"},{"Add":" :req_news_providers => 85,"},{"Add":" :req_historical_news => 86,"},{"Add":" :req_head_timestamp => 87,"},{"Add":" :req_histogram_data => 88,"},{"Add":" :cancel_histogram_data => 89,"},{"Add":" :cancel_head_timestamp => 90,"},{"Add":" :req_market_rule => 91,"},{"Add":" :req_pnl => 92,"},{"Add":" :cancel_pnl => 93,"},{"Add":" :req_pnl_single => 94,"},{"Add":" :cancel_pnl_single => 95,"},{"Add":" :req_historical_ticks => 96,"},{"Add":" :req_tick_by_tick_data => 97,"},{"Add":" :cancel_tick_by_tick_data => 98,"},{"Add":" :req_completed_orders => 99,"},{"Add":" :req_wsh_meta_data => 100,"},{"Add":" :cancel_wsh_meta_data => 101,"},{"Add":" :req_wsh_event_data => 102,"},{"Add":" :cancel_wsh_event_data => 103,"},{"Add":" :req_user_info => 104"},{"Add":" }"},{"Add":""},{"Add":" @spec parse(message_type()) :: integer()"},{"Add":" def parse(mtype) do"},{"Add":" Map.get(@codes, mtype, nil)"},{"Add":" end"},{"Add":" end"},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"message.ex","metadata":0},"context":[{"change":0,"pos":1974}],"contents":[{"Add":"defmodule Ibex.Message do"},{"Add":" require Logger"},{"Add":""},{"Add":" def make_field(f) do"},{"Add":" f <> <<0>>"},{"Add":" end"},{"Add":""},{"Add":" def make_msg(fields, l) do"},{"Add":" <> <> fields <> <<0>>"},{"Add":" end"},{"Add":""},{"Add":" def get_msg_length(msg) do"},{"Add":" byte_size(msg) + 1"},{"Add":" end"},{"Add":""},{"Add":" def message_version() do"},{"Add":" <<2>>"},{"Add":" end"},{"Add":""},{"Add":""},{"Add":"end"},{"Add":"defprotocol IBMessage do"},{"Add":" def to_ib_api(msg)"},{"Add":"end"},{"Add":""},{"Add":"defimpl IBMessage, for: List do"},{"Add":" require Logger"},{"Add":" def to_ib_api(msg) do"},{"Add":" fields ="},{"Add":" Enum.reduce(msg, <<>>, fn f, acc ->"},{"Add":" acc <> Ibex.Message.make_field(f)"},{"Add":" end)"},{"Add":""},{"Add":" length = Ibex.Message.get_msg_length(to_string(fields))"},{"Add":" Ibex.Message.make_msg(fields, length)"},{"Add":" end"},{"Add":"end"},{"Add":"defmodule Ibex.Messages.Inbound do"},{"Add":" require Logger"},{"Add":""},{"Add":" def parse(m) do"},{"Add":" <> = m"},{"Add":" fields = String.split(rest, <<0>>)"},{"Add":" code = Enum.at(fields, 0)"},{"Add":" Ibex.Messages.Types.Inbound.parse(String.to_integer(code))"},{"Add":" {l, fields}"},{"Add":" end"},{"Add":"end"},{"Add":""},{"Add":"defmodule Ibex.Messages.Outbound do"},{"Add":" require Logger"},{"Add":""},{"Add":" defmodule ReqIds do"},{"Add":" alias Ibex.Messages.Types.Outbound, as: Outbound"},{"Add":" import Ibex.Message, only: [message_version: 0]"},{"Add":""},{"Add":" def t() do"},{"Add":" code = to_string(Outbound.parse(:req_ids))"},{"Add":" Logger.debug(\"Code is: #{code}\")"},{"Add":" ["},{"Add":" code,"},{"Add":" <<\"1\">>,"},{"Add":" <<\"1\">>"},{"Add":" ]"},{"Add":" end"},{"Add":" end"},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"historical.ex","metadata":0},"context":[{"change":0,"pos":1974}],"contents":[{"Add":"defmodule Ibex.Messages.Historical do"},{"Add":""},{"Add":" defmodule EarliestAvailableData do"},{"Add":" defstruct [:instrument, :contract, :what_to_show, :use_rth, :format_date]"},{"Add":" end"},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"ibex.ex","metadata":0},"context":[{"change":0,"pos":1952}],"contents":[{"Add":"defmodule Ibex do"},{"Add":" @moduledoc \"\"\""},{"Add":" Documentation for `Ibex`."},{"Add":" \"\"\""},{"Add":""},{"Add":" @doc \"\"\""},{"Add":" Hello world."},{"Add":""},{"Add":" ## Examples"},{"Add":""},{"Add":" iex> Ibex.hello()"},{"Add":" :world"},{"Add":""},{"Add":" \"\"\""},{"Add":" def hello do"},{"Add":" :world"},{"Add":" end"},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"ibclient.ex","metadata":0},"context":[{"change":0,"pos":1952}],"contents":[{"Add":"defmodule IBClient do"},{"Add":" require Logger"},{"Add":" use GenServer"},{"Add":""},{"Add":" @ip {127, 0, 0, 1}"},{"Add":" @port 4001"},{"Add":""},{"Add":" @type connection_state() :: :disconnected | :connecting | :connected"},{"Add":""},{"Add":" def send_message(pid, message) do"},{"Add":" GenServer.cast(pid, {:message, message})"},{"Add":" end"},{"Add":""},{"Add":" def start do"},{"Add":" Logger.debug(\"Starting IBClient...\")"},{"Add":" GenServer.start(__MODULE__, %{"},{"Add":" socket: nil,"},{"Add":" conn_state: :disconnected,"},{"Add":" server_api: nil,"},{"Add":" server_connect_time: nil,"},{"Add":" next_id: 0"},{"Add":" })"},{"Add":" end"},{"Add":""},{"Add":" def init(state) do"},{"Add":" send(self(), :tick)"},{"Add":" {:ok, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info(:tick, state) do"},{"Add":" state ="},{"Add":" case state[:conn_state] do"},{"Add":" :disconnected ->"},{"Add":" connect_to_server(state)"},{"Add":" :send_api_version ->"},{"Add":" send_version(state)"},{"Add":" :waiting_on_version_resp ->"},{"Add":" wait_for_api_version_response(state)"},{"Add":" :sending_start_api ->"},{"Add":" start_api(state)"},{"Add":" :waiting_on_start_api_resp ->"},{"Add":" wait_for_start_api_resp(state)"},{"Add":" :transition_to_non_blocking ->"},{"Add":" transition_to_nonblocking(state)"},{"Add":" :connected ->"},{"Add":" state"},{"Add":" end"},{"Add":" if state[:conn_state] != :connected do"},{"Add":" Logger.info(\"Sending tick...\")"},{"Add":" Process.send_after(self(), :tick, 1000)"},{"Add":" end"},{"Add":""},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info(:start_api, state) do"},{"Add":" Logger.debug(\"Starting API...\")"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info(:req_account_summary, state) do"},{"Add":" Logger.debug(\"Requesting account summary\")"},{"Add":" msg = <<0, 0, 0, 8, \"62\", 0, 2, 0, 2, 0, 0, 0, 0>>"},{"Add":" :ok = :gen_tcp.send(state[:socket], msg)"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info(:req_ids, state) do"},{"Add":" Logger.info(\"Requesting next valid IDs...\")"},{"Add":" msg ="},{"Add":" Ibex.Messages.Outbound.ReqIds.t()"},{"Add":" |> IBMessage.to_ib_api()"},{"Add":" Logger.debug(\"Sending: #{inspect(msg)}\")"},{"Add":" :ok = :gen_tcp.send(state[:socket], msg)"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info({:tcp, _, data}, state) do"},{"Add":" Logger.debug(\"Received: #{inspect(data)}\")"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_info({:tcp_closed, _}, state), do: {:stop, :normal, state}"},{"Add":" def handle_info({:tcp_error, _}, state), do: {:stop, :normal, state}"},{"Add":""},{"Add":" def handle_info({other, _}, state) do"},{"Add":" Logger.debug(\"Received #{inspect(other)}\")"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle_cast({:message, message}, %{socket: socket} = state) do"},{"Add":" :ok = :gen_tcp.send(socket, message)"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def handle({:disconnect, _}, state) do"},{"Add":" disconnect(state, :user_requested)"},{"Add":" {:noreply, state}"},{"Add":" end"},{"Add":""},{"Add":" def disconnect(state, reason) do"},{"Add":" Logger.info(\"Disconnected: #{reason}\")"},{"Add":" {:stop, :normal, state}"},{"Add":" end"},{"Add":""},{"Add":" defp connect_to_server(state) do"},{"Add":" case :gen_tcp.connect(@ip, @port, [:binary, active: false]) do"},{"Add":" {:ok, socket} ->"},{"Add":" %{state | conn_state: :send_api_version, socket: socket}"},{"Add":" {:error, reason} ->"},{"Add":" Logger.error(\"Failed to connect to server: #{inspect(reason)}\")"},{"Add":" state"},{"Add":" end"},{"Add":" end"},{"Add":""},{"Add":" defp send_version(state) do"},{"Add":" Logger.info(\"Sending API version to server...\")"},{"Add":" case :gen_tcp.send(state[:socket], <<\"API\", 0, 0, 0, 0, 9, \"v100..177\">>) do"},{"Add":" :ok ->"},{"Add":" %{state | conn_state: :waiting_on_version_resp}"},{"Add":" {:error, reason} ->"},{"Add":" Logger.error(\"Failed to send API version string to server: #{inspect(reason)}\")"},{"Add":" state"},{"Add":" end"},{"Add":" end"},{"Add":""},{"Add":" defp start_api(state) do"},{"Add":" Logger.info(\"Sending START_API message...\")"},{"Add":" case :gen_tcp.send(state[:socket], <<0, 0, 0, 8, 55, 49, 0, 50, 0, 50, 0, 0>>) do"},{"Add":" :ok ->"},{"Add":" %{state | conn_state: :waiting_on_start_api_resp}"},{"Add":" {:error, reason} ->"},{"Add":" Logger.error(\"Failed to send StartApi message: #{inspect(reason)}\")"},{"Add":" state"},{"Add":" end"},{"Add":" end"},{"Add":""},{"Add":" defp wait_for_api_version_response(state) do"},{"Add":" Logger.info(\"Waiting for API version response...\")"},{"Add":" {_length, data} = wait_for_data(state)"},{"Add":" state ="},{"Add":" case length(data) do"},{"Add":" 3 ->"},{"Add":" Logger.info(\"Extracting Server API version from fields. Version: #{Enum.at(data, 0)}. Time: #{Enum.at(data, 1)}\")"},{"Add":" state = %{ state | server_api: Enum.at(data, 0)}"},{"Add":" %{ state | server_connect_time: Enum.at(data, 1)}"},{"Add":" _ ->"},{"Add":" state"},{"Add":" end"},{"Add":" %{state | conn_state: :sending_start_api}"},{"Add":" end"},{"Add":""},{"Add":" defp wait_for_start_api_resp(state) do"},{"Add":" Logger.info(\"Waiting for START_API response...\")"},{"Add":" wait_for_data(state)"},{"Add":" %{state | conn_state: :transition_to_non_blocking}"},{"Add":" end"},{"Add":""},{"Add":" defp wait_for_data(state) do"},{"Add":" {:ok, data} = :gen_tcp.recv(state[:socket], 0)"},{"Add":" Ibex.Messages.Inbound.parse(data)"},{"Add":" end"},{"Add":""},{"Add":" defp transition_to_nonblocking(state) do"},{"Add":" Logger.info(\"Transitioning to non-blocking mode...\")"},{"Add":" :inet.setopts(state[:socket], active: true)"},{"Add":" %{ state | conn_state: :connected }"},{"Add":" end"},{"Add":""},{"Add":"end"}]}},{"FileAdd":{"meta":{"basename":"README.md","metadata":0},"context":[{"change":2,"pos":1}],"contents":[{"Add":"# Ibex"},{"Add":""},{"Add":"**TODO: Add description**"},{"Add":""},{"Add":"## Installation"},{"Add":""},{"Add":"If [available in Hex](https://hex.pm/docs/publish), the package can be installed"},{"Add":"by adding `ibex` to your list of dependencies in `mix.exs`:"},{"Add":""},{"Add":"```elixir"},{"Add":"def deps do"},{"Add":" ["},{"Add":" {:ibex, \"~> 0.1.0\"}"},{"Add":" ]"},{"Add":"end"},{"Add":"```"},{"Add":""},{"Add":"Documentation can be generated with [ExDoc](https://github.com/elixir-lang/ex_doc)"},{"Add":"and published on [HexDocs](https://hexdocs.pm). Once published, the docs can"},{"Add":"be found at ."},{"Add":""}]}}],"owner":"kurosknight","repo":"ibex","token":"G8nocMopnW4ROzAvngTZdyOLSlW5iAIx+QBeRnUh+jg=","login":null}

…

Dependencies

Change contents