⚡ Pocket Option 24/7 OTC REST API, Reverse-Engineered Binary Stream Gateway & AI Signal Engine

📑 Table of Contents

🌟 System Overview & Highlights

🚀 Live API Interactive Swagger Documentation

🤖 Official Telegram Bots & Live Demos

🏗️ Architectural Design & Protocol Mechanics

┌────────────────────────────────────────────────────────┐
│                   CB TRADERS BD GATEWAY                │
│       https://api1.api.cbtradersbd.com/docs             │
└──────────────┬──────────────────────────┬──────────────┘
               │                          │
       REST API Requests          Decrypted Raw Binary Protocol Pipeline (WSS)
               │                          │
┌──────────────▼──────────────┐   ┌───────▼──────────────────────┐
│  FastAPI Async Web Server   │   │  High-Speed Binary Protocol Stream Pool   │
│  - Endpoint Validation      │   │  - Binary Frame Parsing      │
│  - JSON Schema Serializer   │   │  - Heartbeat Keep-Alive      │
│  - Token Authentication     │   │  - Auto-Reconnect Daemon     │
└──────────────┬──────────────┘   └───────┬──────────────────────┘
               │                          │
┌──────────────▼──────────────────────────▼──────────────┐
│                  Core Engine Layer                     │
│  - Session Manager & Cloudflare Clearance Handler      │
│  - Non-Repaint M1/M5 Historical Candle Persistence     │
│  - AI Multi-Indicator Signal Strategy Pipeline         │
└──────────────────────────────┬─────────────────────────┘
                               │
               ┌───────────────▼───────────────┐
               │    Pocket Option Live Platform    │
               │   (Real Markets & 24/7 OTC)   │
               └───────────────────────────────┘

📦 Complete Project Directory Structure

├── config/
│   ├── default.json             # Server host, port & connection pool configuration
│   └── strategies.json          # Technical indicators, RSI thresholds & Martingale setups
├── docs/
│   ├── API_REFERENCE.md         # Exhaustive endpoint reference and request/response payloads
│   └── DEPLOYMENT_GUIDE.md      # Step-by-step VPS Linux (Ubuntu/Debian) & Docker setup
├── examples/
│   ├── 01_quickstart.py         # 1-Click connection and live price check
│   ├── 02_stream_candles.py     # Real-time Binary Protocol Stream tick and candlestick listener
│   ├── 03_auto_trade_signals.py # Automated execution based on AI indicator signals
│   ├── 04_telegram_alerts.py    # Formatting and broadcasting signals to Telegram channels
│   └── 05_historical_export.py  # Exporting multi-day M1/M5 datasets to CSV and SQLite
├── src/
│   ├── core/
│   │   ├── __init__.py
│   │   ├── auth.py              # Cloudflare session token & cookie rotation manager
│   │   ├── client.py            # High-throughput asynchronous HTTP/REST client
│   │   ├── engine.py            # Master order processing & market event pipeline
│   │   └── binary protocol stream.py         # Resilient Reverse-Engineered Binary Protocol frame parser
│   ├── models/
│   │   ├── __init__.py
│   │   ├── candle.py            # Pydantic OHLCV candle validation schemas
│   │   ├── order.py             # Binary options trade order payload models
│   │   └── payout.py            # Live asset payout percentage schema
│   ├── services/
│   │   ├── __init__.py
│   │   ├── database.py          # SQLite/PostgreSQL persistence for 8-day rolling candles
│   │   └── telegram_bot.py      # Async Telegram broadcast & notification engine
│   ├── strategies/
│   │   ├── __init__.py
│   │   ├── martingale.py        # Dynamic stake sizing & risk mitigation calculator
│   │   ├── price_action.py      # Support/Resistance, Pinbar & Engulfing pattern scanner
│   │   └── rsi_bb.py            # RSI (14) + Bollinger Bands (20, 2) breakout analyzer
│   └── utils/
│       ├── __init__.py
│       ├── helpers.py           # Timezone converters, timestamp formatters & math tools
│       └── logger.py            # Colored asynchronous console & file logger
├── scripts/
│   ├── install.sh               # Automated Linux dependency installer
│   └── start_api.bat            # 1-Click Windows production launcher
├── .env.example                 # Environment variables template
├── .gitignore                   # Standard Python git exclusions
├── Dockerfile                   # Multi-stage optimized Docker build
├── docker-compose.yml           # Complete containerized service stack
├── requirements.txt             # Locked production dependencies
└── README.md                    # In-depth system documentation

⚡ Fast Installation & 1-Click Deployment

Option A: Local Python Environment

# 1. Clone the repository
git clone https://github.com/cbtradersbd/pocket-option-api.git
cd pocket-option-api

# 2. Create and activate virtual environment
python -m venv venv
# On Windows:
venv\Scripts\activate
# On Linux/macOS:
source venv/bin/activate

# 3. Install required production dependencies
pip install -r requirements.txt

# 4. Configure your environment
cp .env.example .env

# 5. Launch the FastAPI server
python -m uvicorn src.core.engine:app --host 0.0.0.0 --port 8000 --reload

Option B: Docker Containerization

docker-compose up -d --build

⚙️ Configuration Parameters (.env & JSON)

# .env Configuration File
API_BASE_URL=https://api1.api.cbtradersbd.com
API_KEY=cb_traders_bd_license_unlocked
BROKER=pocket option
DEFAULT_TIMEFRAME=1m
RETENTION_DAYS=8
TIMEZONE_OFFSET=UTC+6
LOG_LEVEL=INFO
TELEGRAM_BOT_TOKEN=your_telegram_bot_token
TELEGRAM_CHAT_ID=@your_channel

💻 Code Examples & Integration Snippets

1. Fetch Live Price & Continuous 24/7 OTC Feed

from src.core.client import BrokerApiClient
from src.utils.logger import logger

client = BrokerApiClient(base_url="https://api1.api.cbtradersbd.com/docs")
price_data = client.get_live_price("EURUSD_otc")
logger.info(f"Live Tick: {price_data}")

2. Stream Real-Time Candlesticks via Binary Protocol Stream

import asyncio
from src.core.binary protocol stream import ResilientBinary Protocol StreamClient
from src.utils.logger import logger

async def on_candle(candle):
    logger.info(f"Closed M1 Candle: Time={candle.time}, Open={candle.open}, High={candle.high}, Low={candle.low}, Close={candle.close}")

async def main():
    ws = ResilientBinary Protocol StreamClient(pair="EURUSD_otc")
    await ws.connect_and_listen(callback=on_candle)

if __name__ == "__main__":
    asyncio.run(main())

📡 Available REST Endpoints & Binary Protocol Stream Feeds

🎯 Signal Engine, Indicators & Winrate Filter

🛡️ Self-Healing, Cloudflare Bypass & Anti-Ban Architecture

🛒 Commercial Source Code Purchase & Licensing

Full Commercial Package Includes:

💳 Accepted Payment Methods:

💬 Direct Contact & Community

🌐 CB Traders BD Ecosystem : Explore All Broker APIs & Bots

❓ Frequently Asked Questions (FAQ)

🏷️ Search & Discovery Keywords

⭐ Star This Project