SSE, sse-swap not work if i send event with name #1100

Hammer2900 · 2022-10-24T09:50:27Z

Hammer2900
Oct 24, 2022

Here small example, working only global filter for all messages, but specific message with event name not show. Where i went wrong ? What right payload i need send to get all this staff working ?

import asyncio
import weakref

from aiohttp import web
from aiohttp.web import Response
from aiohttp_sse import sse_response
from datetime import datetime

connections = weakref.WeakSet()


async def handle_connection(request):
    stream = await sse_response(request)
    connections.add(stream)
    try:
        await stream.wait()
    finally:
        connections.discard(stream)
    return stream


async def send_all(request):
    now = datetime.now()
    fs = []
    for stream in connections:
        print('[-> all]', stream)
        fs.append(stream.send('{}', id=now.timestamp()))
    await asyncio.gather(*fs)
    return Response(text='All', content_type='text/html')


async def send_filter(request):
    now = datetime.now()
    fs = []
    for stream in connections:
        print('[-> filter]', stream)
        fs.append(stream.send(f'event: Event1 data: {now.timestamp()}\n\n', id=now.timestamp()))
    await asyncio.gather(*fs)
    return Response(text='Filter', content_type='text/html')


async def index(request):
    d = """
        <html>
        <body>
            <h1>Response from server:</h1>
            <div id="response"></div>
            <button hx-trigger="click" hx-get="/send_all" type="button" class="btn btn-default">All</button>
            <button hx-trigger="click" hx-get="/send_filter" type="button" class="btn btn-default">Filter</button>
            <div hx-ext="sse" sse-connect="http://127.0.0.1:8080/handle" sse-swap="message">222</div>
            <div hx-ext="sse" sse-connect="http://127.0.0.1:8080/handle" sse-swap="Event1">222</div>

            <script src="https://cdnjs.cloudflare.com/ajax/libs/htmx/1.8.2/htmx.min.js" integrity="sha512-u/+x1QX84RlxBQDGK+6yuJHMPVCsp1y5SbkmE+W93se2UOw7t6zVhZy0phD6dlf2fEZs66UmLfO0+Z4GRaDVJQ==" crossorigin="anonymous" referrerpolicy="no-referrer"></script>
            <script src="https://cdnjs.cloudflare.com/ajax/libs/htmx/1.8.2/ext/sse.min.js" integrity="sha512-d91UDc+zgPF+9KlDrYLefr1fwBMwM9oow+LwuQ3Hca3ZFx7f6p3e7W7CZ+NalfOG9yScyCNXs03z+kbn5JBk/w==" crossorigin="anonymous" referrerpolicy="no-referrer"></script>
            <script>htmx.logAll();</script>
        </body>
    </html>
    """
    return Response(text=d, content_type='text/html')


app = web.Application()
app.router.add_route('GET', '/handle', handle_connection)
app.router.add_route('GET', '/send_all', send_all)
app.router.add_route('GET', '/send_filter', send_filter)
app.router.add_route('GET', '/', index)
web.run_app(app, host='127.0.0.1', port=8080)

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

SSE, sse-swap not work if i send event with name #1100

{{title}}

Replies: 0 comments

Select a reply

SSE, sse-swap not work if i send event with name #1100

Hammer2900 Oct 24, 2022

Replies: 0 comments

Hammer2900
Oct 24, 2022