diff --git a/QuantConnect.CoinbaseBrokerage/CoinbaseBrokerage.cs b/QuantConnect.CoinbaseBrokerage/CoinbaseBrokerage.cs index a73a9a9..9ce60ba 100644 --- a/QuantConnect.CoinbaseBrokerage/CoinbaseBrokerage.cs +++ b/QuantConnect.CoinbaseBrokerage/CoinbaseBrokerage.cs @@ -149,6 +149,8 @@ protected void Initialize(string webSocketUrl, string apiKey, string apiSecret, return; } + ValidateSubscription(); + Initialize(webSocketUrl, new WebSocketClientWrapper(), null, apiKey, apiSecret); _job = job; @@ -163,8 +165,6 @@ protected void Initialize(string webSocketUrl, string apiKey, string apiSecret, SubscribeImpl = (symbols, _) => SubscribeSymbolsOnDataChannels(symbols.ToList()), UnsubscribeImpl = (symbols, _) => Unsubscribe(symbols) }; - - ValidateSubscription(); } #region IBrokerage @@ -416,10 +416,10 @@ private static void ValidateSubscription() { try { - var productId = 183; - var userId = Config.GetInt("job-user-id"); - var token = Config.Get("api-access-token"); - var organizationId = Config.Get("job-organization-id", null); + const int productId = 183; + var userId = Globals.UserId; + var token = Globals.UserToken; + var organizationId = Globals.OrganizationID; // Verify we can authenticate with this user and token var api = new ApiConnection(userId, token); if (!api.Connected)