Annotation of edoc-applet/Upload.java, revision 1.1.1.1
1.1 rogo 1: //
2: // Upload.java
3: //
4: //
5: // Created by rogo on Wed Jan 29 2003.
6: // Copyright (c) 2001 __MyCompanyName__. All rights reserved.
7: //
8: import com.exploringxml.xml.*;
9: import java.io.*;
10: import java.util.*;
11: import java.net.*;
12: import javax.swing.*;
13: import java.awt.*;
14: import java.awt.event.*;
15: import java.security.*;
16:
17:
18:
19: public class Upload extends JApplet implements ActionListener
20: {
21: static File startFile;
22: static int count = 0;
23: static JFileChooser fileChooser;
24: static String url;
25: static long id = 0L;
26: static Hashtable connections=new Hashtable();
27: static String col = "11"; // Collection /Institute
28: static String grp ="141"; // Group or Bundle
29: static String ses ="";
30: static Bundle bundle;
31: static Bundle bundleRef;
32: JButton upload = new JButton("Upload");
33: JRadioButton proxy = new JRadioButton("Proxy");
34: static int fileCount = 0;
35: // static UploadInfo dialog = new UploadInfo();
36: static String mode = "";
37: static String destination = "";
38: static String proxyHost = "";
39: Upload uploader = this;
40: static boolean runningAsApplet=true;
41: static boolean debug=false;
42: static String rootNode = "edoc";
43: static MessageDigest md ;
44: static
45: {
46: try {
47: md = MessageDigest.getInstance("MD5");
48: } catch(Exception e) { e.printStackTrace();}
49: }
50: public Upload()
51: {
52: if(!runningAsApplet)
53: init();
54: }
55:
56: // start applet code
57: public void init()
58: {
59: this.getContentPane().setLayout(new FlowLayout(FlowLayout.CENTER, 0, 0));
60: this.getContentPane().add(upload);
61: this.getContentPane().add(proxy);
62: upload.addActionListener(this);
63: proxy.addActionListener(this);
64: id = System.currentTimeMillis();
65: Properties prop = System.getProperties();
66:
67: // prop.put("proxySet", "true");
68: // prop.put("http.proxyHost","proxy.unibe.ch");
69: // prop.put("proxyPort", "80");
70: // prop.put("java.protocol.handler.pkgs","HTTPClient");
71: fileChooser=null;
72: if(!runningAsApplet)
73: {
74: Dimension screenSize=Toolkit.getDefaultToolkit().getScreenSize();
75: Point p=new Point((screenSize.width-300)/2,(screenSize.height-180)/2);
76: JFrame testFrame=new JFrame();
77: testFrame.setTitle("Archimedes Applet");
78: testFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
79: testFrame.getContentPane().add(this);
80: testFrame.setSize(300,180);
81: testFrame.setLocation(p);
82: testFrame.setVisible(true);
83: Console console = new Console(testFrame);
84: console.setVisible(true);
85: try
86: {
87: Connection con= new Connection(new URL("http://core.rz-berlin.mpg.de:80/edoctest/adm.epl"));
88: ses=con.getSessionID("name=root&passwd=edoctest&mode=verifylogin");
89: //("name=dwinter&passwd=e1nste1n&mode=verifylogin");
90: con.socket.close();
91: } catch(Exception exc) { }
92: } else
93: {
94: Console console = new Console(new JFrame());
95: console.setVisible(true);
96: ses= getParameter("ses");
97: col = getParameter("col").trim();
98: grp = getParameter("grp").trim();
99: bundleRef = getBundle(getCodeBase()+"oi.epl?mm=list&grp="+grp+"&col="+col);
100: getGenre();
101: //bundle=getBundle("http://core.rz-berlin.mpg.de/edoctest/oi.epl?mm=list&grp=136&col=11");
102:
103: }
104: }
105: public void actionPerformed(ActionEvent e)
106: {
107: if (e.getSource().equals(proxy))
108: {
109: proxyHost = JOptionPane.showInputDialog("Please enter proxy host (format host:port)!");
110: if (proxyHost != null)
111: {
112: if (proxyHost.length() == 0)
113: {
114: proxyHost = "";
115: Properties prop = System.getProperties();
116: prop.remove("proxySet");
117: prop.remove("http.proxyHost");
118: prop.remove("proxyPort");
119:
120: }
121: else
122: {
123: Properties prop = System.getProperties();
124: int index = proxyHost.indexOf(":");
125: String pHost = proxyHost.substring(0, (index > 0) ? index : proxyHost.length());
126: String pPort = (index > 0) ? proxyHost.substring(index + 1) : "80";
127:
128: prop.put("proxySet", "true");
129: prop.put("http.proxyHost",pHost);
130: prop.put("proxyPort", pPort);
131: }
132: System.out.println("pr "); // proxyHost="";
133: } else
134: proxyHost = "";
135: // proxy.setSelected(false);
136: }
137:
138: if (e.getActionCommand().equals("Upload"))
139: {
140:
141: //url=getParameter("url");
142: if(runningAsApplet)
143: set();
144: //System.out.println("url " + url); //+ " " + getCodeBase());
145: upload.setEnabled(false);
146: makeUpload();
147: upload.setEnabled(true);
148: }
149:
150: }
151: public void set()
152: {
153: col = getParameter("col").trim();
154: grp = getParameter("grp").trim();
155: ses = getParameter("ses").trim();
156: System.out.println("uploading to grp "+grp+" col "+col);
157: destination = "";
158: // destination = getParameter("destinationFolder");
159: if (destination == null)
160: destination = "";
161: // e.g."/rogo/servlet/RWServlet/"
162: URL appletURL = getCodeBase();
163: String serverInfo = appletURL.getHost() + ":" + appletURL.getPort();
164: // this.url = (servletURL.startsWith("http")) ? servletURL + url : "http://" + serverInfo + servletURL + url;
165: this.url=appletURL.toString();
166: Properties prop = System.getProperties();
167:
168: // prop.put("proxySet", "true");
169: // prop.put("http.proxyHost","proxy.unibe.ch");
170: // prop.put("proxyPort", "80");
171: // prop.put("java.protocol.handler.pkgs","HTTPClient");
172: Enumeration en = prop.propertyNames();
173: if(debug)
174: while (en.hasMoreElements())
175: {
176: String key = (String) en.nextElement();
177: System.out.println("key: " + key + " value: " + prop.get(key));
178:
179: }
180: System.out.println(url+"oi.epl?mm=list&grp="+grp+"&col="+col);
181:
182: }
183: public static void makeUpload()
184: {
185: try
186: {
187: if (fileChooser == null)
188: {
189: fileChooser = new JFileChooser();
190: // fileChooser.setFileSelectionMode(fileChooser.FILES_AND_DIRECTORIES);
191: fileChooser.setFileFilter(new XMLFilter());
192: fileChooser.setDialogType(JFileChooser.OPEN_DIALOG);
193: fileChooser.addActionListener(new ActionListener()
194: {
195: public void actionPerformed(ActionEvent e2)
196: {
197: System.out.println(e2.getActionCommand());
198: if (!e2.getActionCommand().toString().equals("ApproveSelection")) return;
199: // {
200:
201: Thread thread = new Thread()
202: {
203: public void run()
204: {
205: UploadInfo dialog = new UploadInfo();
206:
207: File startFile=new File(".");
208: try
209: {
210: dialog.thread=Thread.currentThread();
211: System.out.println("Called run with " + fileChooser.getSelectedFile());
212: dialog.setTitle("Upload Status Window");
213: dialog.setSize(400, 175);
214: dialog.setLocation(new java.awt.Point(150, 100));
215: Update update = new Update();
216: startFile = fileChooser.getSelectedFile(); //new File(fileChooser.getFile());
217: int fileCount = 0;
218: int count = 1;
219: long time = System.currentTimeMillis();
220: if( connections.get(startFile.getAbsolutePath())!=null)
221: throw new Error("Upload already running!");
222:
223: if (startFile.isDirectory())
224: {
225: fileCount = countFiles(startFile, fileCount);
226: System.out.println("Number of files to send: " + fileCount);
227: bundle=getBundle(startFile);
228: writeDirectory(startFile, startFile, fileCount, count, dialog, update);
229:
230: } else
231: {
232: fileCount = 1;
233: //writeStream(startFile, startFile, fileCount, count, dialog, update);
234: bundle = getBundle(startFile);
235: writeStream(startFile,bundle, dialog);
236:
237: }
238:
239: long time2 = System.currentTimeMillis();
240: System.out.println("needed " + (time2 - time) + " ms for " + count--);
241: dialog.setVisible(false);
242: if (startFile.isDirectory())
243: showDialog("Finished upload of " + startFile + " containing " + fileCount + " " + ((fileCount > 1) ? " files" : " file") + " in " + ((time2 - time) / 1000) + " seconds", "Finished Upload");
244: else
245: showDialog("Finished upload of " + startFile + " in " + ((time2 - time) / 1000) + " seconds", "Finished Upload");
246: connections.remove(startFile.getAbsolutePath());
247: } catch (Exception e)
248: {
249: dialog.setVisible(false);
250: ByteArrayOutputStream b = new ByteArrayOutputStream();
251: PrintStream stream = new PrintStream(b);
252: e.printStackTrace(stream);
253: connections.remove(startFile.getAbsolutePath());
254:
255: showErrorDialog(b.toString(), "Upload failed");
256: } catch (Error e8)
257: {
258: dialog.setVisible(false);
259: if( e8.toString().indexOf("Upload already running!")<0)
260: connections.remove(startFile.getAbsolutePath());
261: showErrorDialog(e8.toString(), "Upload failed");
262: }
263:
264: }
265: };
266: thread.setPriority(Thread.MIN_PRIORITY);
267: /* dialog = new UploadInfo();
268: dialog.setTitle("Upload Status Window");
269: dialog.setSize(400, 155);
270: dialog.setLocation(new java.awt.Point(150, 100));
271: */
272: thread.start();
273: // } // else
274: //System.exit(0);
275: }
276: });
277:
278: }
279: count = 1;
280: mode = "";
281: fileChooser.showDialog(new JFrame(), "Upload");
282:
283: } catch (Exception e)
284: {
285: System.out.println("Ha " + e);
286: }
287: }
288: private static int countFiles(File file, int fileCount)
289: {
290: if (file.isDirectory())
291: {
292: String[] files = file.list(new UploadFilter());
293:
294: for (int j = 0; j < files.length; ++j)
295: {
296: File f = new File(file + File.separator + files[j]);
297: if (f.isDirectory())
298: {
299: fileCount = countFiles(f, fileCount);
300: } else
301: fileCount = fileCount + 1;
302: }
303:
304: }
305: return fileCount;
306: }
307:
308: private static int writeDirectory(File file, File startFile, int fileCount, int count, UploadInfo dialog, Update update) throws Exception
309: {
310: if (file.isDirectory())
311: {
312: String[] files = file.list(new UploadFilter());
313: for (int j = 0; j < files.length; ++j)
314: {
315: File f = new File(file + File.separator + files[j]);
316: System.out.println(file + " " + f);
317:
318: if (f.isDirectory())
319: {
320: count = writeDirectory(f, startFile, fileCount, count, dialog, update);
321: } else
322: count = writeStream(f, startFile, fileCount, count, dialog, update);
323: }
324: }
325: return count;
326: }
327: private static int writeStream(File file, File startFile, int fileCount, int count, UploadInfo dialog, Update updateMode) throws Exception
328: {
329: // try
330: //{
331: String response = "", mode = "";
332: String path = file.getAbsolutePath();
333: String name = (startFile.isDirectory()) ? startFile.getName() + "/" + path.substring(startFile.getAbsolutePath().length() + 1) : file.getName();
334: if (destination != "")
335: name = (startFile.isDirectory()) ? destination + "/" + path.substring(startFile.getAbsolutePath().length() + 1) : destination + "/" + file.getName();
336:
337: System.out.println("hi " + name + " " + destination + " " + startFile.getName());
338: FileInputStream f = new FileInputStream(file.getAbsolutePath());
339: int length = f.available();
340: int readCount = 0;
341: byte[] b = (length > 512000) ? new byte[512000] : new byte[length];
342: System.out.println(file.getName() + " " + ((length > 1000000) ? (length / 1048576) + " MByte" : length + " Bytes"));
343: String fileName = file.getName() + " " + ((length > 1000000) ? (length / 1048576) + " MByte" : length + " Bytes");
344: dialog.title.setText("Uploading " + startFile);
345: dialog.progress.setValue(0);
346: dialog.file.setText(fileName);
347: dialog.status.setText(count + " of " + fileCount + ((fileCount > 1) ? " files" : " file"));
348: //dialog.pack();
349: //dialog.validate();
350: if (dialog.isVisible())
351: dialog.repaint();
352: else
353: dialog.show();
354: /*
355: URL httpCon = new URL(url + getSHA((id + "").getBytes()) + "/" + convertUml(name) + "?id=" + getSHA((id + "").getBytes()) + "&count=" + count + "&nf=" + fileCount + "&md5=" + md5 + "&mode=" + mode);
356: Connection con = null;
357: con=(Connection)connections.get(startFile.getAbsolutePath());
358: if(con==null)
359: {
360: con=new Connection(httpCon);
361: connections.put(startFile.getAbsolutePath(),con);
362: } else
363: con.url=httpCon;
364: OutputStream mout = con.out; //con.getOutputStream();
365: */
366: // dialog.progress.setValue((int) (((double) readCount / (double) length) * 100.0));
367: // count = filecount
368: Connection conPost = null;
369: System.out.println("hostURL "+url);
370: if(!runningAsApplet)
371: conPost=new Connection( new URL("http://core.rz-berlin.mpg.de/edoctest/oi.epl"));
372: else
373: conPost=new Connection( new URL(url+"/oi.epl"));
374:
375: // new URL("http://localhost:8080/examples/servlet/rogo/"));
376: conPost.ses=ses;
377: conPost.dialog=dialog;
378: Bundle.Document doc=(Bundle.Document)bundle.documents.get(count);
379: System.out.println(doc.title);
380: conPost.post(file,"new",doc.docID+"",doc.title,doc.locator,doc.comment);
381:
382: // conPost.post(new File("./test2.jpg"),picture.elementAt(i).toString(),artist.elementAt(i).toString(),source.elementAt(i).
383: System.out.println(getMD5(md));
384: dialog.progress.setValue(100);
385: count++;
386: return count;
387: }
388: private static int writeStream(File startFile,Bundle bundle, UploadInfo dialog) throws Exception
389: {
390: int count = 1,fileCount = bundle.documents.size();
391: int index = startFile.getAbsolutePath().lastIndexOf(File.separator);
392:
393:
394: String path =startFile.getAbsolutePath().substring(0,index+1);
395: System.out.println(path);mode = "new";
396: boolean newVersionforAll = false;
397: Vector list=new Vector();
398: for(int k=0;k<fileCount;++k)
399: {
400: Bundle.Document doc = (Bundle.Document)bundle.documents.elementAt(k);
401: if(bundleRef.docsLocator.get(doc.locator)!=null)
402: list.addElement(doc.fileName);
403: }
404:
405: for(int k=0;k<fileCount;++k)
406: {
407: Bundle.Document doc = (Bundle.Document)bundle.documents.elementAt(k);
408:
409: String response = "";
410: dialog.title.setText("Uploading " + path+doc.fileName);
411: dialog.progress.setValue(0);
412: String fileName = doc.fileName+ " " + ((doc.size > 1000000) ? (doc.size / 1048576) + " MByte" : doc.size + " Bytes");
413: dialog.file.setText(fileName);
414: dialog.status.setText(count + " of " + fileCount + ((fileCount > 1) ? " files" : " file"));
415: //dialog.pack();
416: //dialog.validate();
417: if (dialog.isVisible())
418: dialog.repaint();
419: else
420: dialog.show();
421:
422: if(bundleRef.docsLocator.get(doc.locator)!=null)
423: {
424: if(!newVersionforAll)
425: {
426: Object[] options = new Object[] { "New Version for this file","New Version for all files", "Skip file" };
427:
428: int option = showDialog("Warning "+doc.locator+" exists! \n What do you want to do?", "Destination exists!", options,list);
429: if(option == 0) mode ="old";
430: if(option == 1)
431: {
432: mode ="old";
433: newVersionforAll=true;
434: }
435: if(option == 2)
436: {
437: count++;
438: System.out.println("Heh Document exists!"+ doc);
439: System.out.println("Skipping");
440: continue;
441: }
442: }
443: Bundle.Document refDoc= (Bundle.Document) bundleRef.docsLocator.get(doc.locator);
444: doc.docID=refDoc.docID;
445: //count++;
446: // System.out.println("Heh Document exists!"+ doc);
447: // System.out.println("Skipping");
448: // continue;
449: } else mode ="new";
450: Connection conPost = null;
451: if(!runningAsApplet)
452: conPost=new Connection( new URL("http://core.rz-berlin.mpg.de/edoctest/oi.epl"));
453: else
454: conPost=new Connection( new URL(url+"/oi.epl"));
455:
456: // new URL("http://localhost:8080/examples/servlet/rogo/"));
457: conPost.ses=ses;
458: conPost.dialog=dialog;
459: conPost.post(path,doc,mode);
460: String md5=getMD5(md);
461: System.out.println("MD5 is equal ?"+doc.md5cs.equals(md5));
462: if(!doc.md5cs.equals(md5))
463: {
464: Object[] options = { "Retry", "Cancel" };
465: int option = showDialog("Transfer failed! \n What do you want to do?", "Transfer failed ", options);
466: if(option == 0)
467: {
468: if(!runningAsApplet)
469: conPost=new Connection( new URL("http://core.rz-berlin.mpg.de/edoctest/oi.epl"));
470: else
471: conPost=new Connection(new URL(url+"/oi.epl"));
472: conPost.ses=ses;
473: conPost.dialog=dialog;
474: conPost.post(path,doc,mode);
475: md5=getMD5(md);
476: }
477: } // System.out.println(getMD5(md));
478: dialog.progress.setValue(100);
479: count++;
480: }
481: return count;
482: }
483:
484: public static String getMD5(MessageDigest md) throws Exception
485: {
486: byte[] bytes = md.digest();
487: // System.out.println("digest " + bytes.length);
488: StringBuffer sb = new StringBuffer();
489: int decValue;
490: for (int i = 0; i < bytes.length; i++)
491: {
492: String hexVal = Integer.toHexString(bytes[i] & 0xFF);
493: if (hexVal.length() == 1)
494: hexVal = "0" + hexVal; // put a leading zero
495: sb.append(hexVal);
496: }
497: return sb.toString();
498: }
499: public static String getSHA(byte[] b) throws Exception
500: {
501: MessageDigest md = MessageDigest.getInstance("SHA");
502: md.update(b, 0, b.length);
503: //System.out.println("digest");
504: byte[] bytes = md.digest();
505: StringBuffer sb = new StringBuffer();
506: int decValue;
507: for (int i = 0; i < bytes.length; i++)
508: {
509: String hexVal = Integer.toHexString(bytes[i] & 0xFF);
510: if (hexVal.length() == 1)
511: hexVal = "0" + hexVal; // put a leading zero
512: sb.append(hexVal);
513: }
514:
515: return sb.toString();
516: }
517:
518: public static String convertUml(String newName)
519: {
520: StringBuffer alterMe = new StringBuffer(newName.trim());
521: int length = alterMe.length();
522: int j = 0;
523: while (j < length)
524: { //if(Character.isSpaceChar(alterMe.charAt(j)))
525: // alterMe.setCharAt(j,'_');
526: if (alterMe.charAt(j) == ' ')
527: {
528: alterMe.setCharAt(j, '%');
529: alterMe.insert(j + 1, "20");
530: length = length + 2;
531: }
532: /* if(Character.isSpaceChar(alterMe.charAt(j))
533: alterMe.setCharAt(j,'_');
534: */
535: ++j;
536: }
537: return alterMe.toString();
538: }
539: public static class UploadInfo extends JDialog
540: {
541: JLabel file = new JLabel(" ");
542: JLabel status = new JLabel(" ");
543: JLabel title = new JLabel(" ");
544: JPanel content = new JPanel();
545: JPanel titlePanel = new JPanel();
546: JPanel labelPanel = new JPanel();
547: JPanel statusPanel = new JPanel();
548: JPanel buttonPanel = new JPanel();
549:
550: JProgressBar progress = new JProgressBar();
551: JButton cancel = new JButton("Cancel");
552: Thread thread;
553: public UploadInfo()
554: {
555:
556: content = new JPanel(true);
557: //content.setBorder(BorderFactory.createRaisedBevelBorder());
558: content.setLayout(new BoxLayout(content, BoxLayout.Y_AXIS));
559: title = new JLabel("Uploading " + startFile);
560: title.setHorizontalTextPosition(title.CENTER);
561: titlePanel.add(title);
562: buttonPanel.add(cancel);
563: // content.add(titlePanel);
564: content.add(Box.createRigidArea(new java.awt.Dimension(0, 15)));
565: content.add(labelPanel);
566: content.add(new JLabel(""));
567: content.add(progress);
568: content.add(statusPanel);
569: content.add(buttonPanel);
570: content.add(Box.createRigidArea(new java.awt.Dimension(0, 15)));
571: labelPanel.add(file);
572: statusPanel.add(status);
573: getContentPane().add(titlePanel, "North");
574: getContentPane().add(content, "Center");
575: cancel.addActionListener(new ActionListener()
576: {
577: public void actionPerformed(ActionEvent e)
578: {
579: setVisible(false);
580: thread.stop();
581: }
582:
583: });
584: pack();
585:
586: }
587:
588: }
589: static class Update
590: {
591: boolean value = false;
592: public Update()
593: {
594: value = false;
595: }
596: }
597: public static int showDialog(String message, String title, Object[] options)
598: {
599: int option = JOptionPane.showOptionDialog(null, message, title, JOptionPane.DEFAULT_OPTION, JOptionPane.WARNING_MESSAGE, null, options, options[0]);
600: return option;
601:
602: }
603: public static int showDialog(String message, String title, Object[] options,Vector fileList)
604: {
605: JOptionPane pane = new JOptionPane( message, JOptionPane.DEFAULT_OPTION, JOptionPane.WARNING_MESSAGE, null, options, options[0]);
606: pane.setMessageType(JOptionPane.WARNING_MESSAGE); // Configure
607: JDialog dialog = pane.createDialog(null, title);
608: JList list=null;
609: if(fileList==null)
610: list= new JList(new String[]{"click","here","test","bla","world","hello"});
611: else list = new JList(fileList);
612: JScrollPane scpane = new JScrollPane(list);
613: scpane.setPreferredSize(new Dimension(100,80));
614: JLabel label= new JLabel("Files : ");
615: label.setPreferredSize(new Dimension(50,80));
616: JPanel panel = new JPanel();
617: panel.add(label);
618: panel.add(scpane);
619: dialog.getContentPane().add(panel,"East");
620: dialog.pack();
621: dialog.show();
622: Object selectedValue = pane.getValue();
623: if(selectedValue == null)
624: return 2;
625: //If there is not an array of option buttons:
626: if(options == null) {
627: if(selectedValue instanceof Integer)
628: return ((Integer)selectedValue).intValue();
629: return 2;
630: }
631: //If there is an array of option buttons:
632: for(int counter = 0, maxCounter = options.length;
633: counter < maxCounter; counter++) {
634: if(options[counter].equals(selectedValue))
635: return counter;
636: }
637: return 2;
638:
639: }
640:
641: public static void showDialog(String message, String title)
642: {
643: JOptionPane.showMessageDialog(null, message, title, JOptionPane.PLAIN_MESSAGE);
644:
645: }
646: public static void showErrorDialog(String message, String title)
647: {
648: JOptionPane.showMessageDialog(null, message, title, JOptionPane.ERROR_MESSAGE);
649: }
650:
651:
652:
653: // end applet code
654:
655: public static StringBuffer readChunked(Connection conTest) throws Exception
656: {
657: InputStream r= conTest.in;
658: //InputStreamReader r= new InputStreamReader(new FileInputStream("FMPro.xml"),"UTF-8");
659: //InputStreamReader r=// new InputStreamReader(new URL(fileMakerTest).openStream(),"UTF-8");
660: //new InputStreamReader(conTest.in,"UTF-8");
661: //while(conTest.in.available()==0);
662: //u.openStream();
663: //InputStream r = new InputStream(f);
664: StringBuffer sb = new StringBuffer();
665: int c,countC=0,limit=conTest.in.available();
666: // r.skip(211);
667: String response = conTest.getResponseMessage();
668: String lowerCase= response.toLowerCase();
669: int index =lowerCase.indexOf("charset");
670: int index2 =lowerCase.indexOf("=",index);
671: int index3 =lowerCase.indexOf("\r",index2);
672: String charset=(index>0) ? response.substring(index2+1,index3):"";
673: charset="";//charset.toUpperCase();
674: System.err.println(response);
675: if(lowerCase.indexOf("chunked")<0)
676: {
677: ByteArrayOutputStream local=new ByteArrayOutputStream();
678: while(r.available()==0);
679: System.err.println(r.available());
680: while ((c = r.read()) != -1)
681: {
682: byte b=(byte)c;
683: local.write(b);
684: if(debug)
685: System.out.print((char)c);
686: }
687: if(charset!="")
688: sb.append(local.toString(charset));
689: else
690: sb.append(local.toString());
691: if(debug)
692: System.out.print(sb);
693: return sb;
694: }
695:
696: // read chunk size
697: while ((c = r.read()) != -1)
698: {
699: ++countC;
700: char ch=(char)c;
701:
702: if(Character.digit(ch, 16) != -1)
703: sb.append((char)c);
704: if(ch=='\r')
705: {
706: ch=(char)r.read();
707: if( ch=='\n')
708: break;
709: }
710: // System.out.print((char)c);
711: }
712: int bufSize=Integer.parseInt(sb.toString().trim(), 16);
713:
714: System.err.println("chunk size "+Integer.parseInt(sb.toString().trim(), 16)+" bytes"+" limit "+limit);
715: //sb.append((char)r.read());
716: // sb.append((char)r.read());
717: sb=new StringBuffer();//.delete(0,sb.length());
718: byte[] b=new byte[bufSize];
719: countC=0;
720: StringBuffer localBuff=new StringBuffer();
721: while (true)
722: {
723: // sb.append(" new Chunk "+r.available()+" \r\n ");
724: int readCount = 0;
725: int available = 0;
726: int readSize = b.length; int loop=0;
727: while (readCount < bufSize)
728: {
729: available=r.available();
730:
731: if(available>=bufSize)
732: readSize=bufSize;
733: else
734: readSize=available;
735:
736: if(readCount + readSize > bufSize)
737: {
738: readSize = r.read(b, readCount, bufSize - readCount); // mout.flush();
739:
740: }
741: else
742: {
743: readSize = r.read(b,readCount,readSize);
744: }
745: if(loop>=200) throw new Error("Connection timed out");
746: if(readSize==0)
747: {
748: long time = System.currentTimeMillis();
749: while(System.currentTimeMillis()-time<100);
750: } else loop=0;
751:
752: if(debug)
753: System.out.println(++loop+" read "+readCount+" bytes"+" readSize "+readSize);
754: readCount+=readSize;
755:
756: }
757:
758:
759: //while(r.available()<bufSize); // critical if connection closed
760: // r.read(b,0,bufSize);
761: //System.err.println(r.available());
762: r.read();r.read();
763: if(charset!="")
764: sb.append(new String(b,0,bufSize,charset));
765: else
766: sb.append(new String(b,0,bufSize));
767: if(debug)
768: System.out.println(new String(b,0,bufSize));
769: while ( (c = r.read()) != -1)
770: {
771: // ++countC;
772: char ch=(char)c;
773: //System.err.println("read lf "+(ch=='\r')+" or cr "+( ch=='\n')+" "+(Character.digit(ch, 16) == -1));
774: //if((ch!='\r')&&( ch!='\n')) System.err.println("read ch "+" "+ch+" "+Character.isSpace(ch));
775: if(Character.digit(ch, 16) != -1)
776: localBuff.append(ch);
777: if(ch=='\r')
778: {
779: ch=(char)r.read();
780: if( ch=='\n')
781: break;
782: }
783: }
784: if(debug)
785: System.out.println("chunk size "+localBuff);
786: if(localBuff.length()>0)
787: {
788: // System.err.println("new chunk size "+Integer.parseInt(localBuff.toString().trim(), 16)+" bytes");
789: // System.err.println((char)r.read());
790: bufSize=Integer.parseInt(localBuff.toString().trim(), 16);
791: //localBuff.delete(0,localBuff.length());
792: localBuff=new StringBuffer();
793: } // else bufSize=0;
794: ++countC;
795: // sb.append("new Chunk"+r.available()+"\r\n ");
796: if(bufSize==0)//(bufSize))
797: break;
798: // System.err.println(" in Chunk "+bufSize+" buffers used "+(countC)+" \r\n ");
799: // // System.out.print((char)c);
800: }
801: // System.out.println(sb);
802: return sb;
803: }
804: public static Hashtable getMetaData(String url)
805: {
806: Hashtable data=new Hashtable();
807: Vector artist=new Vector();
808: Vector picture=new Vector();
809: Vector idnr = new Vector();
810: Vector source = new Vector();
811: data.put("artist",artist);
812: data.put("picture",picture);
813: data.put("IDNR",idnr);
814: data.put("source",source);
815: try
816: {
817: String fileMakerTest="http://localhost/FMRes/FMPro?-db=Bildarchiv%20Daston&-layID=69&-token=25&-max=1000&-format=-dso_xml&-mode=browse&-findall";
818: String fileMakerTest2="http://localhost/FMRes/FMPro?-db=bildarchiv%20daston&-layid=1&-format=-dso_xml&-max=899&-skip=6&-token.0=25&-mode=browse&-lop=and&-find";
819: //Connection con= new Connection(new URL("http://core.rz-berlin.mpg.de:80/edoctest/adm.epl"));
820: //String ses=con.getSessionID("name=root&passwd=&mode=verifylogin");
821:
822: Connection conTest=new Connection(new URL(fileMakerTest));//new URL(url));
823: // conTest.ses=ses;
824: conTest.get();
825: StringBuffer sb=readChunked(conTest);
826: if(debug)
827: System.out.println("file "+sb);
828: // parse string and build document tree
829: Node root = new Xparse().parse(sb.toString());
830: Vector contents=root.index.v;
831: for (int i=0;i<contents.size();++i)
832: {
833: Node n=(Node)contents.elementAt(i);
834: if(n.type.equals("element"))
835: {
836: // System.out.println("tag "+n.name+" with contents ");
837: // System.out.println(n.getCharacters());
838: if(n.name.indexOf("artist")>=0) artist.addElement(n.getCharacters());
839: if(n.name.indexOf("picture")>=0) picture.addElement(n.getCharacters());
840: if(n.name.indexOf("IDNR")>=0) idnr.addElement(n.getCharacters());
841: if(n.name.indexOf("source")>=0) source.addElement(n.getCharacters());
842: //contents=n.contents.v;i=0;
843: }
844: }
845: }catch(Exception e8) { e8.printStackTrace(); }
846: return data;
847: }
848:
849: public static Bundle getBundle(File f)
850: {
851: File xmlFile=null;
852: Bundle bundle=new Bundle();
853: if(f.isDirectory())
854: {
855: String[] files=f.list();
856: for(int j=0;j<files.length;++j)
857: {
858: if(files[j].endsWith("xml"))
859: {
860: xmlFile=new File(f.getAbsolutePath()+"/"+files[j]);
861: break;
862: }
863: }
864: } else xmlFile=f;
865: try
866: {
867: // read XML Metadata from a file
868: FileReader r=new FileReader(xmlFile);
869: StringBuffer sb=new StringBuffer();
870: int c=0;
871: while ((c = r.read()) != -1)
872: {
873: char ch=(char)c;
874: sb.append(ch);
875: // System.out.print((char)c);
876: }
877: addToBundle(bundle,sb);
878: } catch(Exception e) { e.printStackTrace();}
879:
880:
881: return bundle;
882: }
883: public static Bundle getBundle(String url)
884: {
885: Bundle bundle=new Bundle();
886:
887: try
888: {
889: if(url=="") url="http://core.rz-berlin.mpg.de:80/edoctest/oi.epl?mm=list&grp=90";
890: // read XML document from URL into a string
891: URL u = new URL(url);
892: // FileReader r=new FileReader();
893: long time = System.currentTimeMillis();
894:
895: //Connection con= new Connection(new URL("http://core.rz-berlin.mpg.de:80/edoctest/adm.epl"));
896: // String ses=con.getSessionID("name=root&passwd=edoctest&mode=verifylogin");
897: // con.socket.close();
898: Connection conTest=new Connection(new URL(url));
899: conTest.ses=ses;
900: conTest.get();
901: StringBuffer sb=readChunked(conTest);
902: // sb.delete( sb.toString().indexOf("<rt>"),sb.length());
903: //System.out.println(sb);
904: String rt =addToBundle(bundle,sb);
905: StringBuffer sb2=null;
906: int index=sb.toString().indexOf("<edoc>",3)+6,index2=0;
907: //for(int i=20;i<260;i=i+20)
908:
909:
910: while(true)
911: {
912: if(rt.equals("finished")) break;
913: conTest.url=new URL(url+"&rt="+rt);
914: conTest.get();
915: sb2=readChunked(conTest);
916: //sb2.delete(0,index);
917: // index2=sb2.toString().indexOf("<rt>",index);
918: // sb2.delete(index2,sb2.length());
919: //sb.append(sb2);
920: rt=addToBundle(bundle,sb2);
921: }
922: //sb.append("</edoc>");
923: //System.out.println(sb);
924: long timeEnd = System.currentTimeMillis();
925: System.err.println("time to get bundle data "+(timeEnd-time));
926:
927: /*
928: // read XML Metadata from a file
929: FileReader r=new FileReader("list7.xml");
930: sb=new StringBuffer();
931: // String response= conTest.getResponseMessage();
932: int c=0;
933: while ((c = r.read()) != -1)
934: {
935: char ch=(char)c;
936: sb.append(ch);
937: // System.out.print((char)c);
938: }
939: */
940: String data=sb.toString().length()+"";
941: // System.out.println(new String(sb.toString().getBytes(),"UTF-8"));
942: // System.out.println(sb.toString());
943: //addToBundle(bundle,sb);
944: // System.out.println(sb.toString());
945: // System.exit(0);
946:
947: } catch(Exception e) {e.printStackTrace();}
948: return bundle;
949: }
950: public static String addToBundle(Bundle bundle,StringBuffer sb)
951: {
952: boolean finished = false;
953: String rtTag="finished";
954: // parse string and build document tree
955: Node root = new Xparse().parse(sb.toString());
956: /*
957: Vector contents=root.index.v;
958: for (int i=0;i<contents.size();++i)
959: {
960: Node n=(Node)contents.elementAt(i);
961: if(n.type.equals("element"))
962: {
963: // System.out.println("tag "+n.name+" with contents ");
964: // System.out.println(n.getCharacters());
965: //contents=n.contents.v;i=0;
966: }
967: // System.out.println(n.type);
968:
969: }
970: */
971: Node tempNode=root.find(rootNode,new int[] {1});
972: if(tempNode==null) return rtTag;
973: int count=1;
974: /*
975: for(int i=0;i<tempNode.contents.v.size();++i)
976: {
977: // System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
978: }*/
979: if(tempNode.contents.v.size()==0) return rtTag;
980: Node notNull=null;
981: Node rtNode=root.find(rootNode+"/rt",new int[] {1,1});
982: rtTag=(rtNode==null) ? "finished":rtNode.getCharacters();
983: System.out.println("rt tag is "+ rtTag);
984: int length=0;//(tempNode.contents.length()-1)/2;
985: for(int i=0;i<tempNode.contents.v.size();++i) {
986: Node node=(Node)tempNode.contents.v.elementAt(i);
987: if(node.type.equals("element"))
988: if(node.name.equals("doc"))length++;
989: // System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
990: }
991: if(length==0) rtTag="finished";
992: while(count<=length)
993: {
994: //System.out.println(count+" "+length);
995: tempNode=root.find(rootNode+"/doc",new int[] {1,count});
996: if(tempNode==null)
997: {
998: rtTag="finished";
999: break;
1000: }
1001: Bundle.Document doc = new Bundle.Document();
1002: Hashtable attributes=tempNode.attributes;
1003: int docID=0;
1004: int ver=0;
1005: if(attributes != null)
1006: {
1007: docID=Integer.parseInt((String)attributes.get("id"));
1008: ver=Integer.parseInt((String)attributes.get("ver"));
1009: doc.addData("docID",(String)attributes.get("id"));
1010: doc.addData("ver",(String)attributes.get("ver"));
1011: }
1012: bundle.docs.put(new Integer(docID),doc);
1013: bundle.documents.addElement(doc);
1014: // System.out.println("id " +docID+" ver "+ver);
1015: Node fileNode=root.find(rootNode+"/doc/file",new int[] {1,count,1});
1016: attributes=(fileNode==null)? null:fileNode.attributes;
1017: int fileID=0;
1018: int fileVer=0;
1019: if(attributes != null)
1020: {
1021: fileID=Integer.parseInt((String)attributes.get("id"));
1022: fileVer=Integer.parseInt((String)attributes.get("ver"));
1023: doc.addData("fileID",(String)attributes.get("id"));
1024: doc.addData("fileVer",(String)attributes.get("ver"));
1025: // System.out.println("fileid " +fileID+" ver "+fileVer);
1026: }
1027: // add all Document tags to actual Document
1028: for(int i=0;i<tempNode.contents.v.size();++i)
1029: {
1030: Node node=(Node)tempNode.contents.v.elementAt(i);
1031: if(node.type.equals("element"))
1032: {
1033: //System.out.println(node.name+" "+node.getCharacters()+" "+node.contents.v.size());
1034: if(node.contents.v.size()>1)
1035: {
1036: for(int j=0;j<node.contents.v.size();++j)
1037: {
1038: Node node2=(Node)node.contents.v.elementAt(j);
1039: if(node2.type.equals("element"))
1040: {
1041: doc.addData(node2.name,node2.getCharacters());
1042: //System.out.println(node2.name+" "+node2.getCharacters()+" "+node2.contents.v.size());
1043: }
1044: }
1045: } else doc.addData(node.name,node.getCharacters());
1046: }
1047: }
1048: bundle.docsLocator.put(doc.locator,doc);
1049:
1050: //System.out.println( bundle.docsLocator);//doc.extraTags);
1051: /*
1052: notNull=root.find("edoc/doc/title",new int[]{1,count,1});
1053: String title=(notNull!=null) ? notNull.getCharacters():"missing";
1054: // System.out.println("edoc/doc/title "+title);
1055: notNull=root.find("edoc/doc/comment",new int[]{1,count,1});
1056: String comment = (notNull!=null) ? notNull.getCharacters():"missing";
1057: // System.out.println("edoc/doc/comment "+comment);
1058: notNull =root.find("edoc/doc/placeofevent",new int[]{1,count,1});
1059: String placeofevent = (notNull!=null) ? notNull.getCharacters():"missing";
1060: // System.out.println("edoc/doc/placeofevent "+placeofevent);
1061: notNull=root.find("edoc/doc/locater",new int[]{1,count,1});
1062: String locator=(notNull!=null) ? notNull.getCharacters():"missing";
1063: // System.out.println("edoc/doc/locater "+locator);
1064: notNull = root.find("edoc/doc/file/filename",new int[]{1,count,1,1});
1065: String fileName=(notNull!=null) ? notNull.getCharacters():"missing";
1066: // System.out.println("edoc/doc/file/filename "+fileName);
1067: notNull = root.find("edoc/doc/file/mimetype",new int[]{1,count,1,1});
1068: String mimeType=(notNull!=null) ? notNull.getCharacters():"missing";
1069: // System.out.println("edoc/doc/file/mimetype "+mimeType);
1070: notNull = root.find("edoc/doc/file/md5cs",new int[]{1,count,1,1});
1071: String md5cs = (notNull!=null) ? notNull.getCharacters():"missing";
1072: // System.out.println("edoc/doc/file/md5cs "+md5cs);
1073: notNull=root.find("edoc/doc/file/size",new int[]{1,count,1,1});
1074: int size =(notNull!=null) ? Integer.parseInt(notNull.getCharacters()):0;
1075: // System.out.println("edoc/doc/file/size "+size);
1076: notNull = root.find("edoc/doc/file/filelink",new int[]{1,count,1,1});
1077: String fileLink = (notNull!=null) ? notNull.getCharacters():"missing";
1078: // System.out.println("edoc/doc/file/filelink "+fileLink);
1079: Bundle.Document doc=new Bundle. Document(docID,ver,title,locator,comment,placeofevent,fileID,fileVer,fileName,mimeType,md5cs,size,fileLink);
1080: bundle.docs.put(new Integer(docID),doc);
1081: bundle.documents.addElement(doc);
1082: */
1083: count++;
1084: }
1085: // System.out.println(bundle.docs.size());
1086: return rtTag;
1087: }
1088: public static void getGenre()
1089: {
1090:
1091: try
1092: {
1093: String url="http://core.rz-berlin.mpg.de:80/edoctest/oi.epl?mm=help&sm=genres";
1094: // read XML document from URL into a string
1095: URL u = new URL(url);
1096: // FileReader r=new FileReader();
1097: long time = System.currentTimeMillis();
1098: // debug=true;
1099: Connection conTest=new Connection(new URL(url));
1100: conTest.ses=ses;
1101: conTest.get();
1102: StringBuffer sb=readChunked(conTest);
1103: Bundle.genresId.clear();
1104: Bundle.genresLabel.clear();
1105: Bundle.genresName.clear();
1106: Bundle.genVec.removeAllElements();
1107: getGenreList(sb);
1108: long timeEnd = System.currentTimeMillis();
1109: System.err.println("time to get genre data "+(timeEnd-time));
1110: // Enumeration en = Bundle.genres.keys();
1111: //while(en.hasMoreElements()
1112: if(debug)
1113: {
1114: Collections.sort(Bundle.genVec);
1115: // Bundle.Genre.debug=true;
1116:
1117: for(int i=0;i<Bundle.genVec.size();++i)
1118: System.out.println(Bundle.genresId.get(Bundle.genVec.get(i)));
1119: //System.out.println( Bundle.genres);
1120: }
1121: } catch(Exception e) {e.printStackTrace();}
1122: }
1123: public static String getGenreList(StringBuffer sb)
1124: {
1125: boolean finished = false;
1126: String rtTag="finished";
1127: // parse string and build document tree
1128: Node root = new Xparse().parse(sb.toString());
1129: /*
1130: Vector contents=root.index.v;
1131: for (int i=0;i<contents.size();++i)
1132: {
1133: Node n=(Node)contents.elementAt(i);
1134: if(n.type.equals("element"))
1135: {
1136: // System.out.println("tag "+n.name+" with contents ");
1137: // System.out.println(n.getCharacters());
1138: //contents=n.contents.v;i=0;
1139: }
1140: // System.out.println(n.type);
1141:
1142: }
1143: */
1144: Node tempNode=root.find(rootNode,new int[] {1});
1145: if(tempNode==null) return rtTag;
1146: int count=1;
1147: /*
1148: for(int i=0;i<tempNode.contents.v.size();++i)
1149: {
1150: // System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
1151: }*/
1152: if(tempNode.contents.v.size()==0) return rtTag;
1153: Node notNull=null;
1154: int length=0;
1155: for(int i=0;i<tempNode.contents.v.size();++i) {
1156: Node node=(Node)tempNode.contents.v.elementAt(i);
1157: if(node.type.equals("element"))
1158: if(node.name.equals("genre"))length++;
1159: // System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
1160: }
1161: if(length==0) rtTag="finished";
1162: while(count<=length)
1163: {
1164: //System.out.println(count+" "+length);
1165: tempNode=root.find(rootNode+"/genre",new int[] {1,count});
1166: if(tempNode==null)
1167: {
1168: rtTag="finished";
1169: break;
1170: }
1171: Bundle.Genre genre= new Bundle.Genre();
1172: Hashtable attributes=tempNode.attributes;
1173: Integer id=null;
1174: if(attributes != null)
1175: {
1176: genre.id=new Integer((String)attributes.get("id"));
1177: }
1178: for(int i=0;i<tempNode.contents.v.size();++i)
1179: {
1180: Node node=(Node)tempNode.contents.v.elementAt(i);
1181: if(node.type.equals("element"))
1182: {
1183: //System.out.println(node.name+" "+node.getCharacters()+" "+node.contents.v.size());
1184: if(node.contents.v.size()>1)
1185: {
1186: for(int j=0;j<node.contents.v.size();++j)
1187: {
1188: Node node2=(Node)node.contents.v.elementAt(j);
1189: if(node2.type.equals("element"))
1190: {
1191: //genre.addData(node2.name,node2.getCharacters());
1192: //System.out.println(node2.name+" "+node2.getCharacters()+" "+node2.contents.v.size());
1193: }
1194: }
1195: } else genre.addData(node.name,node.getCharacters());
1196: }
1197: }
1198: Bundle.genresId.put(genre.id,genre);
1199: Bundle.genresLabel.put(genre.label.toLowerCase(),genre.id);
1200: Bundle.genresName.put(genre.name.toLowerCase(),genre.id);
1201: Bundle.genVec.addElement(genre.id);
1202: count++;
1203: }
1204: // System.out.println(bundle.docs.size());
1205: return rtTag;
1206: }
1207:
1208: public static void main(String args[])
1209: {
1210: // System.out.println("Bundle for http://core.rz-berlin.mpg.de/edocmike/oi.epl?mm=list&grp=90");
1211: // getBundle("");
1212: // System.out.println("Bundle for http://core.rz-berlin.mpg.de/edocmike/oi.epl?mm=list&grp=89");
1213: // getBundle("http://core.rz-berlin.mpg.de/edoctest/oi.epl?mm=list&grp=136");
1214: // getBundle("http://core.rz-berlin.mpg.de/edoctest/oi.epl?mm=list&grp=136");
1215: runningAsApplet=false;
1216: // Object[] options = new Object[] { "New Version for this file","New Version for all files", "Skip file" };
1217:
1218: // int option = showDialog("Warning exists! \n What do you want to do?", "Destination exists!", options,null);
1219:
1220: long time = System.currentTimeMillis();
1221: new Upload();
1222: // bundle=getBundle("http://core.rz-berlin.mpg.de/edoctest/oi.epl?mm=list&grp=136&col=11");
1223: url="http://core.rz-berlin.mpg.de/edoctest/";
1224: bundleRef = getBundle(url+"oi.epl?mm=list&grp="+grp+"&col="+col);
1225: getGenre();
1226: //getMetaData("");
1227: // if(true)System.exit(0);
1228: /* Hashtable data=getMetaData("");
1229: //if(true)System.exit(0);
1230: try
1231: {
1232: // old edocmike
1233: Connection con= new Connection(new URL("http://core.rz-berlin.mpg.de:80/edoctest/adm.epl"));
1234: String ses=con.getSessionID("name=root&passwd=&mode=verifylogin");
1235: //("name=dwinter&passwd=e1nste1n&mode=verifylogin");
1236: con.socket.close();
1237: Vector artist=(Vector)data.get("artist");
1238: Vector picture=(Vector)data.get("picture");
1239: Vector idnr=(Vector)data.get("IDNR");
1240: Vector source=(Vector)data.get("source");
1241: Connection conPost=new Connection( new URL("http://core.rz-berlin.mpg.de:80/edoctest/oi.epl"));
1242: // new URL("http://localhost:8080/examples/servlet/rogo/"));
1243: conPost.ses=ses;
1244:
1245: for(int i=135;i<136;++i)//i<artist.size();++i)
1246: {
1247: // System.out.println("artist "+artist.elementAt(i));
1248: // System.out.println("picture nr "+ i +" name "+picture.elementAt(i));
1249: // System.out.println("file" +idnr.elementAt(i));
1250: // System.out.println("source"+source.elementAt(i));
1251: // if(!new File("/Volumes/data/tmp/Bildarchiv-Daston/400/"+idnr.elementAt(i)).exists())
1252: // System.out.println("file "+idnr.elementAt(i) +" does not exist");
1253: // if(idnr.elementAt(i)!=null)
1254: // if(idnr.elementAt(i).toString().indexOf("Ÿ")>=0||idnr.elementAt(i).toString().indexOf("š")>=0||idnr.elementAt(i).toString().indexOf("Š")>=0)
1255: // System.out.println("file "+idnr.elementAt(i) +" contains umlaut ");
1256:
1257: if(new File("/Volumes/data/tmp/Bildarchiv-Daston/400/"+idnr.elementAt(i)).exists())
1258: conPost.post(new File("/Volumes/data/tmp/Bildarchiv-Daston/400/"+idnr.elementAt(i)),picture.elementAt(i).toString(),artist.elementAt(i). toString(),source.elementAt(i).toString());
1259: // conPost.post(new File("./test2.jpg"),picture.elementAt(i).toString(),artist.elementAt(i).toString(),source.elementAt(i).toString());
1260:
1261: }// to for
1262:
1263: } catch(Exception e)
1264: {
1265: e.printStackTrace();
1266: }
1267: */
1268: long time2 = System.currentTimeMillis();
1269: // System.out.println("time elapsed for upload " +((time2-time)/1000)+" seconds");
1270: }
1271: static class Connection
1272: {
1273: Socket socket;
1274: URL url;
1275: BufferedInputStream in;
1276: PrintStream out;
1277: String pHost;
1278: int pPort = 80;
1279: String proxyHost="";
1280: String ses="";
1281: HttpURLConnection con;
1282: UploadInfo dialog = new UploadInfo();
1283: public Connection(URL url) throws Exception
1284: {
1285: Properties prop = System.getProperties();
1286: pHost = null;
1287: pPort = 80;
1288: Enumeration en = prop.propertyNames();
1289: while (en.hasMoreElements())
1290: {
1291: String key = (String) en.nextElement();
1292: if (key.toString().indexOf("proxyHost") >= 0)
1293: {
1294: Object host = prop.get(key);
1295: if (host != null)
1296: pHost = host.toString();
1297: }
1298: if (key.toString().indexOf("proxyPort") >= 0)
1299: {
1300: Object port = prop.get(key);
1301: if (port != null)
1302: pPort = Integer.parseInt(port.toString());
1303: }
1304: }
1305:
1306: if (proxyHost != "")
1307: {
1308: int index = proxyHost.indexOf(":");
1309: pHost = proxyHost.substring(0, (index > 0) ? index : proxyHost.length());
1310: pPort = (index > 0) ? Integer.parseInt(proxyHost.substring(index + 1)) : 80;
1311: }
1312: int port = (url.getPort()>0) ? url.getPort():80;
1313: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort :port );
1314: socket.setTcpNoDelay(true);
1315: in = new BufferedInputStream(socket.getInputStream(),2);
1316: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1317: this.url = url;
1318: }
1319: public String getSessionID(String data)
1320: {
1321: try
1322: {
1323: int size=data.length();
1324: // System.out.println("Yeah i called connect");
1325: // socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
1326: // socket.setTcpNoDelay(true);
1327: in = new BufferedInputStream(socket.getInputStream());
1328: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1329:
1330: out.print(("POST " + url + " HTTP/1.1\r\nContent-Type: application/x-www-form-urlencoded'\r\nContent-Length:" + size + "\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
1331: out.print(data);
1332: out.flush();
1333: String response=getResponseMessage();
1334: int index=response.indexOf("Set-Cookie");
1335: int index2=response.indexOf("\r\n",index);
1336: String cookie=response.substring(index,index2);
1337: index=cookie.indexOf("=");
1338:
1339: // // System.out.print(response);
1340: System.err.println("Session key: "+cookie.substring(index+1));
1341: return cookie.substring(index+1);//sessionID
1342: } catch (Exception e)
1343: {
1344: // System.out.println(e);
1345: }
1346: return "";
1347: }
1348: public void post(File file,String mode,String docID,String title,String author,String source) {
1349: try
1350: {
1351: // System.out.println("Yeah i called post");
1352: in = new BufferedInputStream(socket.getInputStream());
1353: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1354: /*if(in.isClosed())
1355: {
1356: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
1357: socket.setTcpNoDelay(true);
1358: in = new BufferedInputStream(socket.getInputStream());
1359: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1360: }*/
1361: FileInputStream f=new FileInputStream(file);
1362: int length=f.available();
1363: // ses="37b9cec1da340f16f5ef603112e6fe84";
1364: /*
1365: String data = "--xYzZY\r\nContent-Disposition: form-data; name=\"mm\"\r\n\r\ninput\r\n"+
1366: "--xYzZY\r\nContent-Disposition: form-data; name=\"ses\"\r\n\r\n"+ses+"\r\n"
1367: +"--xYzZY\r\nContent-Disposition: form-data; name=\"col\"\r\n\r\n"+"11"+"\r\n"
1368: +"--xYzZY\r\nContent-Disposition: form-data; name=\"grp\"\r\n\r\n"+"78"+"\r\n"
1369: +"--xYzZY\r\nContent-Disposition: form-data; name=\"bun\"\r\n\r\n"+"78"+"\r\n"
1370: +"--xYzZY\r\nContent-Disposition: form-data; name=\"sm\"\r\n\r\n"+"new"+"\r\n"
1371: // +"--xYzZY\r\nContent-Disposition: form-data; name=\"ver\"\r\n\r\n"+"0"+"\r\n"
1372: +"--xYzZY\r\nContent-Disposition: form-data; name=\"docid\"\r\n\r\n"+"10924"+"\r\n"
1373: +"--xYzZY\r\nContent-Disposition: form-data; name=\"gentyp\"\r\n\r\n"+"43"+"\r\n"
1374: +"--xYzZY\r\nContent-Disposition: form-data; name=\"title\"\r\n\r\n"+"sometitlexyz"+"\r\n"
1375: +"--xYzZY\r\nContent-Disposition: form-data; name=\"placeofevent\"\r\n\r\n"+"someplaceofevent"+"\r\n"
1376: +"--xYzZY\r\nContent-Disposition: form-data; name=\"locater\"\r\n\r\n"+"somelocator"+"\r\n"
1377: +"--xYzZY\r\nContent-Disposition: form-data; name=\"authorcomment\"\r\n\r\n"+"somecomment"+"\r\n"
1378: +"--xYzZY\r\nContent-Disposition: form-data; name=\"nfiles\"\r\n\r\n"+"1"+"\r\n"
1379: +"--xYzZY\r\nContent-Disposition: form-data; name=\"file1\"; filename=\"test1.jpg\"\r\n"+"Content-Length: "+length+"\r\n"+"Content-Type: image/jpeg"+"\r\n\r\n"; // file data+end data
1380: */
1381:
1382: FormData formData=new FormData(file,ses,col,grp,mode,"0",docID);
1383: //format for const File file,String ses,String col,String grp,String sm,String ver,String docid
1384: formData.addEntry("title",title);
1385: formData.addEntry("placeofevent",author);
1386: formData.addEntry("comment",source);
1387: formData.addEntry("locater",source);
1388: formData.addFile(formData.file.getName(),"image/tiff",length+"");
1389: String data=formData.buff.toString();
1390: String ftacc1="--xYzZY\r\nContent-Disposition: form-data; name=\"ftacc1\"\r\n\r\n"+"PUBLIC"+"\r\n";
1391:
1392: System.err.println("cl "+(data.length()+length+ 13 + ftacc1.length()));
1393: out.print(("POST " + url + " HTTP/1.1\r\n"+"Content-Length:"+(data.length()+length+13+ftacc1.length())+"\r\n"+"Content-Type: multipart/form-data, boundary=xYzZY\r\n"
1394: +"Cookie: EMBPERL_UID="+ses+"\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
1395: //+"Host: " + url.getHost() + "\r\n\r\n"));
1396: // out.print(("POST " + url + " HTTP/1.1\r\nContent-Type: application/x-www-form-//urlencoded'\r\nContent-//Length:" + size + "\r\nCookie: EMBPERL_UID="+ses+"\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
1397: out.print(data);
1398: if(debug)
1399: System.out.print(data);
1400: // System.out.println("Finished upload");
1401: // System.out.println("Content-Length "+(data.length()+11+length));
1402: // System.out.print("\r\n--xYzZY--\r\n");// 11 bytes
1403: // System.out.print("\r\n");
1404: sendFile(f,out);
1405: out.print("\r\n");
1406: out.print(ftacc1);
1407: if(debug)
1408: System.out.print(ftacc1);
1409: out.print("--xYzZY--\r\n");
1410: if(debug)
1411: System.out.print("--xYzZY--\r\n");
1412: // System.err.println("Yeah i called connect");
1413: dialog.progress.setValue(99);
1414: String response=getResponseMessage();
1415: System.err.print(response);
1416: if(response.toLowerCase().indexOf("content-length")>=0||(response.toLowerCase().indexOf("content-type")>=0))
1417: {
1418: int c=0;
1419: while ((c = in.read()) != -1)
1420: {
1421: System.err.print((char)c);
1422: }
1423: }
1424: } catch (Exception e)
1425: {
1426: // System.out.println(e);
1427: }
1428: }
1429: public void post(String path,Bundle.Document doc,String mode) throws Exception{
1430: // try
1431: // {
1432: System.out.println("Yeah i called post");
1433: in = new BufferedInputStream(socket.getInputStream());
1434: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1435: /*if(in.isClosed())
1436: {
1437: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
1438: socket.setTcpNoDelay(true);
1439: in = new BufferedInputStream(socket.getInputStream());
1440: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1441: }*/
1442: String name = doc.fileLink.trim().startsWith("file://") ?doc.fileLink.trim().substring(7):doc.fileLink.trim();
1443: System.out.println(name);
1444: String filePath = name.startsWith("/") ? name:path+name;
1445: FileInputStream f=new FileInputStream( filePath);
1446: int length=f.available();
1447:
1448: FormData formData=new FormData(new File(doc.fileName),ses,col,grp,mode,"1",doc.docID+"",doc.type);// "1" means new version if mode == old
1449: //format for const File file,String ses,String col,String grp,String sm,String ver,String docid
1450: Enumeration en = doc.metaTags.keys();
1451: while(en.hasMoreElements())
1452: {
1453: String key=(String)en.nextElement();
1454: formData.addEntry(key,(String)doc.metaTags.get(key));
1455: }
1456: formData.addFile(formData.file.getName(),doc.mimeType,length+"");
1457: String data=formData.buff.toString();
1458: //System.out.print(data);
1459: String ftacc1="--xYzZY\r\nContent-Disposition: form-data; name=\"ftacc1\"\r\n\r\n"+"PUBLIC"+"\r\n";
1460:
1461: System.err.println("cl "+(data.length()+length+ 13 + ftacc1.length()));
1462: out.print(("POST " + url + " HTTP/1.1\r\n"+"Content-Length:"+(data.length()+length+13+ftacc1.length())+"\r\n"+"Content-Type: multipart/form-data, boundary=xYzZY\r\n"
1463: +"Cookie: EMBPERL_UID="+ses+"\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
1464: //+"Host: " + url.getHost() + "\r\n\r\n"));
1465: // out.print(("POST " + url + " HTTP/1.1\r\nContent-Type: application/x-www-form-//urlencoded'\r\nContent-//Length:" + size + "\r\nCookie: EMBPERL_UID="+ses+"\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
1466: out.print(data);
1467: if(out.checkError()) throw new Error("Error while sending form data");
1468: if(debug)
1469: System.out.print(data);
1470: // System.out.println("Finished upload");
1471: // System.out.println("Content-Length "+(data.length()+11+length));
1472: // System.out.print("\r\n--xYzZY--\r\n");// 11 bytes
1473: // System.out.print("\r\n");
1474: sendFile(f,out);
1475: out.print("\r\n");
1476: out.print(ftacc1);
1477: if(debug)
1478: System.out.print(ftacc1);
1479: out.print("--xYzZY--\r\n");
1480: if(debug)
1481: System.out.print("--xYzZY--\r\n");
1482: // System.err.println("Yeah i called connect");
1483: dialog.progress.setValue(99);
1484: // String response=getResponseMessage();
1485: // System.err.print(response);
1486: int c=0;StringBuffer sb = new StringBuffer();
1487: sb=readChunked(this);
1488: if(debug)
1489: System.out.println(sb);
1490: if(sb.length()>0)
1491: addToBundle(bundleRef,sb);
1492: try
1493: {
1494:
1495: Bundle.Document newDoc =(Bundle.Document) bundleRef.docsLocator.get(doc.locator);
1496: doc.md5cs=newDoc.md5cs;
1497: doc.size=newDoc.size;
1498: doc.fileID=newDoc.fileID;
1499: doc.docID=newDoc.docID;
1500: doc.ver=newDoc.ver;
1501: doc.fileVer=newDoc.fileVer;
1502: bundle.exportToXML(new File("./metaout.xml"));
1503: } catch(Exception e7) { e7.printStackTrace();}
1504: }
1505:
1506: public void sendFile(FileInputStream f,PrintStream out) throws Exception
1507: {
1508: int length=f.available();
1509: md.reset();
1510: dialog.progress.setValue(0);
1511: byte[] b=new byte[512];
1512: int readCount =0;
1513: while (readCount < length)
1514: {
1515: if (readCount + b.length > length)
1516: f.read(b, 0, length - readCount); // mout.flush();
1517: else
1518: f.read(b);
1519: if (readCount + b.length > length)
1520: {
1521: out.write(b, 0, length - readCount); // mout.flush();
1522: md.update(b, 0, length - readCount);
1523: if(out.checkError()) throw new Error("Error while sending file data");
1524: //if(debug)
1525: //System.out.write(b, 0, length - readCount); // mout.flush();
1526: }
1527: else
1528: {
1529: // if(debug)
1530: //System.out.write(b); // mout.flush();
1531: out.write(b);
1532: if(out.checkError()) throw new Error("Error while sending file data");
1533: md.update(b, 0, b.length);
1534: }
1535: readCount += b.length;
1536: dialog.progress.setValue((int) (((double) readCount / (double) length) * 100.0));
1537: }
1538:
1539: }
1540: public void get() throws Exception
1541: {
1542: try
1543: {
1544: // System.out.println("Yeah i called connect");
1545: // socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
1546: // socket.setTcpNoDelay(true);
1547: in = new BufferedInputStream(socket.getInputStream());
1548: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1549:
1550: // out.print(("PUT " + url + " HTTP/1.1\r\nContent-Type: text/html\r\nContent-Length:" + size + "\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
1551: out.print(("GET " + url + " HTTP/1.1\r\nCookie: EMBPERL_UID="+ses+"\r\nHost: " + url.getHost() + "\r\n\r\n"));
1552: out.flush();
1553: } catch (Exception e)
1554: {
1555: int port = (url.getPort()>0) ? url.getPort():80;
1556:
1557: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
1558: socket.setTcpNoDelay(true);
1559: in = new BufferedInputStream(socket.getInputStream());
1560: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1561: // out.print(("PUT " + url + " HTTP/1.1\r\nContent-Type:text/html\r\nContent-Length:" + size + "\r\nHost: " + url. getHost() + "\r\n\r\n"));
1562: out.flush();
1563: // System.out.println("Error "+e);
1564: }
1565:
1566: /*
1567: con = new HTTPClient.HttpURLConnection(url);//(HttpURLConnection) url.openConnection(); // con.setRequestMethod("GET");
1568: con.setUseCaches(false);
1569: con.setRequestMethod("PUT");
1570: con.setDoOutput(true);
1571: con.setRequestProperty("Content-Length", ""+size);
1572: // con.connect();
1573: // System.out.println(con.getClass());
1574: out = new DataOutputStream(con.getOutputStream());
1575: */
1576: }
1577: public boolean update() throws Exception
1578: {
1579: boolean exists = false;
1580: String response = "";
1581: try
1582: {
1583:
1584: URL url = null;//createURL(this.url.toString(), getSHA((id + "").getBytes()));
1585: // con = new HTTPClient.HttpURLConnection(url);//(HttpURLConnection) url.openConnection(); // con.setRequestMethod("GET");
1586: //con.setUseCaches(false);
1587: // con.setRequestMethod("HEAD");
1588: //con.setDoOutput(true);
1589: // con.connect();
1590:
1591: out.print(("HEAD " + url + " HTTP/1.1\r\nConnection:Keep-Alive\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
1592: out.flush();
1593: response = getResponseMessage();
1594: exists = response.indexOf("OK") >= 0;
1595: // System.out.println("Head "+response);
1596:
1597: } catch (Exception e)
1598: {
1599: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
1600: socket.setTcpNoDelay(true);
1601: in = new BufferedInputStream(socket.getInputStream());
1602: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1603: // out.writeBytes("HEAD " + url + " HTTP/1.1\r\n Connection:Keep-Alive\r\n \r\nHost: " + url.getHost() + //"\r\n\r\n");
1604: URL url = null;//createURL(this.url.toString(), getSHA((id + "").getBytes()));
1605: out.print(("HEAD " + url + " HTTP/1.1\r\nConnection:Keep-Alive\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
1606: out.flush();
1607: response = getResponseMessage();
1608: // System.out.println("Head " + response);
1609: exists = response.indexOf("OK") >= 0;
1610: //// System.out.println("Error from Head "+e);
1611: // e.printStackTrace();
1612: return exists;
1613:
1614: }
1615: return exists;
1616: }
1617:
1618: public String getResponseMessage()
1619: {
1620:
1621: int b=0;StringBuffer between=new StringBuffer();int count=0;
1622: try
1623: {
1624: int loop =0;int available = 0;
1625: while((available=in.available())==0)
1626: {
1627: if(loop>=3000) throw new Error("Connection timed out");
1628: long time = System.currentTimeMillis();
1629: while(System.currentTimeMillis()-time<100);
1630: if(available==0) loop++; else loop=0;
1631: }
1632: System.out.println("heh there are bytes "+in.available()+" available");
1633: int limit = in.available();
1634: while(true )
1635: {
1636: b=in.read();
1637: if(b=='\r')
1638: {
1639: between.append((char)b);
1640: // System.out.print("CR found ");
1641: b=in.read();
1642: if(b=='\n')
1643: {
1644: // System.out.print("LF found ");
1645: between.append((char)b);
1646: if((b=in.read())=='\r')
1647: {
1648: b=in.read();
1649: // System.out.print("end found ");
1650: break;
1651: }
1652: }
1653: }
1654: between.append((char)b);
1655: // System.out.print((char)b);
1656: // System.out.println("read "+count+" bytes");
1657: count++;
1658: if(count==limit) break;
1659: }
1660:
1661: } catch(Exception e) {
1662: e.printStackTrace();
1663: // System.out.println("Error found");
1664: if(e.toString().indexOf("peer")>=0)
1665: return getResponseMessage();
1666: else throw new Error("Error while reading response");
1667: }
1668:
1669: /*
1670: String response = "";
1671: try
1672: {
1673: response = con.getResponseMessage();
1674: // con.disconnect();
1675: } catch (Exception e)
1676: {
1677: showErrorDialog(e.getMessage(),"Shit happens");
1678: }
1679: */
1680: String response = between.toString();
1681: if(response.indexOf("close") >= 0)
1682: reconnect();
1683: return response;
1684:
1685: }
1686: public void disconnect() throws Exception
1687: {
1688: //socket.close();
1689: // con.disconnect();
1690: }
1691: public void reconnect()
1692: {
1693: try
1694: {
1695: System.out.println("Reconnect called");
1696: int port= (url.getPort()>=0) ? url.getPort():80;
1697: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort :port);
1698: socket.setTcpNoDelay(true);
1699: in = new BufferedInputStream(socket.getInputStream());
1700: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
1701:
1702: } catch(Exception e)
1703: {
1704: showErrorDialog(e.getMessage(),"Shit happens");
1705: }
1706:
1707: }
1708:
1709: }
1710: public static class FormData
1711: {
1712: public StringBuffer buff=new StringBuffer();
1713: File file;
1714: public FormData()
1715: {}
1716: public FormData(File file,String ses,String col,String grp,String sm,String ver,String docid)
1717: {
1718: this(file,ses,col,grp,sm,ver,docid,"Archimedes Image Collection");
1719: }
1720: public FormData(File file,String ses,String col,String grp,String sm,String ver,String docid,String type)
1721: {
1722: this.file=file;
1723: addEntry("mm","input");
1724: addEntry("ses",ses);
1725: addEntry("col",col);
1726: addEntry("grp",grp);
1727: //addEntry("bun",bun);
1728:
1729: if(sm.equals("old"))
1730: {
1731: addEntry("sm","old");
1732: addEntry("ver",ver);
1733: addEntry("docid",docid);
1734:
1735: }
1736: else
1737: addEntry("sm","new");
1738: System.out.println("Type is "+type);
1739: type=type.toLowerCase().trim();
1740: Object genre=null;
1741: if((genre=Bundle.genresLabel.get(type))!=null)
1742: addEntry("gentyp",genre.toString());
1743: else if((genre=Bundle.genresName.get(type))!=null)
1744: addEntry("gentyp",genre.toString());
1745: else
1746: {
1747: Integer id=new Integer("0");
1748: id= new Integer(type);
1749: if((genre=Bundle.genresId.get(id))!=null)
1750: addEntry("gentyp",((Bundle.Genre)genre).id.toString());
1751: }
1752: System.out.println("Numerical Type is "+genre);
1753: }
1754: public void addEntry(String entry,String data)
1755: {
1756: buff.append("--xYzZY\r\nContent-Disposition: form-data; name=\"");
1757: buff.append(entry);
1758: buff.append("\"; charset=utf-8 \r\n\r\n");
1759: buff.append(data);
1760: buff.append("\r\n");
1761: }
1762: public void addFile(String name,String type,String length)
1763: {
1764: addEntry("nfiles","1");
1765: buff.append("--xYzZY\r\nContent-Disposition: form-data; name=\"file1\"");
1766: buff.append("; filename=\""+name+"\""+"\r\nContent-Length: "+length+"\r\n"+"Content-Type:"+type+"\r\n");
1767: buff.append("\r\n");
1768: }
1769:
1770: public void addEnd()
1771: {
1772: buff.append("\r\n--xYzZY--\r\n");
1773: }
1774:
1775: }
1776: static class UploadFilter implements FilenameFilter
1777: {
1778: public UploadFilter() {}
1779: public boolean accept(File dir, String name)
1780: {
1781: if(name.startsWith(".") || name.endsWith(".xml")) return false;
1782: else return true;
1783: }
1784: }
1785:
1786: static class DotFileFilter implements FilenameFilter
1787: {
1788: public DotFileFilter() {}
1789: public boolean accept(File dir, String name)
1790: {
1791: if(name.startsWith(".")) return false;
1792: else return true;
1793: }
1794: }
1795: static class XMLFilter extends javax.swing.filechooser.FileFilter
1796: {
1797: public boolean accept(java.io.File file)
1798: {
1799: if(file.getName().toLowerCase().endsWith(".xml")||file.isDirectory())
1800: return true ;
1801: else return false;
1802: }
1803: public String getDescription()
1804: {
1805: return "Metadata XML File";
1806: }
1807:
1808: }
1809: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/cvs/cvsweb/icons/back.gif){kind=icon}
Return to Upload.java CVS log ![[TXT]](/cvs/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvs/cvsweb/icons/dir.gif){kind=icon}
Up to [Repository] / edoc-applet