/**
 * 
 * Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
 * 
 * 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 org.apache.tuscany.container.java.builder;

import org.apache.tuscany.core.builder.BuilderException;
import org.apache.tuscany.core.builder.SourcePolicyBuilder;
import org.apache.tuscany.core.builder.TargetPolicyBuilder;
import org.apache.tuscany.core.wire.InvocationConfiguration;
import org.apache.tuscany.core.wire.MessageHandler;
import org.apache.tuscany.core.wire.SourceInvocationConfiguration;
import org.apache.tuscany.core.wire.SourceWireFactory;
import org.apache.tuscany.core.wire.TargetInvocationConfiguration;
import org.apache.tuscany.core.wire.TargetWireFactory;
import org.apache.tuscany.core.wire.WireSourceConfiguration;
import org.apache.tuscany.core.wire.WireTargetConfiguration;
import org.apache.tuscany.model.assembly.AssemblyObject;
import org.apache.tuscany.model.assembly.ConfiguredReference;
import org.apache.tuscany.model.assembly.ConfiguredService;

import java.util.List;

/**
 * Adds a handler to a source or target proxy configuration
 *
 * @version $Rev$ $Date$
 */
public class MockHandlerBuilder implements SourcePolicyBuilder, TargetPolicyBuilder {


    private MessageHandler handler;

    private boolean source;

    private boolean request;

    /**
     * Creates the builder.
     *
     * @param handler the handler to add to the source or target proxy configuration
     * @param source  true if the handler should be added on the source side; false if the handler should be added to the target
     *                side
     * @param request true if the handler is a request handler; false if the handler is a response handler
     */
    public MockHandlerBuilder(MessageHandler handler, boolean source, boolean request) {
        this.handler = handler;
        this.source = source;
        this.request = request;
    }

    public void build(AssemblyObject modelObject) throws BuilderException {
        if (source) {
            if (!(modelObject instanceof ConfiguredReference)) {
                return;
            } else {
                ConfiguredReference cref = (ConfiguredReference) modelObject;
                // /xcv WireFactory pFactory = (WireFactory) cref.getProxyFactory();
                for (ConfiguredService configuredService : cref.getTargetConfiguredServices()) {
                    SourceWireFactory pFactory = (SourceWireFactory) configuredService.getProxyFactory();
                    for (InvocationConfiguration config : pFactory.getConfiguration().getInvocationConfigurations().values()) {
                        if (request) {
                            config.addRequestHandler(handler);
                        } else {
                            config.addResponseHandler(handler);
                        }
                    }
                }
            }
        } else {
            if (!(modelObject instanceof ConfiguredService)) {
                return;
            } else {
                ConfiguredService cservice = (ConfiguredService) modelObject;
                TargetWireFactory pFactory = (TargetWireFactory) cservice.getProxyFactory();
                for (InvocationConfiguration config : pFactory.getConfiguration().getInvocationConfigurations().values()) {
                    if (request) {
                        config.addRequestHandler(handler);
                    } else {
                        config.addResponseHandler(handler);
                    }
                }
            }

        }
    }

    public void build(ConfiguredReference reference, List<WireSourceConfiguration> configurations) throws BuilderException {
        for (WireSourceConfiguration wireSourceConfiguration : configurations) {
            for (SourceInvocationConfiguration configuration : wireSourceConfiguration.getInvocationConfigurations().values()) {
                if (request) {
                    configuration.addRequestHandler(handler);
                } else {
                    configuration.addResponseHandler(handler);
                }

            }

        }
    }

    public void build(ConfiguredService service, WireTargetConfiguration configuration) throws BuilderException {
        for (TargetInvocationConfiguration config : configuration.getInvocationConfigurations().values()) {
            if (request) {
                config.addRequestHandler(handler);
            } else {
                config.addResponseHandler(handler);
            }
        }
    }
}