aiopppp

aiopppp is an asynchronous Python library designed to simplify connecting to and interacting with cameras that utilize the Peer-to-Peer Protocol (PPPP) which is implemented in some cheap cameras (A9, X5, etc.) This library enables seamless communication with compatible cameras for live video streaming, capturing snapshots, or configuring camera settings, all using asyncio for efficient performance.

Features

• Initial camera discovery (plain (not implemented yet), and encoded)
• Asynchronous peer-to-peer connections with PPPP-enabled cameras using JSON control protocol
• Stream live video feeds directly from the camera.
• Remote camera rotation
• (TBD) Capture snapshots and save them locally.
• (TBD) Configure and manage camera settings.
• Lightweight and easy to integrate into Python applications.

Installation

To install the library, run:

pip install aiopppp

Requirements

• Python 3.7 or higher
• Compatible PPPP-enabled cameras
• Required dependencies (automatically installed with pip):
  • asyncio
  • aiohttp

Quick Start

Here’s an example of how to use the library:

import asyncio
from aiopppp import connect, make_session

async def main():
    device = await connect("192.168.1.2", timeout=20)
    disconnected = asyncio.Event()
    session = make_session(device, on_device_lost=lambda lost_device: disconnected.set())
    session.start()
    await session.device_is_ready.wait()
    print("Connected to the device")
    print("Device info:", session.dev_properties)
    session.stop()
    await disconnected.wait()
    print("Disconnected from the device")
    
    
asyncio.run(main())

Or create discovery class and process found devices manually:

import asyncio
from aiopppp import Discovery, JsonSession

def on_disconnect():
    print("Disconnected from the device")

def on_device_found(device):
    print(f"Found device: {device}")
    session = JsonSession(device, on_disconnect=on_disconnect)
    session.start()

async def main():
    discovery = Discovery(remote_addr='255.255.255.255')
    await discovery.discover(on_device_found)

    
asyncio.run(main())

Running test web server

To test the library, you can run a simple web server that streams the camera feed. The server will automatically discover the camera and start streaming the video feed.

python -m aiopppp

Then, visit http://localhost:4000 in your browser to view the camera feed.

Troubleshooting

If you encounter issues:

1. Verify that your camera supports the PPPP protocol with JSON commands. The tested camera had prefix DGOK.
2. Check your camera in the same subnet as the machine with the script running.

Contributing

Contributions are welcome! Feel free to submit issues or pull requests on GitHub.

License

This project is licensed under the Apache 2.0 License. See the LICENSE file for details.