Connect to MessageCenter from RecordNode and ignore any duplicate messages

Author: medengineer

Source/Processors/MessageCenter/MessageCenter.cpp

@@ -63,6 +63,11 @@ AudioProcessorEditor* MessageCenter::createEditor()
 
 }
 
+const EventChannel* MessageCenter::getMessageChannel()
+{
+    return getEventChannel(0);
+}
+
 void MessageCenter::setParameter(int parameterIndex, float newValue)
 {
     if (isRecording)

Source/Processors/MessageCenter/MessageCenter.h

@@ -61,6 +61,8 @@ class MessageCenter : public GenericProcessor
     /** A pointer to the Message Center editor. */
     ScopedPointer<MessageCenterEditor> messageCenterEditor;
 
+    const EventChannel* getMessageChannel();
+
     bool enable() override;
     bool disable() override;
 

Source/Processors/MessageCenter/MessageCenterEditor.h

@@ -64,6 +64,8 @@ class MessageCenterEditor : public AudioProcessorEditor,
 
     String getLabelString();
 
+    MessageCenter* messageCenter;
+
 private:
 
     void buttonClicked(Button* button);
@@ -85,8 +87,6 @@ class MessageCenterEditor : public AudioProcessorEditor,
     /** A JUCE button used to send messages. */
     ScopedPointer<Button> sendMessageButton;
 
-    MessageCenter* messageCenter;
-
     Colour incomingBackground;
     Colour outgoingBackground;
 

Source/Processors/ProcessorGraph/ProcessorGraph.cpp

@@ -447,14 +447,16 @@ void ProcessorGraph::updateConnections(Array<SignalChainTabButton*, CriticalSect
             connectProcessors(conn.source, dest, conn.connectContinuous, conn.connectEvents);
         }
     }
+
+    Array<EventChannel*> extraChannels;
+    getMessageCenter()->addSpecialProcessorChannels(extraChannels);
 
 	getAudioNode()->updatePlaybackBuffer();
 
-	Array<EventChannel*> extraChannels;
-	getMessageCenter()->addSpecialProcessorChannels(extraChannels);
-
+    /*
     for (auto& recordNode : getRecordNodes())
         recordNode->addSpecialProcessorChannels(extraChannels);
+    */
 
 } // end method
 

Source/Processors/RecordNode/RecordNode.cpp

@@ -2,6 +2,7 @@
 
 #include "../../UI/EditorViewport.h"
 #include "../../UI/ControlPanel.h"
+#include "../../Processors/MessageCenter/MessageCenterEditor.h"
 #include "BinaryFormat/BinaryRecording.h"
 #include "OpenEphysFormat/OriginalRecording.h"
 
@@ -40,7 +41,8 @@ RecordNode::RecordNode()
 	hasRecorded(false),
 	settingsNeeded(false),
 	receivedSoftwareTime(false),
-    numSubprocessors(0)
+    numSubprocessors(0),
+	isConnectedToMessageCenter(false)
 {
 	setProcessorType(PROCESSOR_TYPE_RECORD_NODE);
 
@@ -69,6 +71,16 @@ RecordNode::~RecordNode()
 {
 }
 
+void RecordNode::connectToMessageCenter()
+{
+
+	const EventChannel* orig = AccessClass::getMessageCenter()->messageCenter->getEventChannel(0);
+	eventChannelArray.add(new EventChannel(*orig));
+	
+	isConnectedToMessageCenter = true;
+
+}
+
 void RecordNode::addInputChannel(const GenericProcessor* sourceNode, int chan)
 {
 	// not getting called
@@ -341,6 +353,8 @@ void RecordNode::updateSubprocessorMap()
     eventMap.clear();
     syncChannelMap.clear();
     syncOrderMap.clear();
+
+	LOGD("Record Node: ", getNodeId(), " has ", eventChannelArray.size(), " channels");
     for (int ch = 0; ch < eventChannelArray.size(); ch++)
     {
 
@@ -483,6 +497,9 @@ void RecordNode::startRecording()
 
 	hasRecorded = true;
 
+	if (!isConnectedToMessageCenter)
+		connectToMessageCenter();
+
 	/* Set write properties */
 	setFirstBlock = false;
 
@@ -557,6 +574,15 @@ void RecordNode::setRecordSpikes(bool recordSpikes)
 void RecordNode::handleEvent(const EventChannel* eventInfo, const MidiMessage& event, int samplePosition)
 {
 
+	//Ignore any duplicate messages from MessageCenter
+	if (Event::getSourceID(event) > 900)
+	{
+		if (!msgCenterMessages.contains(Event::getTimestamp(event)))
+			msgCenterMessages.add(Event::getTimestamp(event));
+		else
+			return;
+	}
+
 	eventMonitor->receivedEvents++;
 
 	if (recordEvents) 

Source/Processors/RecordNode/RecordNode.h

@@ -49,6 +49,8 @@ class RecordNode : public GenericProcessor, public FilenameComponentListener
 	RecordNode();
 	~RecordNode();
 
+	void connectToMessageCenter();
+
 	void updateRecordChannelIndexes();
 
 	AudioProcessorEditor* createEditor() override;
@@ -167,6 +169,9 @@ class RecordNode : public GenericProcessor, public FilenameComponentListener
 
 private:
 
+	bool isConnectedToMessageCenter;
+	Array<int64> msgCenterMessages;
+
 	bool useSynchronizer; 
 
 	bool receivedSoftwareTime;