|
@@ -63,50 +63,50 @@ export default class ChartList extends Component<PropsType, StateType> {
|
|
|
|
|
|
|
|
setupWebsocket = (kind: string) => {
|
|
setupWebsocket = (kind: string) => {
|
|
|
let { currentCluster, currentProject } = this.context;
|
|
let { currentCluster, currentProject } = this.context;
|
|
|
- let protocol = process.env.NODE_ENV == 'production' ? 'wss' : 'ws'
|
|
|
|
|
- let ws = new WebSocket(`${protocol}://${process.env.API_SERVER}/api/projects/${currentProject.id}/k8s/${kind}/status?cluster_id=${currentCluster.id}&service_account_id=${currentCluster.service_account_id}`)
|
|
|
|
|
|
|
+ let protocol = process.env.NODE_ENV == 'production' ? 'wss' : 'ws';
|
|
|
|
|
+ let ws = new WebSocket(`${protocol}://${process.env.API_SERVER}/api/projects/${currentProject.id}/k8s/${kind}/status?cluster_id=${currentCluster.id}`);
|
|
|
ws.onopen = () => {
|
|
ws.onopen = () => {
|
|
|
- console.log('connected to websocket')
|
|
|
|
|
|
|
+ console.log('connected to websocket');
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
ws.onmessage = (evt: MessageEvent) => {
|
|
ws.onmessage = (evt: MessageEvent) => {
|
|
|
- let event = JSON.parse(evt.data)
|
|
|
|
|
- let object = event.Object
|
|
|
|
|
- let chartKey = this.state.chartLookupTable[object.metadata.uid]
|
|
|
|
|
|
|
+ let event = JSON.parse(evt.data);
|
|
|
|
|
+ let object = event.Object;
|
|
|
|
|
+ let chartKey = this.state.chartLookupTable[object.metadata.uid];
|
|
|
|
|
|
|
|
// ignore if updated object does not belong to any chart in the list.
|
|
// ignore if updated object does not belong to any chart in the list.
|
|
|
if (!chartKey) {
|
|
if (!chartKey) {
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- let chartControllers = this.state.controllers[chartKey]
|
|
|
|
|
- chartControllers[object.metadata.uid] = object
|
|
|
|
|
|
|
+ let chartControllers = this.state.controllers[chartKey];
|
|
|
|
|
+ chartControllers[object.metadata.uid] = object;
|
|
|
|
|
|
|
|
this.setState({
|
|
this.setState({
|
|
|
controllers: {
|
|
controllers: {
|
|
|
...this.state.controllers,
|
|
...this.state.controllers,
|
|
|
[chartKey] : chartControllers
|
|
[chartKey] : chartControllers
|
|
|
}
|
|
}
|
|
|
- })
|
|
|
|
|
|
|
+ });
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
ws.onclose = () => {
|
|
ws.onclose = () => {
|
|
|
- console.log('closing websocket')
|
|
|
|
|
|
|
+ console.log('closing websocket');
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
ws.onerror = (err: ErrorEvent) => {
|
|
ws.onerror = (err: ErrorEvent) => {
|
|
|
- console.log(err)
|
|
|
|
|
- ws.close()
|
|
|
|
|
|
|
+ console.log(err);
|
|
|
|
|
+ ws.close();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- return ws
|
|
|
|
|
|
|
+ return ws;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
setControllerWebsockets = (controllers: any[]) => {
|
|
setControllerWebsockets = (controllers: any[]) => {
|
|
|
let websockets = controllers.map((kind: string) => {
|
|
let websockets = controllers.map((kind: string) => {
|
|
|
- return this.setupWebsocket(kind)
|
|
|
|
|
|
|
+ return this.setupWebsocket(kind);
|
|
|
})
|
|
})
|
|
|
- this.setState({websockets})
|
|
|
|
|
|
|
+ this.setState({ websockets });
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
getControllers = (charts: any[]) => {
|
|
getControllers = (charts: any[]) => {
|