2003/10/29 03:48:13
[org.ibex.core.git] / src / org / xwt / XMLRPC.java
index 7cef4c2..7325476 100644 (file)
@@ -104,8 +104,8 @@ class XMLRPC extends JS.Callable {
                 objects.setElementAt(new Double(new String(content.getBuf(), 0, content.size())), objects.size() - 1);
             
             else if (c.localName.equals("base64"))
-                objects.setElementAt(new ByteStream(Base64.decode(new String(content.getBuf(), 0, content.size()))), objects.size() - 1);
-            
+                objects.setElementAt(new Res.ByteArray(Base64.decode(new String(content.getBuf(), 0, content.size()))), objects.size() - 1);
+
             else if (c.localName.equals("name"))
                 objects.addElement(new String(content.getBuf(), 0, content.size()));
             
@@ -113,33 +113,30 @@ class XMLRPC extends JS.Callable {
                 objects.setElementAt(new String(content.getBuf(), 0, content.size()), objects.size() - 1);
             
             else if (c.localName.equals("dateTime.iso8601")) {
-                throw new Error("not implemented");
-                /*
-                  String s = new String(content.getBuf(), 0, content.size());
-                  
-                  // strip whitespace
-                  int i=0;
-                  while(Character.isWhitespace(s.charAt(i))) i++;
-                  if (i > 0) s = s.substring(i);
-                  
-                  try {
-                  NativeDate nd = (NativeDate)JS.Thread.enter().newObject(org.xwt.util.JS.Obj.defaultObjects, "Date");
-                  double date = NativeDate.date_msecFromDate(Double.valueOf(s.substring(0, 4)).doubleValue(),
-                  Double.valueOf(s.substring(4, 6)).doubleValue() - 1,
-                  Double.valueOf(s.substring(6, 8)).doubleValue(),
-                  Double.valueOf(s.substring(9, 11)).doubleValue(),
-                  Double.valueOf(s.substring(12, 14)).doubleValue(),
-                  Double.valueOf(s.substring(15, 17)).doubleValue(),
-                  (double)0
-                  );
-                  nd.jsFunction_setTime(NativeDate.internalUTC(date));
-                  objects.setElementAt(nd, objects.size() - 1);
-                  
-                  } catch (Exception e) {
-                  if (Log.on) Log.log(this, "error parsing date : " + s);
-                  if (Log.on) Log.log(this, e);
-                  }
-                */
+                String s = new String(content.getBuf(), 0, content.size());
+                
+                // strip whitespace
+                int i=0;
+                while(Character.isWhitespace(s.charAt(i))) i++;
+                if (i > 0) s = s.substring(i);
+                
+                try {
+                    org.xwt.js.Date nd = new org.xwt.js.Date();
+                    double date = org.xwt.js.Date.date_msecFromDate(Double.valueOf(s.substring(0, 4)).doubleValue(),
+                                                                    Double.valueOf(s.substring(4, 6)).doubleValue() - 1,
+                                                                    Double.valueOf(s.substring(6, 8)).doubleValue(),
+                                                                    Double.valueOf(s.substring(9, 11)).doubleValue(),
+                                                                    Double.valueOf(s.substring(12, 14)).doubleValue(),
+                                                                    Double.valueOf(s.substring(15, 17)).doubleValue(),
+                                                                    (double)0
+                                                                    );
+                    nd.jsFunction_setTime(org.xwt.js.Date.internalUTC(date));
+                    objects.setElementAt(nd, objects.size() - 1);
+                    
+                } catch (Exception e) {
+                    if (Log.on) Log.log(this, "error parsing date : " + s);
+                    if (Log.on) Log.log(this, e);
+                }
                 
             } else if (c.localName.equals("member")) {
                 Object memberValue = objects.elementAt(objects.size() - 1);
@@ -196,10 +193,10 @@ class XMLRPC extends JS.Callable {
             sb.append(((Boolean)o).booleanValue() ? "1" : "0");
             sb.append("</boolean></value>\n");
 
-        } else if (o instanceof ByteStream) {
+        } else if (o instanceof Res) {
             try {
                 sb.append("                <value><base64>\n");
-                InputStream is = ((ByteStream)o).getInputStream();
+                InputStream is = ((Res)o).getInputStream();
                 byte[] buf = new byte[54];
                 while(true) {
                     int numread = is.read(buf, 0, 54);
@@ -240,12 +237,9 @@ class XMLRPC extends JS.Callable {
             }
             sb.append("</string></value>\n");
 
-            /*
         } else if (o instanceof org.xwt.js.Date) {
             sb.append("                <value><dateTime.iso8601>");
-              FIXME
-            org.xwt.js.Date d = (org.xwt.js.Date)o;
-            Date d = new Date(nd.getRawTime());
+            java.util.Date d = new java.util.Date(((org.xwt.js.Date)o).getRawTime());
             sb.append(d.getYear() + 1900);
             if (d.getMonth() + 1 < 10) sb.append('0');
             sb.append(d.getMonth() + 1);
@@ -261,7 +255,6 @@ class XMLRPC extends JS.Callable {
             if (d.getSeconds() < 10) sb.append('0');
             sb.append(d.getSeconds());
             sb.append("</dateTime.iso8601></value>\n");
-            */
 
         } else if (o instanceof JS.Array) {
             if (tracker.get(o) != null) throw new JS.Exn("attempted to send multi-ref data structure via XML-RPC");
@@ -308,7 +301,7 @@ class XMLRPC extends JS.Callable {
             while ((s = br2.readLine()) != null) Log.log(this, "send: " + s);
         }
 
-        HTTP.HTTPInputStream is = http.POST("text/xml", content);
+        InputStream is = http.POST("text/xml", content);
         try {
             BufferedReader br = !Log.verbose ?
                 new BufferedReader(new InputStreamReader(new Filter(is))) :
@@ -414,17 +407,17 @@ class XMLRPC extends JS.Callable {
         public Filter(InputStream is) { super(is); }
         public int read() throws IOException {
             java.lang.Thread.yield();
-            while(MessageQueue.nonThreadEventsInQueue > 0) try { java.lang.Thread.sleep(100); } catch (Exception e) { };
+            while(Message.Q.nonThreadEventsInQueue > 0) try { java.lang.Thread.sleep(100); } catch (Exception e) { };
             return super.read();
         }
         public int read(byte[] b) throws IOException {
             java.lang.Thread.yield();
-            while(MessageQueue.nonThreadEventsInQueue > 0) try { java.lang.Thread.sleep(100); } catch (Exception e) { };
+            while(Message.Q.nonThreadEventsInQueue > 0) try { java.lang.Thread.sleep(100); } catch (Exception e) { };
             return super.read(b);
         }
         public int read(byte[] b, int i, int j) throws IOException {
             java.lang.Thread.yield();
-            while(MessageQueue.nonThreadEventsInQueue > 0) try { java.lang.Thread.sleep(100); } catch (Exception e) { };
+            while(Message.Q.nonThreadEventsInQueue > 0) try { java.lang.Thread.sleep(100); } catch (Exception e) { };
             return super.read(b, i, j);
         }
     }