Feat/rpc system

.coveragerc

@@ -0,0 +1,10 @@
+[run]
+branch = True
+source =
+    cbor_rpc
+
+[report]
+show_missing = True
+skip_covered = True
+omit =
+    tests/*

.github/workflows/tests.yml

@@ -0,0 +1,53 @@
+name: Run Tests
+
+on:
+  push:
+    branches:
+      - main
+      - master
+      - dev
+      - develop
+  pull_request:
+    branches:
+      - main
+      - master
+      - dev
+      - develop
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: "3.11"
+
+      - name: Install dependencies
+        run: |
+          python -m pip install --upgrade pip
+          pip install -r requirements.txt
+          pip install -e .
+
+      - name: Run tests with coverage
+        run: |
+          pytest --cov=cbor_rpc --cov-report=xml --junitxml=junit.xml -o junit_family=legacy
+
+      - name: Upload coverage reports to Codecov
+        uses: codecov/codecov-action@v5
+        with:
+          token: ${{ secrets.CODECOV_TOKEN }}
+          files: coverage.xml
+
+      - name: Upload test results to Codecov
+        if: ${{ !cancelled() }}
+        uses: codecov/test-results-action@v1
+        with:
+          token: ${{ secrets.CODECOV_TOKEN }}
+          files: junit.xml

.gitignore

@@ -3,3 +3,4 @@ venv/
 __pycache__/
 .pytest_cache/
 cbor_rpc.egg-info/
+.coverage

.vscode/settings.json

@@ -0,0 +1,7 @@
+{
+  "python.testing.pytestArgs": [
+    "tests"
+  ],
+  "python.testing.unittestEnabled": false,
+  "python.testing.pytestEnabled": true
+}

README.md

@@ -0,0 +1,3 @@
+cbor-rpc
+========
+[![codecov](https://codecov.io/github/mesudip/cbor-rpc-py/graph/badge.svg)](https://codecov.io/github/mesudip/cbor-rpc-py)

cbor_rpc/__init__.py

@@ -2,45 +2,49 @@
 CBOR-RPC: An async-compatible CBOR-based RPC system
 """
 
-from .emitter import AbstractEmitter
-from .async_pipe import Pipe
-from .transformer import Transformer
-from .promise import DeferredPromise
-from .client import RpcClient, RpcAuthorizedClient, RpcV1
-from .server import RpcServer, RpcV1Server
-from .server_base import Server
+from .event import AbstractEmitter
+from .pipe import EventPipe, Pipe
+from .timed_promise import TimedPromise
 from .tcp import TcpPipe, TcpServer
-from .json_transformer import JsonTransformer
-from .sync_pipe import SyncPipe
+from .transformer import CborStreamTransformer, CborTransformer, JsonTransformer, Transformer
+from .rpc import (
+    RpcClient,
+    RpcAuthorizedClient,
+    RpcServer,
+    RpcV1,
+    RpcV1Server,
+    Server,
+    RpcCallContext,
+    RpcLogger,
+)
 
 __all__ = [
-    # Emitter
-    'AbstractEmitter',
-
-    # Pipe classes
-    'Pipe',
-    'SyncPipe',
-    'Transformer',
-
     # Promise
-    'DeferredPromise',
-
-    # Client classes
-    'RpcClient',
-    'RpcAuthorizedClient',
-    'RpcV1',
-
-    # Server classes
-    'Server',
-    'RpcServer',
-    'RpcV1Server',
-
-    # TCP classes
-    'TcpPipe',
-    'TcpServer',
-
+    "TimedPromise",
+    # Emitter
+    "AbstractEmitter",
+    # Pipe abstract  classes
+    "EventPipe",
+    "Pipe",
+    # Server abstract classes
+    "Server",
+    # Rpc abstract classes
+    "RpcClient",
+    "RpcAuthorizedClient",
+    "RpcServer",
+    # Rpc base implementation
+    "RpcV1",
+    "RpcV1Server",
+    # Rpc high level
+    "RpcCallContext",
+        "RpcLogger",  # TCP classes
+    "TcpPipe",
+    "TcpServer",
     # Transformers
-    'JsonTransformer',
+    "Transformer",
+    "JsonTransformer",
+    "CborTransformer",
+    "CborStreamTransformer",
 ]
 
 __version__ = "0.1.0"