package com.ibm.globus.services.mds;

import org.globus.mds.*;
import java.util.Hashtable;
import java.util.Enumeration;

/**
 * A Java Class to query information from the Globus MDS service
 */

public class MDSService {
  // Default MDS server parameters. Change to fit your Global MDS server 
  values
  private final String _MDS_SERVER = "global-pool-giis.intragrid.ibm.com";
  private final String _MDS_BASE_DN = "Mds-Vo-name=POOL-CONTACT,o=grid";

  // Our Grid uses port 2135. Default globus MDS port is 391
  private final String _MDS_PORT = "2135";
  private MDS _mds = null;
  
  /**
  * Constructors
  * @param _MDS_SERVER LDAP Host
  * @param _MDS_PORT LDAP port
  * @param _MDS_BASE_DN LDAP search Dn (Distinguished name)
  */
  
  public MDSService() {
    _mds = new MDS(_MDS_SERVER, _MDS_PORT, _MDS_BASE_DN);
  }
  public MDSService(String host, String port, String baseDN) {
    _mds = new MDS(host, port, baseDN);
  }

                    
  /**
  * This method performs the actual MDS search.
  * @param filter search filter to be used. Ex: (objectClass=*)
  */
  
  public String HostInfoLookup(String filter) {
  try {
    // Attributes to be returned by the search
    String[] attribs = null;
    _mds.connect();

    // The MDS pkg returns a Multi-valued hashtable
    Hashtable t = _mds.search(filter, attribs, _mds.SUBTREE_SCOPE);
    _mds.disconnect();
    return "<mds>\n" + buildStatusXML(false, this.getClass() 
    + "HostLookup","ok") + 
      "\n<data>\n" + ht2XML(t) + "</data>\n</mds>";
  }
  catch (Exception ex) {
    ex.printStackTrace();
    return "<mds>" + buildStatusXML(true, this.getClass().getName(), 
    ex.getMessage()) + "</mds>";
  }
}
  
          
  /*
  * Return xml is composed by a status tag
  */
  
  private String buildStatusXML(boolean bError, String source, String desc){
  String XML = "<status>\n\t" +
    "<error>" + bError + "</error>\n\t<source>" + source 
    + "</source>\n\t" +
    "<desc>" + desc + "</desc>\n</status>";
  return XML;
}
  
          
  /**
  * Convert an MDS Search HashTable (Multi-valued) to XML
  */
  
  private String ht2XML(Hashtable t) throws Exception  {
    Enumeration e = t.elements();
    MDSResult mvRecord = null; // result is a multi-val hash table
    String dn = "";                     // ht key is a dn
    StringBuffer xml = new StringBuffer();

    // sweep HT keys translating to XML
    for (Enumeration dnEnum = t.keys() ; dnEnum.hasMoreElements() ; ){
      mvRecord = (MDSResult)e.nextElement();
      dn = (String)dnEnum.nextElement();

      if ( mvRecord.size() > 0 ) {
        xml.append("\t<record dn=\"" 
        + dn.replace('"',' ').trim()
         + "\">\n\t");
        Enumeration recKeys = mvRecord.keys();
        String sKey = "";
        for (int i = 0; i < mvRecord.size(); i++) {
          sKey = (String)recKeys.nextElement();
          xml.append("\t<" + sKey + ">" 
          + mvRecord.getValueAt(sKey,0) 
          + "</" + sKey + ">\n\t");
        }
        xml.append("</record>\n");
      }
    }
    return xml.toString();
  }

        

                
  /**
  *
  */
  
  public static void main(String[] args) {
    String baseDN = "Mds-Vo-name=AKgrid,o=grid";
    String host = "mdev1.raleigh.ibm.com";

    // Querying a GRIS machine with our grid
    MDSService mds = new MDSService(host,"2135", baseDN);
    String xml = mds.HostInfoLookup("(objectclass=*)");
    System.out.println("GRIS output\n" + xml);

    // Querying the global GIIS of our grid
    MDSService mds1 = new MDSService();
    mds1.HostInfoLookup("(objectclass=*)");
    System.out.println("GIIS output\n" + xml);
  }
}

      

MDS output
<mds>
<status>
  <error>false</error>
  <source>class com.ibm.globus.services.mds.MDSServiceHostLookup</source>  <desc>ok</desc>
</status>
<data>
  <record dn="Mds-Device-name=/usr,Mds-Device-Group-name=filesystems,
  Mds-Host-hn=mdev1.raleigh.ibm.com , Mds-Vo-name=AKgrid,o=grid">
    <objectClass>MdsDevice</objectClass>
    <Mds-Device-name>/usr</Mds-Device-name>
    <Mds-keepto>20030212112509Z</Mds-keepto>
    <Mds-validto>20030212112509Z</Mds-validto>
    <Mds-Fs-freeMB>15592</Mds-Fs-freeMB>
    <Mds-validfrom>20030212111009Z</Mds-validfrom>
    <Mds-Fs-sizeMB>17078</Mds-Fs-sizeMB>
    <Mds-Fs-mount>/usr</Mds-Fs-mount>
  </record>
  <record dn="Mds-Device-name=eth0,Mds-Device-Group-name=networks,
  Mds-Host-hn=mdev6.raleigh.ibm.com, Mds-Vo-name=AKgrid,o=grid">
    <objectClass>MdsDevice</objectClass>
    <Mds-Device-name>eth0</Mds-Device-name>
    <Mds-Net-addr>10.30.10.15</Mds-Net-addr>
    <Mds-keepto>20030212151853Z</Mds-keepto>
    <Mds-Net-netaddr>10.30.0.0/16</Mds-Net-netaddr>
    <Mds-validto>20030212151853Z</Mds-validto>
    <Mds-Net-name>eth0</Mds-Net-name>
   <Mds-validfrom>20030212150353Z</Mds-validfrom>
  </record>
</data>
</mds>

GIIS output
<mds>
<status>
  <error>false</error>
  <source>class com.ibm.globus.services.mds.MDSServiceHostLookup</source>
  <desc>ok</desc>
</status>
<data>
  <record dn="Pool-info=ISE Server System Grid Computing - hyperion, 
  Mds-Vo-name=POOL-CONTACT,o=grid">
    <intraGrid-Pool-name>ISE Server System Grid Computing - hyperion
    </intraGrid-Pool-name>
    <Mds-Host-hn>hyperion.fscjapan.ibm.com</Mds-Host-hn>
    <objectClass>intraGrid</objectClass>
    <intraGrid-Pool-administrator>trent@jp.ibm.com
    </intraGrid-Pool-administrator>
    <Mds-Vo-name>ISE Server System Grid Computing - hyperion</Mds-Vo-name>
    <Mds-Service-Ldap-suffix>Mds-Vo-name=ISE Server System Grid Computing - 
    hyperion, o=grid</Mds-Service-Ldap-suffix>
    <intraGrid-Pool-localGIIS>hyperion.fscjapan.ibm.com
    </intraGrid-Pool-localGIIS>
    <Mds-Service-port>2135</Mds-Service-port>
    <intraGrid-Geo-location>CHIBA CITY-CHIBA, 12, Japan (140.11,35.59)
    </intraGrid-Geo-location>
  </record>
</data>
</mds>