Poloniex connection.

1 files changed, 29 insertions, 0 deletions

diff --git a/api/markets.go b/api/markets.go
new file mode 100644
index 0000000..60fb912
--- /dev/null
+++ b/api/markets.go
@@ -0,0 +1,29 @@
+package api
+
+import (
+        "immae.eu/Immae/Projets/Cryptomonnaies/Cryptoportfolio/Front/markets"
+)
+
+var Poloniex *markets.Poloniex
+
+func OpenMarketsConnection() error {
+        for {
+                err := Poloniex.StartTicker()
+                if err != nil {
+                        return err
+                }
+                log.Warn("connection to poloniex stream ended, restarting it...")
+        }
+}
+
+func init() {
+        Poloniex = markets.NewPoloniex()
+
+        // We open markets connections in the background as it can take time.
+        go func() {
+                err := OpenMarketsConnection()
+                if err != nil {
+                        ErrorChan <- err
+                }
+        }()
+}