WingCloudServer/Tools/TestTools/client/lib/Services/UserService.dart

import 'dart:async';
import 'dart:convert';
import 'dart:js_util';
import 'package:get_it/get_it.dart';
import 'package:http/http.dart' as http;
import 'package:localstorage/localstorage.dart';
import 'package:sprintf/sprintf.dart';
import 'package:ustest/Services/LocalStorageService.dart';
import 'dart:typed_data';

import 'package:web_socket_channel/web_socket_channel.dart';

import 'AppSettings.dart';

class UserService {
  late User currentUser;
  final String UserStroageKey = "CurrentUser";
  final LocalStorage storage = new LocalStorage('UserStroage');
  late WebSocketChannel? Channel = WebSocketChannel.connect(
    Uri.parse('ws://192.168.6.80:9301?token=${currentUser.accessToken}'),
  ); //TODO

  User? getCurrentUser() {
    //if (currentUser != null) //TODO workaround
    //{
    //  if (currentUser?.userName != 'notlogin') {
    //    return currentUser;
    //  }
    //}

    // this.storage.deleteItem(UserStroageKey);
    var value = this.storage.getItem(UserStroageKey);
    if (value != null) {
      print('getCurrentUser value:' + value.toString());
      currentUser = User.fromJson(value);
    } else {
      print('getCurrentUser value: null');
      currentUser =
          new User(userName: 'notlogin', accessToken: '', organizationCode: '');
    }

    return currentUser;
  }

  logout() {
    this.storage.deleteItem(UserStroageKey);
  }

  Future<bool> signInAsync(
      String host, String userName, String password) async {
    AppSettings.host = host;
    var client = http.Client();
    var body = sprintf(
        '{"jsonrpc": "2.0", "method": "CommonLoginAsync", "params": [{"AnyAccount": "%s", "AnyCode": "", "Password": "%s" }], "id": 1 }',
        [userName, password]);
    var response = await client
        .post(Uri.parse(AppSettings.host + '/ILoginService'), body: body);
    print('response.body' + response.body);
    var parsed = jsonDecode(response.body);
    var token = parsed['result']['Token'];
    if (token != null) {
      body = sprintf(
          '{"jsonrpc": "2.0", "method": "GetUserInfoAsync", "params": [{"Token": "%s" }], "id": 1 }',
          [token]);
      response = await client
          .post(Uri.parse(AppSettings.host + '/IUserService'), body: body);
      print('GetUserInfoAsync response.body' + response.body);
      var parsed = jsonDecode(response.body);
      if (parsed != null) {
        var organizationCode = parsed['result']['OrganizationCode'];
        var user = new User(
            userName: userName,
            accessToken: token,
            organizationCode: organizationCode);
        var jsonUser = user.toJson();

        this.storage.setItem(UserStroageKey, jsonUser);
        var userAgenter = UserAgentClient(client, token);

        print('jsonUser:' + jsonUser.toString());
        var url = Uri.parse(AppSettings.host);
        print("object" + url.host);
        Channel = WebSocketChannel.connect(
          Uri.parse('ws://192.168.6.80:9301?token=${token}'),
        );

        return true;
      }
    }

    return false;
  }

  dynamic post(
      http.Client client, String interface, String method, String args) async {
    final body = sprintf(
        '{"jsonrpc": "2.0", "method": "GetUserInfoAsync", "params": %s, "id": 1 }',
        args);
    final response = await client
        .post(Uri.parse(AppSettings.host + '/$interface'), body: body);
    print('GetUserInfoAsync response.body' + response.body);
    var parsed = jsonDecode(response.body);
  }
}

class UserAgentClient extends http.BaseClient {
  //final String userAgent;
  final http.Client _inner;
  final String token;
  late Timer? _timer;
  UserAgentClient(this._inner, this.token) {
    //cancelTimer();
    final Duration duration = Duration(seconds: 300);
    _timer = Timer(duration, () => Run());
  }

  Future<http.StreamedResponse> send(http.BaseRequest request) {
    //request.headers['user-agent'] = userAgent;
    return _inner.send(request);
  }

  void Run() {
    //cancelTimer();
    var request =
        http.Request('POST', Uri.parse(AppSettings.host + '/IUserService'));
    request.body =
        '{"jsonrpc": "2.0", "method": "HeartRateAsync", "params": [{"Token": "$token" }], "id": 1 }';
    var response = send(request);

    response.asStream().listen((event) {
      print('heartrate response:${event.toString()}');
    });
    response.then(
        (value) => {print('heartrate result:' + value.stream.toString())});
    //var parsed = jsonDecode(response.then((value) => {print(value)}));
    //return parsed['result'] as bool;
  }

  void cancelTimer() {
    _timer?.cancel();
  }
}

class JsonRpcResult {}

class User {
  final String userName;
  final String accessToken;
  final String organizationCode;

  User(
      {required this.userName,
      required this.accessToken,
      required this.organizationCode});
  factory User.fromJson(Map<String, dynamic> json) {
    return User(
      userName: json['userName'] as String,
      accessToken: json['accessToken'] as String,
      organizationCode: json['organizationCode'] as String,
    );
  }

  Map<String, dynamic> toJson() => {
        "userName": userName,
        "accessToken": accessToken,
        "organizationCode": organizationCode,
      };
}