From 23f96aeadd68a59c3add135ade75c79e13bb2980 Mon Sep 17 00:00:00 2001
From: Giorgio Azzinnaro <giorgio@azzinna.ro>
Date: Thu, 13 Apr 2023 16:50:06 +0200
Subject: [PATCH] test: add integration test

---
 test/integration.exs | 59 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 59 insertions(+)
 create mode 100644 test/integration.exs

diff --git a/test/integration.exs b/test/integration.exs
new file mode 100644
index 0000000..afea547
--- /dev/null
+++ b/test/integration.exs
@@ -0,0 +1,59 @@
+defmodule MockHandler do
+  @behaviour ExTwelveData.RealTimePrices.Handler
+
+  require Logger
+
+  @impl true
+  def handle_price_update(price) do
+    Logger.info(price)
+  end
+end
+
+{:ok, pid} =
+  ExTwelveData.RealTimePrices.start_link(
+    api_key: System.fetch_env!("TWELVE_DATA_API_KEY"),
+    handler: MockHandler
+  )
+
+alias ExTwelveData.RealTimePrices.SubscriptionsManager
+
+defmodule MockProvider do
+  alias ExTwelveData.Symbol
+  @behaviour SubscriptionsManager.Provider
+
+  require Logger
+
+  @impl true
+  def get_symbols() do
+    new =
+      MapSet.new(
+        Enum.random([
+          [
+            %Symbol{exchange: "Euronext", symbol: "SLBEN"},
+            %Symbol{mic_code: "XPAR", symbol: "ALMIL"},
+            %Symbol{type: "Index", symbol: "IXIC"}
+          ],
+          [
+            %Symbol{mic_code: "XDUS", symbol: "ADS"},
+            %Symbol{mic_code: "XFRA", symbol: "MQ1"},
+            %Symbol{type: "Index", symbol: "VFIAX"}
+          ]
+        ])
+      )
+
+    Logger.warning(new)
+
+    new
+  end
+end
+
+SubscriptionsManager.start_link(
+  pid: pid,
+  provider: MockProvider,
+  max_subscriptions: 8,
+  symbols_extended: true
+)
+
+# ["AAPL", "MSFT", "GOOG"],
+# ["TSLA", "MSFT", "ABML"],
+# ["IXIC", "VFIAX", "QQQ"]