sendMessage function

Future<String?> sendMessage(String _body, String _title, String _toUserId, bool _saveToDB, String cloudKey,)

Implementation

Future<String?> sendMessage(String _body, String _title, String _toUserId,
    bool _saveToDB, String cloudKey) async { // parent.appSettings.cloudKey

  if (_toUserId.isEmpty)
    return "_toId.isEmpty";

  var querySnapshot = await FirebaseFirestore.instance.collection("listusers").doc(_toUserId).get();
  if (!querySnapshot.exists)
    return "querySnapshot not exists";

  var data = querySnapshot.data();
  if (data == null)
    return "data == null";

  String _to = (data["FCB"]  != null) ? data["FCB"] : "";
  bool _enableNotify = (data["enableNotify"]  != null) ? data["enableNotify"] : true;
  if (!_enableNotify)
    return null;
  List<String> _blockedUsers = [];
  if (data['blockedUsers'] != null)
    for (dynamic key in data['blockedUsers']){
      _blockedUsers.add(key.toString());
    }

  User? user = FirebaseAuth.instance.currentUser;
  if (user == null)
    return "user = null";
  if (_blockedUsers.contains(user.uid))
    return "${user.uid} blocked";

  // for (var item in parent.notifyModel.users)
  //   if (item.id == _toId) {
  //     _to = item.fcb;
  //     break;
  //   }

  if (_to.isEmpty)
    return null;

  var pathFCM = 'https://fcm.googleapis.com/fcm/send';

  String _key = cloudKey;
  Map<String, String> requestHeaders = {
    'Content-type': 'application/json',
    'Accept': "application/json",
    'Authorization': "key=$_key",
  };

  dprint("Cloud Key cloudKey");

  var body = json.encoder.convert({
    'notification': {
      'body': _body, 'title': _title, 'click_action': 'FLUTTER_NOTIFICATION_CLICK', 'sound': 'default',
      // 'badge': 1
    },
    'priority': 'high',
    'sound': 'default',
    'data': {
      'body': _body, 'title': _title, 'click_action': 'FLUTTER_NOTIFICATION_CLICK', 'sound': 'default', 'chat': !_saveToDB,
      // 'badge': 1
    },
    'to': _to,
  });

  dprint('body: $body');
  var response = await http.post(Uri.parse(pathFCM), headers: requestHeaders, body: body).timeout(const Duration(seconds: 30));

  dprint('Response status: ${response.statusCode}');
  dprint('Response body: ${response.body}');

  // write to db
  if (_saveToDB) {
    try {
      await FirebaseFirestore.instance.collection("messages").add(
          {
            "time": FieldValue.serverTimestamp(),
            "title": _title,
            "body": _body,
            "user": _toUserId,
            "read": false
          });
    } catch (ex) {
      return "sendMessage " + ex.toString();
    }
  }
}