X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Frgw%2Frgw_lc_s3.cc;fp=src%2Fceph%2Fsrc%2Frgw%2Frgw_lc_s3.cc;h=b03c4c32b9efa5d9b19397de49066a023a156750;hb=812ff6ca9fcd3e629e49d4328905f33eee8ca3f5;hp=0000000000000000000000000000000000000000;hpb=15280273faafb77777eab341909a3f495cf248d9;p=stor4nfv.git

diff --git a/src/ceph/src/rgw/rgw_lc_s3.cc b/src/ceph/src/rgw/rgw_lc_s3.cc
new file mode 100644
index 0000000..b03c4c3
--- /dev/null
+++ b/src/ceph/src/rgw/rgw_lc_s3.cc
@@ -0,0 +1,236 @@
+#include <string.h>
+
+#include <iostream>
+#include <map>
+
+#include "include/types.h"
+
+#include "rgw_user.h"
+#include "rgw_lc_s3.h"
+
+
+#define dout_subsys ceph_subsys_rgw
+
+using namespace std;
+
+bool LCExpiration_S3::xml_end(const char * el) {
+  LCDays_S3 *lc_days = static_cast<LCDays_S3 *>(find_first("Days"));
+  LCDeleteMarker_S3 *lc_dm = static_cast<LCDeleteMarker_S3 *>(find_first("ExpiredObjectDeleteMarker"));
+  LCDate_S3 *lc_date = static_cast<LCDate_S3 *>(find_first("Date"));
+
+  if ((!lc_days && !lc_dm && !lc_date) || (lc_days && lc_dm) 
+      || (lc_days && lc_date) || (lc_dm && lc_date)) {
+    return false;
+  }
+  if (lc_days) {
+    days = lc_days->get_data();
+  } else if (lc_dm) {
+    dm_expiration = lc_dm->get_data().compare("true") == 0;
+    if (!dm_expiration) {
+      return false;
+    }
+  } else {
+    date = lc_date->get_data();
+    //We need return xml error according to S3
+    if (boost::none == ceph::from_iso_8601(date)) {
+      return false;
+    }
+  }
+  return true;
+}
+
+bool LCNoncurExpiration_S3::xml_end(const char *el) {
+  LCDays_S3 *lc_noncur_days = static_cast<LCDays_S3 *>(find_first("NoncurrentDays"));
+  if (!lc_noncur_days) {
+    return false;
+  }
+  days = lc_noncur_days->get_data();
+  return true;
+}
+
+bool LCMPExpiration_S3::xml_end(const char *el) {
+  LCDays_S3 *lc_mp_days = static_cast<LCDays_S3 *>(find_first("DaysAfterInitiation"));
+  if (!lc_mp_days) {
+    return false;
+  }
+  days = lc_mp_days->get_data();
+  return true;
+}
+
+bool RGWLifecycleConfiguration_S3::xml_end(const char *el) {
+  XMLObjIter iter = find("Rule");
+  LCRule_S3 *rule = static_cast<LCRule_S3 *>(iter.get_next());
+  while (rule) {
+    add_rule(rule);
+    rule = static_cast<LCRule_S3 *>(iter.get_next());
+  }
+  return true;
+}
+
+bool LCRule_S3::xml_end(const char *el) {
+  LCID_S3 *lc_id;
+  LCPrefix_S3 *lc_prefix;
+  LCStatus_S3 *lc_status;
+  LCExpiration_S3 *lc_expiration;
+  LCNoncurExpiration_S3 *lc_noncur_expiration;
+  LCMPExpiration_S3 *lc_mp_expiration;
+
+  id.clear();
+  prefix.clear();
+  status.clear();
+  dm_expiration = false;
+
+  // S3 generates a 48 bit random ID, maybe we could generate shorter IDs
+  static constexpr auto LC_ID_LENGTH = 48;
+
+  lc_id = static_cast<LCID_S3 *>(find_first("ID"));
+  if (lc_id){
+    id = lc_id->get_data();
+  } else {
+    gen_rand_alphanumeric_lower(nullptr, &id, LC_ID_LENGTH);
+  }
+
+
+  XMLObj *obj = find_first("Filter");
+
+  if (obj){
+    string _prefix;
+    RGWXMLDecoder::decode_xml("Prefix", _prefix, obj);
+    filter.set_prefix(std::move(_prefix));
+  } else {
+    // Ideally the following code should be deprecated and we should return
+    // False here, The new S3 LC configuration xml spec. makes Filter mandatory
+    // and Prefix optional. However older clients including boto2 still generate
+    // xml according to the older spec, where Prefix existed outside of Filter
+    // and S3 itself seems to be sloppy on enforcing the mandatory Filter
+    // argument. A day will come when S3 enforces their own xml-spec, but it is
+    // not this day
+
+    lc_prefix = static_cast<LCPrefix_S3 *>(find_first("Prefix"));
+
+    if (!lc_prefix){
+      return false;
+    }
+
+    prefix = lc_prefix->get_data();
+  }
+
+
+  lc_status = static_cast<LCStatus_S3 *>(find_first("Status"));
+  if (!lc_status)
+    return false;
+  status = lc_status->get_data();
+  if (status.compare("Enabled") != 0 && status.compare("Disabled") != 0)
+    return false;
+
+  lc_expiration = static_cast<LCExpiration_S3 *>(find_first("Expiration"));
+  lc_noncur_expiration = static_cast<LCNoncurExpiration_S3 *>(find_first("NoncurrentVersionExpiration"));
+  lc_mp_expiration = static_cast<LCMPExpiration_S3 *>(find_first("AbortIncompleteMultipartUpload"));
+  if (!lc_expiration && !lc_noncur_expiration && !lc_mp_expiration) {
+    return false;
+  } else {
+    if (lc_expiration) {
+      if (lc_expiration->has_days()) {
+        expiration.set_days(lc_expiration->get_days_str());
+      } else if (lc_expiration->has_date()) {
+        expiration.set_date(lc_expiration->get_date());
+      } else {
+        dm_expiration = lc_expiration->get_dm_expiration();
+      }
+    }
+    if (lc_noncur_expiration) {
+      noncur_expiration = *lc_noncur_expiration;
+    }
+    if (lc_mp_expiration) {
+      mp_expiration = *lc_mp_expiration;
+    }
+  }
+
+  return true;
+}
+
+void LCRule_S3::to_xml(CephContext *cct, ostream& out) {
+  out << "<Rule>" ;
+  out << "<ID>" << id << "</ID>";
+  if (!filter.empty()) {
+    LCFilter_S3& lc_filter = static_cast<LCFilter_S3&>(filter);
+    lc_filter.to_xml(out);
+  } else {
+    out << "<Prefix>" << prefix << "</Prefix>";
+  }
+  out << "<Status>" << status << "</Status>";
+  if (!expiration.empty() || dm_expiration) {
+    LCExpiration_S3 expir(expiration.get_days_str(), expiration.get_date(), dm_expiration);
+    expir.to_xml(out);
+  }
+  if (!noncur_expiration.empty()) {
+    LCNoncurExpiration_S3& noncur_expir = static_cast<LCNoncurExpiration_S3&>(noncur_expiration);
+    noncur_expir.to_xml(out);
+  }
+  if (!mp_expiration.empty()) {
+    LCMPExpiration_S3& mp_expir = static_cast<LCMPExpiration_S3&>(mp_expiration);
+    mp_expir.to_xml(out);
+  }
+  out << "</Rule>";
+}
+
+int RGWLifecycleConfiguration_S3::rebuild(RGWRados *store, RGWLifecycleConfiguration& dest)
+{
+  int ret = 0;
+  multimap<string, LCRule>::iterator iter;
+  for (iter = rule_map.begin(); iter != rule_map.end(); ++iter) {
+    LCRule& src_rule = iter->second;
+    ret = dest.check_and_add_rule(&src_rule);
+    if (ret < 0)
+      return ret;
+  }
+  if (!dest.valid()) {
+    ret = -ERR_INVALID_REQUEST;
+  }
+  return ret;
+}
+
+void RGWLifecycleConfiguration_S3::dump_xml(Formatter *f) const
+{
+	f->open_object_section_in_ns("LifecycleConfiguration", XMLNS_AWS_S3);
+
+    for (auto iter = rule_map.begin(); iter != rule_map.end(); ++iter) {
+		const LCRule_S3& rule = static_cast<const LCRule_S3&>(iter->second);
+		rule.dump_xml(f);
+	}
+
+	f->close_section(); // Lifecycle
+}
+
+XMLObj *RGWLCXMLParser_S3::alloc_obj(const char *el)
+{
+  XMLObj * obj = NULL;
+  if (strcmp(el, "LifecycleConfiguration") == 0) {
+    obj = new RGWLifecycleConfiguration_S3(cct);
+  } else if (strcmp(el, "Rule") == 0) {
+    obj = new LCRule_S3();
+  } else if (strcmp(el, "ID") == 0) {
+    obj = new LCID_S3();
+  } else if (strcmp(el, "Prefix") == 0) {
+    obj = new LCPrefix_S3();
+  } else if (strcmp(el, "Status") == 0) {
+    obj = new LCStatus_S3();
+  } else if (strcmp(el, "Expiration") == 0) {
+    obj = new LCExpiration_S3();
+  } else if (strcmp(el, "Days") == 0) {
+    obj = new LCDays_S3();
+  } else if (strcmp(el, "Date") == 0) {
+    obj = new LCDate_S3();
+  } else if (strcmp(el, "ExpiredObjectDeleteMarker") == 0) {
+    obj = new LCDeleteMarker_S3();
+  } else if (strcmp(el, "NoncurrentVersionExpiration") == 0) {
+    obj = new LCNoncurExpiration_S3();
+  } else if (strcmp(el, "NoncurrentDays") == 0) {
+    obj = new LCDays_S3();
+  } else if (strcmp(el, "AbortIncompleteMultipartUpload") == 0) {
+    obj = new LCMPExpiration_S3();
+  } else if (strcmp(el, "DaysAfterInitiation") == 0) {
+    obj = new LCDays_S3();
+  }
+  return obj;
+}