change writeTimestampSyncText signature

Author: d1manson

Source/Processors/RecordNode/BinaryFormat/BinaryRecording.cpp

@@ -672,19 +672,18 @@ void BinaryRecording::writeSpike (int electrodeIndex, const Spike* spike)
     increaseEventCounts (rec);
 }
 
-void BinaryRecording::writeTimestampSyncText (uint64 streamId, int64 sampleNumber, float sourceSampleRate, String text)
+void BinaryRecording::writeTimestampSyncText(DataStream* stream, int64 sampleNumber, double timestamp, String text) 
 {
     if (! m_syncTextFile)
         return;
 
     String syncString = text + ": " + String (sampleNumber);
     LOGD (syncString);
 
-    int64 fsn = firstSampleNumber[streamId];
-
-    if(streamId > 0)
+    if(stream != nullptr){
+        int64 fsn = firstSampleNumber[stream->getStreamId()];
         jassert (fsn == sampleNumber);
-
+    }
     m_syncTextFile->writeText (syncString + "\r\n", false, false, nullptr);
 
     m_syncTextFile->flush();

Source/Processors/RecordNode/BinaryFormat/BinaryRecording.h

@@ -69,7 +69,7 @@ class BinaryRecording : public RecordEngine
     void writeSpike (int electrodeIndex, const Spike* spike);
 
     /** Writes timestamp sync texts */
-    void writeTimestampSyncText (uint64 streamId, int64 sampleNumber, float sampleRate, String text);
+    void writeTimestampSyncText (DataStream* stream, int64 sampleNumber, double timestamp, String text);
 
     /** Sets an engine parameter (in this case TTL word writing bool) */
     void setParameter (EngineParameter& parameter);

Source/Processors/RecordNode/RecordEngine.h

@@ -104,8 +104,8 @@ class PLUGIN_API RecordEngine
     /** Write a spike to disk */
     virtual void writeSpike (int electrodeIndex, const Spike* spike) = 0;
 
-    /** Handle the timestamp sync text messages*/
-    virtual void writeTimestampSyncText (uint64 streamId, int64 timestamp, float sourceSampleRate, String text) = 0;
+    /** Handle the timestamp sync text messages. */
+    virtual void writeTimestampSyncText (DataStream* stream, int64 sampleNumber, double timestamp, String text) = 0;
 
     // ------------------------------------------------------------
     //                   VIRTUAL METHODS

Source/Processors/RecordNode/RecordThread.cpp

@@ -240,7 +240,19 @@ void RecordThread::writeData (const AudioBuffer<float>& dataBuffer,
         if (SystemEvent::getBaseType (event) == EventBase::Type::SYSTEM_EVENT)
         {
             String syncText = SystemEvent::getSyncText (event);
-            m_engine->writeTimestampSyncText (SystemEvent::getStreamId (event), SystemEvent::getSampleNumber (event), 0.0f, SystemEvent::getSyncText (event));
+            auto streamId = SystemEvent::getStreamId (event);
+            DataStream* stream = recordNode->getDataStream(streamId);
+            int64 sampleNumber = SystemEvent::getSampleNumber (event);
+            
+            double timestamp;
+            if (stream == nullptr){
+                timestamp = 0;
+            } else if(recordNode->synchronizer.streamGeneratesTimestamps (stream->getKey())){
+                timestamp = static_cast<double>(sampleNumber) / stream->getSampleRate();
+            } else {
+                timestamp = recordNode->synchronizer.convertSampleNumberToTimestamp (stream->getKey(), sampleNumber);
+            }   
+            m_engine->writeTimestampSyncText (stream, sampleNumber, timestamp, SystemEvent::getSyncText (event));
         }
         else
         {