automatic import of python-asyncpg-listenopeneuler20.03

3 files changed, 298 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
index e69de29..7160b27 100644
--- a/.gitignore
+++ b/.gitignore
@@ -0,0 +1 @@
+/asyncpg-listen-0.0.6.tar.gz
diff --git a/python-asyncpg-listen.spec b/python-asyncpg-listen.spec
new file mode 100644
index 0000000..2d12115
--- /dev/null
+++ b/python-asyncpg-listen.spec
@@ -0,0 +1,296 @@
+%global _empty_manifest_terminate_build 0
+Name:		python-asyncpg-listen
+Version:	0.0.6
+Release:	1
+Summary:	Helps to use PostgreSQL listen/notify with asyncpg
+License:	MIT
+URL:		https://github.com/Pliner/asyncpg-listen
+Source0:	https://mirrors.aliyun.com/pypi/web/packages/3b/1f/a6f040117f88b32cffa25b3fa5984822e0b6a8c2baa854bbe5913499370d/asyncpg-listen-0.0.6.tar.gz
+BuildArch:	noarch
+
+Requires:	python3-asyncpg
+Requires:	python3-async-timeout
+
+%description
+# asyncpg-listen
+
+This library simplifies usage of listen/notify with [asyncpg](https://github.com/MagicStack/asyncpg):
+1. Handles loss of a connection
+2. Simplifies notifications processing from multiple channels
+3. Setups a timeout for receiving a notification
+4. Allows to receive all notifications/only last notification depending on ListenPolicy.
+
+```python
+import asyncio
+import asyncpg
+import asyncpg_listen
+
+
+async def handle_notifications(notification: asyncpg_listen.NotificationOrTimeout) -> None:
+    print(f"{notification} has been received")
+
+
+async def main():
+    listener = asyncpg_listen.NotificationListener(asyncpg_listen.connect_func(user="postgres"))
+    listener_task = asyncio.create_task(
+        listener.run(
+            {"simple": handle_notifications},
+            policy=asyncpg_listen.ListenPolicy.LAST,
+            notification_timeout=5
+        )
+    )
+
+    await asyncio.sleep(1)
+
+    connection = await asyncpg.connect(user="postgres")
+    try:
+        for i in range(42):
+            await connection.execute(f"NOTIFY simple, '{i}'")
+    finally:
+        await connection.close()
+
+    await asyncio.sleep(1)
+
+    listener_task.cancel()
+
+
+asyncio.run(main())
+
+```
+
+## v0.0.6 (2022-11-02)
+
+* [Add support of python 3.11](https://github.com/anna-money/asyncpg-listen/pull/135)
+
+
+## v0.0.5 (2022-05-23)
+
+* [Wait for tasks cancellation](https://github.com/anna-money/asyncpg-listen/pull/96)
+
+
+## v0.0.4 (2022-01-24)
+
+* [Reset failed attempts counter on successful connection](https://github.com/anna-money/asyncpg-listen/pull/58)
+
+
+## v0.0.3 (2022-01-23)
+
+* [Support python 3.8](https://github.com/anna-money/asyncpg-listen/pull/55)
+
+
+## v0.0.2 (2021-11-02)
+
+* [Support async-timeout 4.0+](https://github.com/Pliner/asyncpg-listen/pull/10)
+
+
+## v0.0.1 (2021-10-27)
+
+* A first version
+
+
+%package -n python3-asyncpg-listen
+Summary:	Helps to use PostgreSQL listen/notify with asyncpg
+Provides:	python-asyncpg-listen
+BuildRequires:	python3-devel
+BuildRequires:	python3-setuptools
+BuildRequires:	python3-pip
+%description -n python3-asyncpg-listen
+# asyncpg-listen
+
+This library simplifies usage of listen/notify with [asyncpg](https://github.com/MagicStack/asyncpg):
+1. Handles loss of a connection
+2. Simplifies notifications processing from multiple channels
+3. Setups a timeout for receiving a notification
+4. Allows to receive all notifications/only last notification depending on ListenPolicy.
+
+```python
+import asyncio
+import asyncpg
+import asyncpg_listen
+
+
+async def handle_notifications(notification: asyncpg_listen.NotificationOrTimeout) -> None:
+    print(f"{notification} has been received")
+
+
+async def main():
+    listener = asyncpg_listen.NotificationListener(asyncpg_listen.connect_func(user="postgres"))
+    listener_task = asyncio.create_task(
+        listener.run(
+            {"simple": handle_notifications},
+            policy=asyncpg_listen.ListenPolicy.LAST,
+            notification_timeout=5
+        )
+    )
+
+    await asyncio.sleep(1)
+
+    connection = await asyncpg.connect(user="postgres")
+    try:
+        for i in range(42):
+            await connection.execute(f"NOTIFY simple, '{i}'")
+    finally:
+        await connection.close()
+
+    await asyncio.sleep(1)
+
+    listener_task.cancel()
+
+
+asyncio.run(main())
+
+```
+
+## v0.0.6 (2022-11-02)
+
+* [Add support of python 3.11](https://github.com/anna-money/asyncpg-listen/pull/135)
+
+
+## v0.0.5 (2022-05-23)
+
+* [Wait for tasks cancellation](https://github.com/anna-money/asyncpg-listen/pull/96)
+
+
+## v0.0.4 (2022-01-24)
+
+* [Reset failed attempts counter on successful connection](https://github.com/anna-money/asyncpg-listen/pull/58)
+
+
+## v0.0.3 (2022-01-23)
+
+* [Support python 3.8](https://github.com/anna-money/asyncpg-listen/pull/55)
+
+
+## v0.0.2 (2021-11-02)
+
+* [Support async-timeout 4.0+](https://github.com/Pliner/asyncpg-listen/pull/10)
+
+
+## v0.0.1 (2021-10-27)
+
+* A first version
+
+
+%package help
+Summary:	Development documents and examples for asyncpg-listen
+Provides:	python3-asyncpg-listen-doc
+%description help
+# asyncpg-listen
+
+This library simplifies usage of listen/notify with [asyncpg](https://github.com/MagicStack/asyncpg):
+1. Handles loss of a connection
+2. Simplifies notifications processing from multiple channels
+3. Setups a timeout for receiving a notification
+4. Allows to receive all notifications/only last notification depending on ListenPolicy.
+
+```python
+import asyncio
+import asyncpg
+import asyncpg_listen
+
+
+async def handle_notifications(notification: asyncpg_listen.NotificationOrTimeout) -> None:
+    print(f"{notification} has been received")
+
+
+async def main():
+    listener = asyncpg_listen.NotificationListener(asyncpg_listen.connect_func(user="postgres"))
+    listener_task = asyncio.create_task(
+        listener.run(
+            {"simple": handle_notifications},
+            policy=asyncpg_listen.ListenPolicy.LAST,
+            notification_timeout=5
+        )
+    )
+
+    await asyncio.sleep(1)
+
+    connection = await asyncpg.connect(user="postgres")
+    try:
+        for i in range(42):
+            await connection.execute(f"NOTIFY simple, '{i}'")
+    finally:
+        await connection.close()
+
+    await asyncio.sleep(1)
+
+    listener_task.cancel()
+
+
+asyncio.run(main())
+
+```
+
+## v0.0.6 (2022-11-02)
+
+* [Add support of python 3.11](https://github.com/anna-money/asyncpg-listen/pull/135)
+
+
+## v0.0.5 (2022-05-23)
+
+* [Wait for tasks cancellation](https://github.com/anna-money/asyncpg-listen/pull/96)
+
+
+## v0.0.4 (2022-01-24)
+
+* [Reset failed attempts counter on successful connection](https://github.com/anna-money/asyncpg-listen/pull/58)
+
+
+## v0.0.3 (2022-01-23)
+
+* [Support python 3.8](https://github.com/anna-money/asyncpg-listen/pull/55)
+
+
+## v0.0.2 (2021-11-02)
+
+* [Support async-timeout 4.0+](https://github.com/Pliner/asyncpg-listen/pull/10)
+
+
+## v0.0.1 (2021-10-27)
+
+* A first version
+
+
+%prep
+%autosetup -n asyncpg-listen-0.0.6
+
+%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-asyncpg-listen -f filelist.lst
+%dir %{python3_sitelib}/*
+
+%files help -f doclist.lst
+%{_docdir}/*
+
+%changelog
+* Tue Jun 20 2023 Python_Bot <Python_Bot@openeuler.org> - 0.0.6-1
+- Package Spec generated
diff --git a/sources b/sources
new file mode 100644
index 0000000..da64157
--- /dev/null
+++ b/sources
@@ -0,0 +1 @@
+b0a9bc0ba51beff6ee7ad76e8a619db8  asyncpg-listen-0.0.6.tar.gz