Maximum CD 2003 January/maximum-cd-2003-01.iso/Software/Apps/OperawithJava/ow32enen700b1j.exe/OPERA.JAR/opera/OperaURLConnection.class

Java Class File | 2002-11-07 | 5.3 KB | 256 lines

package opera;

import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Enumeration;
import java.util.Hashtable;

public class OperaURLConnection extends HttpURLConnection {
   // $FF: renamed from: is opera.OperaInputStream
   private OperaInputStream field_0 = null;
   private int istream_id = -1;
   // $FF: renamed from: os opera.OperaOutputStream
   private OperaOutputStream field_1 = null;
   private int ostream_id = -1;
   private Hashtable req_props = new Hashtable();
   private Hashtable header_fields = new Hashtable();

   protected OperaURLConnection(URL var1) {
      super(var1);
   }

   public void connect() throws IOException {
      if (!this.connected) {
         String var1 = this.url.toString();
         if (this.url.getPort() == -1) {
            int var2 = var1.indexOf(":-1");
            if (var2 != -1) {
               StringBuffer var3 = new StringBuffer(var1);
               var3.delete(var2, var2 + 3);
               var1 = var3.toString();
            }
         }

         SecurityManager var14 = System.getSecurityManager();
         if (var14 != null) {
            var14.checkConnect(this.url.getHost(), this.url.getPort());
         }

         try {
            this.field_0 = new OperaInputStream(this);
            this.field_1 = new OperaOutputStream(this);
            this.istream_id = OperaInputStream.addStream(this.field_0);
            this.ostream_id = OperaOutputStream.addStream(this.field_1);
            this.field_1.istream_id = this.istream_id;
            if (this.method.compareTo("POST") == 0) {
               Object var15 = PluginContext.opera_mutex;
               synchronized(var15) {
                  this.nativeConnect(var1, this.method, this.ostream_id);
               }

               this.connected = true;
            } else if (this.method.compareTo("GET") == 0) {
               Object var16 = PluginContext.opera_mutex;
               synchronized(var16) {
                  this.nativeConnect(var1, this.method, this.istream_id);
               }

               try {
                  OperaInputStream var5 = this.field_0;
                  synchronized(var5) {
                     if (!this.field_0.isHeaderLoaded()) {
                        this.field_0.wait();
                     }
                  }
               } catch (InterruptedException var10) {
                  Thread.currentThread().interrupt();
               }

               if (this.field_0.getResponse() != 200) {
                  this.connected = false;
               } else {
                  this.connected = true;
               }
            } else {
               OperaInputStream var17 = this.field_0;
               synchronized(var17) {
                  this.field_0.headerLoaded(0, 200);
                  this.field_0.setEOF();
               }
            }
         } catch (Exception var13) {
            var13.printStackTrace(System.err);
         }

         if (!this.connected) {
            throw new IOException("Connection failed.");
         }
      }

   }

   private native void nativeConnect(String var1, String var2, int var3);

   public InputStream getInputStream() throws IOException {
      if (!this.connected) {
         this.connect();
      }

      if (this.method.compareTo("POST") == 0) {
         if (!this.field_1.isClosed()) {
            this.field_1.close();
         }

         if (this.field_0.getResponse() == -1) {
            try {
               OperaInputStream var1 = this.field_0;
               synchronized(var1) {
                  this.field_0.wait();
               }
            } catch (InterruptedException var4) {
               Thread.currentThread().interrupt();
            }
         }

         if (this.field_0.getResponse() != 200) {
            this.connected = false;
            throw new FileNotFoundException(this.url.toString());
         }

         this.connected = true;
      }

      return this.field_0;
   }

   public String getContentType() {
      return this.getHeaderField("content-type");
   }

   public int getContentLength() {
      if (!this.connected) {
         try {
            this.connect();
         } catch (Exception var2) {
         }
      }

      return this.field_0 != null ? this.field_0.getContentLength() : 0;
   }

   public String getContentEncoding() {
      return this.getHeaderField("content-encoding");
   }

   public OutputStream getOutputStream() throws IOException {
      this.method = "POST";
      if (!this.connected) {
         this.connect();
      }

      return this.field_1;
   }

   public int getHeaderFieldInt(String var1, int var2) {
      String var3 = this.getHeaderField(var1);
      if (var3 != null) {
         try {
            return Integer.parseInt(var3);
         } catch (NumberFormatException var5) {
         }
      }

      return var2;
   }

   public String getHeaderField(int var1) {
      if (var1 == 0) {
      }

      for(Enumeration var2 = this.header_fields.elements(); var1 > 0 && var2.hasMoreElements(); --var1) {
         Object var3 = var2.nextElement();
         if (var1 == 1) {
            return (String)var3;
         }
      }

      return null;
   }

   public String getHeaderKey(int var1) {
      if (var1 == 0) {
      }

      for(Enumeration var2 = this.header_fields.keys(); var1 > 0 && var2.hasMoreElements(); --var1) {
         Object var3 = var2.nextElement();
         if (var1 == 1) {
            return (String)var3;
         }
      }

      return null;
   }

   public String getHeaderField(String var1) {
      return (String)this.header_fields.get(var1.toLowerCase());
   }

   public String getRequestProperty(String var1) {
      return (String)this.req_props.get(var1);
   }

   public void setRequestProperty(String var1, String var2) {
      if (var1.compareToIgnoreCase("Content-length") != 0) {
         this.req_props.put(var1, var2);
      }

   }

   public void disconnect() {
   }

   public boolean usingProxy() {
      return false;
   }

   protected void finalize() throws Throwable {
      if (this.field_0 != null) {
         this.field_0 = null;
         OperaInputStream.removeStream(this.istream_id);
      }

      if (this.field_1 != null) {
         this.field_1 = null;
         OperaOutputStream.removeStream(this.ostream_id);
      }

      super.finalize();
   }

   protected String makeExtraHeaders() {
      String var1 = "";
      Enumeration var2 = this.req_props.keys();
      Enumeration var3 = this.req_props.elements();

      while(var2.hasMoreElements()) {
         var1 = var1.concat((String)var2.nextElement());
         String var4 = (String)var3.nextElement();
         if (var4 != null) {
            var1 = var1.concat(": " + var4 + "\r\n");
         } else {
            var1 = var1.concat("\r\n");
         }
      }

      return var1;
   }

   protected void addHeader(String var1, String var2) {
      this.header_fields.put(var1.toLowerCase(), var2);
   }
}