X-Git-Url: http://git.megacz.com/?p=org.ibex.core.git;a=blobdiff_plain;f=src%2Forg%2Fxwt%2FRes.java;h=5b1fc5f73d805a225d17406aa5ac354ecbf89b47;hp=bf7b6f81152c7e753b155bd9f8fe6bdbd17555b8;hb=c6069948906645d974f46bdb96617a9a6a504636;hpb=cf3587e2fd5966b7ebfd721d9413674224d1ad2a

diff --git a/src/org/xwt/Res.java b/src/org/xwt/Res.java
index bf7b6f8..5b1fc5f 100644
--- a/src/org/xwt/Res.java
+++ b/src/org/xwt/Res.java
@@ -2,12 +2,23 @@
 package org.xwt;
 
 import java.io.*;
+import org.xwt.js.*;
 
+// FIXME: ByteStream fileName property
 /** base class for XWT resources */
-public abstract class Res {
+public abstract class Res extends JS {
 
-    public abstract InputStream getInputStream();
-    public Res getSubResource(String key) { return Null.singleton; }
+    public String toString() { return "Resource, source=FIXME"; }
+
+    public final InputStream getInputStream() { return getInputStream(""); }
+
+    public Res graft(Object newResource) { throw new JS.Exn("cannot graft onto this resource"); }
+    public Object get(Object key) { return new Ref(this, key); } 
+    public void put(Object key, Object val) { throw new JS.Exn("cannot put to a resource"); } 
+    public Object[] keys() { throw new JS.Exn("cannot enumerate a resource"); } 
+
+    public abstract InputStream getInputStream(String path) { return getInputStream(""); }
+    public abstract Res addExtension(String extension);
 
     public static Res stringToRes(String url) {
         if (url.indexOf('!') == -1)
@@ -18,19 +29,11 @@ public abstract class Res {
         throw new JS.Exn("invalid resource specifier");
     }
 
-    /** the invalid resource; only causes an error if you actually try to use it */
-    public static class Null extends Res {
-        Null() { }
-        private static singleton = new Null();
-        public InputStream getInputStream() throws JS.Exn { throw new JS.Exn("invalid resource"); }
-    }
-
     /** HTTP or HTTPS resource */
     public static class HTTP extends Res {
         private String url;
         HTTP(String url) { this.url = url; }
-        public InputStream getInputStream() { return new HTTP(url).GET(); }
-        public Res getSubResource(String key) { return new HTTP(url + "/" + key); }
+        public InputStream getInputStream(String path) { return new HTTP(url + path).GET(); }
     }
 
     /** wrap a Res around a preexisting InputStream */
@@ -38,21 +41,140 @@ public abstract class Res {
         InputStream parent;
         IS(InputStream parent) { this.parent = parent; }
         public InputStream getInputStream() { return parent; }
+        public InputStream getInputStream(String path) {
+            if (!"".equals(path)) throw new JS.Exn("can't access subresources of IS");
+            return parent;
+        }
     }
 
     /** "unwrap" a Zip archive */
     public static class Zip extends Res {
         private Res parent;
-        private String path = "";
-        Zip(Res parent, String path) { this.parent = parent; this.path = path; }
-        public InputStream getInputStream() {
+        Zip(Res parent) { this.parent = parent; }
+        public InputStream getInputStream(String path) {
             ZipInputStream zis = new ZipInputStream(parent.getInputStream());
             ZipEntry ze = zis.getNextEntry();
             while(ze != null && !ze.getName().equals(path)) ze = zis.getNextEntry();
             if (ze == null) throw new JS.Exn("zip file not found in archive");
             return zis;
         }
-        public Res getSubResource(String key) { return new Zip(parent, path + '/' + key); }
     }
 
+    /** what you get when you reference a subresource */
+    public static class Ref extends Res {
+        Res parent;
+        Object key;
+        Ref(Res parent, Object key) { this.parent = parent; this.key = key; }
+        public InputStream getInputStream(path) {
+            return parent.getInputStream("/" + key + path);
+        }
+        public Res graft(Object newResource) { return new Graft(parent, key, newResource); }
+    }
+
+    /** shadow resource which replaces the graft */
+    public static class Graft extends Res {
+        Res graftee;
+        Object replaced_key;
+        Object replaced_val;
+        Graft(Res graftee, Object key, Object val) {
+            this.graftee = graftee; replaced_key = key; replaced_val = val; }
+        public boolean equals(Object o) { return (this == o || graftee.equals(o)); }
+        public Object get(Object key) {
+            return replaced_key.equals(key) ? replaced_val : graftee.get(key);
+        }
+    }
+
+    /////////////// bytestream
+
+    public Object callMethod(Object method, Array args, boolean checkOnly) throws JS.Exn {
+        if (method.equals("getUTF")) {
+            if (checkOnly) return Boolean.TRUE;
+            if (args.length() != 0) return null;
+            try {
+                CharArrayWriter caw = new CharArrayWriter();
+                InputStream is = getInputStream();
+                BufferedReader r = new BufferedReader(new InputStreamReader(is));
+                char[] buf = new char[1024];
+                while(true) {
+                    int numread = r.read(buf, 0, 1024);
+                    if (numread == -1) break;
+                    caw.write(buf, 0, numread);
+                }
+                return caw.toString();
+            } catch (IOException e) {
+                if (Log.on) Log.log(ByteStream.class, "IO Exception while reading from file");
+                if (Log.on) Log.log(ByteStream.class, e);
+                throw new JS.Exn("error while reading from ByteStream");
+            }
+        } else if (name.equals("getDOM")) {
+            if (checkOnly) return Boolean.TRUE;
+            if (args.length() != 0) return null;
+            return new XMLHelper().doParse();
+        }
+        if (checkOnly) return Boolean.FALSE;
+        return null;
+    }
+
+    private class XMLHelper extends XML {
+        Vector obStack = new Vector();
+        public XMLHelper() { super(BUFFER_SIZE); }
+        public void startElement(XML.Element c) throws XML.SchemaException {
+            JS o = new JS.Obj();
+            o.put("$name", c.localName);
+            for(int i=0; i<c.len; i++) o.put(c.keys[i], c.vals[i]);
+            o.put("$numchildren", new Integer(0));
+            obStack.addElement(o);
+        }
+        public void endElement(XML.Element c) throws XML.SchemaException {
+            if (obStack.size() == 1) return;
+            JS me = (JS)obStack.lastElement();
+            obStack.setSize(obStack.size() - 1);
+            JS parent = (JS)obStack.lastElement();
+            int numchildren = ((Integer)parent.get("$numchildren")).intValue();
+            parent.put("$numchildren", new Integer(numchildren + 1));
+            parent.put(new Integer(numchildren), me);
+        }
+        public void characters(char[] ch, int start, int length) throws XML.SchemaException {
+            String s = new String(ch, start, length);
+            JS parent = (JS)obStack.lastElement();
+            int numchildren = ((Integer)parent.get("$numchildren")).intValue();
+            Object lastChild = parent.get(new Integer(numchildren - 1));
+            if (lastChild instanceof String) {
+                parent.put(new Integer(numchildren - 1), lastChild + s);
+            } else {
+                parent.put("$numchildren", new Integer(numchildren + 1));
+                parent.put(new Integer(numchildren), s);
+            }
+        }
+        public void whitespace(char[] ch, int start, int length) {}
+        public JS doParse() throws JS.Exn {
+            try { 
+                InputStream is = getInputStream();
+                BufferedReader r = new BufferedReader(new InputStreamReader(is));
+                parse(r);
+            } catch (XML.XMLException e) {
+                throw new JS.Exn("error parsing XML: " + e.toString());
+            } catch (IOException e) {
+                if (Log.on) Log.log(ByteStream.class, "IO Exception while reading from file");
+                if (Log.on) Log.log(ByteStream.class, e);
+                throw new JS.Exn("error reading from ByteStream");
+            }
+            return obStack.size() >= 1 ? (JS)obStack.elementAt(0) : null;
+        }
+    }
+
+    public void writeTo(OutputStream os) throws IOException {
+        InputStream is = getInputStream();
+        byte[] buf = new byte[1024];
+        while(true) {
+            int numread = is.read(buf, 0, 1024);
+            if (numread == -1) break;
+            if (Log.on) Log.log(this, "wrote " + numread + " bytes");
+            os.write(buf, 0, numread);
+        }
+        os.flush();
+
+        // we have to close this because flush() doesn't work on Win32-GCJ
+        os.close();
+    }
 }