Metadata-Version: 2.4
Name: jsocket
Version: 2.0.2
Summary: Python JSON Server & Client
Author-email: Christopher Piekarski <chris@cpiekarski.com>
Maintainer-email: Christopher Piekarski <chris@cpiekarski.com>
License: Apache-2.0
Project-URL: Homepage, https://cpiekarski.com/2012/01/25/python-json-client-server-redux/
Keywords: json,socket,server,client
Classifier: Intended Audience :: Developers
Classifier: Programming Language :: Python :: 3.9
Classifier: Operating System :: OS Independent
Classifier: Development Status :: 5 - Production/Stable
Classifier: Topic :: System :: Networking
Classifier: Topic :: Software Development :: Libraries :: Application Frameworks
Classifier: Topic :: System :: Distributed Computing
Classifier: Topic :: System :: Hardware :: Symmetric Multi-processing
Requires-Python: >=3.8
Description-Content-Type: text/markdown
License-File: LICENSE
Dynamic: license-file

python-json-socket (jsocket)
============================

[![CI](https://github.com/chris-piekarski/python-json-socket/actions/workflows/ci.yml/badge.svg)](https://github.com/chris-piekarski/python-json-socket/actions/workflows/ci.yml)
![PyPI](https://img.shields.io/pypi/v/jsocket.svg)
![Python Versions](https://img.shields.io/pypi/pyversions/jsocket.svg)
![License](https://img.shields.io/pypi/l/jsocket.svg)

Simple JSON-over-TCP sockets for Python. This library provides:

- JsonClient/JsonServer: length‑prefixed JSON message framing over TCP
- ThreadedServer: a single-connection server running in its own thread
- ServerFactory/ServerFactoryThread: a per‑connection worker model for multiple clients

It aims to be small, predictable, and easy to integrate in tests or small services.


Install
-------

```
pip install jsocket
```

Requires Python 3.8+.


Quickstart
----------

Echo server with `ThreadedServer` and a client:

```python
import time
import jsocket

class Echo(jsocket.ThreadedServer):
    def __init__(self, **kwargs):
        super().__init__(**kwargs)
        self.timeout = 2.0  # sets both accept and recv timeouts

    # Return a dict to send a response back to the client
    def _process_message(self, obj):
        if isinstance(obj, dict) and 'echo' in obj:
            return obj
        return None

# Bind to an ephemeral port (port=0)
server = Echo(address='127.0.0.1', port=0)
_, port = server.socket.getsockname()
server.start()

client = jsocket.JsonClient(address='127.0.0.1', port=port)
assert client.connect() is True

payload = {"echo": "hello"}
client.send_obj(payload)
assert client.read_obj() == payload

client.close()
server.stop()
server.join()
```

Per‑connection workers with `ServerFactory`:

```python
import jsocket

class Worker(jsocket.ServerFactoryThread):
    def __init__(self):
        super().__init__()
        self.timeout = 2.0  # sets recv timeout for this worker

    def _process_message(self, obj):
        if isinstance(obj, dict) and 'message' in obj:
            return {"reply": f"got: {obj['message']}"}

server = jsocket.ServerFactory(Worker, address='127.0.0.1', port=5489)
server.start()
# Connect one or more clients; one Worker is spawned per connection
```


API Highlights
--------------

- JsonClient:
  - `connect()` returns True on success
  - `send_obj(dict)` sends a JSON object
  - `read_obj()` blocks until a full message is received; raises `socket.timeout` or `RuntimeError("socket connection broken")`
  - `timeout` sets both accept and recv timeouts
  - `accept_timeout` controls the server's accept timeout
  - `recv_timeout` controls the connection read timeout

- ThreadedServer:
  - Subclass and implement `_process_message(self, obj) -> Optional[dict]`
  - Return a dict to send a response; return `None` to send nothing
  - `start()`, `stop()`, `join()` manage the server thread
  - `send_obj(dict)` sends to the currently connected client

- ServerFactory / ServerFactoryThread:
  - `ServerFactoryThread` is a worker that handles one client connection
  - `ServerFactory` accepts connections and spawns a worker per client


Examples and Tests
------------------

- Examples: see `examples/example_servers.py` and `scripts/smoke_test.py`
- Pytest: end-to-end and listener tests under `tests/`
  - Run: `pytest -q`


Behavior-Driven Tests (Behave)
------------------------------

- Steps live under `features/steps/` and environment hooks in `features/environment.py`.
- To run Behave scenarios, add one or more `.feature` files under `features/` and run:
  - `pip install -r requirements-dev.txt`
  - `PYTHONPATH=. behave -f progress2`
- A minimal example feature:

  ```gherkin
  Feature: Echo round-trip
    Scenario: client/server echo
      Given I start the server
      And I connect the client
      When the client sends the object {"echo": "hi"}
      Then the client sees a message {"echo": "hi"}
  ```


Notes
-----

- Breaking change: version 2.0.0 uses a new framing header (magic + length + CRC32). v1 clients are incompatible.
- Message framing uses a 12‑byte header: 4‑byte magic, 4‑byte big‑endian length, and 4‑byte CRC32 of the payload, followed by a JSON payload encoded as UTF‑8.
- `max_message_size` defaults to 10MB; set `.max_message_size` to adjust or set to `None` to disable.
- On disconnect, reads raise `RuntimeError("socket connection broken")` so callers can distinguish cleanly from timeouts.
- Binding with `port=0` lets the OS choose an ephemeral port; find it with `server.socket.getsockname()`.


Links
-----

- PyPI: https://pypi.org/project/jsocket/
- License: see `LICENSE`
