构建自定义提供商

mirobody/pulse/theta/
├── __init__.py
├── mirobody_<provider>/
│   ├── __init__.py
│   ├── provider_<provider>.py
│   └── README.md (可选)
└── platform/
    ├── __init__.py
    ├── base.py              # BaseThetaProvider
    ├── database_service.py  # 数据库操作
    ├── platform.py          # 平台管理
    ├── pull_task.py         # 计划的数据拉取任务
    └── utils.py             # 工具函数

BaseThetaProvider (来自 mirobody.pulse.theta.platform.base)
    ↓
ThetaYourProvider (您的实现)

from mirobody.pulse.theta.platform.base import BaseThetaProvider, ProviderInfo
from mirobody.pulse.theta.platform.indicator import StandardIndicator
from typing import Dict, List

class ThetaSimpleProvider(BaseThetaProvider):
    """简单示例提供商"""
    
    @classmethod
    def factory(cls, **configs):
        return cls()
    
    @classmethod
    def info(cls) -> ProviderInfo:
        return ProviderInfo(
            slug="theta_simple",
            name="简单提供商",
            description="示例提供商集成"
        )
    
    async def link(self, user_id: str, return_url: str = None) -> Dict:
        """发起 OAuth 流程"""
        # 生成 OAuth URL
        auth_url = self._build_auth_url(user_id)
        return {"link_web_url": auth_url}
    
    async def callback(self, user_id: str, **params) -> Dict:
        """处理 OAuth 回调"""
        # 使用 code 交换令牌
        tokens = await self._exchange_token(params.get("code"))
        # 安全地存储令牌
        await self._store_tokens(user_id, tokens)
        return {"success": True}
    
    async def unlink(self, user_id: str) -> Dict:
        """断开提供商连接"""
        await self._delete_tokens(user_id)
        return {"success": True}
    
    async def pull_from_vendor_api(self, user_id: str) -> List[Dict]:
        """从提供商 API 获取数据"""
        tokens = await self._get_tokens(user_id)
        # 调用厂商 API
        data = await self._api_call("/user/health", tokens)
        return data
    
    def format_data(self, raw_data: Dict) -> List[StandardPulseData]:
        """转换为标准格式"""
        return [
            StandardPulseData(
                indicator=StandardIndicator.DAILY_STEPS,
                value=str(raw_data["steps"]),
                start_time=raw_data["date"],
                end_time=raw_data["date"]
            )
        ]