Merge branch 'main' into patch-1

Author: CodeBooster97

.github/workflows/release.yml

@@ -25,7 +25,7 @@ jobs:
         uses: PyO3/maturin-action@v1
         with:
           target: ${{ matrix.target }}
-          args: --release --out dist -i 3.8 3.9 3.10 3.11 3.12 3.13 pypy3.8 pypy3.9 pypy3.10
+          args: --release --out dist -i 3.9 3.10 3.11 3.12 3.13 pypy3.9 pypy3.10
           sccache: 'true'
           manylinux: auto
           before-script-linux: |
@@ -70,7 +70,7 @@ jobs:
         uses: PyO3/maturin-action@v1
         with:
           target: ${{ matrix.target }}
-          args: --release --out dist -i 3.8 3.9 3.10 3.11 3.12 3.13
+          args: --release --out dist -i 3.9 3.10 3.11 3.12 3.13
           sccache: 'true'
       - name: Upload wheels
         uses: actions/upload-artifact@v3
@@ -110,7 +110,7 @@ jobs:
         uses: PyO3/maturin-action@v1
         with:
           target: ${{ matrix.target }}
-          args: --release --out dist -i 3.8 3.9 3.10 3.11 3.12 3.13 pypy3.8 pypy3.9 pypy3.10
+          args: --release --out dist -i 3.9 3.10 3.11 3.12 3.13 pypy3.9 pypy3.10
           sccache: 'true'
       - name: Upload wheels
         uses: actions/upload-artifact@v3
@@ -164,7 +164,7 @@ jobs:
         uses: messense/maturin-action@v1
         with:
           target: ${{ matrix.target }}
-          args: --release --out dist -i 3.8 3.9 3.10 3.11 3.12 3.13 pypy3.8 pypy3.9 pypy3.10
+          args: --release --out dist -i 3.9 3.10 3.11 3.12 3.13 pypy3.9 pypy3.10
           manylinux: musllinux_1_2
       - name: Upload wheels
         uses: actions/upload-artifact@v3

.github/workflows/test.yaml

@@ -30,12 +30,12 @@ jobs:
     - uses: actions-rs/clippy-check@v1
       with:
         token: ${{ secrets.GITHUB_TOKEN }}
-        args: -p psqlpy --all-features -- -W clippy::all -W clippy::pedantic -D warnings
+        args: -p psqlpy --all-features -- -W clippy::all -W clippy::pedantic
   pytest:
     name: ${{matrix.job.os}}-${{matrix.py_version}}
     strategy:
       matrix:
-        py_version: ["3.8", "3.9", "3.10", "3.11", "3.12", "3.13"]
+        py_version: ["3.9", "3.10", "3.11", "3.12", "3.13"]
         job:
             - os: ubuntu-latest
               ssl_cmd: sudo apt-get update && sudo apt-get install libssl-dev openssl

.pre-commit-config.yaml

@@ -58,8 +58,6 @@ repos:
           - clippy::all
           - -W
           - clippy::pedantic
-          - -D
-          - warnings
 
       - id: check
         types:

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "psqlpy"
-version = "0.8.7"
+version = "0.9.0"
 edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
@@ -10,15 +10,8 @@ crate-type = ["cdylib"]
 
 [dependencies]
 deadpool-postgres = { git = "https://github.com/chandr-andr/deadpool.git", branch = "psqlpy" }
-pyo3 = { version = "*", features = [
-    "chrono",
-    "experimental-async",
-    "rust_decimal",
-    "py-clone",
-    "gil-refs",
-    "macros",
-] }
-pyo3-async-runtimes = { git = "https://github.com/chandr-andr/pyo3-async-runtimes.git", branch = "main", features = [
+pyo3 = { version = "0.23.4", features = ["chrono", "experimental-async", "rust_decimal", "py-clone", "macros"] }
+pyo3-async-runtimes = { git = "https://github.com/chandr-andr/pyo3-async-runtimes.git", branch = "psqlpy", features = [
     "tokio-runtime",
 ] }
 
@@ -59,3 +52,5 @@ pg_interval = { git = "https://github.com/chandr-andr/rust-postgres-interval.git
 pgvector = { git = "https://github.com/chandr-andr/pgvector-rust.git", branch = "psqlpy", features = [
     "postgres",
 ] }
+futures-channel = "0.3.31"
+futures = "0.3.31"

Cargo.toml

@@ -1,4 +1,5 @@
-[![PyPI - Python Version](https://img.shields.io/pypi/pyversions/psqlpy?style=for-the-badge)](https://pypi.org/project/psqlpy/)
+[![PyPI - Python Version](https://img.shields.io/badge/PYTHON-3.9%20%7C%203.10%20%7C%203.11%20%7C%203.12%20%7C%203.13-blue?style=for-the-badge
+)](https://pypi.org/project/psqlpy/)
 [![PyPI](https://img.shields.io/pypi/v/psqlpy?style=for-the-badge)](https://pypi.org/project/psqlpy/)
 [![PyPI - Downloads](https://img.shields.io/pypi/dm/psqlpy?style=for-the-badge)](https://pypistats.org/packages/psqlpy)
 

README.md

@@ -23,6 +23,7 @@ export default sidebar({
         "connection",
         "transaction",
         "cursor",
+        "listener",
         "results",
         "exceptions",
       ],

docs/.vuepress/sidebar.ts

@@ -8,6 +8,7 @@ title: Components
 - `Connection`: represents single database connection, can be retrieved from `ConnectionPool`.
 - `Transaction`: represents database transaction, can be made from `Connection`.
 - `Cursor`: represents database cursor, can be made from `Transaction`.
+- `Listener`: object to work with [LISTEN](https://www.postgresql.org/docs/current/sql-listen.html)/[NOTIFY](https://www.postgresql.org/docs/current/sql-notify.html) functionality, can be mode from `ConnectionPool`.
 - `QueryResult`: represents list of results from database.
 - `SingleQueryResult`: represents single result from the database.
 - `Exceptions`: we have some custom exceptions.

docs/components/components_overview.md

@@ -254,6 +254,18 @@ This is the preferable way to work with the PostgreSQL.
 :::
 
 
+### Listener
+
+Create a new instance of a listener.
+
+```python
+async def main() -> None:
+    ...
+    listener = db_pool.listener()
+```
+```
+
+
 ### Close
 
 To close the connection pool at the stop of your application.

docs/components/connection_pool.md

@@ -15,6 +15,7 @@ stateDiagram-v2
     RustPSQLDriverPyBaseError --> BaseConnectionError
     RustPSQLDriverPyBaseError --> BaseTransactionError
     RustPSQLDriverPyBaseError --> BaseCursorError
+    RustPSQLDriverPyBaseError --> BaseListenerError
     RustPSQLDriverPyBaseError --> RustException
     RustPSQLDriverPyBaseError --> RustToPyValueMappingError
     RustPSQLDriverPyBaseError --> PyToRustValueMappingError
@@ -44,6 +45,11 @@ stateDiagram-v2
         [*] --> CursorFetchError
         [*] --> CursorClosedError
     }
+    state BaseListenerError {
+        [*] --> ListenerStartError
+        [*] --> ListenerClosedError
+        [*] --> ListenerCallbackError
+    }
     state RustException {
         [*] --> DriverError
         [*] --> MacAddrParseError
@@ -127,3 +133,15 @@ Error in cursor fetch (any fetch).
 
 #### CursorClosedError
 Error if underlying connection is closed.
+
+### BaseListenerError
+Base error for all Listener errors.
+
+#### ListenerStartError
+Error if listener start failed.
+
+#### ListenerClosedError
+Error if listener manipulated but it's closed
+
+#### ListenerCallbackError
+Error if callback passed to listener isn't a coroutine