diff --git a/web/src/app/app-routing.module.ts b/web/src/app/app-routing.module.ts index 7b4eee36..4821c9df 100644 --- a/web/src/app/app-routing.module.ts +++ b/web/src/app/app-routing.module.ts @@ -9,7 +9,7 @@ import { Routes, RouterModule } from '@angular/router'; const routes: Routes = [ { path: '', - component: HomeComponent + component: DashboardComponent }, { path:'about', diff --git a/web/src/app/app.module.ts b/web/src/app/app.module.ts index 441af8fb..64ec6c2f 100644 --- a/web/src/app/app.module.ts +++ b/web/src/app/app.module.ts @@ -17,7 +17,8 @@ import { MdFormFieldModule, MdInputModule, MdCheckboxModule, - MdGridListModule + MdGridListModule, + MdProgressSpinnerModule, } from '@angular/material'; @@ -65,7 +66,8 @@ import * as Rx from 'rxjs/Rx'; MdFormFieldModule, MdInputModule, MdCheckboxModule, - MdGridListModule + MdGridListModule, + MdProgressSpinnerModule, ], providers: [ElectronService,WebsocketService,WebsocketHandlerService], bootstrap: [AppComponent] diff --git a/web/src/app/pages/settings/settings.component.html b/web/src/app/pages/settings/settings.component.html index 082d7283..a5f24dd7 100644 --- a/web/src/app/pages/settings/settings.component.html +++ b/web/src/app/pages/settings/settings.component.html @@ -1,3 +1,6 @@ +
+ +
@@ -13,7 +16,7 @@ - + @@ -75,13 +78,11 @@ - - - + - + - {{currency}} + {{currency}} diff --git a/web/src/app/pages/settings/settings.component.ts b/web/src/app/pages/settings/settings.component.ts index b144b61c..266ef9b9 100644 --- a/web/src/app/pages/settings/settings.component.ts +++ b/web/src/app/pages/settings/settings.component.ts @@ -17,17 +17,14 @@ export class SettingsComponent implements OnInit { private getSettingsMessage = { Event: 'GetConfig', data: null, - Exchange: null, - AssetType: null }; constructor(private websocketHandler: WebsocketHandlerService) { this.ws = websocketHandler; this.ws.messages.subscribe(msg => { + if (msg.Event === 'GetConfig') { - console.log('Data:' + JSON.stringify(msg.data)); this.settings = msg.data; - this.fixUpSettings(); } else if (msg.Event === 'SaveConfig') { // something! } @@ -38,30 +35,23 @@ export class SettingsComponent implements OnInit { } private getSettings(): void { - console.log('new message from client to websocket: ', this.getSettingsMessage); this.ws.messages.next(this.getSettingsMessage); this.resendMessageIfPageRefreshed(); } - private fixUpSettings(): void { - - } private saveSettings(): void { //Send the message var settingsSave = { Event: 'SaveConfig', data: this.settings, - - Exchange: null, - AssetType: null } this.ws.messages.next(settingsSave); } - +//there has to be a better way private resendMessageIfPageRefreshed(): void { - if (this.failCount <= 5) { + if (this.failCount <= 10) { setTimeout(() => { if (this.settings === null) { console.log(this.failCount); diff --git a/web/src/app/services/websocket-handler/websocket-handler.service.ts b/web/src/app/services/websocket-handler/websocket-handler.service.ts index a14783c8..d36413f7 100644 --- a/web/src/app/services/websocket-handler/websocket-handler.service.ts +++ b/web/src/app/services/websocket-handler/websocket-handler.service.ts @@ -13,7 +13,16 @@ export interface Message { @Injectable() export class WebsocketHandlerService { - public messages: Subject; + public messages: Subject; + + private authenticateMessage = { + Event:'auth', + data:{"username":"admin","password":"e7cf3ef4f17c3999a94f2c6f612e8a888e5b1026878e4e19398b23bd38ec221a"}, + } + + public authenticate() { + this.messages.next(this.authenticateMessage); + } constructor(wsService: WebsocketService) { this.messages = >wsService @@ -21,12 +30,11 @@ export class WebsocketHandlerService { .map((response: MessageEvent): Message => { let data = JSON.parse(response.data); - - // debug only - //console.log('Recieved response from websocket. Data: ' + JSON.stringify(data)) - var dataData = data.Data === null ? data.data : data.Data; + // variables aren't consistent yet. Here's a hack! + var dataData = data.Data === undefined ? data.data : data.Data; + var eventEvent = data.Event === undefined ? data.event : data.Event; return { - Event: data.Event, + Event: eventEvent, data: dataData, Exchange: data.exchange, AssetType: data.assetType diff --git a/web/src/app/services/websocket/websocket.service.ts b/web/src/app/services/websocket/websocket.service.ts index 7513b29c..ee293713 100644 --- a/web/src/app/services/websocket/websocket.service.ts +++ b/web/src/app/services/websocket/websocket.service.ts @@ -15,9 +15,9 @@ export class WebsocketService { } private authenticateMessage = { - Event:'auth', - data:{"username":"admin","password":"e7cf3ef4f17c3999a94f2c6f612e8a888e5b1026878e4e19398b23bd38ec221a"}, - } + Event:'auth', + data:{"username":"admin","password":"e7cf3ef4f17c3999a94f2c6f612e8a888e5b1026878e4e19398b23bd38ec221a"}, + } private isAuth = false; @@ -32,13 +32,10 @@ export class WebsocketService { return ws.close.bind(ws); }) let observer = { - next: (data: Object) => { + next: (data: any) => { if (ws.readyState === WebSocket.OPEN) { - if(!this.isAuth) { - //This is a shit initial way to be able to authenticate - ws.send(JSON.stringify(this.authenticateMessage)); - this.isAuth = true; - } + ws.send(JSON.stringify(this.authenticateMessage)); + ws.send(JSON.stringify(data)); } } diff --git a/web/src/app/shared/all-enabled-currency-tickers/all-enabled-currency-tickers.component.html b/web/src/app/shared/all-enabled-currency-tickers/all-enabled-currency-tickers.component.html index 35dc542a..19cb8e7c 100644 --- a/web/src/app/shared/all-enabled-currency-tickers/all-enabled-currency-tickers.component.html +++ b/web/src/app/shared/all-enabled-currency-tickers/all-enabled-currency-tickers.component.html @@ -1,3 +1,6 @@ +
+ +
diff --git a/web/src/app/shared/all-enabled-currency-tickers/all-enabled-currency-tickers.component.ts b/web/src/app/shared/all-enabled-currency-tickers/all-enabled-currency-tickers.component.ts index cc44326d..722139ed 100644 --- a/web/src/app/shared/all-enabled-currency-tickers/all-enabled-currency-tickers.component.ts +++ b/web/src/app/shared/all-enabled-currency-tickers/all-enabled-currency-tickers.component.ts @@ -11,8 +11,6 @@ export class AllEnabledCurrencyTickersComponent implements OnInit { allCurrencies:ExchangeCurrency[]; tickerCards: TickerUpdate[]; - - constructor(private websocketHandler: WebsocketHandlerService) { this.ws = websocketHandler; this.allCurrencies = []; @@ -36,35 +34,22 @@ export class AllEnabledCurrencyTickersComponent implements OnInit { ticker.Exchange = msg.Exchange; this.tickerCards.push(ticker); this.allCurrencies.push(modal); - console.log(JSON.stringify(this.allCurrencies)); } else { - console.log('deleting'); + //time to replace for(var j = 0; j< this.tickerCards.length; j++) { - console.log(j); - console.log("exchange" + this.tickerCards[j].Exchange === msg.Exchange ); - console.log("curr" + this.tickerCards[j].CurrencyPair === msg.data.CurrencyPair ); if(this.tickerCards[j].Exchange === msg.Exchange && this.tickerCards[j].CurrencyPair === msg.data.CurrencyPair) { - console.log('doner'); - var ticker = msg.data; this.tickerCards[j] = ticker; this.tickerCards[j].Exchange = msg.Exchange; - - console.log('done'); - return; - } else { - console.log('not found?'); - } + return; + } } } } }); } - - ngOnInit() { - } - + ngOnInit() { } } export interface ExchangeCurrency {