Metacat

/**

 *  '$RCSfile$'

 *  Copyright: 2000 Regents of the University of California and the

 *              National Center for Ecological Analysis and Synthesis

 *    Purpose: To test the MetaCatURL class by JUnit

 *    Authors: Jing Tao

 *

 *   '$Author: jones $'

 *     '$Date: 2006-11-10 11:30:36 -0800 (Fri, 10 Nov 2006) $'

 * '$Revision: 3080 $'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

package edu.ucsb.nceas.metacatnettest;

import edu.ucsb.nceas.metacat.*;

import edu.ucsb.nceas.morpho.framework.*;

import junit.framework.Test;

import junit.framework.TestCase;

import junit.framework.TestResult;

import junit.framework.TestSuite;

import java.io.*;

import java.net.*;

import java.util.*;

/**

 * A JUnit test for testing Step class processing

 */

public class MetaCatServletNetTest extends TestCase

{

  private String metacatURL=MetaCatUtil.getOption("junittesturl");

  private String serialNumber;

  /**

   * Constructor to build the test

   *

   * @param name the name of the test method

   */

  public MetaCatServletNetTest(String name)

  {

    super(name);

  }

 /**

   * Constructor to build the test

   *

   * @param name the name of the test method

   */

  public MetaCatServletNetTest(String name, String serial)

  {

    super(name);

    serialNumber=serial;

  }

  /**

   * Establish a testing framework by initializing appropriate objects

   */

  public void setUp()

 {

 }

  /**

   * Release any objects after tests are complete

   */

  public void tearDown()

  {

  }

  /**

   * Create a suite of tests to be run together

   */

  public static Test suite()

  {

    double number = 0;

    String serial = null;

    TestSuite suite = new TestSuite();

    suite.addTest(new MetaCatServletNetTest("initialize"));

    suite.addTest(new MetaCatServletNetTest("testLterReferralLogin"));

    suite.addTest(new MetaCatServletNetTest("testLterReferralLoginFail"));

    suite.addTest(new MetaCatServletNetTest("testPiscoReferralLogin"));

    suite.addTest(new MetaCatServletNetTest("testPiscoReferralLoginFail"));

    suite.addTest(new MetaCatServletNetTest("testNCEASLoginFail"));

    //Should put a login successfully at the end of login test

    //So insert or update can have cookie.

    suite.addTest(new MetaCatServletNetTest("testNCEASLogin"));

    //create random number for docid, so it can void repeat

    number = Math.random()*100000;

    serial = Integer.toString(((new Double(number)).intValue()));

    MetaCatUtil.debugMessage("serial: "+serial, 1);

    suite.addTest(new MetaCatServletNetTest("testInsertXMLDocument", serial));

    suite.addTest(new MetaCatServletNetTest("testReadXMLDocumentXMLFormat", 

                                                        serial));

    suite.addTest(new MetaCatServletNetTest("testUpdateXMLDocument",serial));    

    suite.addTest(new MetaCatServletNetTest("testReadXMLDocumentHTMLFormat", 

                                                        serial));

    suite.addTest(new MetaCatServletNetTest("testReadXMLDocumentZipFormat", 

                                                        serial));

    suite.addTest(new MetaCatServletNetTest("testDeleteXMLDocument",serial));

    //insert invalid xml document

    number = Math.random()*100000;

    serial = Integer.toString(((new Double(number)).intValue()));

    suite.addTest(new MetaCatServletNetTest("testInsertInvalidateXMLDocument",

                                                                  serial));    

    //insert non well formed document

    number = Math.random()*100000;

    serial = Integer.toString(((new Double(number)).intValue())); 

   suite.addTest(new MetaCatServletNetTest("testInsertNonWellFormedXMLDocument",

                                                            serial));

    //insert data file  

    number = Math.random()*100000;

    serial = Integer.toString(((new Double(number)).intValue()));

    suite.addTest(new MetaCatServletNetTest("testInertDataFile", serial));

    suite.addTest(new MetaCatServletNetTest("testLogOut"));                   

    return suite;

  }

  /**

   * Run an initial test that always passes to check that the test

   * harness is working.

   */

  public void initialize()

  {

    assertTrue(1 == 1);

  }

  /**

   * Test the login to neceas succesfully

   */

  public void testNCEASLogin()

  {

    String user="uid=john,o=NCEAS,dc=ecoinformatics,dc=org";

    String passwd="123456";

    assertTrue(logIn(user,passwd));

    //assertTrue( withProtocol.getProtocol().equals("http"));

  }

  /**

   * Test the login to neceas failed

   */

  public void testNCEASLoginFail()

  {

    String user="uid=john,o=NCEAS,dc=ecoinformatics,dc=org";

    String passwd="12345678";

    assertTrue(!logIn(user,passwd));

  }

  /**

   * Test the login to lter succesfully

   */

  public void testLterReferralLogin()

  {

    String user="uid=jtao,o=LTER,dc=ecoinformatics,dc=org";

    String passwd="qVyGpVeb";

    assertTrue(logIn(user,passwd));

  }

  /**

   * Test the login to lter failed

   */

  public void testLterReferralLoginFail()

  {

    String user="uid=jtao,o=LTER,dc=ecoinformatics,dc=org";

    String passwd="qVyGpveb";

    assertTrue(!logIn(user,passwd));

    //assertTrue( withProtocol.getProtocol().equals("http"));

  }

 /**

   * Test the login to pisco succesfully

   */

   public void testPiscoReferralLogin()

  {

    String user="uid=tao,o=PISCO,dc=ecoinformatics,dc=org";

    String passwd="purple";

    assertTrue(logIn(user,passwd));

    //assertTrue( withProtocol.getProtocol().equals("http"));

  }

 /**

   * Test the login to pisco failed

   */

  public void testPiscoReferralLoginFail()

  {

    String user="uid=tao,o=PISCO,dc=ecoinformatics,dc=org";

    String passwd="hello";

    assertTrue(!logIn(user,passwd));

    //assertTrue( withProtocol.getProtocol().equals("http"));

  }

 /**

   * Test insert a xml document successfully

   */

  public void testInsertXMLDocument()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"1";

    MetaCatUtil.debugMessage("insert docid: "+name, 20);

    String content="<?xml version=\"1.0\"?>"

                   +"<!DOCTYPE acl PUBLIC \"-//ecoinformatics.org//"

                   +"eml-access-2.0.0beta6//EN\" \"http://pine.nceas.ucsb."

                   +"edu:8080/tao/dtd/eml-access-2.0.0beta6.dtd\">"

                   +"<acl authSystem=\"knb\" order=\"allowFirst\">"

                   +"<identifier>"+name+"</identifier>"

                   +"<allow>"

             +"<principal>uid=john,o=NCEAS,dc=ecoinformatics,dc=org</principal>"

                   +"<permission>all</permission>"

                   +"</allow>"

                   +"<allow>"

                   +"<principal>public</principal>"

                   +"<permission>read</permission>"

                   +"</allow>"

                   +"</acl>";

     MetaCatUtil.debugMessage("xml document: "+content, 55);

     assertTrue(handleXMLDocument(content, name, "insert"));

  }

  /**

   * Test insert a invalidate xml document successfully

   * In the String, there is no <!Doctype ... Public/System/>

   */

  public void testInsertInvalidateXMLDocument()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"1";

    MetaCatUtil.debugMessage("insert docid: "+name, 20);

    String content="<?xml version=\"1.0\"?>"

                   +"<acl authSystem=\"knb\" order=\"allowFirst\">"

                   +"<identifier>"+name+"</identifier>"

                   +"<allow>"

             +"<principal>uid=john,o=NCEAS,dc=ecoinformatics,dc=org</principal>"

                   +"<permission>all</permission>"

                   +"</allow>"

                   +"<allow>"

                   +"<principal>public</principal>"

                   +"<permission>read</permission>"

                   +"</allow>"

                   +"</acl>";

     MetaCatUtil.debugMessage("xml document: "+content, 55);

     assertTrue(handleXMLDocument(content, name, "insert"));

  }

   /**

   * Test insert a non well-formed xml document successfully

   * There is no </acl> in this string

   */

  public void testInsertNonWellFormedXMLDocument()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"1";

    MetaCatUtil.debugMessage("insert non well-formed docid: "+name, 20);

    String content="<?xml version=\"1.0\"?>"

                   +"<acl authSystem=\"knb\" order=\"allowFirst\">"

                   +"<identifier>"+name+"</identifier>"

                   +"<allow>"

             +"<principal>uid=john,o=NCEAS,dc=ecoinformatics,dc=org</principal>"

                   +"<permission>all</permission>"

                   +"</allow>"

                   +"<allow>"

                   +"<principal>public</principal>"

                   +"<permission>read</permission>"

                   +"</allow>";

     MetaCatUtil.debugMessage("xml document: "+content, 55);

     assertTrue(!handleXMLDocument(content, name, "insert"));

  } 

  /**

   * Test read a xml document  in xml format successfully

   */

  public void testReadXMLDocumentXMLFormat()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"1";

    assertTrue(handleReadAction(name, "xml"));

  } 

  /**

   * Test read a xml document  in html format successfully

   */

  public void testReadXMLDocumentHTMLFormat()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"1";

    assertTrue(handleReadAction(name, "html"));

  }

  /**

   * Test read a xml document  in zip format successfully

   */

  public void testReadXMLDocumentZipFormat()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"1";

    assertTrue(handleReadAction(name, "zip"));

  }

  /**

   * Test insert a xml document successfully

   */

  public void testUpdateXMLDocument()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"2";

    MetaCatUtil.debugMessage("update docid: "+name, 20);

    String content="<?xml version=\"1.0\"?>"

                   +"<!DOCTYPE acl PUBLIC \"-//ecoinformatics.org//"

                   +"eml-access-2.0.0beta6//EN\" \"http://pine.nceas.ucsb."

                   +"edu:8080/tao/dtd/eml-access-2.0.0beta6.dtd\">"

                   +"<acl authSystem=\"knb\" order=\"allowFirst\">"

                   +"<identifier>"+name+"</identifier>"

                   +"<allow>"

             +"<principal>uid=john,o=NCEAS,dc=ecoinformatics,dc=org</principal>"

                   +"<permission>all</permission>"

                   +"</allow>"

                   +"<allow>"

                   +"<principal>public</principal>"

                   +"<permission>read</permission>"

                   +"</allow>"

                   +"</acl>";

     MetaCatUtil.debugMessage("xml document: "+content, 55);

     assertTrue(handleXMLDocument(content, name, "update"));

  }

  /**

   * Test insert a data file successfully

   */

  public void testInertDataFile()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"1";

    MetaCatUtil.debugMessage("insert data file docid: "+name, 20);

    MetaCatUtil.debugMessage("insert data file ", 55);

    File hello = new File("test/edu/ucsb/nceas/metacatnettest/hello.txt");

    assertTrue(insertDataFile(name, hello));

  }

  /**

   * Test delete a xml document successfully

   */

  public void testDeleteXMLDocument()

  {

    String name = "john"+MetaCatUtil.getOption("accNumSeparator")

                     +serialNumber+MetaCatUtil.getOption("accNumSeparator")+"2";

    MetaCatUtil.debugMessage("delete docid: "+name, 20);

    assertTrue(handleDeleteFile(name));

  }

  /**

   * Test logout action

   */

  public void testLogOut()

  {

    assertTrue(handleLogOut());

  }

 /**

   * Method to hanld login action

   *

   * @param usrerName, the DN name of the test method

   * @param passWord, the passwd of the user

   */

  public boolean logIn(String userName, String passWord)

  {

    Properties prop = new Properties();

    prop.put("action", "login");

    prop.put("qformat", "xml");

    prop.put("username", userName);

    prop.put("password", passWord);

    // Now contact metacat

    String response = getMetacatString(prop);

    MetaCatUtil.debugMessage("Login Message: "+response, 55);

    boolean connected = false;

    if (response.indexOf("<login>") != -1) {

      connected = true;

    } else {

      connected = false;

    }

    return connected;

  }

  /**

   * Method to hanld logout action

   *

   * @param usrerName, the DN name of the test method

   * @param passWord, the passwd of the user

   */

  public boolean handleLogOut()

  {

    boolean disConnected =false;

    Properties prop = new Properties();

    prop.put("action", "logout");

    prop.put("qformat", "xml");

    String response = getMetacatString(prop);

    MetaCatUtil.debugMessage("Logout Message: "+response, 55);

    edu.ucsb.nceas.morpho.framework.HttpMessage.setCookie(null);

    if (response.indexOf("<logout>") != -1) 

    {

      disConnected = true;

    } 

    else 

    {

      disConnected = false;

    }

    return disConnected;

  }

  /**

   * Method to hanld read both xml and data file

   *

   * @param docid, the docid of the document want to read

   * @param qformat, the format of document user want to get

   */

  public boolean handleReadAction(String docid, String qformat)

  {

    Properties prop = new Properties();

    String message ="";

    prop.put("action", "read");

    prop.put("qformat", qformat);

    prop.put("docid", docid);

    message = getMetacatString(prop);

    message = message.trim();

    //MetaCatUtil.debugMessage("Read Message: "+message, 30);

    if (message==null || message.equals("")||message.indexOf("<error>") != -1 )

    {//there was an error

      return false;

    }

    else

    {//successfully

      return true;

    } 

  }

  /**

   * Method to hanld inset or update xml document

   *

   * @param xmlDocument, the content of xml qformat

   * @param docid, the docid of the document

   * @param action, insert or update

   */

  public boolean handleXMLDocument(String xmlDocument, String docid, 

                                                              String action)

  { //-attempt to write file to metacat

    String access = "no";

    StringBuffer fileText = new StringBuffer();

    StringBuffer messageBuf = new StringBuffer();

    String accessFileId = null;

    Properties prop = new Properties();

    prop.put("action", action);

    prop.put("public", access);  //This is the old way of controlling access

    prop.put("doctext", xmlDocument);

    prop.put("docid", docid);

    String message = getMetacatString(prop);

    MetaCatUtil.debugMessage("Insert or Update Message: "+message, 55);

    if(message.indexOf("<error>") != -1)

    {//there was an error

      return false;

    }

    else if(message.indexOf("<success>") != -1)

    {//the operation worked

     //write the file to the cache and return the file object

     return true;

    }

    else

    {//something weird happened.

      return false;

    } 

  }

   public boolean handleDeleteFile(String name)

  {

    Properties prop = new Properties();

    prop.put("action", "delete");

    prop.put("docid", name);

    String message = getMetacatString(prop);

    MetaCatUtil.debugMessage("Delete Message: "+message, 55);

    if(message.indexOf("<error>") != -1)

    {//there was an error

      return false;

    }

    else if(message.indexOf("<success>") != -1)

    {//the operation worked

     //write the file to the cache and return the file object

     return true;

    }

    else

    {//something weird happened.

      return false;

    } 

  }

  /**

   * sends a data file to the metacat using "multipart/form-data" encoding

   *

   * @param id the id to assign to the file on metacat (e.g., knb.1.1)

   * @param file the file to send

   */

  public boolean insertDataFile(String id, File file)

  {

    String response = null;

    //Get response for calling sendDataFile function

    response = sendDataFile(id, file);

    if (response.indexOf("success") != -1)

    {

      //insert successfully

      return true;

    }

    else

    {

      return false;

    }

  }

  /**

   * sends a data file to the metacat using "multipart/form-data" encoding

   *

   * @param id the id to assign to the file on metacat (e.g., knb.1.1)

   * @param file the file to send

   */

  public String sendDataFile(String id, File file) 

  {

    String response = "";

    InputStream returnStream = null;

    // Now contact metacat and send the request

    try

    {

      //FileInputStream data = new FileInputStream(file);

      System.setProperty("java.protocol.handler.pkgs","HTTPClient");

      URL url = new URL(metacatURL);

      edu.ucsb.nceas.morpho.framework.HttpMessage msg = 

                        new edu.ucsb.nceas.morpho.framework.HttpMessage(url);

      Properties args = new Properties();

      args.put("action", "upload");

      args.put("docid", id);

      Properties dataStreams = new Properties();

      String filename = file.getAbsolutePath();

      dataStreams.put("datafile", filename);

      returnStream = msg.sendPostData(args, dataStreams);

      InputStreamReader returnStreamReader = 

                        new InputStreamReader(returnStream);

      StringWriter sw = new StringWriter();

      int len;

      char[] characters = new char[512];

      while ((len = returnStreamReader.read(characters, 0, 512)) != -1)

      {

        sw.write(characters, 0, len);

      }

      returnStreamReader.close();

      response = sw.toString();

      sw.close();

    } 

    catch(Exception e) 

    {

      e.printStackTrace(System.err);

    }

    return response;

  }

  public String getMetacatString(Properties prop)

  {

    String response = null;

    // Now contact metacat and send the request

    try

    {

      InputStreamReader returnStream = 

                        new InputStreamReader(getMetacatInputStream(prop));

      StringWriter sw = new StringWriter();

      int len;

      char[] characters = new char[512];

      while ((len = returnStream.read(characters, 0, 512)) != -1)

      {

        sw.write(characters, 0, len);

      }

      returnStream.close();

      response = sw.toString();

      sw.close();

    }

    catch(Exception e)

    {

      return null;

    }

    return response;

  }

   /**

   * Send a request to Metacat

   *

   * @param prop the properties to be sent to Metacat

   * @return InputStream as returned by Metacat

   */

  public InputStream getMetacatInputStream(Properties prop)

  {

    InputStream returnStream = null;

    // Now contact metacat and send the request

    try

    {

      URL url = new URL(metacatURL);

      edu.ucsb.nceas.morpho.framework.HttpMessage msg = 

              new edu.ucsb.nceas.morpho.framework.HttpMessage(url);

      returnStream = msg.sendPostMessage(prop);

      return returnStream;

    }

    catch(Exception e)

    {

      e.printStackTrace(System.err);

    }

    return returnStream;

  }

}