123456789101112131415161718 |
- import { DO_UPDATE, DONE_UPDATE, LOCAL_RELOAD_SOCKET_URL } from '../constant';
- import MessageInterpreter from '../interpreter';
- export default function initClient({ id, onUpdate }: { id: string; onUpdate: () => void }) {
- const ws = new WebSocket(LOCAL_RELOAD_SOCKET_URL);
- ws.onopen = () => {
- ws.addEventListener('message', event => {
- const message = MessageInterpreter.receive(String(event.data));
- if (message.type === DO_UPDATE && message.id === id) {
- onUpdate();
- ws.send(MessageInterpreter.send({ type: DONE_UPDATE }));
- return;
- }
- });
- };
- }
|