/*
  This file is part of Ingen.
  Copyright 2007-2016 David Robillard <http://drobilla.net/>

  Ingen is free software: you can redistribute it and/or modify it under the
  terms of the GNU Affero General Public License as published by the Free
  Software Foundation, either version 3 of the License, or any later version.

  Ingen 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 Affero General Public License for details.

  You should have received a copy of the GNU Affero General Public License
  along with Ingen.  If not, see <http://www.gnu.org/licenses/>.
*/

#include "InternalBlock.hpp"

#include "Buffer.hpp"
#include "BufferFactory.hpp"
#include "Engine.hpp"
#include "InternalPlugin.hpp"
#include "PluginImpl.hpp"
#include "PortImpl.hpp"

#include "ingen/URIs.hpp"
#include "raul/Array.hpp"

#include <boost/smart_ptr/intrusive_ptr.hpp>

#include <cstddef>
#include <cstdint>
#include <memory>

namespace raul {
class Symbol;
} // namespace raul

namespace ingen {

class Atom;

namespace server {

class GraphImpl;
class RunContext;

InternalBlock::InternalBlock(PluginImpl*         plugin,
                             const raul::Symbol& symbol,
                             bool                poly,
                             GraphImpl*          parent,
                             SampleRate          rate)
	: BlockImpl(plugin, symbol, poly, parent, rate)
{}

BlockImpl*
InternalBlock::duplicate(Engine&             engine,
                         const raul::Symbol& symbol,
                         GraphImpl*          parent)
{
	BufferFactory& bufs = *engine.buffer_factory();

	BlockImpl* copy = reinterpret_cast<InternalPlugin*>(_plugin)->instantiate(
		bufs, symbol, _polyphonic, parent, engine, nullptr);

	for (size_t i = 0; i < num_ports(); ++i) {
		const Atom& value = port_impl(i)->value();
		copy->port_impl(i)->set_property(bufs.uris().ingen_value, value);
		copy->port_impl(i)->set_value(value);
	}

	return copy;
}

void
InternalBlock::pre_process(RunContext& ctx)
{
	for (uint32_t i = 0; i < num_ports(); ++i) {
		PortImpl* const port = _ports->at(i);
		if (port->is_input()) {
			port->pre_process(ctx);
		} else if (port->buffer_type() == _plugin->uris().atom_Sequence) {
			/* Output sequences are initialized in LV2 format, an atom:Chunk
			   with size set to the capacity of the buffer.  Internal nodes
			   don't care, so clear to an empty sequences so appending events
			   results in a valid output. */
			for (uint32_t v = 0; v < port->poly(); ++v) {
				port->buffer(v)->clear();
			}
		}
	}
}

} // namespace server
} // namespace ingen