Metacat

package edu.ucsb.nceas.metacat;

import java.util.*;

import java.util.Date;

import java.io.*;

import java.sql.*;

import java.net.*;

import java.text.*;

import javax.servlet.*;

import javax.servlet.http.*;

import org.apache.log4j.Logger;

import org.xml.sax.*;

  private Date firstTime;

  private boolean timedReplicationIsOn = false;

  Timer replicationDaemon;

  private Vector fileLocks = new Vector();

  private Thread lockThread = null;

  private static final AbstractDatabase dbAdapter = MetaCatUtil.dbAdapter;

  public void init(ServletConfig config) throws ServletException

  {

     //initialize db connections to handle any update requests

    //the default deltaT can be set from metacat.properties

    //create a thread to do the delta-T check but don't execute it yet

    replicationDaemon = new Timer(true);

    try

    {

       logMetacat.info("The timed replication on is"+timedReplicationIsOn);

       logMetacat.warn("The timed replication time Inerval is "+ timeInterval);

       logMetacat.warn("first replication time form property is "+firstTimeStr);

       firstTime = ReplicationHandler.combinateCurrentDateAndGivenTime(firstTimeStr);

       logMetacat.warn("After combine current time, the real first time is "

          // start, stop, getall and servercontrol need to check

          // if user is administor

          HttpSession sess = request.getSession(true);

          String sess_id = "";

          String username = "";

          String[] groupnames = {""};

          if (params.containsKey("sessionid")) 

          {

             sess_id = ((String[]) params.get("sessionid"))[0];

             logMetacat.info("in has sessionid "+ sess_id);

             {

                  logMetacat.info("find the id " + sess_id + " in hash table");

             }

           } 

           logMetacat.warn("The user name from session is: "+ username);

           {

               PrintWriter out = response.getWriter();

               out.print("<error>");

      replicationDaemon.cancel();

      replicationDaemon = new Timer(true);

      timedReplicationIsOn = false;

      out.println("Replication Handler Stopped");

      MetacatReplication.replLog("deltaT handler stopped");

      timedReplicationIsOn = true;

      // save settings to property file

      // note we couldn't use firstTime object because it has date info

      // we only need time info such as 10:00 PM

      replicationDaemon.cancel();

      replicationDaemon = new Timer(true);

      replicationDaemon.scheduleAtFixedRate(new ReplicationHandler(), firstTime,

  }

  /**

  private void handleForceReplicateRequest(PrintWriter out, Hashtable params,

                                           HttpServletResponse response, HttpServletRequest request)

  {

      logMetacat.info("Force replication action: "+dbaction);

      // sending back read request to remote server

      URL u = new URL("https://" + server + "?server="

                +"&action=read&docid=" + docid);

      String xmldoc = MetacatReplication.getURLContent(u);

      // get the document info from server

      URL docinfourl = new URL("https://" + server +

                               +"&action=getdocumentinfo&docid=" + docid);

      String docInfoStr = MetacatReplication.getURLContent(docinfourl);

      logMetacat.info("Force replication action: "+dbaction);

      // get the document info from server

      URL docinfourl = new URL("https://" + server +

                               +"&action=getdocumentinfo&docid=" + docid);

      String docInfoStr = MetacatReplication.getURLContent(docinfourl);

        //Get data file and store it into local file system.

        // sending back readdata request to server

        URL url = new URL("https://" + server + "?server="

                +"&action=readdata&docid=" + docid);

        //register data file into xml_documents table and wite data file

        //into file system

        DocumentImpl.writeDataFileInReplication(url.openStream(), datafilePath,

  {

    // File path for data file

    // Request docid

    String docId = ((String[])(params.get("docid")))[0];

    //check if the doicd is null

    //in the key store, this is security issue

    try

    {

      String server = ((String[])params.get("server"))[0];

      URL u = new URL("https://" + server + "?server="

                +"&action=test");

      String test = MetacatReplication.getURLContent(u);

      //couldn't pass the test

      //in the key store, this is security issue

      String server = ((String[])params.get("server"))[0];

      URL u = new URL("https://" + server + "?server="

                +"&action=test");

      String test = MetacatReplication.getURLContent(u);

      //couldn't pass the test

      //try to open a https stream to test if the request server's public key

      //in the key store, this is security issue

      URL u = new URL("https://" + server + "?server="

                +"&action=test");

      String test = MetacatReplication.getURLContent(u);

      //couldn't pass the test

      // Append local server's name and replication servlet to doclist

      doclist.append("<?xml version=\"1.0\"?><replication>");

      doclist.append("</server><updates>");

      // Get correct docid that reside on this server according the requesting

      ResultSet rs = pstmt.getResultSet();

      boolean tablehasrows = rs.next();

      //If metacat configed to replicate data file

      boolean replicateData = serverList.getDataReplicationValue(server);

      if (replicateData)

      {

        {

          String recordDoctype = rs.getString(3);

          Vector packagedoctypes = MetaCatUtil.getOptionList(

          //if this is a package file, put it at the end

          //because if a package file is read before all of the files it

          //refers to are loaded then there is an error

                doclist.append("</docid><rev>").append(rs.getInt(2));

                doclist.append("</rev>");

                doclist.append("<datafile>");

                doclist.append("</datafile>");

                doclist.append("</updatedDocument>");

              }//else

          if(!recordDoctype.equals("BIN"))

          { //don't replicate data files

            Vector packagedoctypes = MetaCatUtil.getOptionList(

            if(recordDoctype != null && !packagedoctypes.contains(recordDoctype))

            {   //if this is a package file, put it at the end

              //because if a package file is read before all of the files it

            if (recordDoctype.equals("BIN"))

            {

                revDocList.append("<datafile>");

                revDocList.append("</datafile>");

            }

            revDocList.append("</revisionDocument>");

        sb.append("</entry_type><source_doctype>").append(rs.getString(2));

        sb.append("</source_doctype><target_doctype>").append(rs.getString(3));

        sb.append("</target_doctype><public_id>").append(rs.getString(4));

        sb.append("</system_id></row>");

        tablehasrows = rs.next();

    Hashtable sl = new Hashtable();

    DBConnection dbConn = null;

    int serialNumber = -1;

    docId=MetaCatUtil.getDocIdFromString(docId);

    PreparedStatement pstmt=null;

    int serverLocation;

    int serialNumber = -1;

    PreparedStatement pstmt = null;

    int serverCode = 1;

    String docId=MetaCatUtil.getDocIdFromString(accNum);

    try

  }

  /**

  /**

  public static void replErrorLog(String message)

  {

    try

    {

      FileOutputStream fos = new FileOutputStream(

      PrintWriter pw = new PrintWriter(fos);

      SimpleDateFormat formatter = new SimpleDateFormat ("yy-MM-dd HH:mm:ss");

      java.util.Date localtime = new java.util.Date();