SubscriberItemProvider.java

Go to the documentation of this file.

package org.ros.model.ros.provider;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;

import org.best_of_robotics.model.datatypes.DataType;
import org.best_of_robotics.model.datatypes.DatatypesFactory;
import org.eclipse.emf.common.notify.AdapterFactory;
import org.eclipse.emf.common.notify.Notification;

import org.eclipse.emf.common.util.ResourceLocator;

import org.eclipse.emf.edit.provider.ComposeableAdapterFactory;
import org.eclipse.emf.edit.provider.IEditingDomainItemProvider;
import org.eclipse.emf.edit.provider.IItemLabelProvider;
import org.eclipse.emf.edit.provider.IItemPropertyDescriptor;
import org.eclipse.emf.edit.provider.IItemPropertySource;
import org.eclipse.emf.edit.provider.IStructuredItemContentProvider;
import org.eclipse.emf.edit.provider.ITreeItemContentProvider;
import org.eclipse.emf.edit.provider.ItemPropertyDescriptor;
import org.eclipse.emf.edit.provider.ItemProviderAdapter;
import org.eclipse.emf.edit.provider.ViewerNotification;

import org.ros.model.ros.Publisher;
import org.ros.model.ros.RosPackage;
import org.ros.model.ros.Subscriber;

public class SubscriberItemProvider
        extends ItemProviderAdapter
        implements
                IEditingDomainItemProvider,
                IStructuredItemContentProvider,
                ITreeItemContentProvider,
                IItemLabelProvider,
                IItemPropertySource {
        public SubscriberItemProvider(AdapterFactory adapterFactory) {
                super(adapterFactory);
        }

        @Override
        public List<IItemPropertyDescriptor> getPropertyDescriptors(Object object) {
                if (itemPropertyDescriptors == null) {
                        super.getPropertyDescriptors(object);

                        addNamePropertyDescriptor(object);
                        addQueueSizePropertyDescriptor(object);
                        addEventHandlerPropertyDescriptor(object);
                        addMsgPropertyDescriptor(object);
                        addEventPortPropertyDescriptor(object);
                }
                return itemPropertyDescriptors;
        }

        protected void addNamePropertyDescriptor(Object object) {
                itemPropertyDescriptors.add
                        (createItemPropertyDescriptor
                                (((ComposeableAdapterFactory)adapterFactory).getRootAdapterFactory(),
                                 getResourceLocator(),
                                 getString("_UI_Subscriber_name_feature"),
                                 getString("_UI_PropertyDescriptor_description", "_UI_Subscriber_name_feature", "_UI_Subscriber_type"),
                                 RosPackage.Literals.SUBSCRIBER__NAME,
                                 true,
                                 false,
                                 false,
                                 ItemPropertyDescriptor.GENERIC_VALUE_IMAGE,
                                 null,
                                 null));
        }

        protected void addQueueSizePropertyDescriptor(Object object) {
                itemPropertyDescriptors.add
                        (createItemPropertyDescriptor
                                (((ComposeableAdapterFactory)adapterFactory).getRootAdapterFactory(),
                                 getResourceLocator(),
                                 getString("_UI_Subscriber_queueSize_feature"),
                                 getString("_UI_PropertyDescriptor_description", "_UI_Subscriber_queueSize_feature", "_UI_Subscriber_type"),
                                 RosPackage.Literals.SUBSCRIBER__QUEUE_SIZE,
                                 true,
                                 false,
                                 false,
                                 ItemPropertyDescriptor.INTEGRAL_VALUE_IMAGE,
                                 null,
                                 null));
        }

        protected void addEventHandlerPropertyDescriptor(Object object) {
                itemPropertyDescriptors.add
                        (createItemPropertyDescriptor
                                (((ComposeableAdapterFactory)adapterFactory).getRootAdapterFactory(),
                                 getResourceLocator(),
                                 getString("_UI_Subscriber_eventHandler_feature"),
                                 getString("_UI_PropertyDescriptor_description", "_UI_Subscriber_eventHandler_feature", "_UI_Subscriber_type"),
                                 RosPackage.Literals.SUBSCRIBER__EVENT_HANDLER,
                                 true,
                                 false,
                                 false,
                                 ItemPropertyDescriptor.GENERIC_VALUE_IMAGE,
                                 null,
                                 null));
        }

        protected void addMsgPropertyDescriptor(Object object) {
                itemPropertyDescriptors.add
                        (new ItemPropertyDescriptor
                                (((ComposeableAdapterFactory)adapterFactory).getRootAdapterFactory(),
                                 getResourceLocator(),
                                 getString("_UI_Subscriber_msg_feature"),
                                 getString("_UI_PropertyDescriptor_description", "_UI_Subscriber_msg_feature", "_UI_Subscriber_type"),
                                 RosPackage.Literals.SUBSCRIBER__MSG,
                                 true,
                                 false,
                                 false,
                                 ItemPropertyDescriptor.GENERIC_VALUE_IMAGE,
                                 null,
                                 null){
                                @Override
                                public Collection<?> getChoiceOfValues(Object object) {
                                        Subscriber subscriber = (Subscriber) object;
                                        org.ros.model.ros.Package pack = (org.ros.model.ros.Package) subscriber.eContainer().eContainer();
                                        System.out.println(pack.getName());
                                        
                                        DataType test = DatatypesFactory.eINSTANCE.createSimpleType();
                                                                
                                        List<String> strings = new ArrayList<String>(); // Copy the students to a temporary list
                                        for (String item: pack.getDepend()) {
                                                String cmd = "rosmsg package " + item;
                                                Runtime run = Runtime.getRuntime();
                                                Process pr;
                                                try {
                                                        pr = run.exec(cmd);
                                                        pr.waitFor();
                                                        BufferedReader buf = new BufferedReader(new InputStreamReader(pr.getInputStream()));
                                                        String line = "";
                                                        while ((line=buf.readLine())!=null) {
                                                                strings.add(line.replace("/", "::"));
                                                        }
                                                } catch (IOException e) {
                                                        // TODO Auto-generated catch block
                                                        e.printStackTrace();
                                                } catch (InterruptedException e) {
                                                        // TODO Auto-generated catch block
                                                        e.printStackTrace();
                                                }
                                                //strings.add(item);
                                        }
                                        return strings;
                                }
                                });
        }

        protected void addEventPortPropertyDescriptor(Object object) {
                itemPropertyDescriptors.add
                        (createItemPropertyDescriptor
                                (((ComposeableAdapterFactory)adapterFactory).getRootAdapterFactory(),
                                 getResourceLocator(),
                                 getString("_UI_Subscriber_eventPort_feature"),
                                 getString("_UI_PropertyDescriptor_description", "_UI_Subscriber_eventPort_feature", "_UI_Subscriber_type"),
                                 RosPackage.Literals.SUBSCRIBER__EVENT_PORT,
                                 true,
                                 false,
                                 false,
                                 ItemPropertyDescriptor.BOOLEAN_VALUE_IMAGE,
                                 null,
                                 null));
        }

        @Override
        public Object getImage(Object object) {
                return overlayImage(object, getResourceLocator().getImage("full/obj16/Subscriber"));
        }

        @Override
        public String getText(Object object) {
                String label = ((Subscriber)object).getName();
                return label == null || label.length() == 0 ?
                        getString("_UI_Subscriber_type") :
                        getString("_UI_Subscriber_type") + " " + label;
        }

        @Override
        public void notifyChanged(Notification notification) {
                updateChildren(notification);

                switch (notification.getFeatureID(Subscriber.class)) {
                        case RosPackage.SUBSCRIBER__NAME:
                        case RosPackage.SUBSCRIBER__QUEUE_SIZE:
                        case RosPackage.SUBSCRIBER__EVENT_HANDLER:
                        case RosPackage.SUBSCRIBER__MSG:
                        case RosPackage.SUBSCRIBER__EVENT_PORT:
                                fireNotifyChanged(new ViewerNotification(notification, notification.getNotifier(), false, true));
                                return;
                }
                super.notifyChanged(notification);
        }

        @Override
        protected void collectNewChildDescriptors(Collection<Object> newChildDescriptors, Object object) {
                super.collectNewChildDescriptors(newChildDescriptors, object);
        }

        @Override
        public ResourceLocator getResourceLocator() {
                return RosEditPlugin.INSTANCE;
        }

}