automatic import of python-broadcasteropeneuler20.03

3 files changed, 362 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
index e69de29..346c435 100644
--- a/.gitignore
+++ b/.gitignore
@@ -0,0 +1 @@
+/broadcaster-0.2.0.tar.gz
diff --git a/python-broadcaster.spec b/python-broadcaster.spec
new file mode 100644
index 0000000..f401126
--- /dev/null
+++ b/python-broadcaster.spec
@@ -0,0 +1,360 @@
+%global _empty_manifest_terminate_build 0
+Name:		python-broadcaster
+Version:	0.2.0
+Release:	1
+Summary:	Simple broadcast channels.
+License:	BSD
+URL:		https://github.com/encode/broadcaster
+Source0:	https://mirrors.nju.edu.cn/pypi/web/packages/ca/8b/eb664eeae1187c9943ccb7cbfec0883b15a18db04b6028a748505581ca72/broadcaster-0.2.0.tar.gz
+BuildArch:	noarch
+
+Requires:	python3-aiokafka
+Requires:	python3-asyncpg
+Requires:	python3-asyncio-redis
+
+%description
+# Broadcaster
+
+Broadcaster helps you develop realtime streaming functionality in by providing
+a simple broadcast API onto a number of different backend services.
+
+It currently supports [Redis PUB/SUB](https://redis.io/topics/pubsub), [Apache Kafka](https://kafka.apache.org/), and [Postgres LISTEN/NOTIFY](https://www.postgresql.org/docs/current/sql-notify.html), plus a simple in-memory backend, that you can use for local development or during testing.
+
+<img src="https://raw.githubusercontent.com/encode/broadcaster/master/docs/demo.gif" alt='WebSockets Demo'>
+
+Here's a complete example of the backend code for a simple websocket chat app:
+
+**app.py**
+
+```python
+# Requires: `starlette`, `uvicorn`, `jinja2`
+# Run with `uvicorn example:app`
+from broadcaster import Broadcast
+from starlette.applications import Starlette
+from starlette.concurrency import run_until_first_complete
+from starlette.routing import Route, WebSocketRoute
+from starlette.templating import Jinja2Templates
+
+
+broadcast = Broadcast("redis://localhost:6379")
+templates = Jinja2Templates("templates")
+
+
+async def homepage(request):
+    template = "index.html"
+    context = {"request": request}
+    return templates.TemplateResponse(template, context)
+
+
+async def chatroom_ws(websocket):
+    await websocket.accept()
+    await run_until_first_complete(
+        (chatroom_ws_receiver, {"websocket": websocket}),
+        (chatroom_ws_sender, {"websocket": websocket}),
+    )
+
+
+async def chatroom_ws_receiver(websocket):
+    async for message in websocket.iter_text():
+        await broadcast.publish(channel="chatroom", message=message)
+
+
+async def chatroom_ws_sender(websocket):
+    async with broadcast.subscribe(channel="chatroom") as subscriber:
+        async for event in subscriber:
+            await websocket.send_text(event.message)
+
+
+routes = [
+    Route("/", homepage),
+    WebSocketRoute("/", chatroom_ws, name='chatroom_ws'),
+]
+
+
+app = Starlette(
+    routes=routes, on_startup=[broadcast.connect], on_shutdown=[broadcast.disconnect],
+)
+```
+
+The HTML template for the front end [is available here](https://github.com/encode/broadcaster/blob/master/templates/index.html), and is adapted from [Pieter Noordhuis's PUB/SUB demo](https://gist.github.com/pietern/348262).
+
+
+## Installation
+
+* `pip install broadcaster`
+* `pip install broadcaster[redis]`
+* `pip install broadcaster[postgres]`
+* `pip install broadcaster[kafka]`
+
+## Available backends
+
+* `Broadcast('memory://')`
+* `Broadcast("redis://localhost:6379")`
+* `Broadcast("postgres://localhost:5432/hostedapi")`
+* `Broadcast("kafka://localhost:9092")`
+
+## Where next?
+
+At the moment `broadcaster` is in Alpha, and should be considered a working design document.
+
+The API should be considered subject to change. If you *do* want to use Broadcaster in its current
+state, make sure to strictly pin your requirements to `broadcaster==0.2.0`.
+
+To be more capable we'd really want to add some additional backends, provide API support for reading recent event history from persistent stores, and provide a serialization/deserialization API...
+
+* Serialization / deserialization to support broadcasting structured data.
+* Backends for Redis Streams, Apache Kafka, and RabbitMQ.
+* Add support for `subscribe('chatroom', history=100)` for backends which provide persistence. (Redis Streams, Apache Kafka) This will allow applications to subscribe to channel updates, while also being given an initial window onto the most recent events. We *might* also want to support some basic paging operations, to allow applications to scan back in the event history.
+* Support for pattern subscribes in backends that support it.
+
+
+
+
+%package -n python3-broadcaster
+Summary:	Simple broadcast channels.
+Provides:	python-broadcaster
+BuildRequires:	python3-devel
+BuildRequires:	python3-setuptools
+BuildRequires:	python3-pip
+%description -n python3-broadcaster
+# Broadcaster
+
+Broadcaster helps you develop realtime streaming functionality in by providing
+a simple broadcast API onto a number of different backend services.
+
+It currently supports [Redis PUB/SUB](https://redis.io/topics/pubsub), [Apache Kafka](https://kafka.apache.org/), and [Postgres LISTEN/NOTIFY](https://www.postgresql.org/docs/current/sql-notify.html), plus a simple in-memory backend, that you can use for local development or during testing.
+
+<img src="https://raw.githubusercontent.com/encode/broadcaster/master/docs/demo.gif" alt='WebSockets Demo'>
+
+Here's a complete example of the backend code for a simple websocket chat app:
+
+**app.py**
+
+```python
+# Requires: `starlette`, `uvicorn`, `jinja2`
+# Run with `uvicorn example:app`
+from broadcaster import Broadcast
+from starlette.applications import Starlette
+from starlette.concurrency import run_until_first_complete
+from starlette.routing import Route, WebSocketRoute
+from starlette.templating import Jinja2Templates
+
+
+broadcast = Broadcast("redis://localhost:6379")
+templates = Jinja2Templates("templates")
+
+
+async def homepage(request):
+    template = "index.html"
+    context = {"request": request}
+    return templates.TemplateResponse(template, context)
+
+
+async def chatroom_ws(websocket):
+    await websocket.accept()
+    await run_until_first_complete(
+        (chatroom_ws_receiver, {"websocket": websocket}),
+        (chatroom_ws_sender, {"websocket": websocket}),
+    )
+
+
+async def chatroom_ws_receiver(websocket):
+    async for message in websocket.iter_text():
+        await broadcast.publish(channel="chatroom", message=message)
+
+
+async def chatroom_ws_sender(websocket):
+    async with broadcast.subscribe(channel="chatroom") as subscriber:
+        async for event in subscriber:
+            await websocket.send_text(event.message)
+
+
+routes = [
+    Route("/", homepage),
+    WebSocketRoute("/", chatroom_ws, name='chatroom_ws'),
+]
+
+
+app = Starlette(
+    routes=routes, on_startup=[broadcast.connect], on_shutdown=[broadcast.disconnect],
+)
+```
+
+The HTML template for the front end [is available here](https://github.com/encode/broadcaster/blob/master/templates/index.html), and is adapted from [Pieter Noordhuis's PUB/SUB demo](https://gist.github.com/pietern/348262).
+
+
+## Installation
+
+* `pip install broadcaster`
+* `pip install broadcaster[redis]`
+* `pip install broadcaster[postgres]`
+* `pip install broadcaster[kafka]`
+
+## Available backends
+
+* `Broadcast('memory://')`
+* `Broadcast("redis://localhost:6379")`
+* `Broadcast("postgres://localhost:5432/hostedapi")`
+* `Broadcast("kafka://localhost:9092")`
+
+## Where next?
+
+At the moment `broadcaster` is in Alpha, and should be considered a working design document.
+
+The API should be considered subject to change. If you *do* want to use Broadcaster in its current
+state, make sure to strictly pin your requirements to `broadcaster==0.2.0`.
+
+To be more capable we'd really want to add some additional backends, provide API support for reading recent event history from persistent stores, and provide a serialization/deserialization API...
+
+* Serialization / deserialization to support broadcasting structured data.
+* Backends for Redis Streams, Apache Kafka, and RabbitMQ.
+* Add support for `subscribe('chatroom', history=100)` for backends which provide persistence. (Redis Streams, Apache Kafka) This will allow applications to subscribe to channel updates, while also being given an initial window onto the most recent events. We *might* also want to support some basic paging operations, to allow applications to scan back in the event history.
+* Support for pattern subscribes in backends that support it.
+
+
+
+
+%package help
+Summary:	Development documents and examples for broadcaster
+Provides:	python3-broadcaster-doc
+%description help
+# Broadcaster
+
+Broadcaster helps you develop realtime streaming functionality in by providing
+a simple broadcast API onto a number of different backend services.
+
+It currently supports [Redis PUB/SUB](https://redis.io/topics/pubsub), [Apache Kafka](https://kafka.apache.org/), and [Postgres LISTEN/NOTIFY](https://www.postgresql.org/docs/current/sql-notify.html), plus a simple in-memory backend, that you can use for local development or during testing.
+
+<img src="https://raw.githubusercontent.com/encode/broadcaster/master/docs/demo.gif" alt='WebSockets Demo'>
+
+Here's a complete example of the backend code for a simple websocket chat app:
+
+**app.py**
+
+```python
+# Requires: `starlette`, `uvicorn`, `jinja2`
+# Run with `uvicorn example:app`
+from broadcaster import Broadcast
+from starlette.applications import Starlette
+from starlette.concurrency import run_until_first_complete
+from starlette.routing import Route, WebSocketRoute
+from starlette.templating import Jinja2Templates
+
+
+broadcast = Broadcast("redis://localhost:6379")
+templates = Jinja2Templates("templates")
+
+
+async def homepage(request):
+    template = "index.html"
+    context = {"request": request}
+    return templates.TemplateResponse(template, context)
+
+
+async def chatroom_ws(websocket):
+    await websocket.accept()
+    await run_until_first_complete(
+        (chatroom_ws_receiver, {"websocket": websocket}),
+        (chatroom_ws_sender, {"websocket": websocket}),
+    )
+
+
+async def chatroom_ws_receiver(websocket):
+    async for message in websocket.iter_text():
+        await broadcast.publish(channel="chatroom", message=message)
+
+
+async def chatroom_ws_sender(websocket):
+    async with broadcast.subscribe(channel="chatroom") as subscriber:
+        async for event in subscriber:
+            await websocket.send_text(event.message)
+
+
+routes = [
+    Route("/", homepage),
+    WebSocketRoute("/", chatroom_ws, name='chatroom_ws'),
+]
+
+
+app = Starlette(
+    routes=routes, on_startup=[broadcast.connect], on_shutdown=[broadcast.disconnect],
+)
+```
+
+The HTML template for the front end [is available here](https://github.com/encode/broadcaster/blob/master/templates/index.html), and is adapted from [Pieter Noordhuis's PUB/SUB demo](https://gist.github.com/pietern/348262).
+
+
+## Installation
+
+* `pip install broadcaster`
+* `pip install broadcaster[redis]`
+* `pip install broadcaster[postgres]`
+* `pip install broadcaster[kafka]`
+
+## Available backends
+
+* `Broadcast('memory://')`
+* `Broadcast("redis://localhost:6379")`
+* `Broadcast("postgres://localhost:5432/hostedapi")`
+* `Broadcast("kafka://localhost:9092")`
+
+## Where next?
+
+At the moment `broadcaster` is in Alpha, and should be considered a working design document.
+
+The API should be considered subject to change. If you *do* want to use Broadcaster in its current
+state, make sure to strictly pin your requirements to `broadcaster==0.2.0`.
+
+To be more capable we'd really want to add some additional backends, provide API support for reading recent event history from persistent stores, and provide a serialization/deserialization API...
+
+* Serialization / deserialization to support broadcasting structured data.
+* Backends for Redis Streams, Apache Kafka, and RabbitMQ.
+* Add support for `subscribe('chatroom', history=100)` for backends which provide persistence. (Redis Streams, Apache Kafka) This will allow applications to subscribe to channel updates, while also being given an initial window onto the most recent events. We *might* also want to support some basic paging operations, to allow applications to scan back in the event history.
+* Support for pattern subscribes in backends that support it.
+
+
+
+
+%prep
+%autosetup -n broadcaster-0.2.0
+
+%build
+%py3_build
+
+%install
+%py3_install
+install -d -m755 %{buildroot}/%{_pkgdocdir}
+if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi
+if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi
+if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi
+if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi
+pushd %{buildroot}
+if [ -d usr/lib ]; then
+	find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/lib64 ]; then
+	find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/bin ]; then
+	find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/sbin ]; then
+	find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+touch doclist.lst
+if [ -d usr/share/man ]; then
+	find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst
+fi
+popd
+mv %{buildroot}/filelist.lst .
+mv %{buildroot}/doclist.lst .
+
+%files -n python3-broadcaster -f filelist.lst
+%dir %{python3_sitelib}/*
+
+%files help -f doclist.lst
+%{_docdir}/*
+
+%changelog
+* Fri May 05 2023 Python_Bot <Python_Bot@openeuler.org> - 0.2.0-1
+- Package Spec generated
diff --git a/sources b/sources
new file mode 100644
index 0000000..e4f2a94
--- /dev/null
+++ b/sources
@@ -0,0 +1 @@
+acd5c174716cac7a26f3685ed1df86bd  broadcaster-0.2.0.tar.gz