130 lines
4.5 KiB
Dart
130 lines
4.5 KiB
Dart
// Author: fruit.com.cn
|
|
|
|
import 'package:flutter_test/flutter_test.dart';
|
|
import 'package:fruitshorts/core/data/models/auth_session.dart';
|
|
import 'package:fruitshorts/core/data/remote/api_client.dart';
|
|
import 'package:fruitshorts/core/data/remote/catalog_api.dart';
|
|
import 'package:fruitshorts/core/data/remote/library_api.dart';
|
|
import 'package:fruitshorts/core/data/remote/playback_api.dart';
|
|
import 'package:fruitshorts/core/data/remote/watch_api.dart';
|
|
|
|
/// K1 端到端联调：直连本机客户端接口服务（8081），把"首页 → 详情 → 播放票据 →
|
|
/// 上报进度 → 读回续看位置 → 收藏 → 收藏列表 → 取消收藏"整条链路走一遍。
|
|
///
|
|
/// 用一个一次性邮箱注册（需要登录态的接口才会通）；服务没起时自动跳过。
|
|
void main() {
|
|
const baseUrl = 'http://127.0.0.1:8081';
|
|
final email =
|
|
'k1.selftest.${DateTime.now().millisecondsSinceEpoch}@example.com';
|
|
const password = 'Passw0rd!23';
|
|
|
|
AuthSession? session;
|
|
final client = ApiClient(
|
|
baseUrl: baseUrl,
|
|
accessTokenReader: () => session?.accessToken,
|
|
deviceIdReader: () async => 'k1-live-device',
|
|
);
|
|
final catalog = CatalogApi(client);
|
|
final playback = PlaybackApi(client);
|
|
final watch = WatchApi(client);
|
|
final library = LibraryApi(client);
|
|
|
|
tearDownAll(client.close);
|
|
|
|
Future<bool> register() async {
|
|
try {
|
|
final raw = await client.post(
|
|
'/app/auth/register',
|
|
body: {
|
|
'targetType': 'EMAIL',
|
|
'target': email,
|
|
'password': password,
|
|
'nickname': 'K1 联调',
|
|
'deviceId': 'k1-live-device',
|
|
},
|
|
);
|
|
if (raw is! Map<String, dynamic>) return false;
|
|
session = AuthSession.fromJson(raw);
|
|
return true;
|
|
} catch (_) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
test('should_complete_the_watch_flow_when_backend_is_running', () async {
|
|
if (!await register()) {
|
|
markTestSkipped('客户端接口服务未启动，已跳过联调测试');
|
|
return;
|
|
}
|
|
expect(session?.user.uid, isNotEmpty);
|
|
|
|
final recentProbe = await client.get(
|
|
'/app/watch/recent',
|
|
query: {'pageIndex': '1', 'pageSize': '1'},
|
|
);
|
|
final favoriteProbe = await client.get(
|
|
'/app/favorites',
|
|
query: {'pageIndex': '1', 'pageSize': '1'},
|
|
);
|
|
if (recentProbe is! Map<String, dynamic> ||
|
|
favoriteProbe is! Map<String, dynamic>) {
|
|
markTestSkipped('运行中的后端仍返回旧版 List，分页契约联调已跳过');
|
|
return;
|
|
}
|
|
|
|
// 1) 首页 → 取第一部剧
|
|
final feed = await catalog.homeFeed();
|
|
expect(feed.dramas, isNotEmpty);
|
|
final card = feed.dramas.first;
|
|
expect(card.id, isNotEmpty);
|
|
|
|
// 2) 详情：剧集列表按集号升序，可播剧集带已签名地址
|
|
final detail = await catalog.dramaDetail(card.id);
|
|
expect(detail.id, card.id);
|
|
expect(detail.episodes, isNotEmpty);
|
|
final playable = detail.episodes
|
|
.where((episode) => episode.videoUrl.isNotEmpty)
|
|
.toList();
|
|
if (playable.isEmpty) {
|
|
markTestSkipped('这部演示剧没有可播剧集，已跳过播放相关断言');
|
|
return;
|
|
}
|
|
|
|
// 3) 播放票据：签名地址带 e/s，客户端原样使用
|
|
final ticket = await playback.ticket(playable.first.id);
|
|
expect(ticket.accessible, isTrue);
|
|
expect(ticket.accessType, isNotEmpty);
|
|
expect(ticket.playUrl, startsWith('/files/'));
|
|
expect(ticket.playUrl, contains('e='));
|
|
expect(ticket.playUrl, contains('s='));
|
|
|
|
// 4) 上报进度 → 读回续看位置
|
|
const position = Duration(seconds: 42);
|
|
final saved = await watch.saveProgress(
|
|
episodeId: playable.first.id,
|
|
position: position,
|
|
duration: Duration(seconds: ticket.durationSec),
|
|
);
|
|
expect(saved?.episodeId, playable.first.id);
|
|
expect(saved?.position, position);
|
|
|
|
final resume = await watch.progressOfDrama(card.id);
|
|
expect(resume?.episodeId, playable.first.id);
|
|
expect(resume?.position, position);
|
|
|
|
// 最近观看里能看到这部剧
|
|
final recent = await watch.recent(pageSize: 20);
|
|
expect(recent.list.map((item) => item.dramaId), contains(card.id));
|
|
|
|
// 5) 收藏 → 出现在收藏列表 → 取消收藏
|
|
final savedState = await library.toggleFavorite(card.id);
|
|
expect(savedState, isTrue);
|
|
final favorites = await library.favorites();
|
|
expect(favorites.list.map((drama) => drama.id), contains(card.id));
|
|
|
|
await library.removeFavorite(card.id);
|
|
final afterRemove = await library.favorites();
|
|
expect(afterRemove.list.map((drama) => drama.id), isNot(contains(card.id)));
|
|
});
|
|
}
|