Added x-amz-expiration, missing HTTP header in the response of object GET/PUT/HEAD

Signed-off-by: Aayush Chouhan <achouhan@redhat.com>

Author: achouhan09

src/api/bucket_api.js

@@ -1215,6 +1215,7 @@ module.exports = {
                     $ref: 'common_api#/definitions/bucket_policy'
                 },
                 replication_policy_id: { objectid: true },
+                lifecycle_configuration_rules: { $ref: 'common_api#/definitions/bucket_lifecycle_configuration' },
             }
         },
 

src/endpoint/s3/ops/s3_get_object.js

@@ -49,6 +49,7 @@ async function get_object(req, res) {
         }
     }
     http_utils.set_response_headers_from_request(req, res);
+    http_utils.set_expiration_header(req, res, object_md);
     const obj_size = object_md.size;
     const params = {
         object_md,

src/endpoint/s3/ops/s3_head_object.js

@@ -29,6 +29,7 @@ async function head_object(req, res) {
     s3_utils.set_response_object_md(res, object_md);
     s3_utils.set_encryption_response_headers(req, res, object_md.encryption);
     http_utils.set_response_headers_from_request(req, res);
+    http_utils.set_expiration_header(req, res, object_md);
 }
 
 module.exports = {

src/sdk/object_sdk.js

@@ -223,6 +223,11 @@ class ObjectSDK {
         return policy_info;
     }
 
+    async read_bucket_lifecycle_config_info(name) {
+        const { bucket } = await bucket_namespace_cache.get_with_cache({ sdk: this, name });
+        return bucket.bucket_info.lifecycle_configuration_rules;
+    }
+
     async read_bucket_usage_info(name) {
         const { bucket } = await bucket_namespace_cache.get_with_cache({ sdk: this, name });
         return bucket.bucket_info.data;

src/server/system_services/bucket_server.js

@@ -1653,6 +1653,7 @@ function get_bucket_info({
         website: bucket.website,
         s3_policy: bucket.s3_policy,
         replication_policy_id: bucket.replication_policy_id,
+        lifecycle_configuration_rules: bucket.lifecycle_configuration_rules,
     };
 
     const metrics = _calc_metrics({ bucket, nodes_aggregate_pool, hosts_aggregate_pool, tiering_pools_status, info });

src/util/http_utils.js

@@ -664,6 +664,72 @@ function set_amz_headers(req, res) {
     res.setHeader('x-amz-id-2', req.request_id);
 }
 
+/**
+ * @param {Object} req
+ * @param {http.ServerResponse} res
+ * @param {Object} object_md
+ */
+async function set_expiration_header(req, res, object_md) {
+    if (req.method === 'HEAD' || req.method === 'GET' || req.method === 'PUT') {
+        const rules = req.params.bucket && await req.object_sdk.read_bucket_lifecycle_config_info(req.params.bucket);
+        if (rules?.length > 0) {
+            for (const rule of rules) {
+                if (rule?.status !== 'Enabled') continue;
+
+                const filter = rule?.filter || {};
+
+                if (filter.prefix && !object_md?.key.startsWith(filter.prefix)) continue;
+
+                if (filter.object_size_greater_than && object_md?.size <= filter.object_size_greater_than) continue;
+                if (filter.object_size_less_than && object_md?.size >= filter.object_size_less_than) continue;
+
+                if (filter.tagging && Array.isArray(filter.tagging)) {
+                    const obj_tags = object_md?.tagging || [];
+
+                    const matches_all_tags = filter.tagging.every(filter_tag =>
+                        obj_tags.some(obj_tag => obj_tag.key === filter_tag.key && obj_tag.value === filter_tag.value)
+                    );
+
+                    if (!matches_all_tags) continue;
+                }
+
+                const expiration_head = parse_expiration_header(rule?.expiration, rule?.id);
+                if (expiration_head) {
+                    dbg.log0('set x_amz_expiration header from applied rule: ', rule);
+                    res.setHeader('x-amz-expiration', expiration_head);
+                    break; // apply only for first matching rule
+                }
+            }
+        }
+    }
+}
+
+/**
+ * parse_expiration_header converts an expiration rule (either with `date` or `days`)
+ * into an s3 style `x-amz-expiration` header value
+ *
+ * @param {Object} expiration - expiration object from lifecycle config
+ * @param {string} rule_id - id of the lifecycle rule
+ * @returns {string|undefined}
+ *
+ * Example output:
+ *   expiry-date="Thu, 10 Apr 2025 00:00:00 GMT", rule-id="rule_id"
+ */
+function parse_expiration_header(expiration, rule_id) {
+    if (!expiration || (!expiration.date && !expiration.days)) return undefined;
+
+    const expiration_date = expiration.date ?
+        new Date(expiration.date) :
+        new Date(Date.UTC(
+            new Date().getUTCFullYear(),
+            new Date().getUTCMonth(),
+            new Date().getUTCDate() + expiration.days
+        ));
+
+    return `expiry-date="${expiration_date.toUTCString()}", rule-id="${rule_id}"`;
+}
+
+
 /**
  * @typedef {{
  *      allow_origin: string;
@@ -945,6 +1011,7 @@ exports.set_keep_alive_whitespace_interval = set_keep_alive_whitespace_interval;
 exports.parse_xml_to_js = parse_xml_to_js;
 exports.check_headers = check_headers;
 exports.set_amz_headers = set_amz_headers;
+exports.set_expiration_header = set_expiration_header;
 exports.set_cors_headers = set_cors_headers;
 exports.set_cors_headers_s3 = set_cors_headers_s3;
 exports.set_cors_headers_sts = set_cors_headers_sts;