diff --git a/frontend/main.js b/frontend/main.js index 684ffac..fbf98c7 100644 --- a/frontend/main.js +++ b/frontend/main.js @@ -5,6 +5,34 @@ import App from './App' Vue.config.productionTip = false +console.log('Kafkakitty bootstrapping..') + +function wsConnect () { + const socket = new WebSocket('ws://localhost:8001') + socket.onopen = (event) => { + console.log('Kafkakitty connected! 😺') + } + socket.onerror = (err) => { + console.error('😿 Kafkakitty encountered an error:', err) + socket.close() + wsConnect() + } + socket.onclose = (event) => { + console.log('Kafkakitty connection lost, retrying..') + wsConnect() + } + + socket.onmessage = (event) => { + console.log(`Received: ${event.data}`) + const container = document.getElementById('app') + const d = document.createElement('div') + d.className = 'row' + d.innerHTML = `
${event.data}
` + container.insertBefore(d, container.firstChild) + } +} +wsConnect() + /* eslint-disable no-new */ new Vue({ el: '#app', diff --git a/index.html b/index.html index b16abd0..5661a5d 100644 --- a/index.html +++ b/index.html @@ -2,9 +2,7 @@ - Kafkakitty 😻 - -
- diff --git a/static/sock.js b/static/sock.js deleted file mode 100644 index f249120..0000000 --- a/static/sock.js +++ /dev/null @@ -1,18 +0,0 @@ -/* - * Main module for the Kafkakitty client side code - */ - -console.log('😺 Kafkakitty bootstrapping..'); - -const socket = new WebSocket('ws://127.0.0.1:8001'); - -socket.onmessage = (event) => { - console.log(`Received: ${event.data}`); - const container = document.getElementById('app'); - const d = document.createElement('div'); - d.className = 'row' - d.innerHTML = `
${event.data}
`; - container.insertBefore(d, container.firstChild); -}; - -