1 files changed, 52 insertions, 0 deletions
diff --git a/src/rgw/rgw_lua_data_filter.h b/src/rgw/rgw_lua_data_filter.h
new file mode 100644
index 000000000..75596b64e
--- /dev/null
+++ b/src/rgw/rgw_lua_data_filter.h
@@ -0,0 +1,52 @@
+#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
+