export const handler: Handlers = {
async GET(_req) {
const kv = await Deno.openKv(`https://api.deno.com/databases/${DATABASE_ID}/connect`);
return new Response(
new ReadableStream({
async start(controller) {
for await (
const [{ value: message }] of kv.watch([["maps", "couve", "teste", "1"]])
) {
controller.enqueue({
data: message,
id: Date.now(),
event: "message",
});
}
},
cancel() {
console.log("cancel");
},
}).pipeThrough(new ServerSentEventStream()),
{
headers: {
"Content-Type": "text/event-stream",
},
},
);
},
};
export const handler: Handlers = {
async GET(_req) {
const kv = await Deno.openKv(`https://api.deno.com/databases/${DATABASE_ID}/connect`);
return new Response(
new ReadableStream({
async start(controller) {
for await (
const [{ value: message }] of kv.watch([["maps", "couve", "teste", "1"]])
) {
controller.enqueue({
data: message,
id: Date.now(),
event: "message",
});
}
},
cancel() {
console.log("cancel");
},
}).pipeThrough(new ServerSentEventStream()),
{
headers: {
"Content-Type": "text/event-stream",
},
},
);
},
};