/*
 * Copyright 2015 Institut Laue-Langevin
 *
 * Licensed under the EUPL, Version 1.1 only (the "License");
 * You may not use this work except in compliance with the Licence.
 * You may obtain a copy of the Licence at:
 *
 * http://joinup.ec.europa.eu/software/page/eupl
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the Licence is distributed on an "AS IS" basis,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the Licence for the specific language governing permissions and
 * limitations under the Licence.
 */

#include "EventThread.h"
#include "Server.h"
#include "EventStreamSocket.h"
#include "EventListener.h"

using namespace std;

namespace cameo {

EventThread::EventThread(Server * server, std::unique_ptr<EventStreamSocket>& socket) :
	m_server(server) {
	m_socket = std::move(socket);
}

EventThread::~EventThread() {

	if (m_thread != nullptr) {
		m_thread->join();
	}
}

void EventThread::start() {

	m_thread.reset(new thread([this] {

		while (true) {
			unique_ptr<Event> event = m_socket->receive();

			if (event.get() == nullptr) {
				// The stream is canceled.
				return;
			}

			// Forward the event to the listeners.
			auto eventListeners = m_server->getEventListeners();
			for (EventListener * listener : eventListeners) {

				// If the application name is null, all the status are pushed, otherwise, filter on the name.
				if (listener->getName() == ""
					|| listener->getName() == event->getName()) {

					// Clone the event is necessary because the event is passed to different listeners working in different threads.
					unique_ptr<Event> clonedEvent(event->clone());

					// Push the cloned event.
					listener->pushEvent(clonedEvent);
				}
			}
		}
	}));
}

void EventThread::cancel() {
	m_socket->cancel();
}

}