MessageDefinitionFileProvider.java

Go to the documentation of this file.

/*
 * Copyright (C) 2011 Google Inc.
 * 
 * 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.ros.internal.message.definition;

import com.google.common.collect.Maps;

import org.ros.internal.message.StringFileProvider;

import org.apache.commons.io.FilenameUtils;
import org.ros.message.MessageDefinitionProvider;
import org.ros.message.MessageIdentifier;

import java.io.File;
import java.util.Collection;
import java.util.HashSet;
import java.util.Map;
import java.util.Map.Entry;

public class MessageDefinitionFileProvider implements MessageDefinitionProvider {

  private final StringFileProvider stringFileProvider;
  private final Map<String, Collection<MessageIdentifier>> messageIdentifiers;
  private final Map<String, String> definitions;

  public MessageDefinitionFileProvider(StringFileProvider stringFileProvider) {
    this.stringFileProvider = stringFileProvider;
    messageIdentifiers = Maps.newConcurrentMap();
    definitions = Maps.newConcurrentMap();
  }

  private static String getParent(String filename) {
    return FilenameUtils.getFullPathNoEndSeparator(filename);
  }

  protected static String getParentBaseName(String filename) {
    return FilenameUtils.getBaseName(getParent(filename));
  }

  private static MessageIdentifier fileToMessageIdentifier(File file) {
    String filename = file.getAbsolutePath();
    String name = FilenameUtils.getBaseName(filename);
    String pkg = getParentBaseName(getParent(filename));
    return MessageIdentifier.of(pkg, name);
  }

  private void addDefinition(File file, String definition) {
    MessageIdentifier topicType = fileToMessageIdentifier(file);
    if (definitions.containsKey(topicType.getType())) {
      // First definition wins.
      return;
    }
    definitions.put(topicType.getType(), definition);
    if (!messageIdentifiers.containsKey(topicType.getPackage())) {
      messageIdentifiers.put(topicType.getPackage(), new HashSet<MessageIdentifier>());
    }
    messageIdentifiers.get(topicType.getPackage()).add(topicType);
  }

  public void update() {
    stringFileProvider.update();
    for (Entry<File, String> entry : stringFileProvider.getStrings().entrySet()) {
      addDefinition(entry.getKey(), entry.getValue());
    }
  }

  public void addDirectory(File directory) {
    stringFileProvider.addDirectory(directory);
  }

  @Override
  public Collection<String> getPackages() {
    return messageIdentifiers.keySet();
  }

  @Override
  public Collection<MessageIdentifier> getMessageIdentifiersByPackage(String pkg) {
    return messageIdentifiers.get(pkg);
  }

  @Override
  public String get(String type) {
    return definitions.get(type);
  }

  @Override
  public boolean has(String type) {
    return definitions.containsKey(type);
  }
}