/**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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.apache.oodt.cas.webcomponents.filemgr;

import java.net.URL;
import java.util.List;
import java.util.Vector;
import java.util.logging.Level;
import java.util.logging.Logger;

import org.apache.oodt.cas.filemgr.metadata.CoreMetKeys;
import org.apache.oodt.cas.filemgr.structs.Element;
import org.apache.oodt.cas.filemgr.structs.Product;
import org.apache.oodt.cas.filemgr.structs.ProductType;
import org.apache.oodt.cas.filemgr.structs.Reference;
import org.apache.oodt.cas.filemgr.structs.exceptions.CatalogException;
import org.apache.oodt.cas.filemgr.structs.exceptions.RepositoryManagerException;
import org.apache.oodt.cas.filemgr.system.XmlRpcFileManagerClient;
import org.apache.oodt.cas.metadata.Metadata;

/**
 * 
 * Describe your class here.
 * 
 * @author mattmann
 * @version $Revision$
 * 
 */
public class FileManagerConn {

  private XmlRpcFileManagerClient fm;

  private static final Logger LOG = Logger.getLogger(FileManagerConn.class
      .getName());

  public FileManagerConn(String fmUrlStr) {
    this.initFm(fmUrlStr);
  }

  public String getProdReceivedTime(Product p) {
    Metadata met = getMetadata(p);
    String prodReceivedTime = met.getMetadata("CAS."
        + CoreMetKeys.PRODUCT_RECEVIED_TIME);
    return prodReceivedTime != null && !prodReceivedTime.equals("") ? prodReceivedTime
        : "UNKNOWN";
  }

  public List<Reference> getProductReferences(Product p) {
    List<Reference> refs = new Vector<Reference>();
    try {
      refs = fm.getProductReferences(p);
    } catch (Exception e) {
      LOG.log(Level.WARNING, "Unable to get references for product: ["
          + p.getProductName() + "]: Reason: " + e.getMessage());
    }

    return refs;
  }

  public ProductType safeGetProductTypeByName(String name) {
    try {
      return fm.getProductTypeByName(name);
    } catch (Exception e) {
      LOG.log(Level.WARNING, "Unable to get product type by name: [" + name
          + "]: Message: " + e.getMessage());
      return null;
    }
  }

  public Product safeGetProductById(String id) {
    try {
      return fm.getProductById(id);
    } catch (Exception e) {
      LOG.log(Level.WARNING, "Unable to get product by id: [" + id
          + "]: Message: " + e.getMessage());
      return null;
    }
  }

  public Metadata getMetadata(Product p) {
    Metadata met = null;
    try {
      met = fm.getMetadata(p);
    } catch (CatalogException e) {
      LOG.log(Level.WARNING,
          "Unable to get metadata and display product received time for: ["
              + p.getProductName() + "]: Reason: " + e.getMessage());
    }

    return met;
  }

  public List<Element> safeGetElementsForProductType(ProductType type) {
    try {
      return fm.getElementsByProductType(type);
    } catch (Exception e) {
      LOG.log(Level.WARNING, "Unable to obtain elements for product type: ["
          + type.getName() + "]: Reason: " + e.getMessage());
      return new Vector<Element>();
    }
  }

  public List<ProductType> safeGetProductTypes() {
    List<ProductType> types = new Vector<ProductType>();
    try {
      types = this.fm.getProductTypes();
    } catch (RepositoryManagerException e) {
      e.printStackTrace();
      LOG.log(Level.WARNING, "Unable to obtain product types: Reason: ["
          + e.getMessage() + "]");
    }
    return types;
  }

  public XmlRpcFileManagerClient getFm() {
    return this.fm;
  }

  public void initFm(String urlStr) {
    try {
      this.fm = new XmlRpcFileManagerClient(new URL(urlStr));
    } catch (Exception e) {
      LOG.log(Level.WARNING, "Unable to connect to the file manager at: ["
          + urlStr + "]");
      this.fm = null;
    }
  }

}