logs

Author: SylvainSenechal

.github/workflows/test.yml

@@ -69,9 +69,9 @@ jobs:
           wget -nc https://ftp.debian.org/debian/pool/main/o/openssl/libssl1.1_1.1.1w-0+deb11u1_amd64.deb
           sudo dpkg -i libssl1.1_1.1.1w-0+deb11u1_amd64.deb
       - run: yarn --network-concurrency 1
-      - run: yarn --silent lint -- --max-warnings 0
-      - run: yarn --silent test:unit
-      - run: yarn --silent test:functional
+      # - run: yarn --silent lint -- --max-warnings 0
+      # - run: yarn --silent test:unit
+      # - run: yarn --silent test:functional
         env:
           MONGODB_REPLICASET: "127.0.0.1:27018"
       - name: "Debug: SSH to runner"

CRR/ReplicationStatusUpdater.js

@@ -270,14 +270,19 @@ class ReplicationStatusUpdater {
      * @returns {void}
      */
     _listObjectVersions(bucket, VersionIdMarker, KeyMarker, cb) {
+        this.log.error(`AAAAA 11 ${bucket}, ${VersionIdMarker}, ${KeyMarker}`);
+
         this.s3.send(new ListObjectVersionsCommand({
             Bucket: bucket,
             MaxKeys: this.listingLimit,
             Prefix: this.targetPrefix,
             VersionIdMarker,
             KeyMarker,
         }))
-            .then(data => cb(null, data))
+            .then(data => {
+                this.log.error(`AAAAA ListObjectVersions IsTruncated: ${data.IsTruncated}, NextVersionIdMarker: ${data.NextVersionIdMarker}, NextKeyMarker: ${data.NextKeyMarker}, ${data}`);
+                cb(null, data);
+            })
             .catch(err => cb(err));
     }
 
@@ -298,10 +303,12 @@ class ReplicationStatusUpdater {
                     .then(res => next(null, res.ReplicationConfiguration))
                     .catch(err => {
                         this.log.error('error getting bucket replication', { error: err });
-                        next(err);
+                        return next(err);
                     });
             },
             (repConfig, next) => {
+                this.log.error(`AAAAA 6 ${repConfig}`);
+
                 const { Rules } = repConfig;
                 const storageClass = this.siteName || Rules[0].Destination.StorageClass;
                 if (!storageClass) {
@@ -346,6 +353,7 @@ class ReplicationStatusUpdater {
             this.log.info(`resuming bucket: ${bucket} at: KeyMarker=${this._KeyMarker} `
                 + `VersionIdMarker=${this._VersionIdMarker}`);
         }
+        this.log.error(`AAAAA 1`);
         return doWhilst(
             done => this._listObjectVersions(
                 bucket,
@@ -356,7 +364,13 @@ class ReplicationStatusUpdater {
                         this.log.error('error listing object versions', { error: err });
                         return done(err);
                     }
-                    return this._markPending(bucket, data.Versions.concat(data.DeleteMarkers), err => {
+                    this.log.error(`AAAAA 2 ${err}`);
+                    this.log.error(`AAAAA 3 ${data}`);
+                    
+                    const versions = (data.Versions || []).concat(data.DeleteMarkers || []);
+                    this.log.error(`AAAAA 4 ${versions}`);
+                    this.log.error(`AAAAA 5 ${JSON.stringify(versions)}`);
+                    return this._markPending(bucket, versions, err => {
                         if (err) {
                             return done(err);
                         }