package gs.embtel.netsms.iden.engine;

import java.io.*;
import gs.mobile.messaging.*;
import javax.microedition.io.*;
import javax.microedition.lcdui.*;
import javax.wireless.messaging.*;

/**
 * Clase que implementa el motor de mensajería vía puerto serial
 * @author Ing.Giancarlo Santini
 * @version 1.0
 */
public class CommPortMessagingEngine implements Runnable{
   
    private Form console;
    private Thread thread;
    private boolean execute;   
    private CommConnection port;
    private DataInputStream input;
    private DataOutputStream output;
   
    public CommPortMessagingEngine(CommConnection port , Form console){
        input = null;
        output = null;
        thread = null;       
        this.port = port;
        this.console = console;
        execute = false;
    }
   
    public void start(){
        execute = true;
       
        try{
            input = port.openDataInputStream();
            output = port.openDataOutputStream();
            thread = new Thread(this);
            thread.start();
        } catch(Exception ex){
            console.append("Cannot start Messaging engine because of Exception: " +
                    ex.getMessage() + "\n");
        }
    }
   
    public void stop(){
        execute = false;
       
        try{
            input.close();
            output.close();
        } catch(Exception ex){
            console.append("Error while closing input/output buffers. Exception: " +
                    ex.getMessage() + "\n");
        } finally{
            input = null;
            output = null;
        }
       
        thread.interrupt();
    }
   
    public void run() {
        console.append("Starting Messaging engine..\n");
       
        while(execute){
            int data = 0;
            StringBuffer sb = new StringBuffer("");
           
            try{
                while((data = input.read()) != '\r'){
                    sb.append((char)data);
                }
               
                if(sb.toString().indexOf("|") > -1){
                    String ptn = sb.toString().substring(0, sb.toString().indexOf("|"));
                    String message = sb.toString().substring(sb.toString().indexOf("|") + 1);
                   
                    console.deleteAll();
                    console.append("Sending message to PTN: " + ptn + " - Message:" + message + "\n");
                   
                    console.append("Sending Message...\n");
                   
                    SmsInfo smsBody = new SmsInfo();
                    smsBody.setAddress(ptn.trim());
                    smsBody.setMessage(message.trim());
                   
                    SmsSender sms = new SmsSender(smsBody);
                   
                    MessageConnection smsConn = (MessageConnection)Connector.open("sms://" + smsBody.getAddress());
                   
                    sms.setConnection(smsConn);
                    sms.start();
                   
                    while(sms.isSending());
                   
                    if(sms.getResultCode() == 1){
                        console.append("Message Sent Successfully!\n");
                        output.writeUTF("OK");
                    }
                   
                    else{
                        MmsInfo mmsBody = new MmsInfo();
                        mmsBody.setAddress(ptn.trim());
                        mmsBody.setSubject("Santini Embtel NetSMS MMS");
                        mmsBody.setTextMsg(message);
                       
                        MmsSender mms = new MmsSender(mmsBody);
                       
                        MessageConnection mmsConn = (MessageConnection)Connector.open("mms://" + mmsBody.getAddress());
                       
                        mms.setConnection(mmsConn);
                        mms.start();
                       
                        while(mms.isSending());
                       
                        if(mms.getResultCode() == 1){
                            console.append("Message Sent Successfully!\n");
                            output.writeUTF("OK");
                        }
                       
                        else{
                            console.append("Error while sending message!!\n");
                            output.writeUTF("ERROR");
                        }
                       
                        mmsConn.close();
                        mmsConn = null;
                       
                        mmsBody = null;
                        mms = null;
                    }
                   
                    smsConn.close();
                    smsConn = null;
                   
                    smsBody = null;
                    sms = null;
                }
               
                sb = null;
            } catch(Exception ex){
                console.append("Error while reading port. Exception: " +
                        ex.getMessage() + "\n");
            }
        }
    }

}