combineLast Observer of openSocket and userData was added

lib/getAccountPositions.js

@@ -2,13 +2,16 @@ const rx = require('./rx.js')
 const rpc = require('./rpc.js')
 const { filter, take } = require('rxjs/operators')
 
-function getAccountPositions (instrument, callback = () => {}) {
-  rx.socketOpen
-  .pipe(filter(open => open),take(1))
+function getAccountPositions (callback = () => {}) {
+  rx.socketOpenUserData
+  .pipe(filter(data => {
+    const [socket, user] = data
+    return socket && user.UserId != 0
+  }),take(1))
   .subscribe(open => {
     rpc.call('GetAccountPositions', {
       OMSId: rx.userData.value.OMSId || 1,
-      AccountId: cubobit.user.AccountId
+      AccountId: rx.userData.value.AccountId
     }, callback)
   })
 }

lib/rx.js

@@ -1,9 +1,11 @@
-const { BehaviorSubject } = require('rxjs')
+const { BehaviorSubject, combineLatest } = require('rxjs')
 
 const socketOpen = new BehaviorSubject(false)
-const userData = new BehaviorSubject({})
+const userData = new BehaviorSubject({ UserId: 0 })
+const socketOpenUserData = combineLatest(socketOpen, userData)
 
 module.exports = {
   socketOpen,
-  userData
+  userData,
+  socketOpenUserData
 }