/***************************************************************************
 * Copyright 2015 Kieker Project (http://kieker-monitoring.net)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 ***************************************************************************/

package kieker.analysisteetime;

import org.apache.commons.lang3.tuple.Pair;

import kieker.analysisteetime.model.analysismodel.deployment.DeployedOperation;
import kieker.analysisteetime.model.analysismodel.execution.AggregatedInvocation;
import kieker.analysisteetime.model.analysismodel.execution.ExecutionFactory;
import kieker.analysisteetime.model.analysismodel.execution.ExecutionModel;
import kieker.analysisteetime.model.analysismodel.trace.OperationCall;
import kieker.analysisteetime.model.analysismodel.trace.Trace;
import kieker.analysisteetime.trace.traversal.OperationCallVisitor;
import kieker.analysisteetime.trace.traversal.TraceTraverser;

/**
 * @author Sren Henning
 *
 * @since 1.13
 */
public class ExecutionModelAssembler {

	private final ExecutionFactory factory = ExecutionFactory.eINSTANCE;

	private final TraceTraverser traceTraverser = new TraceTraverser();
	private final OperationCallInserter operationCallInserter = new OperationCallInserter();

	private final ExecutionModel executionModel;

	public ExecutionModelAssembler(final ExecutionModel executionModel) {
		this.executionModel = executionModel;
	}

	public void addTrace(final Trace trace) {
		this.traceTraverser.traverse(trace, this.operationCallInserter);
	}

	protected void addExecution(final DeployedOperation source, final DeployedOperation target) {

		final Pair<DeployedOperation, DeployedOperation> key = Pair.of(source, target);
		if (!this.executionModel.getAggregatedInvocations().contains(key)) {
			final AggregatedInvocation invocation = this.factory.createAggregatedInvocation();
			invocation.setSource(source);
			invocation.setTarget(target);

			this.executionModel.getAggregatedInvocations().put(key, invocation);
		}

		// TODO Statistics and so on

	}

	private class OperationCallInserter extends OperationCallVisitor {
		public OperationCallInserter() {}

		@Override
		public void visit(final OperationCall operationCall) {
			// Check if operationCall is an entry operation call. If so than source is null
			final DeployedOperation source = operationCall.getParent() != null ? operationCall.getParent().getOperation() : null;
			final DeployedOperation target = operationCall.getOperation();

			ExecutionModelAssembler.this.addExecution(source, target);
		}
	}
}

@@ -808,52 +808,8 @@
 e;%0A%0A
-import org.apache.commons.lang3.tuple.Pair;%0A
 %0Aimp
@@ -1384,16 +1384,64 @@
 averser;
+%0Aimport kieker.analysisteetime.util.ComposedKey;
 %0A%0A/**%0A *
@@ -2135,20 +2135,27 @@
 %09%09final 
-Pair
+ComposedKey
 %3CDeploye
@@ -2195,12 +2195,19 @@
 y = 
-Pair
+ComposedKey
 .of(

use new ComposedKey