viseq/src/signal-manager.h

#pragma once

#include "connection-manager.h"
#include "datatypes.h"
#include "signal.h"
#include "node.h"
#include "midi.h"

#include <chrono>
#include <thread>

class SignalManager{

	public:
		SignalManager() {}
		SignalManager(ConnectionManager *cm, std::mutex *mutex) : mutex(mutex), cm(cm) {}
		
		Midi midi;
		
		std::mutex *mutex;
		ConnectionManager *cm;

		std::vector<Signal> signals;

		bool loop = true;
		bool play = false;
	
		void pause(){
			play = false;
		}

		void stop(){
			play = false;
			reset();
		}

		void start(){
			play = true;
		}
		
		void reset(){
			for(auto &s : signals){
				s.position = s.start->position + Vec2D<float>{0.1, 0.1};
				s.next = s.start;
				s.last = s.start;
			}
			cm->reset();
		}

		void startSignalThread(){
			std::thread t1(&SignalManager::updateSignals, this);
			t1.detach();
		}

		void stopSignalThread(){
			loop = false;
		}
	
		void addSignalAtNode(Node *node){
			Color c = {(unsigned char)(232 - (rand() % 120)), (unsigned char)(125 + (int)(rand() % 120)), 62, 255};
			signals.emplace(signals.end(), Signal(node->position.x+1, node->position.y+1, 5.0f, 0, c)); // position + 1 or else it does not render. why? no idea!
			signals.back().next = node;
			signals.back().last = node;
			signals.back().start = node;
		}

		void removeSignal(int n){
			signals.erase(signals.begin() + n);
		}

		void updateSignals(){
			auto last = std::chrono::steady_clock::now();
			while(loop){
				std::chrono::duration<double, std::micro> diff = std::chrono::steady_clock::now() - last;
				if(diff.count() > 500){
					mutex->lock();
					if(play){
						for(auto& s : signals){
							s.direction = (s.next->position - s.position).norm();
							s.update(diff.count());
							if(s.position.dist(&s.next->position) < 1.0f) {
								Node* n = cm->next(s.next, s.last);
								
								if(n != s.next && n != nullptr) {
									for(auto &m : s.next->midi_outs){
										if(m.second.enabled) midi.note(m.second.i, s.next->midi_channel, s.next->midi_note, s.next->midi_velocity, s.next->midi_gate);	
									}
									s.last = s.next;
									s.next = n;
								}
							}
						}
					}
					midi.update();
					mutex->unlock();
				last = std::chrono::steady_clock::now();
				}
			}
		}

		void drawSignals(Vec2D<float> *mouse_pos, Camera2D *camera){
			for(auto& s : signals){
				s.draw(mouse_pos, camera);
			}
		}

};