🧭 feat(admin): add crypto v2 migration status command

Add /crypto_migration_status for admins to track wallet_crypto_v2 rollout progress with pending breakdown, include the command in /help, and cover behavior with router tests.

Author: attid

bot/routers/admin.py

@@ -434,6 +434,51 @@ async def cmd_set_usdt(message: types.Message, session: AsyncSession):
     )
 
 
+@router.message(Command(commands=["crypto_migration_status"]))
+async def cmd_crypto_migration_status(message: types.Message, session: AsyncSession):
+    base_filter = MyMtlWalletBot.need_delete == 0
+
+    total_wallets = (
+        await session.execute(
+            select(func.count()).select_from(MyMtlWalletBot).filter(base_filter)
+        )
+    ).scalar() or 0
+
+    migrated_wallets = (
+        await session.execute(
+            select(func.count())
+            .select_from(MyMtlWalletBot)
+            .filter(base_filter, MyMtlWalletBot.wallet_crypto_v2.is_not(None))
+        )
+    ).scalar() or 0
+
+    pending_wallets = max(total_wallets - migrated_wallets, 0)
+
+    pending_requires_user_pin = (
+        await session.execute(
+            select(func.count())
+            .select_from(MyMtlWalletBot)
+            .filter(
+                base_filter,
+                MyMtlWalletBot.wallet_crypto_v2.is_(None),
+                MyMtlWalletBot.use_pin.in_([1, 2]),
+            )
+        )
+    ).scalar() or 0
+
+    pending_other = max(pending_wallets - pending_requires_user_pin, 0)
+    progress_pct = (migrated_wallets / total_wallets * 100) if total_wallets else 0.0
+
+    await message.answer(
+        "🔐 Crypto v2 migration status\n"
+        f"Total wallets: {total_wallets}\n"
+        f"Migrated: {migrated_wallets} ({progress_pct:.1f}%)\n"
+        f"Pending: {pending_wallets}\n"
+        f"- Pending (requires user PIN/password): {pending_requires_user_pin}\n"
+        f"- Pending (other): {pending_other}"
+    )
+
+
 @router.message(Command(commands=["help"]))
 async def cmd_help(message: types.Message):
     await message.answer(
@@ -448,6 +493,7 @@ async def cmd_help(message: types.Message):
         "/usdt1 — автовывод первого в очереди\n"
         "/check_usdt @user — сверка баланса БД и блокчейна\n"
         "/set_usdt @user amount — установка баланса БД\n"
+        "/crypto_migration_status — прогресс миграции wallet_crypto_v2\n"
         "/balance — проверить баланс"
     )
 

bot/tests/routers/test_admin.py

@@ -119,6 +119,48 @@ async def test_cmd_stats(mock_telegram, router_app_context, setup_admin_mocks):
     assert "op1: 5" in req["data"]["text"]
 
 
+@pytest.mark.asyncio
+async def test_cmd_crypto_migration_status(
+    mock_telegram, router_app_context, setup_admin_mocks
+):
+    """Test /crypto_migration_status: should show migration counters."""
+    dp = router_app_context.dispatcher
+    dp.include_router(admin_router)
+
+    def _result_with_scalar(value):
+        result = MagicMock()
+        result.scalar.return_value = value
+        return result
+
+    setup_admin_mocks.mock_session.execute = AsyncMock(
+        side_effect=[
+            _result_with_scalar(100),  # total
+            _result_with_scalar(80),  # migrated
+            _result_with_scalar(15),  # pending requires user pin/password
+        ]
+    )
+
+    update = create_message_update(
+        user_id=123,
+        text="/crypto_migration_status",
+        username="itolstov",
+    )
+    await dp.feed_update(
+        bot=router_app_context.bot,
+        update=update,
+        app_context=router_app_context,
+    )
+
+    req = get_telegram_request(mock_telegram, "sendMessage")
+    text = req["data"]["text"]
+    assert "Crypto v2 migration status" in text
+    assert "Total wallets: 100" in text
+    assert "Migrated: 80 (80.0%)" in text
+    assert "Pending: 20" in text
+    assert "Pending (requires user PIN/password): 15" in text
+    assert "Pending (other): 5" in text
+
+
 @pytest.mark.asyncio
 async def test_cmd_exit_restart_flow(
     mock_telegram, router_app_context, setup_admin_mocks

docs/exec-plans/active/2026-03-01-admin-crypto-migration-status.md

@@ -0,0 +1,38 @@
+# admin-crypto-migration-status: Admin command for crypto v2 migration progress
+
+## Context
+
+Need an admin-visible command to show how many wallets are not yet migrated to
+`wallet_crypto_v2`, with a compact breakdown useful during rollout.
+
+## Files/Directories To Change
+
+- `bot/routers/admin.py`
+- `bot/tests/routers/test_admin.py`
+- `docs/exec-plans/active/2026-03-01-admin-crypto-migration-status.md`
+
+## Edit Permission
+
+- [x] Allowed paths confirmed by user.
+- [x] No edits outside listed paths.
+
+Permission evidence (copy user wording or exact confirmation):
+
+> "новая задача пиши новый план. в админ режим хочу коменда которая покажет сколкьо еще не перешло на новый секрет" and "ок и еще в хелп добавить ее чтоб я не искал"
+
+## Change Plan
+
+1. [x] Add `/crypto_migration_status` command in admin router.
+2. [x] Include new command in `/help` output.
+3. [x] Add router test that validates command output structure.
+4. [x] Run targeted admin tests and `just check-fast`.
+
+## Risks / Open Questions
+
+- Keep query logic simple and deterministic for testability.
+- Exclude `need_delete=1` wallets from totals to match migration script behavior.
+
+## Verification
+
+- `cd bot && uv run --package mmwb-bot pytest tests/routers/test_admin.py`
+- `just check-fast`