import { WebSocket } from 'ws';
// ...snip...
Effect.gen(function* () {
// Works!
const socket = yield* Effect.try({
try: () => new WebSocket(SOCKET_URL),
catch: () => new Error()
});
socket.on('error', console.error);
socket.on('open', () => {});
socket.on('message', (data) => {
const { metadata, payload } = JSON.parse(data.toString('utf8')) ?? {};
if (metadata?.message_type === 'session_welcome') {
// Need to update my Ref with payload.session.id here...
}
});
})
import { WebSocket } from 'ws';
// ...snip...
Effect.gen(function* () {
// Works!
const socket = yield* Effect.try({
try: () => new WebSocket(SOCKET_URL),
catch: () => new Error()
});
socket.on('error', console.error);
socket.on('open', () => {});
socket.on('message', (data) => {
const { metadata, payload } = JSON.parse(data.toString('utf8')) ?? {};
if (metadata?.message_type === 'session_welcome') {
// Need to update my Ref with payload.session.id here...
}
});
})