#include "aare/CtbRawFile.hpp" #include "aare/File.hpp" #include "aare/Frame.hpp" #include "aare/defs.hpp" // #include "aare/fClusterFileV2.hpp" #include #include #include #include #include #include #include #include namespace py = pybind11; using namespace ::aare; void define_file_io_bindings(py::module &m) { PYBIND11_NUMPY_DTYPE(DetectorHeader, frameNumber, expLength, packetNumber, bunchId, timestamp, modId, row, column, reserved, debug, roundRNumber, detType, version, packetMask); py::class_(m, "CtbRawFile") .def(py::init()) .def("read_frame", [](CtbRawFile &self) { size_t image_size = self.image_size_in_bytes(); py::array image; std::vector shape; shape.reserve(2); shape.push_back(1); shape.push_back(image_size); py::array_t header(1); // always read bytes image = py::array_t(shape); self.read_into( reinterpret_cast(image.mutable_data()), header.mutable_data()); return py::make_tuple(header, image); }) .def("seek", &CtbRawFile::seek) .def("tell", &CtbRawFile::tell) .def("image_size_in_bytes", &CtbRawFile::image_size_in_bytes) .def("frames_in_file", &CtbRawFile::frames_in_file); py::class_(m, "File") .def(py::init([](const std::filesystem::path &fname) { return File(fname, "r", {}); })) .def(py::init( [](const std::filesystem::path &fname, const std::string &mode) { return File(fname, mode, {}); })) .def(py::init()) .def("frame_number", &File::frame_number) .def_property_readonly("bytes_per_frame", &File::bytes_per_frame) .def_property_readonly("pixels_per_frame", &File::pixels_per_frame) .def("seek", &File::seek) .def("tell", &File::tell) .def_property_readonly("total_frames", &File::total_frames) .def_property_readonly("rows", &File::rows) .def_property_readonly("cols", &File::cols) .def_property_readonly("bitdepth", &File::bitdepth) .def_property_readonly("bytes_per_pixel", &File::bytes_per_pixel) .def_property_readonly( "detector_type", [](File &self) { return ToString(self.detector_type()); }) .def("read_frame", [](File &self) { const uint8_t item_size = self.bytes_per_pixel(); py::array image; std::vector shape; shape.reserve(2); shape.push_back(self.rows()); shape.push_back(self.cols()); if (item_size == 1) { image = py::array_t(shape); } else if (item_size == 2) { image = py::array_t(shape); } else if (item_size == 4) { image = py::array_t(shape); } self.read_into( reinterpret_cast(image.mutable_data())); return image; }) .def("read_frame", [](File &self, size_t frame_number) { self.seek(frame_number); const uint8_t item_size = self.bytes_per_pixel(); py::array image; std::vector shape; shape.reserve(2); shape.push_back(self.rows()); shape.push_back(self.cols()); if (item_size == 1) { image = py::array_t(shape); } else if (item_size == 2) { image = py::array_t(shape); } else if (item_size == 4) { image = py::array_t(shape); } self.read_into( reinterpret_cast(image.mutable_data())); return image; }) .def("read_n", [](File &self, size_t n_frames) { const uint8_t item_size = self.bytes_per_pixel(); py::array image; std::vector shape; shape.reserve(3); shape.push_back(n_frames); shape.push_back(self.rows()); shape.push_back(self.cols()); if (item_size == 1) { image = py::array_t(shape); } else if (item_size == 2) { image = py::array_t(shape); } else if (item_size == 4) { image = py::array_t(shape); } self.read_into(reinterpret_cast(image.mutable_data()), n_frames); return image; }); py::class_(m, "FileConfig") .def(py::init<>()) .def_readwrite("rows", &FileConfig::rows) .def_readwrite("cols", &FileConfig::cols) .def_readwrite("version", &FileConfig::version) .def_readwrite("geometry", &FileConfig::geometry) .def_readwrite("detector_type", &FileConfig::detector_type) .def_readwrite("max_frames_per_file", &FileConfig::max_frames_per_file) .def_readwrite("total_frames", &FileConfig::total_frames) .def_readwrite("dtype", &FileConfig::dtype) .def("__eq__", &FileConfig::operator==) .def("__ne__", &FileConfig::operator!=) .def("__repr__", [](const FileConfig &a) { return ""; }); // py::class_(m, "ClusterHeader") // .def(py::init<>()) // .def_readwrite("frame_number", &ClusterHeader::frame_number) // .def_readwrite("n_clusters", &ClusterHeader::n_clusters) // .def("__repr__", [](const ClusterHeader &a) { return ""; }); // py::class_(m, "ClusterV2_") // .def(py::init<>()) // .def_readwrite("x", &ClusterV2_::x) // .def_readwrite("y", &ClusterV2_::y) // .def_readwrite("data", &ClusterV2_::data) // .def("__repr__", [](const ClusterV2_ &a) { return ""; }); // py::class_(m, "ClusterV2") // .def(py::init<>()) // .def_readwrite("cluster", &ClusterV2::cluster) // .def_readwrite("frame_number", &ClusterV2::frame_number) // .def("__repr__", [](const ClusterV2 &a) { return ""; }); // py::class_(m, "ClusterFileV2") // .def(py::init()) // .def("read", py::overload_cast<>(&ClusterFileV2::read)) // .def("read", py::overload_cast(&ClusterFileV2::read)) // .def("frame_number", &ClusterFileV2::frame_number) // .def("write", py::overload_cast const // &>(&ClusterFileV2::write)) // .def("close", &ClusterFileV2::close); // m.def("to_clustV2", [](std::vector &clusters, const int // frame_number) { // std::vector clusters_; // for (auto &c : clusters) { // ClusterV2 cluster; // cluster.cluster.x = c.x; // cluster.cluster.y = c.y; // int i=0; // for(auto &d : cluster.cluster.data) { // d=c.get(i++); // } // cluster.frame_number = frame_number; // clusters_.push_back(cluster); // } // return clusters_; // }); }