/src/edu/ucsb/nceas/metacat/DataFileServer.java - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 656

Added by berkley over 23 years ago

added support for the new abstract class) to handle data file uploading through metnewninterface (actuall

     /**
      *  '$RCSfile$'
      *    Purpose: A Class that implements a socket server for data files
      *    Purpose: A Class that implements a socket server for data files that
      *             writes the file to the servlet's local file system
      *  Copyright: 2000 Regents of the University of California and the
      *             National Center for Ecological Analysis and Synthesis
      *    Authors: Chad Berkley
-...
     import java.text.SimpleDateFormat;
     import java.sql.*;
     public class DataFileServer extends Thread
     public class DataFileServer extends DataFileUploadInterface
+    {
       MetaCatUtil util = new MetaCatUtil();
       static String filedir = "";
       String user = null;
       String sess_id = null;
       int port;
       static String httpstring = "http://dev.nceas.ucsb.edu:8090/metacat/upload/";
       protected Socket s;
       DataFileServer (int port, String user, String sess_id)
       public DataFileServer(int port, String user, String sess_id)
+      {
         this.sess_id = sess_id;
         this.user = user;
         this.port = port;
         filedir = util.getOption("datafilepath");
         super(port, user, sess_id);
         System.out.println("port: " + port + " user: " + user + " sess: " +
                            sess_id);
+      }
       /**
        * attempts to connect a socket, returns null if it is not successful
        * returns the connected socket if it is successful.
        */
       public static Socket getSocket(String host, int port)
       public void getFile(int port, String user, String sess_id)
+      {
         Socket s = null;
         try
+        {
           s = new Socket(host, port);
           //we could create a socket on this port so the port is not available
           //System.out.println("socket connnected");
           return s;
+        }
         catch(UnknownHostException u)
+        {
+        }
         catch(IOException i)
+        {
           //an ioexception is thrown if the port is not in use
           //System.out.println("socket not connected");
           return s;
+        }
         return s;
+      }
       /**
        * returns true if the port specified is not in use.  false otherwise
        */
       public static boolean portIsAvailable(int port)
+      {
         Socket s;
         String host = "localhost";
         try
+        {
           s = new Socket(host, port);
           //s.close();
           //we could create a socket on this port so the port is not available
           //System.out.println("socket not available");
           return false;
+        }
         catch(UnknownHostException u)
+        {
           //it better know localhost!
+        }
         catch(IOException i)
+        {
           //an ioexception is thrown if the port is not in use
           //System.out.println("socket available");
           return true;
+        }
         return true;
+      }
       /**
        * Updates xml_documents with the new data document information
        * @param accnum the accession number of the new data file
        * @param filename the filename of the new data file
        * @param userOwner the document's owner's username
        */
       private void updateDB(String accnum, String filename, String userOwner)
+      {
         SimpleDateFormat formatter = new SimpleDateFormat ("yy-MM-dd HH:mm:ss");
         java.util.Date localtime = new java.util.Date();
         String dateString = formatter.format(localtime);
         String sqlDateString = "to_date('" + dateString + "', 'YY-MM-DD HH24:MI:SS')";
         StringBuffer sql = new StringBuffer();
         sql.append("insert into xml_documents (docid, docname, doctype, ");
         sql.append("user_owner, user_updated, server_location, rev, date_created");
         sql.append(", date_updated, public_access) values ('");
         sql.append(accnum).append("','").append(filename).append("','BIN','");
         sql.append(userOwner).append("','").append(userOwner).append("','1','");
         sql.append("1',").append(sqlDateString).append(",");
         sql.append(sqlDateString).append(",'0')");
         //System.out.println("sql: " + sql.toString());
         try
+        {
           Connection conn = util.openDBConnection();
           PreparedStatement pstmt = conn.prepareStatement(sql.toString());
           pstmt.execute();
           conn.close();
+        }
         catch(Exception e)
+        {
           System.out.println("error with db connection in DataFileServer.updateDB" +
                              ": " + e.getMessage());
+        }
+      }
       /**
        * This method is invoked when this class is broken off into a new thread
        */
       public void run ()
+      {
         filedir = util.getOption("datafilepath");
         ServerSocket server = null;
         Socket client = null;
         OutputStreamWriter osw = null;
         try
+        {
           //System.out.println("Starting on port " + port);
           //System.out.println("Waiting for sess_id: " + sess_id);
           System.out.println("Starting on port " + port);
           System.out.println("Waiting for sess_id: " + sess_id);
           server = new ServerSocket((new Integer(port)).intValue());
           //System.out.println("Waiting");
           server.setSoTimeout(30000); //set a 30 second timeout
           client = server.accept();
           //System.out.println("Accepted from " + client.getInetAddress());
           System.out.println("Accepted from " + client.getInetAddress());
           InputStream in = client.getInputStream();      //in from the client
           OutputStream sout = client.getOutputStream();  //out to the client
           osw = new OutputStreamWriter(sout);
           //System.out.println("output stream received");
           System.out.println("output stream received");
           // first read to get the file name
           byte[] str = new byte[1024];
           int val = -1;
-...
             i++;
+          }
           String filename = (new String(str,0, i-1)).trim();
           //System.out.println("filename: " + filename);
           System.out.println("filename: " + filename);
           val = -1;
           i = 0;
-...
           if(!sess_id.equals(session_id))
           {//this is an unauthorized connection to this port
             System.out.println("unauthorized request");
             osw.write("<?xml version=\"1.0\"?><error>unauthorized request</error>");
             osw.flush();
             osw.close();
             return;
+          }
           else
+          {
             //System.out.println("User authenticated on port " + port);
             System.out.println("User authenticated on port " + port);
+          }
           String restext=null;
           File outfile = new File(filedir + filename);
           //System.out.println("outfile: " + filedir + filename);
           System.out.println("outfile: " + filedir + filename);
           boolean nameInUse = outfile.exists();
           int filenametemp = 1;
           String fn = filename;
-...
+          {
             AccessionNumber anum = new AccessionNumber();
             String accnum = anum.generate(null, "INSERT");
             //osw.write(restext,0,restext.length());
             //osw.flush();
             FileOutputStream out = new FileOutputStream(outfile);
             byte[] buf = new byte[1024];
-...
             int j = 0;
             while (j < fsize)
+            {
               //System.out.println("1 j:" + j);
               cnt = in.read(buf, 0, 1024);
               if (cnt!=-1)
+              {
-...
+          {
             ex.printStackTrace();
+          }
           //System.out.println("done");
+        }
+      }
+    }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 656

Added by berkley over 23 years ago