#pragma once

#include "rgw_op.h"

class DoutPrefixProvider;

namespace rgw::lua {

class RGWObjFilter {
  req_state* const s;
  const std::string script;

public:
  RGWObjFilter(req_state* s,
      const std::string& script) : 
    s(s), script(script) {}

  int execute(bufferlist& bl, off_t offset, const char* op_name) const;
};

class RGWGetObjFilter : public RGWGetObj_Filter {
  const RGWObjFilter filter;

public:
  RGWGetObjFilter(req_state* s,
      const std::string& script,
      RGWGetObj_Filter* next) : RGWGetObj_Filter(next), filter(s, script) 
  {}

  ~RGWGetObjFilter() override = default;

  int handle_data(bufferlist& bl,
                  off_t bl_ofs,
                  off_t bl_len) override;

};

class RGWPutObjFilter : public rgw::putobj::Pipe {
  const RGWObjFilter filter;

public:
  RGWPutObjFilter(req_state* s,
      const std::string& script,
      rgw::sal::DataProcessor* next) : rgw::putobj::Pipe(next), filter(s, script) 
  {}

  ~RGWPutObjFilter() override = default;

  int process(bufferlist&& data, uint64_t logical_offset) override;
};
} // namespace rgw::lua