trackoffical_app/app_business/lib/service/api.dart

import 'dart:async';
import 'dart:typed_data';

import 'package:app_business/app_config.dart';
import 'package:app_business/generated/base.pb.dart' as pb;
import 'package:app_business/generated/track_offical.pbgrpc.dart' as pb;
import 'package:app_business/service/app.dart';
import 'package:grpc/grpc.dart';
import 'package:track_common/track_common.dart';

import 'abase.dart';

typedef SmsType = pb.SmsType;

class ApiService extends IService {
  ClientChannel? channel;

  @override
  Future<void> init() async {
    channel = _newChannel();
  }

  ClientChannel _newChannel() {
    return ClientChannel(
      AppConfig.apiHost,
      port: AppConfig.apiPort,
      options: const ChannelOptions(credentials: ChannelCredentials.secure()
          // ChannelCredentials.insecure()
          ),
    );
  }

  pb.ApiToClient get stub {
    return _newStub(timeout: 10.seconds);
  }

  pb.ApiToClient _newStub({Duration? timeout, ClientChannel? channel}) {
    if (this.channel == null) {
      throw Exception('$runtimeType 未初始化');
    }
    final metadata = <String, String>{};
    metadata['version'] = _appVersion;
    if (token != null) {
      metadata['token'] = token!;
    }
    // debug("token: $token");

    return pb.ApiToClient(channel ?? this.channel!,
        options: CallOptions(
          metadata: metadata,
          timeout: timeout,
        ));
  }

  String get _appVersion => Get.find<AppService>().appVersion;

  set token(String? v) {
    Get.find<AppService>().token.val = v ?? '';
  }

  String? get token {
    final app = Get.find<AppService>();
    final token = app.token.val;
    if (token.isEmpty) {
      return null;
    }
    return token;
  }

  // 获取短信验证码
  Future<void> authSendCodeToPhone(String phone, SmsType smsType) async {
    info('authSendCodeToPhone [$phone]');
    await stub.toSendCodeToPhoneV2(pb.ToSendCodeToPhoneRequestV2()
      ..phone = phone
      ..smsType = smsType);
  }

  // 场控端_登录
  Future<void> signIn(String userCode, String password, String ip) async {
    final r = await stub.toSignInV2(pb.ToSignInRequestV2()
      ..userCode = userCode
      ..password = password
      ..ip = ip);
    token = r.token;

    debug('sign in success: $token');
  }

  // 场控端_登出
  void signOut() {
    stub.toSignOutV2(pb.DefaultRequest());
    token = null;
  }

  Future<Duration> getSmsSendLeftTime(String phone) async {
    final r = await stub
        .toGetSmsSendLeftTimeV2(pb.GetSmsSendLeftTimeRequest()..phone = phone);
    info('getSmsSendLeftTime: $phone - ${r.second}s');
    return r.second.seconds;
  }

  Future<BinReader> getBinReaderByMd5(Uint8List md5) async {
    final stream =
        stub.toGetBinaryByMd5(pb.ToGetBinaryByMd5Request()..md5 = md5);
    final controller = StreamController<List<int>>();
    controller.onCancel = () {
      stream.cancel();
    };

    Future<void> rcv() async {
      try {
        await for (final one in stream) {
          controller.add(one.data);
        }
      } finally {
        controller.close();
        stream.cancel();
      }
    }

    rcv();
    stream.headers.then((value) => debug(value));
    final headers = await stream.headers;
    final lenStr = headers['all-length']!;
    final length = int.parse(lenStr);
    final nonce = headers['nonce']!;
    final ext = headers['ext']!;

    return BinReader(
        data: controller.stream, length: length, ext: ext, nonce: nonce);
  }
}