package elte.java2_utikalauz5.j2me;

import javax.microedition.midlet.*;
import javax.microedition.lcdui.*;
import javax.microedition.io.*;
import java.io.*;

/**
HTTP kliens midlet.

@link.forrásfájl {@docRoot}/../data/j2me/src HelloWorldClient.java
@link.letöltés {@docRoot}/../data/j2me HelloWorldClient.jar
@link.letöltés {@docRoot}/../data/j2me HelloWorldClient.jad
@since Java 2 Útikalauz programozóknak 5.0
*/
public class HelloWorldClient extends MIDlet
        implements CommandListener {
/*
 * az alapértelmezett URL, ahol a szervlet található
 */

private static String defaultURL =
  "http://192.168.0.2:8991/javakonyv-ReverseServlet-context-root/servlet/ReverseServlet";

private String rsp="";

// A szöveg beírásakor használt GUI komponensek
private Display myDisplay = null;
private Form mainScreen;
private TextField requestField;

// A szervertôl kapott választ megjelenítô GUI komponensek
private Form resultScreen;
private StringItem resultField;

// a mainScreen-en használt "KÜLDÉS" gomb
Command sendCommand = new Command("KÜLDÉS", Command.OK, 1);

// a resultScreen-en használt "VISSZA" gomb
Command backCommand = new Command("VISSZA", Command.OK, 1);

public HelloWorldClient(){
        // inicializáljuk a GUI komponenseket
        myDisplay = Display.getDisplay(this);
        mainScreen = new Form("Kérjük írja be a szöveget:");
        requestField = new TextField(null, "HELLO VILÁG", 100, TextField.ANY);
        mainScreen.append(requestField);
        mainScreen.addCommand(sendCommand);
        mainScreen.setCommandListener(this);
}

public void startApp() {
        myDisplay.setCurrent(mainScreen);
}

public void pauseApp() {
}

public void destroyApp(boolean unconditional) {
}

public void commandAction(Command c, Displayable s) {
        if (c == sendCommand) {
                // a felhasználó által írt szöveg beolvasása
                String requeststring = requestField.getString();
                // POST kérés elküldése a szervernek
                sendPostRequest(requeststring);
                // a kapott eredmény megmutatása a képernyôn
                resultScreen = new Form("A kapott eredmény:");
                resultField = new StringItem(null, rsp);
                resultScreen.append(resultField);
                resultScreen.addCommand(backCommand);
                resultScreen.setCommandListener(this);
                myDisplay.setCurrent(resultScreen);
        } else if (c == backCommand) {
                // visszalépünk a mainScreen-re
                requestField.setString("ÚJABB ÜZENET");
                myDisplay.setCurrent(mainScreen);
        }
}

// POST üzenet elküldése a web szervernek
public void sendPostRequest(final String requeststring) {

     Thread thread = new Thread() {
     public void run() {
      try {
        HttpConnection hc = null;
        DataInputStream dis = null;
        DataOutputStream dos = null;

        try {
                // olvasásra és írásra megnyitunk egy http kapcsolatot
                hc = (HttpConnection) Connector.open(defaultURL, Connector.READ_WRITE);
                // beállítjuk az üzenetküldés típusát POST-ra
                hc.setRequestMethod(HttpConnection.POST);
                // byte-nként elküldjük az üzenetet
                dos = hc.openDataOutputStream();
                byte[] request_body = requeststring.getBytes();
                for (int i = 0; i<request_body.length; i++) {
                  dos.writeByte(request_body[i]);
                }
                dos.flush();
                dos.close();
                int rc = hc.getResponseCode();
                switch (rc) {
                  case HttpConnection.HTTP_OK:
                    // a szervertôl kapott választ beolvassuk
                    dis = new DataInputStream(hc.openInputStream());
                    //StringBuffer messagebuffer = new StringBuffer();
                    //int ch;
                    // ellenôrizzük a 'Content-Length'
                    //long len = hc.getLength();
                    //if (len != -1) {
                      //for (int i = 0; i < len; i++) {
                        //if ( (ch = dis.read()) != -1) {
                        //  messagebuffer.append( (char) ch);
                        //}
                        //else {
                        //  while ( (ch = dis.read()) != -1)
                        //    messagebuffer.append( (char) ch);
                        //}
                      //}
                        String r = dis.readUTF();
                        if (r != null) {
                          rsp=r;
                        } else {
                          rsp="Sikertelen olvasás";
                        }
                    //}
                    dis.close();
                    break;
                  case HttpConnection.HTTP_INTERNAL_ERROR:
                  case HttpConnection.HTTP_NO_CONTENT:
                  case HttpConnection.HTTP_CONFLICT:
                  case HttpConnection.HTTP_NOT_ACCEPTABLE:
                  case HttpConnection.HTTP_NOT_FOUND:
                  case HttpConnection.HTTP_BAD_REQUEST:
                  case HttpConnection.HTTP_NOT_IMPLEMENTED:
                  case HttpConnection.HTTP_EXPECT_FAILED:
                  case HttpConnection.HTTP_FORBIDDEN :
                  case HttpConnection.HTTP_UNAVAILABLE:
                    rsp = "Sikertelen kapcsolat a szerverrrel!";
                    break;
                  default:
                    rsp = "Hiba lépett fel a feldolgozás során!";
                    break;
                }
        } catch (IOException ioe) {
                rsp = "Hiba lépett fel a feldolgozás során!";
        } finally {
                // bezárjuk az i/o streamet és a http kapcsolatot
                try {
                  if (hc != null) hc.close();
                } catch (IOException ignored) {}
                try {
                  if (dis != null) dis.close();
                } catch (IOException ignored) {}
                try {
                  if (dos != null) dos.close();
                } catch (IOException ignored) {}
        }
        //rsp=messagebuffer.toString();
       } catch(Exception e) {
         //értesítjük a felhasználót, hogy nem sikerült a kérést elküldeni
        rsp = "Hiba lépett fel a feldolgozás során!";
        //rsp=messagebuffer.toString();
     }
     }
   };
   thread.start();
}

}