package supplychain.client;


import java.io.File;
import java.net.URL;
import java.util.Hashtable;


import org.apache.tuscany.sca.assembly.Composite;
import org.apache.tuscany.sca.contribution.Contribution;
import org.apache.tuscany.sca.contribution.service.ContributionService;
import org.apache.tuscany.sca.host.embedded.impl.EmbeddedSCADomain;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;



import supplychain.customer.Customer;

/**
 * SupplyChain test client
 */
public class SupplyChainClient implements BundleActivator {

    private EmbeddedSCADomain scaDomain;
    private Customer customer;
    
    

    public void start(BundleContext context) throws Exception {
        
        context.registerService(SupplyChainClient.class.getName(), this, new Hashtable());
        
    }

    public void stop(BundleContext context) throws Exception {
        
    }

    protected void setUp(String contributionJarName) throws Exception {
        
        scaDomain = new EmbeddedSCADomain(EmbeddedSCADomain.class.getClassLoader(), "http://localhost");
        scaDomain.start();
        ContributionService contributionService = scaDomain.getContributionService();
        String folderName = "../test-bundles/target/"; 
        String supplychainJarName = contributionJarName;
        URL supplyChainURL = new File(folderName + supplychainJarName).toURI().toURL();
        
        Contribution contribution = contributionService.contribute("SupplyChain", supplyChainURL, false);
        for (Composite deployable : contribution.getDeployables() ) {
            scaDomain.getDomainComposite().getIncludes().add(deployable);
            scaDomain.buildComposite(deployable);
        }
        
        for (Composite deployable : contribution.getDeployables() ) {
            scaDomain.getCompositeActivator().activate(deployable);
            scaDomain.getCompositeActivator().start(deployable);
        }
        customer = scaDomain.getService(Customer.class, "CustomerComponent");
    }
    
    protected void tearDown() throws Exception {
        if (scaDomain != null) {
            scaDomain.close();
            scaDomain = null;
        }
    }


    public void runTest(String contributionJarName) throws Exception {
        
        try {
            setUp(contributionJarName);
            customer.purchaseGoods();
            int retries = 10;
            int outstandingCount = 1;
            while (retries-- > 0) {

                outstandingCount = customer.outstandingOrderCount();
                if (outstandingCount == 0)
                    break;
                else
                    Thread.sleep(100);
            }
            if (outstandingCount != 0)
                throw new RuntimeException("Orders not processed on time");
            
        } finally {
            
            tearDown();
        }    
        
        
    }
    
    
}