{
  "partialFilterExpression": {
    "data.emailAddress": {
      "$exists": true
    }
  }
}

"use strict";

function getFieldSafely( parentObject, fieldName, valueIfAbsent ) {

  if (parentObject.hasOwnProperty(fieldName)) {
      return parentObject[fieldName];
  } else {
      return valueIfAbsent;
  }
    
}

function main() {
  
  var response = {};
  
  const BACKUP_INTERVAL   = 86400000; // 24 hours
  const TTL               = 2592000000; // 30 days
  const ENTITY_COLLECTION = "playerBackup";
  const LAST_BACKUP_STAT  = "lastBackup";
  
  var message = data.message;
  
  // Utiliser la réponse d'authentification (c'est-à-dire data.message) 
  // pour obtenir certaines des valeurs dont nous avons besoin
  var currentTime = data.message.server_time;
  
  var lastBackupMillis = getFieldSafely(
    data.message.statistics, LAST_BACKUP_STAT, 0);
  
  // Avons-nous besoin d'effectuer une sauvegarde?
  if ( (currentTime - lastBackupMillis) < BACKUP_INTERVAL ) {
      
    // Non. Quittez simplement plus tôt
    message.backupMessage = "Skipping backup (recently backed up)";
    response.status = 200;
    response.data = message;
    return response;
      
  } else {
      
    // Effectuer la sauvegarde

    var customEntityProxy = bridge.getCustomEntityServiceProxy();
    var playerStatisticsProxy = 
      bridge.getPlayerStatisticsServiceProxy();
    var userProxy = bridge.getUserServiceProxy();
    
    var optionsJson = { "includeEntities": true };
    var profileId = data.message.profileId;

    // Mettre à jour les statistiques avant d'exporter - pour éviter 
    // les problèmes de concurrence. 
    var stat_lastBackup = {};
    stat_lastBackup[LAST_BACKUP_STAT] = "SET#"+currentTime;
    playerStatisticsProxy.processStatistics(stat_lastBackup);

    var userExport = 
      userProxy.sysGetUserExport(profileId, optionsJson);   
    
    if (userExport.status == 200) {
    
      var saveDate = new Date().toISOString().slice(0, 10);
    
      // Formater l'identifiant
      var identifier = "";
      var playerName = getFieldSafely( 
        data.message, "playerName", "" );
      var emailAddress = getFieldSafely(
        data.message, "emailAddress", null);
      if ((playerName !== null) && (playerName !== "")) {
        if ((emailAddress !== null) && (emailAddress !== "")) {
          identifier = playerName + 
            " (" + emailAddress + ") - " + saveDate;
        } else {
          identifier = playerName + 
            " (" + profileId + ") - " + saveDate;
        }
      } else {
        if ((emailAddress !== null) && (emailAddress !== "")) {
          identifier = emailAddress + " - " + saveDate;
        } else {
          identifier = profileId + " - " + saveDate;
        }
      }
      
      var dataJson = {
        "profileId": profileId,
        "saveDate" : saveDate,
        "identifier": identifier,
        "exportData": userExport.data
      };

      // Écrire l'adresse e-mail uniquement si elle est définie...
      if ((emailAddress !== "") && (emailAddress !== null)) {
        dataJson.emailAddress = emailAddress;
      }
    
      var backupResult = 
        customEntityProxy.createEntity(
          ENTITY_COLLECTION, dataJson, {"other": 1}, TTL, false);
    
      if (backupResult.status == 200) {
        message.backupMessage = "new backup entity " + 
          backupResult.data.entityId + 
          " saved in custom entity collection " + 
          ENTITY_COLLECTION;
          
      } else {
        message.backupMessage = 
          "Unexpected error backing up player data";
        message.backupResult = backupResult;
        
        // Réinitialiser l'heure de lastBackup à ce qu'elle était précédemment  
        stat_lastBackup[LAST_BACKUP_STAT] = "SET#"+lastBackupMillis;
        playerStatisticsProxy.processStatistics(stat_lastBackup);
      }
      
    } else {
      message.backupMessage = 
        "Unexpected error exporting player data";
      message.backupResult = userExport;
      
      // Réinitialiser l'heure de lastBackup à ce qu'elle était précédemment    
      stat_lastBackup[LAST_BACKUP_STAT] = "SET#"+lastBackupMillis;
      playerStatisticsProxy.processStatistics(stat_lastBackup);
    }

    response.status = 200;
    response.data = message;
    return response;
    
  }

}

main();

{
  "data.profileId": "aaa-bbb-ccc"
}

{ 
  "data.profileId": "aaa-bbb-ccc", 
  "data.saveDate": "2022-04-29" 
}

{ 
  "data.emailAddress": "bruce@waynetech.com", 
  "data.saveDate": "2022-04-29" 
}