/*
 * CINELERRA
 * Copyright (C) 2008 Adam Williams <broadcast at earthling dot net>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 */

#include "attachmentpoint.h"
#include "bcsignals.h"
#include "cache.h"
#include "commonrender.h"
#include "edl.h"
#include "edlsession.h"
#include "filexml.h"
#include "module.h"
#include "mwindow.h"
#include "patch.h"
#include "patchbay.h"
#include "plugin.h"
#include "pluginarray.h"
#include "pluginserver.h"
#include "renderengine.h"
#include "sharedlocation.h"
#include "track.h"
#include "tracks.h"
#include "transportque.h"
#include "virtualconsole.h"


Module::Module(RenderEngine *renderengine,
	CommonRender *commonrender,
	PluginArray *plugin_array,
	Track *track)
{
	this->renderengine = renderengine;
	this->commonrender = commonrender;
	this->plugin_array = plugin_array;
	this->track = track;
	transition = 0;
	transition_server = 0;
	attachments = 0;
	total_attachments = 0;
	new_total_attachments = 0;
	new_attachments = 0;
	nested_edl = 0;
	nested_renderengine = 0;
	nested_command = 0;
	private_cache = 0;
	cache = 0;
}

Module::~Module()
{
	if(attachments)
	{
		for(int i = 0; i < track->plugin_set.total; i++)
		{
			if(attachments[i])
			{
// For some reason it isn't used here.
//				attachments[i]->render_stop(0);
				delete attachments[i];
			}
		}
		delete [] attachments;
	}
	if(transition_server)
	{
		transition_server->close_plugin();
		delete transition_server;
	}

	delete nested_renderengine;
	delete nested_command;
	if(private_cache) delete cache;
}

void Module::create_objects()
{
	create_new_attachments();
	swap_attachments();
}

EDL* Module::get_edl()
{
	return renderengine ? renderengine->get_edl() : edl;
}

Preferences* Module::get_preferences()
{
	if( renderengine ) return renderengine->preferences;
	if( plugin_array ) return plugin_array->mwindow->preferences;
	return 0;
}


void Module::create_new_attachments()
{
// Not used in pluginarray
	if(commonrender)
	{
		new_total_attachments = track->plugin_set.size();
		if(new_total_attachments)
		{
			new_attachments = new AttachmentPoint*[new_total_attachments];
			for(int i = 0; i < new_total_attachments; i++)
			{
				Plugin *plugin =
					track->get_current_plugin(commonrender->current_position,
						i,
						renderengine->command->get_direction(),
						0,
						1);

				if(plugin && plugin->plugin_type != PLUGIN_NONE && plugin->on)
				{
					new_attachments[i] = new_attachment(plugin);
// printf("Module::create_new_attachments %d new_attachment=%p\n",
// __LINE__,
// new_attachments[i]->virtual_plugins.values);
				}
				else
				{
					new_attachments[i] = 0;
				}
			}
		}
		else
			new_attachments = 0;

// Create plugin servers in virtual console expansion
	}
}

void Module::swap_attachments()
{
// for(int i = 0; i < total_attachments; i++)
// printf("Module::swap_attachments %d attachment=%p\n", __LINE__, attachments[i] ? attachments[i]->virtual_plugins.values : 0);
// for(int i = 0; i < new_total_attachments; i++)
// printf("Module::swap_attachments %d new_attachment=%p\n", __LINE__, new_attachments[i] ? new_attachments[i]->virtual_plugins.values : 0);

// None of this is used in a pluginarray
	for(int i = 0;
		i < new_total_attachments &&
		i < total_attachments;
		i++)
	{
// Delete new attachment which is identical to the old one and copy
// old attachment.
		if(new_attachments[i] &&
			attachments[i] &&
			new_attachments[i]->identical(attachments[i]))
		{
// printf("Module::swap_attachments %d virtual_plugins=%p new_virtual_plugins=%p\n",
// __LINE__,
// new_attachments[i]->virtual_plugins.values,
// new_attachments[i]->new_virtual_plugins.values);

			delete new_attachments[i];
			new_attachments[i] = attachments[i];
			attachments[i] = 0;
		}
	}

// Delete old attachments which weren't identical to new ones
	for(int i = 0; i < total_attachments; i++)
	{
		if(attachments[i]) delete attachments[i];
	}

	if(attachments)
	{
		delete [] attachments;
	}

	attachments = new_attachments;
	total_attachments = new_total_attachments;

	new_attachments = 0;
	new_total_attachments = 0;

// for(int i = 0; i < total_attachments; i++)
// printf("Module::swap_attachments %d final_attachment=%p\n", __LINE__, attachments[i] ? attachments[i]->virtual_plugins.values : 0);
}

int Module::render_init()
{
	for(int i = 0; i < total_attachments; i++)
	{
		if(attachments[i])
			attachments[i]->render_init();
	}

	return 0;
}

void Module::render_stop()
{
	for(int i = 0; i < total_attachments; i++)
	{
		if(attachments[i])
			attachments[i]->render_stop();
	}
}

AttachmentPoint* Module::attachment_of(Plugin *plugin)
{
//printf("Module::attachment_of 1 %d\n", total_attachments);
	for(int i = 0; i < total_attachments; i++)
	{
//printf("Module::attachment_of 2 %p\n", attachments[i]);
		if(attachments[i] &&
			attachments[i]->plugin == plugin) return attachments[i];
	}
	return 0;
}

AttachmentPoint* Module::get_attachment(int number)
{
	if(number < total_attachments)
		return attachments[number];
	else
		return 0;
}

void Module::reset_attachments()
{
//printf("Module::reset_attachments 1 %d\n", total_attachments);
	for(int i = 0; i < total_attachments; i++)
	{
//printf("Module::reset_attachments 2 %p\n", attachments[i]);
		AttachmentPoint *attachment = attachments[i];
		if(attachment) attachment->reset_status();
	}
}

// Test plugins for reconfiguration.
// Used in playback
int Module::test_plugins()
{
	if(total_attachments != track->plugin_set.total) return 1;

	for(int i = 0; i < total_attachments; i++)
	{
		AttachmentPoint *attachment = attachments[i];
		Plugin *plugin = track->get_current_plugin(
			commonrender->current_position,
			i,
			renderengine->command->get_direction(),
			0,
			1);
// One exists and one doesn't
		int use_plugin = plugin &&
			plugin->plugin_type != PLUGIN_NONE &&
			plugin->on;

		if((attachment && !use_plugin) ||
			(!attachment && use_plugin)) return 1;

// Plugin not the same
		if(plugin &&
			attachment &&
			attachment->plugin &&
			!plugin->identical(attachment->plugin)) return 1;
	}

	return 0;
}

void Module::update_transition(int64_t current_position,
	int direction)
{
	transition = track->get_current_transition(current_position,
		direction, 0, 0);

// For situations where we had a transition but not anymore,
// keep the server open.
// Maybe the same transition will follow and we won't need to reinit.
// (happens a lot while scrubbing over transitions left and right)


// If the current transition differs from the previous transition, delete the
// server.
	if (transition && transition_server) {
		if (strcmp(transition->title, transition_server->plugin->title)) {
			transition_server->close_plugin();
			delete transition_server;
			transition_server = 0;
		}
		else {
			transition_server->plugin = transition;
		}
	}

	if(transition && !transition_server) {
		if(renderengine) {
			PluginServer *plugin_server = MWindow::scan_plugindb(transition->title,
				track->data_type);
			transition_server = new PluginServer(*plugin_server);
			transition_server->open_plugin(0,
				get_preferences(),
				get_edl(),
				transition);
			transition_server->init_realtime(
				get_edl()->session->real_time_playback &&
				renderengine->command->realtime,
				1,
				get_buffer_size());
		}
		else
		if(plugin_array) {
			PluginServer *plugin_server = MWindow::scan_plugindb(transition->title,
				plugin_array->data_type);
			transition_server = new PluginServer(*plugin_server);
			transition_server->open_plugin(0,
				get_preferences(),
				get_edl(),
				transition);
			transition_server->init_realtime(
				0,
				1,
				get_buffer_size());
		}
	}
}


void Module::dump()
{
	printf("  Module title=%s\n", track->title);
	printf("   Plugins total_attachments=%d\n", total_attachments);
	for(int i = 0; i < total_attachments; i++)
	{
		attachments[i]->dump();
	}
}