/*
* Copyright 2014, The Sporting Exchange Limited
*
* 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 com.betfair.cougar.core.impl.ev;
import com.betfair.cougar.api.ExecutionContext;
import com.betfair.cougar.api.fault.CougarApplicationException;
import com.betfair.cougar.core.api.ev.ExecutionObserver;
import com.betfair.cougar.core.api.ev.ExecutionPreProcessor;
import com.betfair.cougar.core.api.ev.ExecutionRequirement;
import com.betfair.cougar.core.api.ev.ExecutionResult;
import com.betfair.cougar.core.api.ev.InterceptorResult;
import com.betfair.cougar.core.api.ev.InterceptorState;
import com.betfair.cougar.core.api.ev.OperationKey;
import com.betfair.cougar.core.api.exception.CougarException;
import com.betfair.cougar.core.api.exception.CougarFrameworkException;
import com.betfair.cougar.core.api.exception.ServerFaultCode;
import com.betfair.cougar.logging.CougarLogger;
import com.betfair.cougar.logging.CougarLoggingUtils;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Level;
/**
*
*/
public class InterceptionUtils {
private static final InterceptorResult CONTINUE = new InterceptorResult(InterceptorState.CONTINUE);
private final static CougarLogger logger = CougarLoggingUtils.getLogger(InterceptingExecutableWrapper.class);
public static void execute(List<ExecutionPreProcessor> preExecutionInterceptorList, List<ExecutionPreProcessor> unexecutedPreExecutionInterceptorList, ExecutionRequirement phase, Runnable executionBody, ExecutionContext ctx, OperationKey key, Object[] args,
ExecutionObserver observer) {
InterceptorResult result = invokePreProcessingInterceptors(preExecutionInterceptorList, unexecutedPreExecutionInterceptorList, phase, ctx, key, args);
/**
* Pre-processors can force ON_EXCEPTION or ON_RESULT without execution.
* The shouldInvoke will indicate whether actual invocation should take place.
*/
if (result.getState().shouldInvoke()) {
executionBody.run();
} else {
if (InterceptorState.FORCE_ON_EXCEPTION.equals(result.getState())) {
Object interceptorResult = result.getResult();
ExecutionResult executionResult;
if (interceptorResult instanceof CougarException) {
executionResult = new ExecutionResult(interceptorResult);
} else if (interceptorResult instanceof CougarApplicationException) {
executionResult = new ExecutionResult(interceptorResult);
} else if (result.getResult() instanceof Exception) {
executionResult = new ExecutionResult(
new CougarFrameworkException(ServerFaultCode.ServiceRuntimeException,
"Interceptor forced exception", (Exception)result.getResult()));
} else {
// onException forced, but result is not an exception
executionResult = new ExecutionResult(
new CougarFrameworkException(ServerFaultCode.ServiceRuntimeException,
"Interceptor forced exception, but result was not an exception - I found a " +
result.getResult()));
}
observer.onResult(executionResult);
} else if (InterceptorState.FORCE_ON_RESULT.equals(result.getState())) {
observer.onResult(new ExecutionResult(result.getResult()));
}
}
}
private static InterceptorResult invokePreProcessingInterceptors(List<ExecutionPreProcessor> preExecutionInterceptorList, List<ExecutionPreProcessor> unexecutedPreExecutionInterceptorList, ExecutionRequirement phase, ExecutionContext ctx, OperationKey key, Object[] args) {
InterceptorResult result = CONTINUE;
List<ExecutionPreProcessor> toIterateOver = new ArrayList<>(preExecutionInterceptorList);
for (ExecutionPreProcessor pre : toIterateOver) {
ExecutionRequirement req = pre.getExecutionRequirement();
if (req == ExecutionRequirement.EVERY_OPPORTUNITY || req == phase || (req == ExecutionRequirement.EXACTLY_ONCE && unexecutedPreExecutionInterceptorList.contains(pre))) {
try {
result = pre.invoke(ctx, key, args);
unexecutedPreExecutionInterceptorList.remove(pre);
if (result == null || result.getState() == null) {
// defensive
throw new IllegalStateException(pre.getName() +" did not return a valid InterceptorResult");
}
} catch (Exception e) {
logger.log(Level.SEVERE, "Pre Processor " + pre.getName() + " has failed.");
logger.log(e);
result = new InterceptorResult(InterceptorState.FORCE_ON_EXCEPTION, e);
break;
}
if (result.getState().shouldAbortInterceptorChain()) {
break;
}
}
}
return result;
}
}