Poloniex connection.

1 files changed, 40 insertions, 0 deletions

diff --git a/api/external_services.go b/api/external_services.go
new file mode 100644
index 0000000..c467171
--- /dev/null
+++ b/api/external_services.go
@@ -0,0 +1,40 @@
+package api
+
+import (
+        "context"
+        "fmt"
+        "time"
+)
+
+// Use this to call external services. It will handle timeout and request cancellation gracefully.
+func CallExternalService(tag string, timeout time.Duration, routine func() *Error) *Error {
+        routineDone := make(chan *Error)
+
+        go func() {
+                routineDone <- routine()
+        }()
+
+        ctx, cancel := context.WithTimeout(context.Background(), timeout)
+        defer cancel()
+
+        select {
+        case err := <-routineDone:
+                return err
+        case <-ctx.Done():
+                return &Error{ExternalServiceTimeout, "external service timeout", fmt.Errorf("'%v' routine timeouted", tag)}
+        }
+}
+
+var ErrorChan chan error
+
+func ErrorMonitoring() {
+        for {
+                err := <-ErrorChan
+                log.Errorf("error: %v", err)
+        }
+}
+
+func init() {
+        ErrorChan = make(chan error)
+        go ErrorMonitoring()
+}