/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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.sca.itest.conversational.impl;

import org.apache.tuscany.sca.itest.conversational.ConversationalClient;
import org.apache.tuscany.sca.itest.conversational.ConversationalReferenceClient;
import org.apache.tuscany.sca.itest.conversational.ConversationalService;
import org.apache.tuscany.sca.itest.conversational.ConversationalServiceNonConversationalCallback;
import org.apache.tuscany.sca.itest.conversational.NonConversationalCallback;
import org.oasisopen.sca.ComponentContext;
import org.oasisopen.sca.ServiceReference;
import org.oasisopen.sca.annotation.Context;
import org.oasisopen.sca.annotation.ConversationAttributes;
import org.oasisopen.sca.annotation.Destroy;
import org.oasisopen.sca.annotation.Init;
import org.oasisopen.sca.annotation.Reference;
import org.oasisopen.sca.annotation.Scope;
import org.oasisopen.sca.annotation.Service;

/**
 * The client for the conversational itest which presents a stateful
 * callback interface
 *
 * @version $Rev: 537240 $ $Date: 2007-05-11 18:35:03 +0100 (Fri, 11 May 2007) $
 */

@Service(interfaces = {ConversationalClient.class})
@Scope("CONVERSATION")
@ConversationAttributes(maxAge = "10 minutes", maxIdleTime = "5 minutes", singlePrincipal = false)
public class ConversationalClientStatefulNonConversationalCallbackImpl implements ConversationalClient,
    NonConversationalCallback {

    @Context
    protected ComponentContext componentContext;

    @Reference
    protected ConversationalServiceNonConversationalCallback conversationalService;

    @Reference
    protected ConversationalServiceNonConversationalCallback conversationalService2;

    @Reference
    protected ConversationalReferenceClient conversationalReferenceClient;

    private int clientCount = 0;
    private int callbackCount = 0;

    // a static member variable that records the number of times this service is called
    public static StringBuffer calls = new StringBuffer();

    // From ConversationalClient
    public int runConversationFromInjectedReference() {
        calls.append("runConversationFromInjectedReference,");
        conversationalService.initializeCount(1);
        conversationalService.incrementCount();
        clientCount = conversationalService.retrieveCount();
        conversationalService.endConversation();

        return clientCount;
    }

    public int runConversationFromInjectedReference2() {
        calls.append("runConversationFromInjectedReference2,");

        conversationalService2.initializeCount(1);
        conversationalService2.incrementCount();

        // stick in a call to the first reference to
        // make sure the two references don't clash
        conversationalService.initializeCount(1);

        clientCount = conversationalService2.retrieveCount();
        conversationalService2.endConversation();

        // end the conversation through the first reference
        conversationalService.endConversation();

        return clientCount;
    }

    public int runConversationFromServiceReference() {
        calls.append("runConversationFromServiceReference,");
        ServiceReference<ConversationalService> serviceReference =
            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
        ConversationalService callableReference = serviceReference.getService();

        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();

        // serviceReference.getConversation().end();

        return clientCount;
    }

    public int runConversationWithUserDefinedConversationId() {
        calls.append("runConversationWithUserDefinedConversationId,");
        ServiceReference<ConversationalService> serviceReference =
            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
        serviceReference.setConversationID("MyConversation1");

        ConversationalService callableReference = serviceReference.getService();

        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();

        // serviceReference.getConversation().end();

        return clientCount;
    }

    public String runConversationCheckUserDefinedConversationId() {
        calls.append("runConversationCheckUserDefinedConversationId,");
        ServiceReference<ConversationalService> serviceReference =
            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
        serviceReference.setConversationID("MyConversation2");

        ConversationalService callableReference = serviceReference.getService();

        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        return callableReference.endConversation();

    }

    public int runConversationCheckingScope() {
        calls.append("runConversationCheckingScope,");
        // run a conversation
        return runConversationFromInjectedReference();

        // test will then use a static method to find out how many times
        // init/destroy were called
    }

    public int runConversationWithCallback() {
        calls.append("runConversationWithCallback,");
        callbackCount = 2;
        conversationalService.initializeCountCallback(1);
        conversationalService.incrementCountCallback();
        clientCount = conversationalService.retrieveCountCallback();
        conversationalService.endConversationCallback();

        return clientCount;
    }

    public int runConversationHavingPassedReference() {
        calls.append("runConversationHavingPassedReference,");
        ServiceReference<ConversationalService> serviceReference =
            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
        ConversationalService callableReference = serviceReference.getService();

        callableReference.initializeCount(1);
        callableReference.incrementCount();
        conversationalReferenceClient.incrementCount(serviceReference);
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();

        // serviceReference.getConversation().end();

        return clientCount;
    }

    public String runConversationBusinessException() {
        calls.append("runConversationbusinessException,");
        try {
            conversationalService.initializeCount(1);
            conversationalService.businessException();
            clientCount = conversationalService.retrieveCount();
            conversationalService.endConversation();
        } catch (Exception ex) {
            return ex.getMessage();
        }

        return "No Exception Returned";
    }

    public String runConversationBusinessExceptionCallback() {
        calls.append("runConversationbusinessExceptionCallback,");
        try {
            conversationalService.initializeCountCallback(1);
            conversationalService.businessExceptionCallback();
            clientCount = conversationalService.retrieveCountCallback();
            conversationalService.endConversationCallback();
        } catch (Exception ex) {
            return ex.getMessage();
        }

        return "No Exception Returned";
    }

    public String runConversationCallingEndedConversationCheckConversationId() {
        calls.append("runConversationCallingEndedConversationCheckConversationId,");
        ServiceReference<ConversationalService> serviceReference =
            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
        serviceReference.setConversationID("MyConversation3");

        ConversationalService callableReference = serviceReference.getService();

        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        callableReference.endConversation();

        if (serviceReference.getConversation() == null) {
            return null;
        } else {
            return serviceReference.getConversation().getConversationID().toString();
        }
    }

    public String runConversationCallingEndedConversationCallbackCheckConversationId() {
        calls.append("runConversationCallingEndedConversationCallbackCheckConversationId,");
        ServiceReference<ConversationalService> serviceReference =
            componentContext.getServiceReference(ConversationalService.class, "conversationalService");
        serviceReference.setConversationID("MyConversation3");

        ConversationalService callableReference = serviceReference.getService();

        callableReference.initializeCount(1);
        callableReference.incrementCount();
        clientCount = callableReference.retrieveCount();
        callableReference.endConversationCallback();

        if (serviceReference.getConversation() == null) {
            return null;
        } else {
            return serviceReference.getConversation().getConversationID().toString();
        }
    }

    public int runConversationCallingEndedConversation() {
        calls.append("runConversationCallingEndedConversation,");
        conversationalService.initializeCount(1);
        conversationalService.endConversation();
        return conversationalService.retrieveCount();
    }

    public int runConversationCallingEndedConversationCallback() {
        calls.append("runConversationCallingEndedConversationCallback,");
        conversationalService.initializeCountCallback(1);
        conversationalService.endConversationCallback();
        return conversationalService.retrieveCountCallback();
    }

    public int runConversationAgeTimeout() {
        calls.append("runConversationAgeTimeout,");
        // done in other testing
        return clientCount;
    }

    public int runConversationIdleTimeout() {
        calls.append("runConversationIdleTimeout,");
        // done in other testing
        return clientCount;
    }

    public int runConversationPrincipleError() {
        calls.append("runConversationPrincipleError,");
        // TODO - when policy framework is done
        return clientCount;
    }

    // From ConversationalCallback
    @Init
    public void init() {
        calls.append("init,");
    }

    @Destroy
    public void destroy() {
        calls.append("destroy,");
    }

    public void initializeCount(int count) {
        calls.append("initializeCount,");
        callbackCount += count;
    }

    public void incrementCount() {
        calls.append("incrementCount,");
        callbackCount++;
    }

    public int retrieveCount() {
        calls.append("retrieveCount,");
        return callbackCount;
    }

    public void businessException() throws Exception {
        throw new Exception("Business Exception");
    }

    public String endConversation() {
        calls.append("endConversation,");
        return null;
    }

}