wangjia
32bd64d676
- 心跳读取 /auth/ping 回带的授权概况，直接刷新横幅/状态栏/只读门禁，省去单独轮询 /license/info - 账号被停用/删除（401 USER_DISABLED）即强制重新登录 - 令牌持久化经串行队列 + 会话代号守卫，杜绝续期写入与登出交叉把失效 token 写回 - 写操作门禁（write_guard）+ 授权文案（license_copy）按 grace/readonly/locked 分阶段降级 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
53 lines
2.1 KiB
Dart
53 lines
2.1 KiB
Dart
import 'dart:async';
|
||
import 'package:flutter/foundation.dart';
|
||
import 'package:flutter_riverpod/flutter_riverpod.dart';
|
||
import '../core/api/api_client.dart';
|
||
import '../core/auth/auth_state.dart';
|
||
import 'license_provider.dart';
|
||
|
||
/// 登录态心跳：已登录时每 30s 执行一次 **单个** POST /auth/ping：
|
||
/// - 会话/在线检查：若会话已被撤销（被踢/管理员强制下线），后端返回 401，
|
||
/// ApiClient 拦截器触发 refresh→失败→onAuthFailed→logout，因此空闲用户也能在
|
||
/// ~30s 内感知到被下线；同时刷新 last_seen_at（在线状态）。
|
||
/// - 授权状态检查：ping 响应**回带**当前授权概况（license 字段，与 /license/info 同构），
|
||
/// 直接喂给 licenseProvider，使到期/续费/被改动等变化在 ~30s 内反映到横幅/状态栏/设置页。
|
||
/// 如此一次心跳即覆盖两件事，**无需**再单独轮询 /license/info（每 30s 少一次请求）。
|
||
final sessionHeartbeatProvider = Provider<SessionHeartbeat>((ref) {
|
||
final hb = SessionHeartbeat(ref);
|
||
ref.onDispose(hb.dispose);
|
||
hb.start();
|
||
return hb;
|
||
});
|
||
|
||
class SessionHeartbeat {
|
||
final Ref _ref;
|
||
Timer? _timer;
|
||
|
||
SessionHeartbeat(this._ref);
|
||
|
||
void start() {
|
||
_timer?.cancel();
|
||
_timer = Timer.periodic(const Duration(seconds: 30), (_) => _ping());
|
||
}
|
||
|
||
Future<void> _ping() async {
|
||
if (!_ref.read(authStateProvider).isLoggedIn) return;
|
||
// 一次 ping 同时完成会话/在线检查与授权概况刷新。
|
||
try {
|
||
final resp = await _ref.read(apiClientProvider).post('/auth/ping');
|
||
// ping 可能已触发登出，故重新判断登录态后再采纳授权概况。
|
||
final data = resp.data is Map ? resp.data['data'] : null;
|
||
if (data is Map &&
|
||
data.containsKey('license') &&
|
||
_ref.read(authStateProvider).isLoggedIn) {
|
||
_ref.read(licenseProvider.notifier).applyServerInfo(data['license']);
|
||
}
|
||
} catch (e) {
|
||
// 401 已由 ApiClient 拦截器处理（触发登出）；其余错误忽略，保留上次授权状态
|
||
debugPrint('[Heartbeat] ping failed: $e');
|
||
}
|
||
}
|
||
|
||
void dispose() => _timer?.cancel();
|
||
}
|