From b484b45b88ff033971e0766b5cbcd40990853693 Mon Sep 17 00:00:00 2001
From: Dmitry Ozerov <dmitry.ozerov@psi.ch>
Date: Fri, 1 May 2020 14:20:16 +0200
Subject: [PATCH] working version of sf_stream (sends to streamvis assembled
 frame)

---
 scripts/JF07-replay-worker.sh |  2 +-
 sf-buffer/src/sf_stream.cpp   | 75 ++++++++++++++++++++---------------
 2 files changed, 44 insertions(+), 33 deletions(-)

diff --git a/scripts/JF07-replay-worker.sh b/scripts/JF07-replay-worker.sh
index 2a60dbe..6d77992 100644
--- a/scripts/JF07-replay-worker.sh
+++ b/scripts/JF07-replay-worker.sh
@@ -14,7 +14,7 @@ coreAssociated=(17 17 17 17 17 17 17 17 18 18 18 18 18 18 18 18 19 19 19 19 19 1
 latest_file=`cat /gpfs/photonics/swissfel/buffer/JF07T32V01/M00/LATEST`
 last_pulse_id=`basename ${latest_file} | sed 's/.h5//'`
 #first_pulse_id=$((${last_pulse_id}-100000))
-first_pulse_id=$((${last_pulse_id}-1000))
+first_pulse_id=$((${last_pulse_id}-100000))
 
 echo "First/last pulse_id : ${first_pulse_id} ${last_pulse_id}"
 
diff --git a/sf-buffer/src/sf_stream.cpp b/sf-buffer/src/sf_stream.cpp
index dd3ccb7..1303692 100644
--- a/sf-buffer/src/sf_stream.cpp
+++ b/sf-buffer/src/sf_stream.cpp
@@ -96,7 +96,7 @@ void receive_replay(
                     if (frame_meta_buffer->pulse_id[i_buffer] !=
                         module_meta_buffer->pulse_id) {
                         frame_meta_buffer->is_good_frame[i_buffer] = false;
-                        throw runtime_error("Unexpected pulse_id received.");
+                        //throw runtime_error("Unexpected pulse_id received.");
                     }
 
                     if (frame_meta_buffer->frame_index[i_buffer] !=
@@ -214,6 +214,7 @@ int main (int argc, char *argv[])
     auto start_time = chrono::steady_clock::now();
 
     Json::Value header;
+    Json::StreamWriterBuilder builder;
 
     while (true) {
 
@@ -247,42 +248,52 @@ int main (int argc, char *argv[])
             header["daq_rec"] = metadata->daq_rec[i_buffer];
             header["pulse_id"] = (Json::Value::UInt64)metadata->pulse_id[i_buffer];
 
-            string text_header = Json::FastWriter().write(header);
-            zmq_send(socket_streamvis,
-                 text_header,
-                 text_header.size(),
-                 ZMQ_SNDMORE);
+            //this needs to be re-read from external source
+            header["pedestal_file"] = "/sf/bernina/data/p17534/res/JF_pedestals/pedestal_20200423_1018.JF07T32V01.res.h5"; 
+            header["gain_file"] = "/sf/bernina/config/jungfrau/gainMaps/JF07T32V01/gains.h5";
+
+            header["number_frames_expected"] = 10000;
+            header["run_name"] = to_string(uint64_t(metadata->pulse_id[i_buffer]/10000)*10000);
+
+            // detector name should come as parameter to sf_stream
+            header["detector_name"] = "JF07T32V01";
+
+            header["htype"] = "array-1.0";
+            header["type"]  = "uint16";
+
+            int send_streamvis = 0;
+            if ( reduction_factor_streamvis > 1 ) {
+                send_streamvis = rand() % reduction_factor_streamvis;
+            }
+            if ( send_streamvis == 0 ) {
+                header["shape"][0] = 16384;
+                header["shape"][1] = 1024;
+            } else{ 
+                header["shape"][0] = 2;
+                header["shape"][1] = 2; 
+            }
+
+            string text_header = Json::writeString(builder, header);
 
             zmq_send(socket_streamvis,
-            (char*)data_empty,
-            8,
-            0);
+                 text_header.c_str(),
+                 text_header.size(),
+                 ZMQ_SNDMORE);
+ 
+            if ( send_streamvis == 0 ) {
+                zmq_send(socket_streamvis,
+                (char*)data,
+                core_buffer::MODULE_N_BYTES*n_modules,
+                0);
+            } else {
+                zmq_send(socket_streamvis,
+                (char*)data_empty,
+                8,
+                0);
+            }
 
         }
  
-        //int send_streamvis = 0;
-        //if ( reduction_factor_streamvis > 1 ) {
-        //    send_streamvis = rand() % reduction_factor_streamvis;
-        //}
-        //send_streamvis = 0;
-        //zmq_send(socket_streamvis,
-        //         &metadata,
-        //         sizeof(DetectorFrame),
-        //         ZMQ_SNDMORE);
-
-        //if ( send_streamvis == 0 ) {
-        //    zmq_send(socket_streamvis,
-        //             (char*)data,
-        //             MODULE_N_BYTES*n_modules,
-        //             0);
-        //} else {
-        //    zmq_send(socket_streamvis,
-        //             (char*)data_empty,
-        //             8,
-        //             0);
-        //}    
-
-
         queue.release();
 
         // TODO: Some poor statistics.