fetchMpesaToken function

Future<Map<String, dynamic>> fetchMpesaToken(String username, String password, { ApplicationMode applicationMode = ApplicationMode.production, })

Implementation

Future<Map<String, dynamic>> fetchMpesaToken(String username, String password,
    {ApplicationMode applicationMode = ApplicationMode.production}) async {
  final MpesaTokenModel _mpesaTokenModel = MpesaTokenModel();
  // models
  var mpesaTokenModel = await _mpesaTokenModel.fetch(username);

  // check if expires
  final bool _tokenModelRes = mpesaTokenModel?.isNotExpired() ?? false;
  if (_tokenModelRes) {
    return {'status': 0, 'token': mpesaTokenModel!.token};
  }

  final _base64E = base64Encode(utf8.encode('$username:$password'));
  final String basicAuth = 'Basic $_base64E';

  try {
    String _url = applicationMode == ApplicationMode.production
        ? mpesaTokenUrl
        : mpesaTokenUrlTest;
    final http.Response _res = await http.get(Uri.parse(_url),
        headers: <String, String>{'authorization': basicAuth});
    if (_res.statusCode == 200) {
      final _body = json.decode(_res.body);

      // save to hive box
      await _mpesaTokenModel.put(
          // token model
          MpesaTokenModel(
              _body['access_token'].toString(), // token
              DateTime.now().add(Duration(
                  seconds: int.tryParse(_body['expires_in'].toString()) ?? 0))),

          // token key
          username);

      return {'status': 0, 'token': _body['access_token'].toString()};
    } else {
      throw FetchTokenError(_res.body);
      // return {
      //   'status': 1,
      //   'errorMessage': json.decode(_res.body)
      // };
    }
  } catch (e) {
    throw FetchTokenError(e.toString());
    // return {
    //     'status': 101,
    //     'errorMessage': 'cannot reach mpesa daraja endpoint'
    //   };
  }
}