examples/client_integration.py

"""
POCKETAI Sovereign Client Wrapper (Production SDK)
Architected and Engineered by Mohamed-Gamal-F-R
"""

import json
import urllib.request
import urllib.error

print("=== POCKETAI ENTERPRISE CLIENT SDK ===")

class PocketAIClient:
    def __init__(self, endpoint: str = "http://localhost:5000/v1/sovereign/query", token: str = None):
        self.endpoint = endpoint
        self.token = token or "SECURE_LOCAL_TOKEN"

    def query(self, prompt: str) -> dict:
        payload = json.dumps({"prompt": prompt}).encode("utf-8")
        headers = {
            "Content-Type": "application/json",
            "Authorization": f"Bearer {self.token}"
        }
        
        req = urllib.request.Request(self.endpoint, data=payload, headers=headers, method="POST")
        try:
            with urllib.request.urlopen(req, timeout=5) as response:
                return json.loads(response.read().decode("utf-8"))
        except urllib.error.URLError as e:
            return {
                "status": "connection_offline_or_unauthorized",
                "reason": str(e.reason),
                "hint": "Ensure local Termux bridge node or licensed runtime is active."
            }

if __name__ == "__main__":
    client = PocketAIClient()
    result = client.query("Initialize sovereign sync pipeline.")
    print("Execution Result:", json.dumps(result, indent=2))