getCampaigns method

@override Future<Campaigns> getCampaigns(String envId, String visitorId, String? anonymousId, bool hasConsented, Map<String, Object> context,)

Implementation

@override
Future<Campaigns> getCampaigns(
    String envId,
    String visitorId,
    String? anonymousId,
    bool hasConsented,
    Map<String, Object> context) async {
  // Create url
  String urlString = Endpoints.DECISION_API + envId + Endpoints.CAMPAIGNS;

  Flagship.logger(Level.INFO, 'GET CAMPAIGNS :' + urlString);

  // create headers
  Map<String, String> fsHeaders = {
    "x-api-key": Flagship.sharedInstance().apiKey ?? "",
    "x-sdk-client": "flutter",
    "x-sdk-version": FlagshipVersion,
    "Content-type": "application/json"
  };

  /// Map to send
  Map<String, Object> params = {
    "visitorId": visitorId,
    "context": context,
    "trigger_hit": false,
    "visitor_consent": hasConsented ? true : false
  };
  // add xpc infos if needed
  if (anonymousId != null) {
    params.addEntries({"anonymousId": anonymousId}.entries);
  }
  // Create data to post
  Object data = json.encode(params);
  var response = await service.sendHttpRequest(
      RequestType.Post, urlString, fsHeaders, data,
      timeoutMs:
          Flagship.sharedInstance().getConfiguration()?.timeout ?? TIMEOUT);
  switch (response.statusCode) {
    case 200:
      Flagship.logger(Level.ALL, response.body, isJsonString: true);
      return Campaigns.fromJson(json.decode(response.body));
    default:
      Flagship.logger(
        Level.ALL,
        "Failed to synchronize",
      );
      throw Exception(
          'Flagship, Failed to synchronize'); // later will use the message of the body response ...
  }
}