Save azimuthal integration map

frame_serialize/CBORStream2Serializer.cpp

@@ -423,6 +423,23 @@ inline void CBOR_ENC_PIXEL_MASK(CborEncoder &encoder, const StartMessage &msg) {
     cborErr(cbor_encoder_close_container(&encoder, &mapEncoder));
 }
 
+inline void CBOR_ENC_AZINT_MAP(CborEncoder &encoder, const StartMessage &msg) {
+    if (msg.az_int_map.empty())
+        return;
+
+    if (msg.az_int_map.size() != msg.image_size_x * msg.image_size_y)
+        throw JFJochException(JFJochExceptionCategory::InputParameterInvalid,
+                              "Mismatch in size of pixel mask");
+
+    JFJochBitShuffleCompressor compressor(CompressionAlgorithm::BSHUF_LZ4);
+    auto mask_compressed = compressor.Compress(msg.az_int_map);
+    CompressedImage image(mask_compressed.data(), mask_compressed.size(),
+                          msg.image_size_x, msg.image_size_y,
+                          CompressedImageMode::Uint16,
+                          CompressionAlgorithm::BSHUF_LZ4, "az_int_map");
+    CBOR_ENC_2D_TYPED_ARRAY(encoder, image);
+}
+
 inline void CBOR_ENC(CborEncoder &encoder, const char* key, const UnitCell &val) {
     CborEncoder mapEncoder;
 
@@ -637,6 +654,7 @@ void CBORStream2Serializer::SerializeSequenceStart(const StartMessage& message)
     CBOR_ENC(mapEncoder, "geometry_transformation_enabled", message.geometry_transformation_enabled);
 
     CBOR_ENC_PIXEL_MASK(mapEncoder, message);
+    CBOR_ENC_AZINT_MAP(mapEncoder, message);
 
     CBOR_ENC(mapEncoder, "channels", message.channels);
     CBOR_ENC(mapEncoder, "max_spot_count", message.max_spot_count);