v0.6.0: CLI expansion — full endpoint coverage

Add CLI commands for company, financials, dividends, events, and
real-time stream. The stream command outputs JSON lines to stdout
with reconnect status on stderr; stop with Ctrl+C. All SDK endpoints
are now accessible via the CLI.

Author: sahmk-sa

CHANGELOG.md

@@ -4,6 +4,21 @@ All notable changes to the `sahmk` Python SDK will be documented in this file.
 
 This project follows [Semantic Versioning](https://semver.org/).
 
+## [0.6.0] — 2026-04-02
+
+### Added
+
+- **CLI: `company` command** — `sahmk company 2222` to get company info
+- **CLI: `financials` command** — `sahmk financials 2222` for financial statements
+- **CLI: `dividends` command** — `sahmk dividends 2222` for dividend history
+- **CLI: `events` command** — `sahmk events --symbol 2222 --limit 10` for stock events
+- **CLI: `stream` command** — `sahmk stream 2222,1120` for real-time WebSocket streaming with auto-reconnect; outputs JSON lines to stdout, status/errors to stderr; stop with Ctrl+C
+
+### Changed
+
+- CLI now covers all SDK endpoints (previously only quote, quotes, market, historical)
+- Stream command outputs each quote as a single JSON line for easy piping/parsing
+
 ## [0.5.0] — 2026-04-02
 
 ### Added

README.md

@@ -58,6 +58,11 @@ export SAHMK_API_KEY="your_api_key"
 sahmk quote 2222
 sahmk market gainers --limit 5
 sahmk historical 2222 --from 2026-01-01 --to 2026-01-28
+sahmk company 2222
+sahmk financials 2222
+sahmk dividends 2222
+sahmk events --symbol 2222 --limit 5
+sahmk stream 2222,1120
 ```
 
 You can also pass the key directly:

ROADMAP.md

@@ -47,13 +47,13 @@ Timelines are approximate and can change based on user feedback and API evolutio
 - Nested typed sub-objects (Liquidity, Fundamentals, Technicals, etc.)
 - `.raw` attribute on all models for original API response access
 
-## Next Milestones
+### v0.6.0 (released)
 
-### v0.6.0 (planned) — CLI expansion
+- CLI commands for `company`, `financials`, `dividends`, `events`, and `stream`
+- Full endpoint coverage in CLI
+- Stream command outputs JSON lines with auto-reconnect
 
-- CLI commands for `company`, `financials`, `dividends`, `events`
-- Optional `stream` CLI command
-- Improved CLI output modes
+## Next Milestones
 
 ## Documentation and Examples Plan
 

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "sahmk"
-version = "0.5.0"
+version = "0.6.0"
 description = "Lightweight Python client for the SAHMK Developer API."
 readme = "README.md"
 requires-python = ">=3.9"

sahmk/__init__.py

@@ -26,7 +26,7 @@
     Liquidity,
 )
 
-__version__ = "0.5.0"
+__version__ = "0.6.0"
 __all__ = [
     "SahmkClient",
     "SahmkError",

sahmk/cli.py

@@ -3,6 +3,7 @@
 """
 
 import argparse
+import asyncio
 import json
 import os
 import sys
@@ -73,6 +74,44 @@ def _build_parser():
         help='Interval: "1d", "1w", or "1m".',
     )
 
+    company_parser = subparsers.add_parser(
+        "company", help="Get company info (tiered by plan)."
+    )
+    company_parser.add_argument("symbol", help='Stock symbol (e.g., "2222").')
+
+    financials_parser = subparsers.add_parser(
+        "financials", help="Get financial statements (Starter+ plan)."
+    )
+    financials_parser.add_argument("symbol", help='Stock symbol (e.g., "2222").')
+
+    dividends_parser = subparsers.add_parser(
+        "dividends", help="Get dividend history and yield (Starter+ plan)."
+    )
+    dividends_parser.add_argument("symbol", help='Stock symbol (e.g., "2222").')
+
+    events_parser = subparsers.add_parser(
+        "events", help="Get AI-generated stock events (Pro+ plan)."
+    )
+    events_parser.add_argument(
+        "--symbol",
+        default=None,
+        help="Filter events for a specific stock symbol.",
+    )
+    events_parser.add_argument(
+        "--limit",
+        type=int,
+        default=None,
+        help="Number of events to return.",
+    )
+
+    stream_parser = subparsers.add_parser(
+        "stream", help="Stream real-time quotes via WebSocket (Pro+ plan)."
+    )
+    stream_parser.add_argument(
+        "symbols",
+        help='Comma-separated symbols to stream, e.g. "2222,1120".',
+    )
+
     return parser
 
 
@@ -88,6 +127,55 @@ def _print_json(payload, compact=False):
     print(json.dumps(data, ensure_ascii=False, indent=2))
 
 
+def _run_stream(client, symbols):
+    """Run the WebSocket stream, printing quotes as JSON lines."""
+
+    async def on_quote(msg):
+        symbol = msg.get("symbol", "?")
+        data = msg.get("data", {})
+        line = json.dumps(
+            {"symbol": symbol, **data},
+            ensure_ascii=False,
+        )
+        print(line, flush=True)
+
+    async def on_error(error):
+        err_msg = error.get("message", str(error))
+        print(
+            json.dumps({"error": err_msg}, ensure_ascii=False),
+            file=sys.stderr,
+            flush=True,
+        )
+
+    async def on_disconnect(reason):
+        print(
+            json.dumps({"status": "disconnected", "reason": reason}, ensure_ascii=False),
+            file=sys.stderr,
+            flush=True,
+        )
+
+    async def on_reconnect(attempt):
+        print(
+            json.dumps({"status": "reconnecting", "attempt": attempt}, ensure_ascii=False),
+            file=sys.stderr,
+            flush=True,
+        )
+
+    async def _stream():
+        await client.stream(
+            symbols,
+            on_quote=on_quote,
+            on_error=on_error,
+            on_disconnect=on_disconnect,
+            on_reconnect=on_reconnect,
+        )
+
+    try:
+        asyncio.run(_stream())
+    except KeyboardInterrupt:
+        pass
+
+
 def main(argv=None):
     parser = _build_parser()
     args = parser.parse_args(argv)
@@ -130,6 +218,20 @@ def main(argv=None):
                 to_date=args.to_date,
                 interval=args.interval,
             )
+        elif args.command == "company":
+            result = client.company(args.symbol)
+        elif args.command == "financials":
+            result = client.financials(args.symbol)
+        elif args.command == "dividends":
+            result = client.dividends(args.symbol)
+        elif args.command == "events":
+            result = client.events(symbol=args.symbol, limit=args.limit)
+        elif args.command == "stream":
+            symbols = [s.strip() for s in args.symbols.split(",") if s.strip()]
+            if not symbols:
+                parser.error("At least one symbol is required for stream.")
+            _run_stream(client, symbols)
+            return 0
         else:
             parser.error("Unknown command.")
             return 2

tests/test_cli.py

@@ -8,7 +8,7 @@
 
 import pytest
 import responses
-from sahmk.cli import main, _build_parser, _resolve_api_key, _print_json
+from sahmk.cli import main, _build_parser, _resolve_api_key, _print_json, _run_stream
 from sahmk.client import SahmkError
 
 
@@ -453,8 +453,169 @@ def test_compact_output(self, capsys, sample_quote_response):
         )
 
         exit_code = main(["--api-key", "test_key", "--compact", "quote", "2222"])
-        
+
         assert exit_code == 0
         captured = capsys.readouterr()
         # Compact output should not have indentation
         assert "\n  " not in captured.out
+
+
+class TestMainCompanyCommand:
+    """Tests for main function with company command."""
+
+    @responses.activate
+    def test_company_success(self, capsys, sample_company_response, monkeypatch):
+        """Test successful company command."""
+        monkeypatch.setenv("SAHMK_API_KEY", "test_key")
+        responses.add(
+            responses.GET,
+            "https://app.sahmk.sa/api/v1/company/2222/",
+            json=sample_company_response,
+            status=200,
+        )
+
+        exit_code = main(["company", "2222"])
+
+        assert exit_code == 0
+        captured = capsys.readouterr()
+        assert "2222" in captured.out
+        assert "Saudi Arabian Oil Company" in captured.out
+
+
+class TestMainFinancialsCommand:
+    """Tests for main function with financials command."""
+
+    @responses.activate
+    def test_financials_success(self, capsys, sample_financials_response, monkeypatch):
+        """Test successful financials command."""
+        monkeypatch.setenv("SAHMK_API_KEY", "test_key")
+        responses.add(
+            responses.GET,
+            "https://app.sahmk.sa/api/v1/financials/2222/",
+            json=sample_financials_response,
+            status=200,
+        )
+
+        exit_code = main(["financials", "2222"])
+
+        assert exit_code == 0
+        captured = capsys.readouterr()
+        assert "income_statement" in captured.out
+
+
+class TestMainDividendsCommand:
+    """Tests for main function with dividends command."""
+
+    @responses.activate
+    def test_dividends_success(self, capsys, sample_dividends_response, monkeypatch):
+        """Test successful dividends command."""
+        monkeypatch.setenv("SAHMK_API_KEY", "test_key")
+        responses.add(
+            responses.GET,
+            "https://app.sahmk.sa/api/v1/dividends/2222/",
+            json=sample_dividends_response,
+            status=200,
+        )
+
+        exit_code = main(["dividends", "2222"])
+
+        assert exit_code == 0
+        captured = capsys.readouterr()
+        assert "dividend_yield" in captured.out
+
+
+class TestMainEventsCommand:
+    """Tests for main function with events command."""
+
+    @responses.activate
+    def test_events_success(self, capsys, sample_events_response, monkeypatch):
+        """Test successful events command."""
+        monkeypatch.setenv("SAHMK_API_KEY", "test_key")
+        responses.add(
+            responses.GET,
+            "https://app.sahmk.sa/api/v1/events/",
+            json=sample_events_response,
+            status=200,
+        )
+
+        exit_code = main(["events"])
+
+        assert exit_code == 0
+        captured = capsys.readouterr()
+        assert "events" in captured.out
+
+    @responses.activate
+    def test_events_with_symbol(self, capsys, sample_events_response, monkeypatch):
+        """Test events command with --symbol filter."""
+        monkeypatch.setenv("SAHMK_API_KEY", "test_key")
+        responses.add(
+            responses.GET,
+            "https://app.sahmk.sa/api/v1/events/",
+            json=sample_events_response,
+            status=200,
+        )
+
+        exit_code = main(["events", "--symbol", "2222"])
+
+        assert exit_code == 0
+        request = responses.calls[0].request
+        assert "symbol=2222" in request.url
+
+    @responses.activate
+    def test_events_with_limit(self, capsys, sample_events_response, monkeypatch):
+        """Test events command with --limit."""
+        monkeypatch.setenv("SAHMK_API_KEY", "test_key")
+        responses.add(
+            responses.GET,
+            "https://app.sahmk.sa/api/v1/events/",
+            json=sample_events_response,
+            status=200,
+        )
+
+        exit_code = main(["events", "--limit", "5"])
+
+        assert exit_code == 0
+        request = responses.calls[0].request
+        assert "limit=5" in request.url
+
+
+class TestParserNewCommands:
+    """Tests for parsing new CLI commands."""
+
+    def test_parser_company_command(self):
+        parser = _build_parser()
+        args = parser.parse_args(["company", "2222"])
+        assert args.command == "company"
+        assert args.symbol == "2222"
+
+    def test_parser_financials_command(self):
+        parser = _build_parser()
+        args = parser.parse_args(["financials", "2222"])
+        assert args.command == "financials"
+        assert args.symbol == "2222"
+
+    def test_parser_dividends_command(self):
+        parser = _build_parser()
+        args = parser.parse_args(["dividends", "2222"])
+        assert args.command == "dividends"
+        assert args.symbol == "2222"
+
+    def test_parser_events_command(self):
+        parser = _build_parser()
+        args = parser.parse_args(["events", "--symbol", "2222", "--limit", "10"])
+        assert args.command == "events"
+        assert args.symbol == "2222"
+        assert args.limit == 10
+
+    def test_parser_events_no_args(self):
+        parser = _build_parser()
+        args = parser.parse_args(["events"])
+        assert args.command == "events"
+        assert args.symbol is None
+        assert args.limit is None
+
+    def test_parser_stream_command(self):
+        parser = _build_parser()
+        args = parser.parse_args(["stream", "2222,1120"])
+        assert args.command == "stream"
+        assert args.symbols == "2222,1120"