exports = async function() {
  
    const clusterName = "profilehub-test01-env02";
    const db = "profilehub-test01-env02";
    const dest_coll = "individualsAuditCOPY5";
  
    const client = context.services.get('FederatedDatabaseInstance0')
    const archiveCol = client.db(db).collection(dest_coll);
  
    try {
  
        const pipe = [{
          "$addFields": {
            "archived_date": new Date()
          }
        },{
          "$merge": {
            "into": {
              "atlas": {
                "projectId": "",
                "clusterName": clusterName,
                "db": db,
                "coll": dest_coll
              }
            }
          }
        }];
        
        await archiveCol.aggregate(pipe).toArray();
        
    } catch (err) {
        error = err;
        throw error;
    } finally {
      
    }
    
    return true;
    
  };