AI自動売買の結果をDiscordに自動通知する仕組みを実装した

DISCORD_CONTENT_LIMIT = 2000
"""Discord webhookのcontentフィールドの文字数上限。"""
 
def send_discord_message(content: str, *, webhook_url: str | None = None) -> None:
    """Discordのincoming webhookへメッセージを送信する。
 
    webhook_url省略時はsettings.alert_webhook_urlを使う。空文字なら
    何もしない(通知は任意機能)。送信失敗時はログに残すだけで例外は
    送出しない。
    """
    url = webhook_url if webhook_url is not None else settings.alert_webhook_url
    if not url:
        return
 
    if len(content) > DISCORD_CONTENT_LIMIT:
        content = content[: DISCORD_CONTENT_LIMIT - 1] + "…"
 
    try:
        response = httpx.post(url, json={"content": content}, timeout=10.0)
        response.raise_for_status()
    except Exception:
        logger.exception("Discordへの通知送信に失敗しました")

if result.aborted:
    send_discord_message(f"⚠️ [{now_jst}] 実発注ジョブ: kabuステーションへの接続に失敗し、今回はスキップしました。")
elif result.orders_submitted:
    send_discord_message(
        f"🤖 [{now_jst}] 実発注ジョブ実行\n"
        f"総資産: {result.total_asset:,.0f}円\n"
        f"判断{result.decisions_made}件 / 発注{result.orders_submitted}件\n" + "\n".join(order_lines)
    )
else:
    send_discord_message(
        f"🤖 [{now_jst}] 実発注ジョブ実行: 発注なし(判断{result.decisions_made}件、"
        f"総資産{result.total_asset:,.0f}円)"
    )

except Exception as exc:
    logger.exception("live trading job failed")
    with session_scope() as session:
        session.add(SystemEvent(level="ERROR", category="live_trading_job_failed", message=str(exc), detail={}))
    send_discord_message(f"❌ [{now_jst}] 実発注ジョブでエラーが発生しました: {exc}")

def _format_order_line(session, broker, positions: dict, order: Order) -> str:
    name = symbol_name(order.symbol)
    display_name = f"{name}（{order.symbol}）" if name else order.symbol
 
    if order.side == "SELL":
        price = ...  # 判断時点の市場データを優先、無ければ現在値
        held_avg_cost = _held_avg_cost_for_decision(session, order.symbol, "SELL", order.submitted_at)
        if held_avg_cost is not None:
            pnl = (price - held_avg_cost) * order.qty
            pnl_text = f" (損益: {'+' if pnl >= 0 else ''}{pnl:,.0f}円)"
        else:
            pnl_text = ""
        return f"・{display_name} {order.qty}株 売却 @{price:,.1f}円{pnl_text}"
 
    ...
    return f"・{display_name} {order.qty}株 購入 @{price:,.1f}円"

@pytest.fixture(autouse=True)
def _disable_discord_webhook(monkeypatch):
    monkeypatch.setattr(settings, "alert_webhook_url", "")

"""pytest共通フィクスチャ。
 
2026-09-11、`test_scheduler_jobs.py`のテストが`settings.alert_webhook_url`
(ユーザーが実際に設定した本物のDiscord webhook URL)を無効化しないまま
`send_discord_message`を呼び出し、テスト用のダミーメッセージが実際のDiscord
チャンネルへ送信されてしまう事故が起きた。テスト全体でalert_webhook_urlを
強制的に空文字にし、個別のテストが明示的に上書きしない限り、外部へは
一切送信されないようにする。
"""
 
@pytest.fixture(autouse=True)
def _disable_discord_webhook_by_default(monkeypatch):
    monkeypatch.setattr(settings, "alert_webhook_url", "")