connect.dart 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. import 'dart:core';
  2. import 'package:fis_jsonrpc/client_base.dart';
  3. import 'package:fis_common/json_convert.dart';
  4. import 'connect.m.dart';
  5. import 'authentication.m.dart';
  6. class ConnectService extends JsonRpcClientBase {
  7. ConnectService(
  8. String host, {
  9. String serviceName = "IConnectService",
  10. Map<String, String>? headers,
  11. int? timeout,
  12. }) : super(
  13. host,
  14. serviceName,
  15. headers: headers,
  16. timeout: timeout,
  17. ) {
  18. /// 注册响应实体反序列化处理器
  19. FJsonConvert.setDecoder((map) => ConnectResult.fromJson(map));
  20. FJsonConvert.setDecoder((map) => CacheDeviceDTO.fromJson(map));
  21. }
  22. Future<ConnectResult> connect(ConnectRequest request) async {
  23. var rpcRst = await call("Connect", request);
  24. var result = ConnectResult.fromJson(rpcRst as Map<String, dynamic>);
  25. return result;
  26. }
  27. Future<CacheDeviceDTO> getDeviceByToken(TokenRequest request) async {
  28. var rpcRst = await call("GetDeviceByToken", request);
  29. var result = CacheDeviceDTO.fromJson(rpcRst as Map<String, dynamic>);
  30. return result;
  31. }
  32. Future<bool> disConnect(TokenRequest request) async {
  33. var rpcRst = await call("DisConnect", request);
  34. return rpcRst;
  35. }
  36. }