update
This commit is contained in:
@@ -15,10 +15,9 @@
|
|||||||
onMount(async () => {
|
onMount(async () => {
|
||||||
setStatus('connecting');
|
setStatus('connecting');
|
||||||
try {
|
try {
|
||||||
const nc = await connect({ servers: 'wss://nats.yiem.cc' });
|
nc = await connect({ servers: 'wss://nats.yiem.cc' });
|
||||||
setStatus('connected');
|
setStatus('connected');
|
||||||
|
|
||||||
// closed() resolves when connection closes or errors
|
|
||||||
nc.closed().then((err) => {
|
nc.closed().then((err) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
console.error('NATS closed with error:', err);
|
console.error('NATS closed with error:', err);
|
||||||
@@ -29,21 +28,37 @@
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
// optional: watch low-level disconnect/slow events via nc.transport
|
|
||||||
// (nats.js does not expose DOM events; rely on closed() and errors)
|
|
||||||
|
|
||||||
// create a subscription and responder
|
|
||||||
const sc = StringCodec();
|
const sc = StringCodec();
|
||||||
const sub = nc.subscribe(SUBJECT);
|
const sub = nc.subscribe(SUBJECT);
|
||||||
|
|
||||||
(async () => {
|
(async () => {
|
||||||
for await (const m of sub) {
|
for await (const m of sub) {
|
||||||
try {
|
try {
|
||||||
const raw = sc.decode(m.data);
|
const raw = sc.decode(m.data || new Uint8Array());
|
||||||
const payload = JSON.parse(raw);
|
// Defensive JSON parse
|
||||||
if (payload?.text) message = payload.text;
|
let payload;
|
||||||
|
try {
|
||||||
|
payload = JSON.parse(raw);
|
||||||
|
} catch (e) {
|
||||||
|
console.warn('received non-json payload', raw);
|
||||||
|
payload = null;
|
||||||
|
}
|
||||||
|
|
||||||
|
// If payload has text, update UI
|
||||||
|
if (payload && typeof payload.text === 'string') {
|
||||||
|
message = payload.text;
|
||||||
|
} else {
|
||||||
|
message = 'received invalid payload';
|
||||||
|
}
|
||||||
|
|
||||||
|
// Reply if requester supplied reply subject
|
||||||
if (m.reply) {
|
if (m.reply) {
|
||||||
await nc.publish(m.reply, sc.encode(JSON.stringify(payload)));
|
const replyPayload = { text: `displaying: ${payload && payload.text ? payload.text : 'invalid'}` };
|
||||||
|
await nc.publish(m.reply, sc.encode(JSON.stringify(replyPayload)));
|
||||||
await nc.flush();
|
await nc.flush();
|
||||||
|
console.log('replied', replyPayload);
|
||||||
|
} else {
|
||||||
|
console.log('no reply subject, not replying');
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
console.error('message handler error', e);
|
console.error('message handler error', e);
|
||||||
@@ -51,15 +66,6 @@
|
|||||||
}
|
}
|
||||||
})();
|
})();
|
||||||
|
|
||||||
// quick verify: publish a ping and see if there is no error
|
|
||||||
try {
|
|
||||||
await nc.publish(SUBJECT, sc.encode(JSON.stringify({ text: 'ping-from-client' })));
|
|
||||||
await nc.flush();
|
|
||||||
console.log('published ping');
|
|
||||||
} catch (e) {
|
|
||||||
console.error('publish error', e);
|
|
||||||
}
|
|
||||||
|
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error('connect failed', err);
|
console.error('connect failed', err);
|
||||||
setStatus('error');
|
setStatus('error');
|
||||||
@@ -79,7 +85,3 @@
|
|||||||
<div><strong>Message:</strong> {message}</div>
|
<div><strong>Message:</strong> {message}</div>
|
||||||
<button on:click={disconnect} disabled={status !== 'connected'}>Disconnect</button>
|
<button on:click={disconnect} disabled={status !== 'connected'}>Disconnect</button>
|
||||||
</main>
|
</main>
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user