/*
 * Copyright  1999-2004 The Apache Software Foundation.
 *
 *  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.savan.subscription;

import org.apache.axiom.soap.SOAPEnvelope;
import org.apache.axis2.context.ServiceContext;
import org.apache.savan.SavanException;
import org.apache.savan.SavanMessageContext;
import org.apache.savan.publication.client.PublicationClient;
import org.apache.savan.storage.SubscriberStore;
import org.apache.savan.subscribers.Subscriber;
import org.apache.savan.util.CommonUtil;

/**
 * Abstractly defines subscription methods.
 * Each protocol may extend this to add its own work.
 */
public abstract class SubscriptionProcessor {
	
	public abstract void init (SavanMessageContext smc) throws SavanException;
	
	public void unsubscribe(SavanMessageContext endSubscriptionMessage)  throws SavanException {
		String subscriberID = getSubscriberID (endSubscriptionMessage);
		if (subscriberID==null) {
			String message = "Cannot find the subscriber ID";
			throw new SavanException (message);
		}
		
		SubscriberStore store = endSubscriptionMessage.getSubscriberStore();
		if (store==null)
			throw new SavanException ("AbstractSubscriber store not found");
		
		store.delete (subscriberID);
	}

	public void renewSubscription(SavanMessageContext renewMessage)  throws SavanException {
		SubscriberStore store = renewMessage.getSubscriberStore();
		if (store==null)
			throw new SavanException ("AbstractSubscriber store not found");
			
		ExpirationBean bean = getExpirationBean(renewMessage);
		Subscriber subscriber = (Subscriber) store.retrieve(bean.getSubscriberID());
		if (subscriber==null) {
			throw new SavanException ("Given subscriber is not present");
		}
		
		subscriber.renewSubscription(bean);
	}

	public void subscribe(SavanMessageContext subscriptionMessage) throws SavanException {
		SubscriberStore store = subscriptionMessage.getSubscriberStore();
		if (store==null)
			throw new SavanException ("AbstractSubscriber store not found");
			
		if (store==null)
			throw new SavanException ("Sabscriber store not found");
		
		Subscriber subscriber = getSubscriberFromMessage (subscriptionMessage);
		store.store (subscriber);
	}
	
	public void endSubscription(String subscriberID,String reason,ServiceContext serviceContext)  throws SavanException {
		
		SubscriberStore store =CommonUtil.getSubscriberStore(serviceContext.getAxisService());
		if (store==null) {
			//TODO do something
		}
		
		Subscriber subscriber = store.retrieve(subscriberID);
//		doProtocolSpecificEndSubscription(subscriber,reason,serviceContext.getConfigurationContext());
		
		store.delete(subscriberID);
	}
	
	public void publish(SavanMessageContext publishMessage) throws SavanException{
		//TODO handle Topics
		SOAPEnvelope requestEnvelope = publishMessage.getEnvelope();
		ServiceContext serviceContext = publishMessage.getMessageContext().getServiceContext();
		PublicationClient client = new PublicationClient(serviceContext.getConfigurationContext());
		client.sendPublication(requestEnvelope.getBody().getFirstElement(),serviceContext.getAxisService(),null);
	}
	
	
	
	public abstract void pauseSubscription (SavanMessageContext pauseSubscriptionMessage) throws SavanException;
	
	public abstract void resumeSubscription (SavanMessageContext resumeSubscriptionMessage) throws SavanException;
	
	public abstract Subscriber getSubscriberFromMessage (SavanMessageContext smc) throws SavanException;
	
	public abstract ExpirationBean getExpirationBean (SavanMessageContext renewMessage) throws SavanException;
	
	public abstract String getSubscriberID (SavanMessageContext smc) throws SavanException;
	

}