Annotation of upload-applet/ServerWriter.java, revision 1.1.1.1
1.1 rogo 1: /**
2: * @author rogo
3: *
4: * To change this generated comment edit the template variable "typecomment":
5: * Window>Preferences>Java>Templates.
6: * To enable and disable the creation of type comments go to
7: * Window>Preferences>Java>Code Generation.
8: */
9: import java.net.*;
10: import java.io.*;
11: import javax.swing.*;
12: import java.awt.*;
13: import java.awt.event.*;
14: import java.security.*;
15: import java.util.*;
16:
17: public class ServerWriter extends JApplet implements ActionListener
18: {
19: static File startFile;
20: static int count = 0;
21: static JFileChooser fileChooser;
22: static String url;
23: static long id = 0L;
24: static Hashtable connections=new Hashtable();
25: JButton upload = new JButton("Upload");
26: JRadioButton proxy = new JRadioButton("Proxy");
27: static int fileCount = 0;
28: // static UploadInfo dialog = new UploadInfo();
29: static String mode = "";
30: static String destination = "";
31: static String prefix = "";
32: static String proxyHost = "";
33: ServerWriter uploader = this;
34: static final int md5Length = 32;
35: public ServerWriter()
36: {
37:
38: }
39: public void init()
40: {
41: this.getContentPane().setLayout(new FlowLayout(FlowLayout.LEFT, 0, 0));
42: this.getContentPane().add(upload);
43: this.getContentPane().add(proxy);
44: upload.addActionListener(this);
45: proxy.addActionListener(this);
46: id = System.currentTimeMillis();
47: Properties prop = System.getProperties();
48:
49: // prop.put("proxySet", "true");
50: // prop.put("http.proxyHost","proxy.unibe.ch");
51: // prop.put("proxyPort", "80");
52: prop.put("java.protocol.handler.pkgs","HTTPClient");
53: fileChooser=null;
54: }
55: public void actionPerformed(ActionEvent e)
56: {
57: if (e.getSource().equals(proxy))
58: {
59: proxyHost = JOptionPane.showInputDialog("Please enter proxy host (format host:port)!");
60: if (proxyHost != null)
61: {
62: if (proxyHost.length() == 0)
63: {
64: proxyHost = "";
65: Properties prop = System.getProperties();
66: prop.remove("proxySet");
67: prop.remove("http.proxyHost");
68: prop.remove("proxyPort");
69:
70: }
71: else
72: {
73: Properties prop = System.getProperties();
74: int index = proxyHost.indexOf(":");
75: String pHost = proxyHost.substring(0, (index > 0) ? index : proxyHost.length());
76: String pPort = (index > 0) ? proxyHost.substring(index + 1) : "80";
77:
78: prop.put("proxySet", "true");
79: prop.put("http.proxyHost",pHost);
80: prop.put("proxyPort", pPort);
81: }
82: System.out.println("pr "); // proxyHost="";
83: } else
84: proxyHost = "";
85: // proxy.setSelected(false);
86: }
87:
88: if (e.getActionCommand().equals("Upload"))
89: {
90:
91: //url=getParameter("url");
92: set();
93: System.out.println("url " + url); //+ " " + getCodeBase());
94: upload.setEnabled(false);
95: main(new String[] { "", "" });
96: upload.setEnabled(true);
97: }
98:
99: }
100: public void set()
101: {
102: String url = getParameter("baseURL");
103: String servletURL = getParameter("servletURL");
104: destination = "";
105: destination = getParameter("destinationFolder");
106: if (destination == null)
107: destination = "";
108: prefix = getParameter("prefix");
109: if(prefix == null) prefix="";
110: // e.g."/rogo/servlet/RWServlet/"
111: URL appletUrl = getCodeBase();
112: String serverInfo = appletUrl.getHost() + ":" + appletUrl.getPort();
113: this.url = (servletURL.startsWith("http")) ? servletURL + url : "http://" + serverInfo + servletURL + url;
114: Properties prop = System.getProperties();
115:
116: // prop.put("proxySet", "true");
117: // prop.put("http.proxyHost","proxy.unibe.ch");
118: // prop.put("proxyPort", "80");
119: // prop.put("java.protocol.handler.pkgs","HTTPClient");
120: Enumeration en = prop.propertyNames();
121: while (en.hasMoreElements())
122: {
123: String key = (String) en.nextElement();
124: System.out.println("key: " + key + " value: " + prop.get(key));
125:
126: }
127: }
128: public static void main(String[] args)
129: {
130: try
131: {
132: if (fileChooser == null)
133: {
134: fileChooser = new JFileChooser();
135: fileChooser.setFileSelectionMode(fileChooser.FILES_AND_DIRECTORIES);
136: fileChooser.setFileFilter(new ImageFilter());
137: fileChooser.setDialogType(JFileChooser.OPEN_DIALOG);
138: fileChooser.addActionListener(new ActionListener()
139: {
140: public void actionPerformed(ActionEvent e2)
141: {
142: System.out.println(e2.getActionCommand());
143: if (!e2.getActionCommand().toString().equals("ApproveSelection")) return;
144: // {
145:
146: Thread thread = new Thread()
147: {
148: public void run()
149: {
150: UploadInfo dialog = new UploadInfo();
151:
152: File startFile=new File(".");
153: try
154: {
155: dialog.thread=Thread.currentThread();
156: System.out.println("Called run with " + fileChooser.getSelectedFile());
157: dialog.setTitle("Upload Status Window");
158: dialog.setSize(400, 175);
159: dialog.setLocation(new java.awt.Point(150, 100));
160: Update update = new Update();
161: startFile = fileChooser.getSelectedFile(); //new File(fileChooser.getFile());
162: int fileCount = 0;
163: int count = 1;
164: System.out.println(startFile);
165: long time = System.currentTimeMillis();
166: if( connections.get(startFile.getAbsolutePath())!=null)
167: throw new Error("Upload already running!");
168:
169: if (startFile.isDirectory())
170: {
171: fileCount = countFiles(startFile, fileCount);
172: System.out.println("Number of files to send: " + fileCount);
173: writeDirectory(startFile, startFile, fileCount, count, dialog, update);
174:
175: } else
176: {
177: fileCount = 1;
178: writeStream(startFile, startFile, fileCount, count, dialog, update);
179:
180: }
181:
182: long time2 = System.currentTimeMillis();
183: System.out.println("needed " + (time2 - time) + " ms for " + count--);
184: dialog.setVisible(false);
185: if (startFile.isDirectory())
186: showDialog("Finished upload of " + startFile + " containing " + fileCount + " " + ((fileCount > 1) ? " files" : " file") + " in " + ((time2 - time) / 1000) + " seconds", "Finished Upload");
187: else
188: showDialog("Finished upload of " + startFile + " in " + ((time2 - time) / 1000) + " seconds", "Finished Upload");
189: connections.remove(startFile.getAbsolutePath());
190: } catch (Exception e)
191: {
192: dialog.setVisible(false);
193: ByteArrayOutputStream b = new ByteArrayOutputStream();
194: PrintStream stream = new PrintStream(b);
195: e.printStackTrace(stream);
196: connections.remove(startFile.getAbsolutePath());
197:
198: showErrorDialog(b.toString(), "Upload failed");
199: } catch (Error e8)
200: {
201: dialog.setVisible(false);
202: if( e8.toString().indexOf("Upload already running!")<0)
203: connections.remove(startFile.getAbsolutePath());
204: showErrorDialog(e8.toString(), "Upload failed");
205: }
206:
207: }
208: };
209: thread.setPriority(Thread.MIN_PRIORITY);
210: /* dialog = new UploadInfo();
211: dialog.setTitle("Upload Status Window");
212: dialog.setSize(400, 155);
213: dialog.setLocation(new java.awt.Point(150, 100));
214: */
215: thread.start();
216: // } // else
217: //System.exit(0);
218: }
219: });
220:
221: }
222: count = 1;
223: mode = "";
224: fileChooser.showDialog(new JFrame(), "Upload");
225:
226: } catch (Exception e)
227: {
228: System.out.println("Ha " + e);
229: }
230: }
231: private static int countFiles(File file, int fileCount)
232: {
233: if (file.isDirectory())
234: {
235: String[] files = file.list(new DotFileFilter());
236:
237: for (int j = 0; j < files.length; ++j)
238: {
239: File f = new File(file + File.separator + files[j]);
240: if (f.isDirectory())
241: {
242: fileCount = countFiles(f, fileCount);
243: } else
244: fileCount = fileCount + 1;
245: }
246:
247: }
248: return fileCount;
249: }
250:
251: private static int writeDirectory(File file, File startFile, int fileCount, int count, UploadInfo dialog, Update update) throws Exception
252: {
253: if (file.isDirectory())
254: {
255: String[] files = file.list(new DotFileFilter());
256: for (int j = 0; j < files.length; ++j)
257: {
258: File f = new File(file + File.separator + files[j]);
259: System.out.println(file + " " + f);
260:
261: if (f.isDirectory())
262: {
263: count = writeDirectory(f, startFile, fileCount, count, dialog, update);
264: } else
265: count = writeStream(f, startFile, fileCount, count, dialog, update);
266: }
267: }
268: return count;
269: }
270: private static int writeStream(File file, File startFile, int fileCount, int count, UploadInfo dialog, Update updateMode) throws Exception
271: {
272: // try
273: //{
274: String response = "", mode = "";
275: String path = file.getAbsolutePath();
276: String fName=file.getName();
277: String name = (startFile.isDirectory()) ? startFile.getName() + "/" + path.substring(startFile.getAbsolutePath().length() + 1) : file.getName();
278: if (destination != "")
279: name = (startFile.isDirectory()) ? destination + "/" + path.substring(startFile.getAbsolutePath().length() + 1) : destination + "/" + file.getName();
280: if(prefix!="")
281: name=name.substring(0,name.indexOf(fName))+prefix+fName;
282: System.out.println("hi " + name + " " + destination + " " + startFile.getName()+" "+file.getName());
283: FileInputStream f = new FileInputStream(file.getAbsolutePath());
284: int length = f.available();
285: int readCount = 0;
286: byte[] b = (length > 8192) ? new byte[8192] : new byte[length];
287: System.out.println(file.getName() + " " + ((length > 1000000) ? (length / 1048576) + " MByte" : length + " Bytes"));
288: String fileName = file.getName() + " " + ((length > 1000000) ? (length / 1048576) + " MByte" : length + " Bytes");
289: dialog.title.setText("Uploading " + startFile);
290: dialog.progress.setValue(0);
291: dialog.file.setText(fileName);
292: dialog.status.setText(count + " of " + fileCount + ((fileCount > 1) ? " files" : " file"));
293: //dialog.pack();
294: //dialog.validate();
295: if (dialog.isVisible())
296: dialog.repaint();
297: else
298: dialog.show();
299:
300: MessageDigest md = MessageDigest.getInstance("MD5");
301: FileInputStream f2 = new FileInputStream(file.getAbsolutePath());
302:
303: readCount = 0;
304:
305: /* while (readCount < length)
306: {
307: if (readCount + b.length > length)
308: f2.read(b, 0, length - readCount); // mout.flush();
309: else
310: f2.read(b);
311: if (readCount + b.length > length)
312: md.update(b, 0, length - readCount);
313: else
314: md.update(b, 0, b.length);
315: readCount += b.length;
316: //System.out.println("rock " + readCount);
317:
318: }*/
319: String md5 = "rogo";getMD5(md);
320: //md = null;
321: f2.close();
322: f2 = null;
323: if (updateMode.value)
324: mode = "replace";
325:
326: URL httpCon = new URL(url + getSHA((id + "").getBytes()) + "/" + convertUml(name) + "?id=" + getSHA((id + "").getBytes()) + "&count=" + count + "&nf=" + fileCount + "&md5=" + md5 + "&mode=" + mode);
327: /* HttpURLConnection con = (HttpURLConnection) httpCon.openConnection();
328: con.setUseCaches(false);
329: con.setRequestMethod("PUT");
330: con.setDoOutput(true);
331: con.connect();
332: */
333: Connection con = null;
334: con=(Connection)connections.get(startFile.getAbsolutePath());
335: if(con==null)
336: {
337: con=new Connection(httpCon);
338: connections.put(startFile.getAbsolutePath(),con);
339: } else
340: con.url=httpCon;
341: OutputStream mout = con.out; //con.getOutputStream();
342: // InputStream min= con.getInputStream();
343: // System.out.println(httpCon);
344: //System.out.println("Response " + con.getResponseMessage()+" "+con.getContentLength());
345: boolean update = con.update();
346:
347: System.out.println("update is" + update);
348:
349: if (!update || mode.equals("update") || mode.equals("replace"))
350: //if(true)
351: {
352: con.connect(length+md5Length);
353: mout = con.out;
354: md.reset();
355: /* System.out.println("Free memory "+(Runtime.getRuntime().freeMemory()/ 1048576));
356: System.gc();
357: System.out.println("Free memory after"+(Runtime.getRuntime().freeMemory()/ 1048576));
358: System.out.println("Total memory after"+(Runtime.getRuntime().totalMemory()/ 1048576));
359: */
360: readCount = 0;
361: while (readCount < length)
362: {
363: if (readCount + b.length > length)
364: f.read(b, 0, length - readCount); // mout.flush();
365: else
366: f.read(b);
367: if (readCount + b.length > length)
368: mout.write(b, 0, length - readCount); // mout.flush();
369: else
370: mout.write(b);
371: if (readCount + b.length > length)
372: md.update(b, 0, length - readCount);
373: else
374: md.update(b, 0, b.length);
375: readCount += b.length;
376: if(((PrintStream)mout).checkError()) throw new Error("Error while sending data");
377: dialog.progress.setValue((int) (((double) readCount / (double) length) * 100.0));
378:
379: if (readCount % 1000 == 0)
380: {
381: //System.out.println("Free memory while writing"+(Runtime.getRuntime().freeMemory()/ 1048576));
382: //System.out.println("Total memory while writing"+(Runtime.getRuntime().totalMemory()/ 1048576));
383: //mout.flush();
384: //System.out.println(con.getClass());
385: }
386: }
387: md5 = getMD5(md);
388: mout.write(md5.getBytes());
389: if(((PrintStream)mout).checkError()) throw new Error("Error while sending md5");
390: //mout.close();
391: //con.disconnect();
392:
393: response = con.getResponseMessage();
394: System.out.println(response + " " + md5);
395: }
396: if (update && !mode.equals("update") && !mode.equals("replace"))
397: //(response.indexOf("Conflict")>=0 && !mode.equals("update") && !mode.equals("replace"))
398: {
399: updateMode.value = true;
400: Object[] options = new Object[] { "Replace folder", "Cancel" }, options2 = new Object[] { "Replace file", "Cancel" };
401:
402: int option = showDialog("Warning destination exists! \n What do you want to do?", "Destination exists!", (startFile.isDirectory()) ? options : options2);
403: if (option == 0)
404: mode = "replace";
405: //System.out.println("performing update");
406: else
407: throw new Error("Upload cancelled");
408: //mode = "cancel"; //System.out.println("performing replace");
409: //System.out.println("Watershine" + name + " " + mode);
410: // mout.close();
411:
412: con.disconnect();
413: httpCon = new URL(url + getSHA((id + "").getBytes()) + "/" + convertUml(name) + "?id=" + getSHA((id + "").getBytes()) + "&count=" + count + "&nf=" + fileCount + "&md5=" + md5 + "&mode=" + mode);
414: /* con = (HttpURLConnection) httpCon.openConnection();
415: con.setRequestMethod("PUT");
416: con.setDoOutput(true);
417: con.connect();
418: mout = con.getOutputStream();
419: */
420: //con=new Connection(httpCon);
421: con.url = httpCon;
422: con.connect(length+md5Length);
423: md.reset();
424: mout = con.out;
425: readCount = 0;
426: FileInputStream f3 = new FileInputStream(file.getAbsolutePath());
427: while (readCount < length)
428: {
429: if (readCount + b.length > length)
430: f3.read(b, 0, length - readCount); // mout.flush();
431: else
432: f3.read(b);
433: if (readCount + b.length > length)
434: mout.write(b, 0, length - readCount); // mout.flush();
435: else
436: mout.write(b);
437: if (readCount + b.length > length)
438: md.update(b, 0, length - readCount);
439: else
440: md.update(b, 0, b.length);
441: readCount += b.length;
442:
443: if(((PrintStream)mout).checkError()) throw new Error("Error while sending data");
444:
445: dialog.progress.setValue((int) (((double) readCount / (double) length) * 100.0));
446:
447: }
448: f3.close();
449: // mout.flush();
450: md5=getMD5(md);
451: mout.write(md5.getBytes()); // write md5 code
452: if(((PrintStream)mout).checkError()) throw new Error("Error while sending md5");
453:
454: response = con.getResponseMessage();
455: System.out.println("MyResponse " + response);
456:
457: } else if (response.indexOf(" Checksums not identical!") >= 0)
458: {
459: Object[] options = { "Retry", "Cancel" };
460:
461: int option = showDialog("Transfer failed! \n What do you want to do?", "Transfer failed ", options);
462: con.disconnect();
463: if (option == 0)
464: {
465: httpCon = new URL(url + getSHA((id + "").getBytes()) + "/" + convertUml(name) + "?id=" + getSHA((id + "").getBytes()) + "&count=" + count + "&nf=" + fileCount + "&md5=" + md5 + "&mode=" + mode);
466: /* con = (HttpURLConnection) httpCon.openConnection(); // con.setRequestMethod("GET");
467: con.setRequestMethod("PUT");
468: con.setDoOutput(true);
469: con.connect();
470: mout = con.getOutputStream();
471: // System.out.println(htt readCount = 0;
472: */
473:
474: con.url = httpCon;
475: con.connect(length+md5Length);
476: mout = con.out;
477: FileInputStream f4 = new FileInputStream(file.getAbsolutePath());
478: readCount = 0;
479: while (readCount < length)
480: {
481: if (readCount + b.length > length)
482: f4.read(b, 0, length - readCount); // mout.flush();
483: else
484: f4.read(b);
485: if (readCount + b.length > length)
486: mout.write(b, 0, length - readCount); // mout.flush();
487: else
488: mout.write(b);
489: readCount += b.length;
490: if(((PrintStream)mout).checkError()) throw new Error("Error while sending data");
491: dialog.progress.setValue((int) (((double) readCount / (double) length) * 100.0));
492:
493: }
494: f4.close();
495: mout.write(md5.getBytes());
496: if(((PrintStream)mout).checkError()) throw new Error("Error while sending md5");
497: response = con.getResponseMessage();
498: System.out.println("MyResponse " + response);
499: }
500:
501: } else
502: con.disconnect();
503:
504: f.close();
505: count++;
506: /*
507: } catch (IOException ioe)
508: {
509: System.out.println("IOException: " + ioe);
510: ioe.printStackTrace();
511: throw(ioe);
512: } catch (Exception e)
513: {
514: System.out.println("IOException: " + e);
515: showErrorDialog(e.toString(),"Upload failed");
516: }*/
517: return count;
518: }
519: public static String getMD5(MessageDigest md) throws Exception
520: {
521: byte[] bytes = md.digest();
522: System.out.println("digest " + bytes.length);
523: StringBuffer sb = new StringBuffer();
524: int decValue;
525: for (int i = 0; i < bytes.length; i++)
526: {
527: String hexVal = Integer.toHexString(bytes[i] & 0xFF);
528: if (hexVal.length() == 1)
529: hexVal = "0" + hexVal; // put a leading zero
530: sb.append(hexVal);
531: }
532: return sb.toString();
533: }
534: public static String getSHA(byte[] b) throws Exception
535: {
536: MessageDigest md = MessageDigest.getInstance("SHA");
537: md.update(b, 0, b.length);
538: //System.out.println("digest");
539: byte[] bytes = md.digest();
540: StringBuffer sb = new StringBuffer();
541: int decValue;
542: for (int i = 0; i < bytes.length; i++)
543: {
544: String hexVal = Integer.toHexString(bytes[i] & 0xFF);
545: if (hexVal.length() == 1)
546: hexVal = "0" + hexVal; // put a leading zero
547: sb.append(hexVal);
548: }
549:
550: return sb.toString();
551: }
552:
553: public static String convertUml(String newName)
554: {
555: StringBuffer alterMe = new StringBuffer(newName.trim());
556: int length = alterMe.length();
557: int j = 0;
558: while (j < length)
559: { //if(Character.isSpaceChar(alterMe.charAt(j)))
560: // alterMe.setCharAt(j,'_');
561: if (alterMe.charAt(j) == ' ')
562: {
563: alterMe.setCharAt(j, '%');
564: alterMe.insert(j + 1, "20");
565: length = length + 2;
566: }
567: /* if(Character.isSpaceChar(alterMe.charAt(j))
568: alterMe.setCharAt(j,'_');
569: */
570: ++j;
571: }
572: return alterMe.toString();
573: }
574: public static class UploadInfo extends JDialog
575: {
576: JLabel file = new JLabel(" ");
577: JLabel status = new JLabel(" ");
578: JLabel title = new JLabel(" ");
579: JPanel content = new JPanel();
580: JPanel titlePanel = new JPanel();
581: JPanel labelPanel = new JPanel();
582: JPanel statusPanel = new JPanel();
583: JPanel buttonPanel = new JPanel();
584:
585: JProgressBar progress = new JProgressBar();
586: JButton cancel = new JButton("Cancel");
587: Thread thread;
588: public UploadInfo()
589: {
590:
591: content = new JPanel(true);
592: //content.setBorder(BorderFactory.createRaisedBevelBorder());
593: content.setLayout(new BoxLayout(content, BoxLayout.Y_AXIS));
594: title = new JLabel("Uploading " + startFile);
595: title.setHorizontalTextPosition(title.CENTER);
596: titlePanel.add(title);
597: buttonPanel.add(cancel);
598: // content.add(titlePanel);
599: content.add(Box.createRigidArea(new java.awt.Dimension(0, 15)));
600: content.add(labelPanel);
601: content.add(new JLabel(""));
602: content.add(progress);
603: content.add(statusPanel);
604: content.add(buttonPanel);
605: content.add(Box.createRigidArea(new java.awt.Dimension(0, 15)));
606: labelPanel.add(file);
607: statusPanel.add(status);
608: getContentPane().add(titlePanel, "North");
609: getContentPane().add(content, "Center");
610: cancel.addActionListener(new ActionListener()
611: {
612: public void actionPerformed(ActionEvent e)
613: {
614: setVisible(false);
615: thread.stop();
616: }
617:
618: });
619: pack();
620:
621: }
622:
623: }
624: public static int showDialog(String message, String title, Object[] options)
625: {
626: int option = JOptionPane.showOptionDialog(null, message, title, JOptionPane.DEFAULT_OPTION, JOptionPane.WARNING_MESSAGE, null, options, options[0]);
627: return option;
628:
629: }
630: public static void showDialog(String message, String title)
631: {
632: JOptionPane.showMessageDialog(null, message, title, JOptionPane.PLAIN_MESSAGE);
633:
634: }
635: public static void showErrorDialog(String message, String title)
636: {
637: JOptionPane.showMessageDialog(null, message, title, JOptionPane.ERROR_MESSAGE);
638: }
639:
640: static class Connection
641: {
642: Socket socket;
643: URL url;
644: BufferedInputStream in;
645: PrintStream out;
646: String pHost;
647: int pPort = 80;
648: HttpURLConnection con;
649: public Connection(URL url) throws Exception
650: {
651: Properties prop = System.getProperties();
652: pHost = null;
653: pPort = 80;
654: Enumeration en = prop.propertyNames();
655: while (en.hasMoreElements())
656: {
657: String key = (String) en.nextElement();
658: if (key.toString().indexOf("proxyHost") >= 0)
659: {
660: Object host = prop.get(key);
661: if (host != null)
662: pHost = host.toString();
663: }
664: if (key.toString().indexOf("proxyPort") >= 0)
665: {
666: Object port = prop.get(key);
667: if (port != null)
668: pPort = Integer.parseInt(port.toString());
669: }
670: }
671:
672: if (proxyHost != "")
673: {
674: int index = proxyHost.indexOf(":");
675: pHost = proxyHost.substring(0, (index > 0) ? index : proxyHost.length());
676: pPort = (index > 0) ? Integer.parseInt(proxyHost.substring(index + 1)) : 80;
677: }
678: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
679: socket.setTcpNoDelay(true);
680: in = new BufferedInputStream(socket.getInputStream());
681: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
682: this.url = url;
683: }
684: public void connect(int size) throws Exception
685: {
686: try
687: {
688: //System.out.println("Yeah i called connect");
689: // socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
690: // socket.setTcpNoDelay(true);
691: in = new BufferedInputStream(socket.getInputStream());
692: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
693:
694: 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());
695: out.flush();
696: } catch (Exception e)
697: {
698: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
699: socket.setTcpNoDelay(true);
700: in = new BufferedInputStream(socket.getInputStream());
701: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
702: 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());
703: out.flush();
704: //System.out.println("Error "+e);
705: }
706:
707: /* con = new HTTPClient.HttpURLConnection(url);//(HttpURLConnection) url.openConnection(); // con.setRequestMethod("GET");
708: con.setUseCaches(false);
709: con.setRequestMethod("PUT");
710: con.setDoOutput(true);
711: con.setRequestProperty("Content-Length", ""+size);
712: // con.connect();
713: System.out.println(con.getClass());
714: out = new DataOutputStream(con.getOutputStream());
715: */
716: }
717: public boolean update() throws Exception
718: {
719: boolean exists = false;
720: String response = "";
721: try
722: {
723:
724: URL url = createURL(this.url.toString(), getSHA((id + "").getBytes()));
725: // con = new HTTPClient.HttpURLConnection(url);//(HttpURLConnection) url.openConnection(); // con.setRequestMethod("GET");
726: //con.setUseCaches(false);
727: // con.setRequestMethod("HEAD");
728: //con.setDoOutput(true);
729: // con.connect();
730:
731: out.print(("HEAD " + url + " HTTP/1.1\r\nConnection:Keep-Alive\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
732: out.flush();
733: response = getResponseMessage();
734: exists = response.indexOf("OK") >= 0;
735: System.out.println("Head "+response);
736:
737: } catch (Exception e)
738: {
739: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort : url.getPort());
740: socket.setTcpNoDelay(true);
741: in = new BufferedInputStream(socket.getInputStream());
742: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
743: // out.writeBytes("HEAD " + url + " HTTP/1.1\r\n Connection:Keep-Alive\r\n \r\nHost: " + url.getHost() + //"\r\n\r\n");
744: URL url = createURL(this.url.toString(), getSHA((id + "").getBytes()));
745: out.print(("HEAD " + url + " HTTP/1.1\r\nConnection:Keep-Alive\r\nHost: " + url.getHost() + "\r\n\r\n"));//.getBytes());
746: out.flush();
747: response = getResponseMessage();
748: System.out.println("Head " + response);
749: exists = response.indexOf("OK") >= 0;
750: //System.out.println("Error from Head "+e);
751: // e.printStackTrace();
752: return exists;
753:
754: }
755: return exists;
756: }
757: public URL createURL(String fileToPut, String id) throws Exception
758: {
759: int index = fileToPut.lastIndexOf("/") + 1;
760: String source = fileToPut; //.substring(0, index);
761: // String fileName = fileToPut.substring(index);
762: index = source.indexOf(id);
763: int index2 = index + id.length() + 1;
764: int index3 = source.indexOf("/", index2);
765:
766: // System.out.println(fileToPut+" "+index2+" "+index3+" "+id);
767: // String dest = (index3 > 0) ? source.substring(0, index) + source.substring(index2, index3)+"/"+fileName : //source.substring(0, index) + fileName;
768: // file check versus folder Check if destination !="" folder check is performed
769: String dest = (destination!="") ? source.substring(0, index) + source.substring(index2,index3):source.substring(0, index) + source.substring(index2);
770: // System.out.println("dest "+source.substring(0,index)+ source.substring(index2));
771: // File f = new File(dest);
772: //return f.exists();
773: return new URL(dest);
774: }
775:
776: public String getResponseMessage()
777: {
778:
779: int b=0;StringBuffer between=new StringBuffer();int count=0;
780: // while(!between.toString().equals("\r"))
781: // {
782: // between=new StringBuffer(40);
783: try
784: {
785: int loop =0;int available = 0;
786: while((available=in.available())==0)
787: {
788: if(loop>=600) throw new Error("Connection timed out");
789: long time = System.currentTimeMillis();
790: while(System.currentTimeMillis()-time<100);
791: if(available==0) loop++; else loop=0;
792: }
793: // System.out.println("heh there are bytes "+in.available()+" available");
794: int limit = in.available();
795: while(true )
796: {
797: //Thread.sleep(10);
798: b=in.read();
799: /*
800: if(b=='\r')
801: {
802: b=in.read();
803: b=in.read();
804: count=count+2;
805: // if(b=='\r') break;
806: //else
807: between.append('\n');
808: }
809: */
810: between.append((char)b);
811: // System.out.print((char)b);
812: //System.out.println("read "+count+" bytes");
813: count++;
814: if(count==limit) break;
815: }
816:
817: } catch(Exception e) {
818: e.printStackTrace();
819: System.out.println("Error found");
820: if(e.toString().indexOf("peer")>=0)
821: return getResponseMessage();
822: else throw new Error("Error while reading response");
823: }
824: String response = between.toString();
825: if(response.indexOf("close") >= 0)
826: reconnect();
827: return response;
828:
829: /*
830: String response = "";
831: try
832: {
833: response = con.getResponseMessage();
834: // con.disconnect();
835: } catch (Exception e)
836: {
837: showErrorDialog(e.getMessage(),"Shit happens");
838: }
839: */
840:
841: // return response;
842: }
843: public void disconnect() throws Exception
844: {
845: //socket.close();
846: // con.disconnect();
847: }
848: public void reconnect()
849: {
850: try
851: {
852: System.out.println("Reconnect called");
853: int port= (url.getPort()>=0) ? url.getPort():80;
854: socket = new Socket((pHost != null) ? pHost : url.getHost(), (pHost != null) ? pPort :port);
855: socket.setTcpNoDelay(true);
856: in = new BufferedInputStream(socket.getInputStream());
857: out = new PrintStream(new BufferedOutputStream(socket.getOutputStream()),true);
858:
859: } catch(Exception e)
860: {
861: showErrorDialog(e.getMessage(),"Shit happens");
862: }
863:
864: }
865: }
866: static class Update
867: {
868: boolean value = false;
869: public Update()
870: {
871: value = false;
872: }
873: }
874: static class DotFileFilter implements FilenameFilter
875: {
876: public DotFileFilter() {}
877: public boolean accept(File dir, String name)
878: {
879: if(name.startsWith(".")) return false;
880: else return true;
881: }
882: }
883: static class ImageFilter extends javax.swing.filechooser.FileFilter
884: {
885: public boolean accept(java.io.File file)
886: {
887: String name=file.getName().toLowerCase();
888: if(name.endsWith(".gif")||name.endsWith(".jpg")||name.endsWith(".tif")||name.endsWith(".png")||name.endsWith(".jpeg")||file.isDirectory())
889: return true ;
890: else return false;
891: }
892: public String getDescription()
893: {
894: return "Image File";
895: }
896: }
897:
898: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/cvs/cvsweb/icons/back.gif){kind=icon}
Return to ServerWriter.java CVS log ![[TXT]](/cvs/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvs/cvsweb/icons/dir.gif){kind=icon}
Up to [Repository] / upload-applet