Added Support for API

Author: Maneesh

lib/kite_connect_ex.ex

@@ -1,5 +1,5 @@
 defmodule KiteConnectEx do
-  alias KiteConnectEx.{User, Response, Portfolio}
+  alias KiteConnectEx.{User, Response, Portfolio, Instrument}
 
   @api_url "https://api.kite.trade"
 
@@ -84,4 +84,14 @@ defmodule KiteConnectEx do
   """
   @spec holdings(String.t()) :: {:ok, List.t()} | Response.error()
   defdelegate holdings(access_token), to: Portfolio
+
+  @doc """
+  Get list of all tradable `instruments` by `exchange`
+
+  ## Example
+
+    {:ok, instruments} = KiteConnectEx.instruments("access-token")
+  """
+  @spec instruments(String.t(),String.t()) :: {:ok, List.t()} | Response.error()
+  defdelegate instruments(access_token, exchange), to: Instrument
 end

lib/kite_connect_ex/instrument.ex

@@ -0,0 +1,37 @@
+defmodule KiteConnectEx.Instrument do
+  @moduledoc """
+  Module to represent a user's portfolio
+  """
+
+  alias KiteConnectEx.Portfolio.Holding
+  alias KiteConnectEx.Request
+
+  @instruments_base_path "/instruments"
+
+  @doc """
+  Get user's portfolio `holdings`
+
+  ## Example
+
+    {:ok, holdings} = KiteConnectEx.Portfolio.holdings("access-token")
+  """
+  @spec instruments(String.t(), String.t()) :: {:ok, List.t()} | Response.error()
+  def instruments(access_token, exchange) when is_binary(access_token) do
+    Request.get(instruments_path(exchange), nil, auth_header(access_token), KiteConnectEx.request_options())
+    |> case do
+      {:ok, instruments_csv_dump} ->
+        {:ok, instruments_csv_dump}
+
+      {:error, error} ->
+        {:error, error}
+    end
+  end
+
+  defp instruments_path(exchange) do
+    @instruments_base_path <> "/" <> exchange    
+  end
+
+  defp auth_header(access_token) do
+    [{"Authorization", "token " <> KiteConnectEx.api_key() <> ":" <> access_token}]
+  end
+end

lib/kite_connect_ex/request.ex

@@ -18,6 +18,16 @@ defmodule KiteConnectEx.Request do
   @spec api_version() :: String.t()
   def api_version, do: @api_version
 
+  @spec get_csv(String.t(), map() | nil, list, list) :: Response.success() | Response.error()
+  def get_csv(path, query, headers, opts \\ []) do
+    HTTPoison.get(
+      build_url(path, query),
+      build_headers(headers),
+      request_options(opts)
+    )
+    |> parse_csv_response()
+  end
+
   @spec get(String.t(), map() | nil, list, list) :: Response.success() | Response.error()
   def get(path, query, headers, opts \\ []) do
     HTTPoison.get(
@@ -107,6 +117,10 @@ defmodule KiteConnectEx.Request do
     Response.parse_response(response)
   end
 
+  defp parse_csv_response({:ok, response}) do
+    Response.parse_csv_response(response)
+  end
+
   defp parse_response({:error, error}) do
     Response.parse_error(error)
   end

lib/kite_connect_ex/response.ex

@@ -7,16 +7,23 @@ defmodule KiteConnectEx.Response do
   @success_status "success"
   @error_status "error"
 
+  @doc false
+  @spec parse_csv_response(HTTPoison.Response.t()) :: success | error
+  def parse_csv_response(%HTTPoison.Response{} = response) do
+    case response do
+      %{body: body, status_code: status} when status in @success_status_codes ->
+        {:ok, body}
+
+      %{body: body, status_code: _status} ->
+        {:error, KiteConnectEx.Error.new(body)}
+    end
+  end
+
   @doc false
   @spec parse_response(HTTPoison.Response.t()) :: success | error
   def parse_response(%HTTPoison.Response{} = response) do
     case response do
       %{body: body, status_code: status} when status in @success_status_codes ->
-        body =
-          body
-          |> Jason.decode!()
-          |> parse_body()
-
         {:ok, body}
 
       %{body: body, status_code: _status} ->