E2EEChat/lib/common/api.dart

import 'dart:convert';
import 'dart:io';

import 'package:crypto/crypto.dart';
import 'package:dio/adapter.dart';
import 'package:dio/dio.dart';
import 'package:e2ee_chat/common/global.dart';

class Api {
  Api();

  static Dio dio = Dio(BaseOptions(
    baseUrl: 'http://10.122.237.112:80/',
  ));

  static init() async {
    if (!Global.isRelease) {
      (dio.httpClientAdapter as DefaultHttpClientAdapter).onHttpClientCreate = (client) {
        client.findProxy = (uri) {
          return "PROXY 10.122.237.112:8080";
        };
        //代理工具会提供一个抓包的自签名证书，会通不过证书校验，所以我们禁用证书校验
        client.badCertificateCallback = (X509Certificate cert, String host, int port) => true;
      };
    }

    debug(await Dio().get('http://10.122.237.112/account/login'));
  }

  Future<String?> login({required String username, String? password, String? token}) async {
    debug('Api login begin');
    String _password = "";
    String? _token;
    if (password != null) {
      var bytes = utf8.encode(password);
      var digest = sha1.convert(bytes);
      _password = digest.toString();
    }
    var data = {"username": username, "token": token ?? Global.emptyToken, "password": password};
    debug('Api login data: $data');
    try {
      var r = await dio.post(
        "/account/login/", data: FormData.fromMap(data),
        // options: _options,
      );
      debug('Api login response: $r');
      var json = jsonDecode(r.data);
      _token = json["token"].toString();
      debug('Api login new token: $_token');
    } on DioError catch (e) {
      var data = e.response?.data;
      var status = e.response?.statusCode;
      debug('Api login error, statusCode: $status, data: $data');
      throw e;
    }
    debug('Api login end');
    return _token;
  }

  Future<bool> logout() async {
    debug('Api logout begin');
    bool _result = true;
    try {
      await dio.post("/account/logout/");
    } on DioError catch (e) {
      _result = false;
    }
    debug('Api logout end');
    return _result;
  }

  Future<bool> register(String username, String password) async {
    debug('Api register begin');
    bool _result = true;
    try {
      var data = {"username": username, "password": password, "password2": password};
      await dio.post('/account/register/', data: FormData.fromMap(data));
    } on DioError catch (e) {
      _result = false;
    }
    debug('Api register end');
    return _result;
  }

  Future<bool> edit({String? bio, File? avatar, String? phone}) async {
    debug('Api edit begin');
    bool _result = Global.profile.isLogin;
    if (_result) {
      try {
        Map<String, dynamic> data = {"bio": bio, "phone": phone};
        if (avatar != null) {
          var path = avatar.path;
          var name = path.substring(path.lastIndexOf("/") + 1, path.length);
          data["file"] = await MultipartFile.fromFile(path, filename: name);
        }
        var form = FormData.fromMap(data);
        await dio.post('/account/edit/${Global.profile.username}/', data: form);
      } on DioError catch (e) {
        _result = false;
      }
    }
    debug('Api edit end');
    return _result;
  }

  Future<List<String>?> friendList() async {
    debug('Api friendList begin');
    List<String>? friends;
    try {
      var r = await dio.post('/friends/friends_list/');
      friends = jsonDecode(r.data);
    } on DioError catch (e) {
      debug('get friend list failed!');
    }
    debug('Api friendList end');
    return friends;
  }

  Future<bool> addFriend(String username) async {
    debug("add friend begin");
    bool _result = true;
    try {
      await dio.post('/friends/add/', data: FormData.fromMap({"username": username}));
    } on DioError catch (e) {
      _result = false;
      debug("add friend failed: ${ () {
        switch (e.response?.statusCode) {
          case null: return "unknown error";
          case 421: return "already friend";
          case 422:case 400: return "failed";
        }
      } ()}");
    }
    debug("add friend end");
    return _result;
  }

  Future<bool> acceptFriend(String username) async {
    debug("accept friend begin");
    bool _result = true;
    try {
      await dio.post('/friends/accept/', data: FormData.fromMap({"username": username}));
    } on DioError catch (e) {
      debug("accept friend failed");
      _result = false;
    }
    debug("accept friend end");
    return _result;
  }

  Future<List<String>?> friendRequest() async {
    debug('Api friendRequest begin');
    List<String>? apps;
    try {
      var r = await dio.post('/friends/get_requests/');
      apps = jsonDecode(r.data);
    } on DioError catch (e) {
      debug('get friend request failed!');
    }
    debug('Api friendRequest end');
    return apps;
  }

  Future<bool> deleteFriend(String username) async {
    debug("delete friend begin");
    bool _result = true;
    try {
      await dio.post('/friends/delete/', data: FormData.fromMap({"username": username}));
    } on DioError catch (e) {
      debug("delete friend failed: ${ () {
        switch (e.response?.statusCode) {
          case null: return "unknown error";
          case 422:case 400: return "failed";
        }
      } ()}");
      _result = false;
    }
    debug("delete friend end");
    return _result;
  }
}