diff --git a/jf-live-writer/include/JFH5LiveWriter.hpp b/jf-live-writer/include/JFH5LiveWriter.hpp
new file mode 100644
index 0000000..b20962c
--- /dev/null
+++ b/jf-live-writer/include/JFH5LiveWriter.hpp
@@ -0,0 +1,53 @@
+#ifndef SFWRITER_HPP
+#define SFWRITER_HPP
+
+#include <memory>
+#include <string>
+#include <H5Cpp.h>
+
+#include "LiveImageAssembler.hpp"
+
+const auto& H5_UINT64 = H5::PredType::NATIVE_UINT64;
+const auto& H5_UINT32 = H5::PredType::NATIVE_UINT32;
+const auto& H5_UINT16 = H5::PredType::NATIVE_UINT16;
+const auto& H5_UINT8 = H5::PredType::NATIVE_UINT8;
+
+class JFH5LiveWriter {
+
+    const std::string detector_name_;
+    const size_t n_modules_;
+
+    const uint64_t start_pulse_id_;
+    const size_t n_pulses_;
+    const size_t pulse_id_step_;
+    size_t write_index_;
+
+    H5::H5File file_;
+    H5::DataSet image_dataset_;
+
+    uint64_t* b_pulse_id_;
+    uint64_t* b_frame_index_;
+    uint32_t* b_daq_rec_;
+    uint8_t* b_is_good_frame_ ;
+
+    void init_file(const std::string &output_file);
+    void write_dataset(const std::string name,
+                       const void *buffer,
+                       const H5::PredType &type);
+    void write_metadata();
+    std::string get_detector_name(const std::string& detector_folder);
+
+    void close_file();
+
+public:
+    JFH5LiveWriter(const std::string& output_file,
+                   const std::string& detector_folder,
+                   const size_t n_modules,
+                   const uint64_t start_pulse_id,
+                   const size_t n_pulses,
+                   const size_t pulse_id_step);
+    ~JFH5LiveWriter();
+    void write(const ImageMetadata* metadata, const char* data);
+};
+
+#endif //SFWRITER_HPP
diff --git a/jf-live-writer/src/JFH5LiveWriter.cpp b/jf-live-writer/src/JFH5LiveWriter.cpp
new file mode 100644
index 0000000..324b5a0
--- /dev/null
+++ b/jf-live-writer/src/JFH5LiveWriter.cpp
@@ -0,0 +1,138 @@
+#include "JFH5LiveWriter.hpp"
+
+#include <cstring>
+#include <hdf5_hl.h>
+
+
+#include "buffer_config.hpp"
+
+using namespace std;
+using namespace buffer_config;
+
+JFH5LiveWriter::JFH5LiveWriter(const string& output_file,
+                       const string& detector_folder,
+                       const size_t n_modules,
+                       const uint64_t start_pulse_id,
+                       const size_t n_pulses,
+                       const size_t pulse_id_step) :
+        detector_name_(get_detector_name(detector_folder)),
+        n_modules_(n_modules),
+        start_pulse_id_(start_pulse_id),
+        n_pulses_(n_pulses),
+        pulse_id_step_(pulse_id_step),
+        write_index_(0)
+{
+    b_pulse_id_ = new uint64_t[n_pulses_];
+    b_frame_index_= new uint64_t[n_pulses_];
+    b_daq_rec_ = new uint32_t[n_pulses_];
+    b_is_good_frame_ = new uint8_t[n_pulses_];
+
+    init_file(output_file);
+}
+
+void JFH5LiveWriter::init_file(const string& output_file)
+{
+    file_ = H5::H5File(output_file, H5F_ACC_TRUNC);
+    file_.createGroup("/data");
+    file_.createGroup("/data/" + detector_name_);
+
+    H5::DataSpace att_space(H5S_SCALAR);
+    H5::DataType data_type = H5::StrType(0, H5T_VARIABLE);
+
+    file_.createGroup("/general");
+    auto detector_dataset = file_.createDataSet(
+            "/general/detector_name", data_type ,att_space);
+
+    detector_dataset.write(detector_name_, data_type);
+
+    hsize_t image_dataset_dims[3] =
+            {n_pulses_, n_modules_ * MODULE_Y_SIZE, MODULE_X_SIZE};
+
+    H5::DataSpace image_dataspace(3, image_dataset_dims);
+
+    hsize_t image_dataset_chunking[3] =
+            {1, n_modules_ * MODULE_Y_SIZE, MODULE_X_SIZE};
+    H5::DSetCreatPropList image_dataset_properties;
+    image_dataset_properties.setChunk(3, image_dataset_chunking);
+
+    image_dataset_ = file_.createDataSet(
+            "/data/" + detector_name_ + "/data",
+            H5_UINT16,
+            image_dataspace,
+            image_dataset_properties);
+}
+
+
+std::string JFH5LiveWriter::get_detector_name(const string& detector_folder)
+{
+    size_t last_separator;
+    if ((last_separator = detector_folder.rfind("/")) == string::npos) {
+        return detector_folder;
+    }
+
+    return detector_folder.substr(last_separator + 1);
+}
+
+JFH5LiveWriter::~JFH5LiveWriter()
+{
+    close_file();
+
+    delete[] b_pulse_id_;
+    delete[] b_frame_index_;
+    delete[] b_daq_rec_;
+    delete[] b_is_good_frame_;
+}
+
+void JFH5LiveWriter::write_dataset(
+        const string name, const void* buffer, const H5::PredType& type)
+{
+    hsize_t b_m_dims[] = {n_pulses_};
+    H5::DataSpace b_m_space (1, b_m_dims);
+
+    hsize_t f_m_dims[] = {n_pulses_, 1};
+    H5::DataSpace f_m_space(2, f_m_dims);
+
+    auto complete_name = "/data/" + detector_name_ + "/" + name;
+    auto dataset = file_.createDataSet(complete_name, type, f_m_space);
+
+    dataset.write(buffer, type, b_m_space, f_m_space);
+
+    dataset.close();
+}
+
+void JFH5LiveWriter::write_metadata()
+{
+    write_dataset("pulse_id", &b_pulse_id_, H5_UINT64);
+    write_dataset("frame_index", &b_frame_index_, H5_UINT64);
+    write_dataset("daq_rec", &b_daq_rec_, H5_UINT32);
+    write_dataset("is_good_frame", &b_is_good_frame_, H5_UINT8);
+}
+
+void JFH5LiveWriter::close_file()
+{
+    if (file_.getId() == -1) {
+        return;
+    }
+
+    image_dataset_.close();
+
+    write_metadata();
+
+    file_.close();
+}
+
+void JFH5LiveWriter::write(const ImageMetadata* metadata, const char* data)
+{
+
+    hsize_t offset[] = {write_index_, 0, 0};
+
+    H5DOwrite_chunk(image_dataset_.getId(), H5P_DEFAULT, 0,
+            offset, MODULE_N_BYTES * n_modules_, data);
+
+    b_pulse_id_[write_index_] = metadata->pulse_id;
+    b_frame_index_[write_index_] = metadata->frame_index;
+    b_daq_rec_[write_index_] = metadata->daq_rec;
+    b_is_good_frame_[write_index_] = metadata->is_good_image;
+
+    write_index_++;
+}