/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package gov.hhs.fha.nhinc.hiemsubscription;

import gov.hhs.fha.nhinc.nhinclib.NullChecker;
import gov.hhs.fha.nhinc.nhincsubscription.NhincNotificationProducerService;
import gov.hhs.fha.nhinc.nhincsubscription.NotificationProducer;
import gov.hhs.fha.nhinc.saml.extraction.SamlTokenExtractorHelper;
import gov.hhs.fha.nhinc.common.nhinccommoninternalorch.SubscribeRequestType;
import gov.hhs.fha.nhinc.saml.extraction.SamlTokenExtractor;
import javax.xml.ws.WebServiceContext;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.oasis_open.docs.wsn.b_2.Subscribe;
import org.oasis_open.docs.wsn.b_2.SubscribeResponse;

/**
 *
 * @author jhoppesc
 */
public class HiemSubscriptionImpl {

    private static Log log = LogFactory.getLog(HiemSubscriptionImpl.class);

    public static SubscribeResponse subscribe(Subscribe subscribeRequest, WebServiceContext context) {
        log.debug("Entering HiemSubscriptionImpl.subscribe");
        
        SubscribeResponse resp = new SubscribeResponse();
        SubscribeRequestType request = new SubscribeRequestType();
        
        request.setSubscribe(subscribeRequest);
        request.setAssertion(SamlTokenExtractor.GetAssertion(context));
        
        
        String homeCommunityId = SamlTokenExtractorHelper.getHomeCommunityId();

        if (NullChecker.isNotNullish(homeCommunityId)) {
           NhincNotificationProducerService service = new NhincNotificationProducerService();
           NotificationProducer port = service.getNotificationProducerPort();
           ((javax.xml.ws.BindingProvider) port).getRequestContext().put(javax.xml.ws.BindingProvider.ENDPOINT_ADDRESS_PROPERTY, SamlTokenExtractorHelper.getEndpointURL(homeCommunityId, SamlTokenExtractorHelper.INTERNAL_HIEM_SUBSCRIBE));
        
           try {
               resp = port.subscribe(request);
           } catch (Exception e) {
               log.error("Received Fault: " + e.getMessage());
               resp = null;
           }
        }
        else {
            resp = null;
        }      

        log.debug("Exiting HiemSubscriptionImpl.subscribe");
        return resp;
    }
}