package handler import ( "context" "fmt" "net/http" "strconv" "time" "git.frostfs.info/TrueCloudLab/frostfs-s3-gw/api" "git.frostfs.info/TrueCloudLab/frostfs-s3-gw/api/data" apiErrors "git.frostfs.info/TrueCloudLab/frostfs-s3-gw/api/errors" "git.frostfs.info/TrueCloudLab/frostfs-s3-gw/api/layer" "git.frostfs.info/TrueCloudLab/frostfs-s3-gw/api/middleware" ) const ( dayDuration = 24 * time.Hour yearDuration = 365 * dayDuration enabledValue = "Enabled" governanceMode = "GOVERNANCE" complianceMode = "COMPLIANCE" legalHoldOn = "ON" legalHoldOff = "OFF" ) func (h *handler) PutBucketObjectLockConfigHandler(w http.ResponseWriter, r *http.Request) { reqInfo := middleware.GetReqInfo(r.Context()) bktInfo, err := h.getBucketAndCheckOwner(r, reqInfo.BucketName) if err != nil { h.logAndSendError(w, "could not get bucket info", reqInfo, err) return } if !bktInfo.ObjectLockEnabled { h.logAndSendError(w, "couldn't put object locking configuration", reqInfo, apiErrors.GetAPIError(apiErrors.ErrObjectLockConfigurationNotAllowed)) return } lockingConf := &data.ObjectLockConfiguration{} if err = h.cfg.NewXMLDecoder(r.Body).Decode(lockingConf); err != nil { h.logAndSendError(w, "couldn't parse locking configuration", reqInfo, err) return } if err = checkLockConfiguration(lockingConf); err != nil { h.logAndSendError(w, "invalid lock configuration", reqInfo, err) return } settings, err := h.obj.GetBucketSettings(r.Context(), bktInfo) if err != nil { h.logAndSendError(w, "couldn't get bucket settings", reqInfo, err) return } // settings pointer is stored in the cache, so modify a copy of the settings newSettings := *settings newSettings.LockConfiguration = lockingConf sp := &layer.PutSettingsParams{ BktInfo: bktInfo, Settings: &newSettings, } if err = h.obj.PutBucketSettings(r.Context(), sp); err != nil { h.logAndSendError(w, "couldn't put bucket settings", reqInfo, err) return } } func (h *handler) GetBucketObjectLockConfigHandler(w http.ResponseWriter, r *http.Request) { reqInfo := middleware.GetReqInfo(r.Context()) bktInfo, err := h.getBucketAndCheckOwner(r, reqInfo.BucketName) if err != nil { h.logAndSendError(w, "could not get bucket info", reqInfo, err) return } if !bktInfo.ObjectLockEnabled { h.logAndSendError(w, "object lock disabled", reqInfo, apiErrors.GetAPIError(apiErrors.ErrObjectLockConfigurationNotFound)) return } settings, err := h.obj.GetBucketSettings(r.Context(), bktInfo) if err != nil { h.logAndSendError(w, "couldn't get bucket settings", reqInfo, err) return } if settings.LockConfiguration == nil { settings.LockConfiguration = &data.ObjectLockConfiguration{} } if settings.LockConfiguration.ObjectLockEnabled == "" { settings.LockConfiguration.ObjectLockEnabled = enabledValue } if err = middleware.EncodeToResponse(w, settings.LockConfiguration); err != nil { h.logAndSendError(w, "something went wrong", reqInfo, err) } } func (h *handler) PutObjectLegalHoldHandler(w http.ResponseWriter, r *http.Request) { reqInfo := middleware.GetReqInfo(r.Context()) bktInfo, err := h.getBucketAndCheckOwner(r, reqInfo.BucketName) if err != nil { h.logAndSendError(w, "could not get bucket info", reqInfo, err) return } if !bktInfo.ObjectLockEnabled { h.logAndSendError(w, "object lock disabled", reqInfo, apiErrors.GetAPIError(apiErrors.ErrObjectLockConfigurationNotFound)) return } legalHold := &data.LegalHold{} if err = h.cfg.NewXMLDecoder(r.Body).Decode(legalHold); err != nil { h.logAndSendError(w, "couldn't parse legal hold configuration", reqInfo, err) return } if legalHold.Status != legalHoldOn && legalHold.Status != legalHoldOff { h.logAndSendError(w, "invalid legal hold status", reqInfo, fmt.Errorf("invalid status %s", legalHold.Status)) return } p := &layer.PutLockInfoParams{ ObjVersion: &data.ObjectVersion{ BktInfo: bktInfo, ObjectName: reqInfo.ObjectName, VersionID: reqInfo.URL.Query().Get(api.QueryVersionID), }, NewLock: &data.ObjectLock{ LegalHold: &data.LegalHoldLock{ Enabled: legalHold.Status == legalHoldOn, }, }, } p.CopiesNumbers, err = h.pickCopiesNumbers(parseMetadata(r), reqInfo.Namespace, bktInfo.LocationConstraint) if err != nil { h.logAndSendError(w, "invalid copies number", reqInfo, err) return } if err = h.obj.PutLockInfo(r.Context(), p); err != nil { h.logAndSendError(w, "couldn't head put legal hold", reqInfo, err) return } } func (h *handler) GetObjectLegalHoldHandler(w http.ResponseWriter, r *http.Request) { reqInfo := middleware.GetReqInfo(r.Context()) bktInfo, err := h.getBucketAndCheckOwner(r, reqInfo.BucketName) if err != nil { h.logAndSendError(w, "could not get bucket info", reqInfo, err) return } if !bktInfo.ObjectLockEnabled { h.logAndSendError(w, "object lock disabled", reqInfo, apiErrors.GetAPIError(apiErrors.ErrObjectLockConfigurationNotFound)) return } p := &data.ObjectVersion{ BktInfo: bktInfo, ObjectName: reqInfo.ObjectName, VersionID: reqInfo.URL.Query().Get(api.QueryVersionID), } lockInfo, err := h.obj.GetLockInfo(r.Context(), p) if err != nil { h.logAndSendError(w, "couldn't head lock object", reqInfo, err) return } legalHold := &data.LegalHold{Status: legalHoldOff} if lockInfo.IsLegalHoldSet() { legalHold.Status = legalHoldOn } if err = middleware.EncodeToResponse(w, legalHold); err != nil { h.logAndSendError(w, "something went wrong", reqInfo, err) } } func (h *handler) PutObjectRetentionHandler(w http.ResponseWriter, r *http.Request) { reqInfo := middleware.GetReqInfo(r.Context()) bktInfo, err := h.getBucketAndCheckOwner(r, reqInfo.BucketName) if err != nil { h.logAndSendError(w, "could not get bucket info", reqInfo, err) return } if !bktInfo.ObjectLockEnabled { h.logAndSendError(w, "object lock disabled", reqInfo, apiErrors.GetAPIError(apiErrors.ErrObjectLockConfigurationNotFound)) return } retention := &data.Retention{} if err = h.cfg.NewXMLDecoder(r.Body).Decode(retention); err != nil { h.logAndSendError(w, "couldn't parse object retention", reqInfo, err) return } lock, err := formObjectLockFromRetention(r.Context(), retention, r.Header) if err != nil { h.logAndSendError(w, "invalid retention configuration", reqInfo, err) return } p := &layer.PutLockInfoParams{ ObjVersion: &data.ObjectVersion{ BktInfo: bktInfo, ObjectName: reqInfo.ObjectName, VersionID: reqInfo.URL.Query().Get(api.QueryVersionID), }, NewLock: lock, } p.CopiesNumbers, err = h.pickCopiesNumbers(parseMetadata(r), reqInfo.Namespace, bktInfo.LocationConstraint) if err != nil { h.logAndSendError(w, "invalid copies number", reqInfo, err) return } if err = h.obj.PutLockInfo(r.Context(), p); err != nil { h.logAndSendError(w, "couldn't put legal hold", reqInfo, err) return } } func (h *handler) GetObjectRetentionHandler(w http.ResponseWriter, r *http.Request) { reqInfo := middleware.GetReqInfo(r.Context()) bktInfo, err := h.getBucketAndCheckOwner(r, reqInfo.BucketName) if err != nil { h.logAndSendError(w, "could not get bucket info", reqInfo, err) return } if !bktInfo.ObjectLockEnabled { h.logAndSendError(w, "object lock disabled", reqInfo, apiErrors.GetAPIError(apiErrors.ErrObjectLockConfigurationNotFound)) return } p := &data.ObjectVersion{ BktInfo: bktInfo, ObjectName: reqInfo.ObjectName, VersionID: reqInfo.URL.Query().Get(api.QueryVersionID), } lockInfo, err := h.obj.GetLockInfo(r.Context(), p) if err != nil { h.logAndSendError(w, "couldn't head lock object", reqInfo, err) return } if !lockInfo.IsRetentionSet() { h.logAndSendError(w, "retention lock isn't set", reqInfo, apiErrors.GetAPIError(apiErrors.ErrNoSuchKey)) return } retention := &data.Retention{ Mode: governanceMode, RetainUntilDate: lockInfo.UntilDate(), } if lockInfo.IsCompliance() { retention.Mode = complianceMode } if err = middleware.EncodeToResponse(w, retention); err != nil { h.logAndSendError(w, "something went wrong", reqInfo, err) } } func checkLockConfiguration(conf *data.ObjectLockConfiguration) error { if conf.ObjectLockEnabled != "" && conf.ObjectLockEnabled != enabledValue { return fmt.Errorf("invalid ObjectLockEnabled value: %s", conf.ObjectLockEnabled) } if conf.Rule == nil || conf.Rule.DefaultRetention == nil { return nil } retention := conf.Rule.DefaultRetention if retention.Mode != governanceMode && retention.Mode != complianceMode { return fmt.Errorf("invalid Mode value: %s", retention.Mode) } if retention.Days == 0 && retention.Years == 0 { return fmt.Errorf("you must specify Days or Years") } if retention.Days != 0 && retention.Years != 0 { return fmt.Errorf("you cannot specify Days and Years at the same time") } return nil } func formObjectLock(ctx context.Context, bktInfo *data.BucketInfo, defaultConfig *data.ObjectLockConfiguration, header http.Header) (*data.ObjectLock, error) { if !bktInfo.ObjectLockEnabled { if existLockHeaders(header) { return nil, apiErrors.GetAPIError(apiErrors.ErrObjectLockConfigurationNotFound) } return nil, nil } objectLock := &data.ObjectLock{} if defaultConfig == nil { defaultConfig = &data.ObjectLockConfiguration{} } if defaultConfig.Rule != nil && defaultConfig.Rule.DefaultRetention != nil { retention := &data.RetentionLock{} defaultRetention := defaultConfig.Rule.DefaultRetention retention.IsCompliance = defaultRetention.Mode == complianceMode now := layer.TimeNow(ctx) if defaultRetention.Days != 0 { retention.Until = now.Add(time.Duration(defaultRetention.Days) * dayDuration) } else { retention.Until = now.Add(time.Duration(defaultRetention.Years) * yearDuration) } objectLock.Retention = retention } if header.Get(api.AmzObjectLockLegalHold) == legalHoldOn { objectLock.LegalHold = &data.LegalHoldLock{Enabled: true} } mode := header.Get(api.AmzObjectLockMode) until := header.Get(api.AmzObjectLockRetainUntilDate) if mode != "" && until == "" || mode == "" && until != "" { return nil, apiErrors.GetAPIError(apiErrors.ErrObjectLockInvalidHeaders) } if mode != "" { if objectLock.Retention == nil { objectLock.Retention = &data.RetentionLock{} } if mode != complianceMode && mode != governanceMode { return nil, apiErrors.GetAPIError(apiErrors.ErrUnknownWORMModeDirective) } objectLock.Retention.IsCompliance = mode == complianceMode } if until != "" { retentionDate, err := time.Parse(time.RFC3339, until) if err != nil { return nil, apiErrors.GetAPIError(apiErrors.ErrInvalidRetentionDate) } if objectLock.Retention == nil { objectLock.Retention = &data.RetentionLock{} } objectLock.Retention.Until = retentionDate } if objectLock.Retention != nil { if bypassStr := header.Get(api.AmzBypassGovernanceRetention); len(bypassStr) > 0 { bypass, err := strconv.ParseBool(bypassStr) if err != nil { return nil, fmt.Errorf("couldn't parse bypass governance header: %w", err) } objectLock.Retention.ByPassedGovernance = bypass } if objectLock.Retention.Until.Before(layer.TimeNow(ctx)) { return nil, apiErrors.GetAPIError(apiErrors.ErrPastObjectLockRetainDate) } } return objectLock, nil } func existLockHeaders(header http.Header) bool { return header.Get(api.AmzObjectLockMode) != "" || header.Get(api.AmzObjectLockLegalHold) != "" || header.Get(api.AmzObjectLockRetainUntilDate) != "" } func formObjectLockFromRetention(ctx context.Context, retention *data.Retention, header http.Header) (*data.ObjectLock, error) { if retention.Mode != governanceMode && retention.Mode != complianceMode { return nil, apiErrors.GetAPIError(apiErrors.ErrMalformedXML) } retentionDate, err := time.Parse(time.RFC3339, retention.RetainUntilDate) if err != nil { return nil, apiErrors.GetAPIError(apiErrors.ErrMalformedXML) } if retentionDate.Before(layer.TimeNow(ctx)) { return nil, apiErrors.GetAPIError(apiErrors.ErrPastObjectLockRetainDate) } var bypass bool if bypassStr := header.Get(api.AmzBypassGovernanceRetention); len(bypassStr) > 0 { bypass, err = strconv.ParseBool(bypassStr) if err != nil { return nil, fmt.Errorf("couldn't parse bypass governance header: %w", err) } } lock := &data.ObjectLock{ Retention: &data.RetentionLock{ Until: retentionDate, IsCompliance: retention.Mode == complianceMode, ByPassedGovernance: bypass, }, } return lock, nil }