diff --git a/src/app/messages/messages.component.ts b/src/app/messages/messages.component.ts index 4649205..acadec0 100644 --- a/src/app/messages/messages.component.ts +++ b/src/app/messages/messages.component.ts @@ -23,7 +23,7 @@ export class MessagesComponent implements OnInit { ngOnInit() { this.websocketService.connect(); - this.websocketService.observeAnchor('message').subscribe( + this.websocketService.observeKey('message').subscribe( (event) => { this.messages.push(event.data); event.data.message = this.convert(event.data.message); diff --git a/src/app/services/fsmupdate.service.ts b/src/app/services/fsmupdate.service.ts index 6423ca5..eabd14d 100644 --- a/src/app/services/fsmupdate.service.ts +++ b/src/app/services/fsmupdate.service.ts @@ -11,7 +11,7 @@ export class FSMUpdateService { constructor(private websocketService: WebSocketService) {} public init(): void { - this.websocketService.observeAnchor('FSMUpdate').subscribe((event) => { + this.websocketService.observeKey('FSMUpdate').subscribe((event) => { this.current_state = event.data.current_state; this.valid_transitions = event.data.valid_transitions; }); diff --git a/src/app/services/websocket.service.ts b/src/app/services/websocket.service.ts index b9b0b3f..ef7eab4 100644 --- a/src/app/services/websocket.service.ts +++ b/src/app/services/websocket.service.ts @@ -41,17 +41,17 @@ export class WebSocketService { console.log('ws connected'); } - public observeAnchor(anchor: string): Observable> { - return this.downlink.pipe(filter(message => message.anchor === anchor)); + public observeKey(key: string): Observable> { + return this.downlink.pipe(filter(message => message.key === key)); } - public send(anchor: string, data: any): void { + public send(key: string, data: any): void { // If the WebSocket is not connected then the QueueingSubject will ensure // that messages are queued and delivered when the WebSocket reconnects. // A regular Subject can be used to discard messages sent when the WebSocket // is disconnected. this.uplink.next({ - 'anchor': anchor, + 'key': key, 'data': data }); } diff --git a/src/app/services/wsmessage.ts b/src/app/services/wsmessage.ts index 6326d5d..22f20eb 100644 --- a/src/app/services/wsmessage.ts +++ b/src/app/services/wsmessage.ts @@ -1,4 +1,4 @@ export class WSMessage { - anchor: string; + key: string; data: T; // TODO: sane annotation } diff --git a/src/app/webide/webide.component.ts b/src/app/webide/webide.component.ts index 7509f20..b4d542e 100644 --- a/src/app/webide/webide.component.ts +++ b/src/app/webide/webide.component.ts @@ -25,7 +25,7 @@ const defaultSourceCode = `alert( 'Hello, world!' );`; styleUrls: ['./webide.component.scss'] }) export class WebideComponent implements OnInit { - anchor_id = 'anchor_webide'; + key_id = 'webide'; filename = 'demo.js'; code: string = defaultSourceCode; language = 'javascript'; @@ -47,7 +47,7 @@ export class WebideComponent implements OnInit { } subscribeWS() { - this.webSocketService.observeAnchor(this.anchor_id).subscribe((event) => { + this.webSocketService.observeKey(this.key_id).subscribe((event) => { this.command_handlers[event.data.command](event.data); this.changeDetectorRef.detectChanges(); }); @@ -81,7 +81,7 @@ export class WebideComponent implements OnInit { } sendCode() { - this.webSocketService.send(this.anchor_id, { + this.webSocketService.send(this.key_id, { 'command': 'write', 'content': this.code }); @@ -89,13 +89,13 @@ export class WebideComponent implements OnInit { } requestCode() { - this.webSocketService.send(this.anchor_id, { + this.webSocketService.send(this.key_id, { 'command': 'read' }); } selectCode(filename: string) { - this.webSocketService.send(this.anchor_id, { + this.webSocketService.send(this.key_id, { 'command': 'select', 'filename': filename });