Support AbortIncompleteMultipartUpload bucket lifecycle rule

Signed-off-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>

fully functional noncurrent_expiry

Signed-off-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>

fully functional ExpiredDeleteMarker
Signed-off-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>

add support for filters in AbortMultipartUpload

Signed-off-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>

minor optimization submit LIKE only when prefix is provided

Signed-off-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>

add basic tests and improve reliability of the version queries by relying on version_seq for ordering instead of time

Co-authored-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>
Co-authored-by: Ben <belimele@redhat.com>
Signed-off-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>

Author: Neon-White

src/api/object_api.js

@@ -1410,6 +1410,136 @@ module.exports = {
             auth: { system: ['admin', 'user'] }
         },
 
+        delete_incomplete_multiparts: {
+            method: 'DELETE',
+            params: {
+                type: 'object',
+                required: [
+                    'bucket',
+                    'days_after_initiation',
+                ],
+                properties: {
+                    bucket: { $ref: 'common_api#/definitions/bucket_name' },
+                    days_after_initiation: {
+                        type: 'integer',
+                    },
+                    prefix: {
+                        type: 'string',
+                    },
+                    size_less: {
+                        type: 'integer'
+                    },
+                    size_greater: {
+                        type: 'integer'
+                    },
+                    tags: {
+                        $ref: 'common_api#/definitions/tagging'
+                    },
+                    limit: {
+                        type: 'integer'
+                    },
+                    reply_objects: {
+                        type: 'boolean'
+                    }
+                },
+            },
+            reply: {
+                type: 'object',
+                properties: {
+                    num_objects_deleted: {
+                        type: 'integer'
+                    }
+                }
+            },
+            auth: { system: ['admin', 'user'] }
+        },
+
+        delete_noncurrent_versions: {
+            method: 'DELETE',
+            params: {
+                type: 'object',
+                required: [
+                    'bucket',
+                    'noncurrent_days'
+                ],
+                properties: {
+                    bucket: { $ref: 'common_api#/definitions/bucket_name' },
+                    noncurrent_days: {
+                        type: 'integer',
+                    },
+                    newer_noncurrent_versions: {
+                        type: 'integer',
+                    },
+                    prefix: {
+                        type: 'string',
+                    },
+                    size_less: {
+                        type: 'integer'
+                    },
+                    size_greater: {
+                        type: 'integer'
+                    },
+                    tags: {
+                        $ref: 'common_api#/definitions/tagging'
+                    },
+                    limit: {
+                        type: 'integer'
+                    },
+                    reply_objects: {
+                        type: 'boolean'
+                    }
+                },
+            },
+            reply: {
+                type: 'object',
+                properties: {
+                    num_objects_deleted: {
+                        type: 'integer'
+                    }
+                }
+            },
+            auth: { system: ['admin', 'user'] }
+        },
+
+        delete_expired_delete_markers: {
+            method: 'DELETE',
+            params: {
+                type: 'object',
+                required: [
+                    'bucket',
+                ],
+                properties: {
+                    bucket: { $ref: 'common_api#/definitions/bucket_name' },
+                    prefix: {
+                        type: 'string',
+                    },
+                    size_less: {
+                        type: 'integer'
+                    },
+                    size_greater: {
+                        type: 'integer'
+                    },
+                    tags: {
+                        $ref: 'common_api#/definitions/tagging'
+                    },
+                    limit: {
+                        type: 'integer'
+                    },
+                    reply_objects: {
+                        type: 'boolean'
+                    }
+                },
+            },
+            reply: {
+                type: 'object',
+                properties: {
+                    num_objects_deleted: {
+                        type: 'integer'
+                    }
+                }
+            },
+            auth: { system: ['admin', 'user'] }
+        },
     },
 
     definitions: {

src/deploy/NVA_build/standalone_deploy.sh

@@ -73,6 +73,9 @@ function main() {
     mkdir -p storage/backingstores/drive1
     execute "npm -- run backingstore storage/backingstores/drive1 --port 9991" backingstore1.log
     sleep 30
+
+    # Wait if stdin is attached
+    if [ -t 0 ]; then wait; fi
 }
 
 main

src/sdk/nb.d.ts

@@ -737,6 +737,11 @@ interface DBSequence {
     nextsequence(): Promise<number>;
 }
 
+interface sqlResult<T> {
+    rows: T[],
+    rowCount: number | null,
+}
+
 interface DBCollection {
     find(query?: object, options?: object): Promise<DBDoc[]>;
     findOne(query?: object, options?: object): Promise<DBDoc>;
@@ -761,6 +766,9 @@ interface DBCollection {
     stats(): Promise<mongodb.CollStats>;
 
     validate(doc: object, warn?: 'warn'): object;
+
+    executeSQL<T>(query: string, params: Array<any>, options?: { query_name?: string }): Promise<sqlResult<T>>;
+    name: any;
 }
 
 type DBDoc = any;