platform/sensinact-generic/extra-src/test/java/org/eclipse/sensinact/gateway/generic/test/moke/Activator.java

/*
* Copyright (c) 2020 Kentyou.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
*    Kentyou - initial API and implementation
 */
package org.eclipse.sensinact.gateway.generic.test.moke;

import org.eclipse.sensinact.gateway.common.bundle.AbstractActivator;
import org.eclipse.sensinact.gateway.common.bundle.Mediator;
import org.eclipse.sensinact.gateway.core.SensiNactResourceModelConfiguration.BuildPolicy;
import org.eclipse.sensinact.gateway.generic.ExtModelConfiguration;
import org.eclipse.sensinact.gateway.generic.ExtModelConfigurationBuilder;
import org.eclipse.sensinact.gateway.generic.ExtModelInstance;
import org.eclipse.sensinact.gateway.generic.ExtModelInstanceBuilder;
import org.eclipse.sensinact.gateway.generic.test.moke.MokePacket;
import org.eclipse.sensinact.gateway.test.ProcessorService;
import org.eclipse.sensinact.gateway.test.StarterService;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceRegistration;

import java.net.URL;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Properties;

public class Activator extends AbstractActivator<Mediator> {
    private ExtModelConfiguration manager;
    private MokeStack endpoint;
    private ServiceRegistration starterRegistration;
    private ServiceRegistration processorRegistration;

    @Override
    public void doStart() throws Exception {
        Properties props = new Properties();
        URL url = super.mediator.getContext().getBundle().getResource("props.xml");
        props.loadFromXML(url.openStream());
        String startAtInitTime = (String) props.remove("startAtInitializationTime");
        boolean startAtInitializationTime = startAtInitTime == null ? false : Boolean.parseBoolean(startAtInitTime);
        Map<String, String> defaults = new HashMap<String, String>();
        Iterator<Object> iterator = props.keySet().iterator();

        while (iterator.hasNext()) {
            String key = (String) iterator.next();
            defaults.put(key, props.getProperty(key));
        }

    	this.manager = new ExtModelConfigurationBuilder(super.mediator, 
    			ExtModelConfiguration.class, 
    			ExtModelInstance.class, 
    			MokePacket.class
    		).withDesynchronization(false
    		).withStartAtInitializationTime(startAtInitializationTime
    		).build("resources.xml", defaults);

    	
        this.endpoint = new MokeStack(mediator);
        this.endpoint.connect(this.manager);

        MokeStarter starter = new MokeStarter(this.endpoint.getConnector());
        this.starterRegistration = super.mediator.getContext().registerService(StarterService.class, starter, null);

        MokeProcessor processor = new MokeProcessor(super.mediator, this.endpoint.getConnector());

        this.processorRegistration = super.mediator.getContext().registerService(ProcessorService.class, processor, null);
    }

    @Override
    public void doStop() throws Exception {
        if (this.starterRegistration != null) {
            try {
                this.starterRegistration.unregister();

            } catch (IllegalStateException e) {
            }
            this.starterRegistration = null;
        }
        if (this.processorRegistration != null) {
            try {
                this.processorRegistration.unregister();

            } catch (IllegalStateException e) {
            }
            this.processorRegistration = null;
        }
    }

    @Override
    public Mediator doInstantiate(BundleContext context) {
        return new Mediator(context);
    }
}