Deduplication flutter

example/ios/.vscode/launch.json

@@ -0,0 +1,15 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "type": "chrome",
+            "request": "launch",
+            "name": "Launch Chrome against localhost",
+            "url": "http://localhost:8080",
+            "webRoot": "${workspaceFolder}"
+        }
+    ]
+}

example/lib/Providers/fs_data.dart

@@ -6,7 +6,7 @@ import 'package:flutter/material.dart';
 
 class FSData extends ChangeNotifier {
   // Apikey
-  String _apiKey = "apiKey"; //
+  String _apiKey = "DxAcxlnRB9yFBZYtLDue1q01dcXZCw6aM49CQB23"; //
   // EnvId
   String _envId = "bkk9glocmjcg0vtmdlng"; //
   // Mode

example/lib/widgets/configuration.dart

@@ -406,8 +406,7 @@ class _ConfigurationState extends State<Configuration> with ShowDialog {
       GestureBinding.instance.pointerRouter
           .addGlobalRoute(_emotionAIGlobalPointerRoute);
     } catch (e) {
-      // Todo later add flagship logger
-      print(e);
+      Flagship.logger(Level.ERROR, e.toString());
     }
 
     Flagship.sharedInstance()

example/pubspec.lock

@@ -103,7 +103,7 @@ packages:
       path: ".."
       relative: true
     source: path
-    version: "4.1.1-beta"
+    version: "4.1.2-beta"
   flutter:
     dependency: "direct main"
     description: flutter

lib/flagship_version.dart

@@ -1,2 +1,2 @@
 /// This file is automatically updated
-const FlagshipVersion = "4.1.2-beta";
+const FlagshipVersion = "4.2.0-beta";

lib/model/exposed_flag.dart

@@ -15,8 +15,11 @@ class ExposedFlag<T> implements IFlag {
   final T _value;
   // Metadata
   final FlagMetadata _metadata;
+  // If flag is already activated
+  bool alreadyActivatedCampaign = false;
 
-  ExposedFlag(this._key, this._value, this._defaultValue, this._metadata);
+  ExposedFlag(this._key, this._value, this._defaultValue, this._metadata,
+      {bool alreadyActivatedCampaign = false});
 
   T get value {
     return _value;
@@ -37,7 +40,8 @@ class ExposedFlag<T> implements IFlag {
       "key": this.key,
       "value": this.value,
       "defaultValue": this.defaultValue,
-      "metadata": this.metadata().toJson()
+      "metadata": this.metadata().toJson(),
+      "alreadyActivatedCampaign": this.alreadyActivatedCampaign
     };
   }
 }

lib/visitor.dart

@@ -40,6 +40,8 @@ enum Instance {
   NEW_INSTANCE
 }
 
+const Duration FSSessionVisitor = Duration(seconds: 1 * 60 * 30); // 30 min
+
 class Visitor with EmotionAiDelegate {
   /// VisitorId
   String visitorId;
@@ -77,6 +79,7 @@ class Visitor with EmotionAiDelegate {
   Map<String, dynamic> assignmentsHistory = {};
 
   /// Delegate visitor
+
   late VisitorDelegate _visitorDelegate;
 
   /// Delegate to update the status
@@ -137,6 +140,9 @@ class Visitor with EmotionAiDelegate {
     }
   }
 
+  // Init the sesssion
+  DateTime sessionDuration = DateTime.now();
+
   // Create new instance for visitor
   Visitor(
       this.config,
@@ -208,11 +214,13 @@ class Visitor with EmotionAiDelegate {
 
   // Update context directely with map for <String, Object>
   void clearContext() {
+    sessionDuration = DateTime.now();
     _context.clear();
   }
 
   // Update context directely with map for <String, Object>
   void updateContextWithMap(Map<String, Object> context) {
+    sessionDuration = DateTime.now();
     var oldContext = Map.fromEntries(_context.entries);
     _context.addAll(context);
     if (mapEquals(oldContext, _context) == false) {
@@ -241,6 +249,7 @@ class Visitor with EmotionAiDelegate {
   /// otherwise the update context skip with warnning log
 
   void updateContext<T>(String key, T value) {
+    sessionDuration = DateTime.now();
     var oldContext = Map.fromEntries(_context.entries);
 
     /// Delegate the action to strategy to update
@@ -259,6 +268,7 @@ class Visitor with EmotionAiDelegate {
 
   /// Update with predefined context
   void updateFlagshipContext<T>(FlagshipContext flagshipContext, T value) {
+    sessionDuration = DateTime.now();
     if (FlagshipContextManager.chekcValidity(flagshipContext, value)) {
       updateContext(rawValue(flagshipContext), value);
     } else {
@@ -270,6 +280,7 @@ class Visitor with EmotionAiDelegate {
   // Get Flag
   // - Return Flag instance
   Flag getFlag<T>(String key) {
+    sessionDuration = DateTime.now();
     if (_flagSyncStatus != FlagSyncStatus.FLAGS_FETCHED) {
       Flagship.logger(
           Level.ALL, _flagSyncStatus.warningMessage(visitorId, key));
@@ -280,6 +291,7 @@ class Visitor with EmotionAiDelegate {
   // Get the colllection flags
   /// - Returns: an instance of FSFlagCollection with flags
   FlagCollection getFlags() {
+    sessionDuration = DateTime.now();
     Map<String, Flag> ret = {};
 
     this.modifications.forEach((keyItem, modifItem) {
@@ -289,6 +301,8 @@ class Visitor with EmotionAiDelegate {
   }
 
   Future<void> fetchFlags() async {
+    sessionDuration = DateTime.now();
+
     /// Delegate the action to strategy
     this.flagStatus = FlagStatus.FETCHING;
     return _visitorDelegate.fetchFlags().then((fetchResponse) {
@@ -308,12 +322,14 @@ class Visitor with EmotionAiDelegate {
 
   /// Send hit
   Future<void> sendHit(BaseHit hit) async {
+    sessionDuration = DateTime.now();
     // Delegate the action to strategy
     _visitorDelegate.sendHit(hit);
   }
 
   /// Set Consent
   void setConsent(bool newValue) {
+    sessionDuration = DateTime.now();
     // flush the hits from the pool
     if (newValue == false) {
       this.trackingManager?.flushAllTracking(this.visitorId);
@@ -343,6 +359,7 @@ class Visitor with EmotionAiDelegate {
   /// - Requires: Make sure that the experience continuity option is enabled on the flagship platform before using this method
 
   authenticate(String visitorId) {
+    sessionDuration = DateTime.now();
     _isAuthenticated = true;
     _visitorDelegate.getStrategy().authenticateVisitor(visitorId);
     this.flagStatus = FlagStatus.FETCH_REQUIRED;
@@ -353,6 +370,7 @@ class Visitor with EmotionAiDelegate {
 
   /// Use authenticate methode to go from Logged in  session to logged out session
   unauthenticate() {
+    sessionDuration = DateTime.now();
     _isAuthenticated = false;
     _visitorDelegate.getStrategy().unAuthenticateVisitor();
     this.flagStatus = FlagStatus.FETCH_REQUIRED;
@@ -368,11 +386,13 @@ class Visitor with EmotionAiDelegate {
 
   @visibleForTesting
   FlagSyncStatus getFlagSyncStatus() {
+    sessionDuration = DateTime.now();
     return _flagSyncStatus;
   }
 
   // Add emotionAI function
   collectEmotionsAIEvents(String screenName) {
+    sessionDuration = DateTime.now();
     if (Flagship.sharedInstance().eaiCollectEnabled == true) {
       if (eaiVisitorScored == true) {
         Flagship.logger(Level.INFO,

lib/visitor/Ivisitor.dart

@@ -15,7 +15,7 @@ abstract class IVisitor {
 // Fetch Flags
   Future<void> fetchFlags();
 // Activate modification
-  Future<void> activateModification(String key);
+  // Future<void> activateModification(String key);
 // Activate flag
   Future<void> activateFlag(Modification pModification);
 // Send Hits

lib/visitor/strategy/default_strategy.dart

@@ -22,7 +22,6 @@ import 'package:flagship/visitor/Ivisitor.dart';
 // This class represent the default behaviour
 class DefaultStrategy implements IVisitor {
   final Visitor visitor;
-
   DefaultStrategy(this.visitor);
 
   @override
@@ -39,65 +38,85 @@ class DefaultStrategy implements IVisitor {
     }
   }
 
-  // Activate
-  Future<void> _sendActivate(Modification pModification) async {
-    // Check if the callback is defined
-    String? exposedFlag;
-    String? exposedVisitor;
-    if (Flagship.sharedInstance().getConfiguration()?.onVisitorExposed !=
-        null) {
-      exposedFlag = jsonEncode(ExposedFlag(
-              pModification.key,
-              pModification.value,
-              pModification.defaultValue,
-              FlagMetadata.withMap(pModification.toJsonInformation()))
-          .toJson());
-
-      exposedVisitor = jsonEncode(VisitorExposed(
-              visitor.visitorId, visitor.anonymousId, visitor.getContext())
-          .toJson());
-    }
-    // Build the activate hit
-    Activate activateHit = Activate(
-        pModification,
+  Future<void> _sendActivate(
+    Modification modification,
+    bool isDuplicated,
+  ) async {
+    // Get config and callback
+    final config = Flagship.sharedInstance().getConfiguration();
+    final onExposed = config?.onVisitorExposed;
+
+    // Prepare exposure object
+    ExposedFlag? exposedFlag;
+    VisitorExposed? exposedVisitor;
+    if (onExposed != null) {
+      exposedFlag = ExposedFlag(
+        modification.key,
+        modification.value,
+        modification.defaultValue,
+        FlagMetadata.withMap(modification.toJsonInformation()),
+      );
+      exposedVisitor = VisitorExposed(
         visitor.visitorId,
         visitor.anonymousId,
-        Flagship.sharedInstance().envId ?? "",
-        exposedFlag,
-        exposedVisitor);
-    // Process the troubleShooting
-    DataUsageTracking.sharedInstance().processTroubleShootingHits(
-        CriticalPoints.VISITOR_SEND_ACTIVATE.name, visitor, activateHit);
-    visitor.trackingManager?.sendActivate(activateHit).then((activateResponse) {
-      if (activateResponse.statusCode >= 200 &&
-          activateResponse.statusCode < 300) {
-      } else {
-        Flagship.logger(
-            Level.ERROR,
-            ACTIVATE_FAILED +
-                " status code = ${activateResponse.statusCode.toString()}");
+        visitor.getContext(),
+      );
+    }
+
+    // When deduplicated
+    if (isDuplicated) {
+      if (onExposed != null && exposedFlag != null && exposedVisitor != null) {
+        exposedFlag.alreadyActivatedCampaign = true;
+        onExposed(exposedVisitor, exposedFlag);
       }
-    });
-  }
+      Flagship.logger(Level.INFO, " The camapign's flag already activated ");
+      return;
+    }
 
-  @override
-  Future<void> activateModification(String key) async {
-    if (visitor.modifications.containsKey(key)) {
-      try {
-        var modification = visitor.modifications[key];
+    // When not duplicated
+    final String? flagJson =
+        exposedFlag != null ? jsonEncode(exposedFlag) : null;
+    final String? visitorJson =
+        exposedVisitor != null ? jsonEncode(exposedVisitor) : null;
+
+    final activateHit = Activate(
+      modification,
+      visitor.visitorId,
+      visitor.anonymousId,
+      Flagship.sharedInstance().envId ?? '',
+      flagJson,
+      visitorJson,
+    );
+
+    // Send troubleshooting
+    DataUsageTracking.sharedInstance().processTroubleShootingHits(
+      CriticalPoints.VISITOR_SEND_ACTIVATE.name,
+      visitor,
+      activateHit,
+    );
 
-        if (modification != null) {
-          await _sendActivate(modification);
-        }
-      } catch (exp) {
-        Flagship.logger(Level.EXCEPTIONS, EXCEPTION.replaceFirst("%s", "$exp"));
+    // Send Activate hit
+    try {
+      final response = await visitor.trackingManager?.sendActivate(activateHit);
+      final status = response?.statusCode ?? -1;
+      if (status < 200 || status >= 300) {
+        Flagship.logger(
+          Level.ERROR,
+          'ACTIVATE_FAILED: status code = $status',
+        );
       }
+    } catch (e, stack) {
+      Flagship.logger(
+        Level.ERROR,
+        'ACTIVATE_FAILED: exception = $e\n$stack',
+      );
     }
   }
 
   @override
-  Future<void> activateFlag(Modification pModification) async {
-    return _sendActivate(pModification);
+  Future<void> activateFlag(Modification pModification,
+      {bool isDuplicated = false}) async {
+    return _sendActivate(pModification, isDuplicated);
   }
 
   @override
@@ -147,7 +166,10 @@ class DefaultStrategy implements IVisitor {
         }
         if (activate && hasSameType) {
           // Send activate later
-          _sendActivate(modification);
+
+          this._sendActivate(modification, false);
+
+          /// Attention a remove cette partie ou a revoir
         }
       } catch (exp) {
         Flagship.logger(Level.INFO,

lib/visitor/strategy/no_consent_strategy.dart

@@ -12,12 +12,13 @@ class NoConsentStrategy extends DefaultStrategy {
 
 // The activate modification is not allowed
   @override
-  Future<void> activateModification(String key) async {
-    Flagship.logger(Level.INFO, CONSENT_ACTIVATE);
-  }
+  // Future<void> activateModification(String key) async {
+  // Flagship.logger(Level.INFO, CONSENT_ACTIVATE);
+  // }
 
   @override
-  Future<void> activateFlag(Modification pFlag) async {
+  Future<void> activateFlag(Modification pFlag,
+      {bool isDuplicated = false}) async {
     Flagship.logger(Level.INFO, CONSENT_ACTIVATE);
   }
 

lib/visitor/strategy/not_ready_strategy.dart

@@ -18,12 +18,8 @@ class NotReadyStrategy extends DefaultStrategy {
   }
 
   @override
-  Future<void> activateModification(String key) async {
-    Flagship.logger(Level.ERROR, ACTIVATE_NOT_READY);
-  }
-
-  @override
-  Future<void> activateFlag(Modification pFlag) async {
+  Future<void> activateFlag(Modification pFlag,
+      {bool isDuplicated = false}) async {
     Flagship.logger(Level.ERROR, ACTIVATE_NOT_READY);
   }