// ClientBox.java



import java.io.DataInputStream; 
import java.io.DataOutputStream; 
import java.io.IOException; 

import java.util.Vector; 

import javax.microedition.io.Connector; 
import javax.microedition.io.StreamConnection; 
import javax.microedition.lcdui.Command; 
import javax.microedition.lcdui.CommandListener; 
import javax.microedition.lcdui.Displayable; 
import javax.microedition.lcdui.Form; 
import javax.microedition.lcdui.Gauge; 
import javax.microedition.lcdui.StringItem; 
import javax.microedition.lcdui.TextField; 

//jsr082 API 
import javax.bluetooth.BluetoothStateException; 

import javax.bluetooth.DeviceClass; 
import javax.bluetooth.DiscoveryAgent; 
import javax.bluetooth.DiscoveryListener; 
import javax.bluetooth.LocalDevice; 
import javax.bluetooth.RemoteDevice; 
import javax.bluetooth.ServiceRecord; 
import javax.bluetooth.UUID; 

/** 
* 客戶端GUI 
* @author Jagie 
* 
* TODO To change the template for this generated type comment go to 
* Window - Preferences - Java - Code style - Code Templates 
*/ 
public class ClientBox extends Form implements Runnable,CommandListener,DiscoveryListener { 

    
   //字串輸入框 
   TextField input = new TextField(null, "", 50, TextField.ANY); 
   //loger 
   StringItem result = new StringItem("結果:", ""); 

   private DiscoveryAgent discoveryAgent; 

    
   private UUID[] uuidSet; 

   //響應服務的UUID 
   private static final UUID ECHO_SERVER_UUID = new UUID( 
           "F0E0D0C0B0A000908070605040302010", false); 

   //設備集合 
   Vector devices = new Vector(); 
   //服務集合 
   Vector records = new Vector(); 
    
   //服務搜索的事務id集合 
   int[] transIDs; 
   StupidBTMIDlet midlet; 

   public ClientBox(StupidBTMIDlet midlet) { 
       super(""); 
       this.midlet=midlet; 
        
       this.append(result); 
        
       this.addCommand(new Command("取消",Command.CANCEL,1)); 
       this.setCommandListener(this); 
        
       new Thread(this).start(); 
   } 
    
   public void commandAction(Command arg0, Displayable arg1) { 
       if(arg0.getCommandType()==Command.CANCEL){ 
           midlet.showMainMenu(); 
       }else{ 
           //匿名內部Thread，訪問遠程服務。 
           Thread fetchThread=new Thread(){ 
               public void run(){ 
                   for(int i=0;i<records.size();i++){ 
                       ServiceRecord sr=(ServiceRecord)records.elementAt(i); 
                       if(accessService(sr)){ 
                           //訪問到一個可用的服務即可 
                           break; 
                       } 
                   } 
               } 
           }; 
           fetchThread.start(); 
       } 
        
   } 
    
    
   private boolean  accessService(ServiceRecord sr){ 
       boolean result=false; 
        try { 
           String url = sr.getConnectionURL( 
                   ServiceRecord.NOAUTHENTICATE_NOENCRYPT, false); 
           StreamConnection    conn = (StreamConnection) Connector.open(url); 
            
           DataOutputStream dos=conn.openDataOutputStream(); 
           dos.writeUTF(input.getString()); 
           dos.close(); 
           DataInputStream dis=conn.openDataInputStream(); 
           String echo=dis.readUTF(); 
           dis.close(); 
           showInfo("反饋結果是:"+echo); 
           result=true; 
            
       } catch (IOException e) { 
            
       } 
       return result; 
   } 

   public synchronized void run() { 
       //發現設備和服務的過程中，給用戶以Gauge 
       Gauge g=new Gauge(null,false,Gauge.INDEFINITE,Gauge.CONTINUOUS_RUNNING); 
       this.append(g); 
       showInfo("藍牙初始化..."); 
       boolean isBTReady = false; 

       try { 

           LocalDevice localDevice = LocalDevice.getLocalDevice(); 
           discoveryAgent = localDevice.getDiscoveryAgent(); 

           isBTReady = true; 
       } catch (Exception e) { 
           e.printStackTrace(); 
       } 

       if (!isBTReady) { 
           showInfo("藍牙不可用"); 
           //刪除Gauge 
           this.delete(1); 
           return; 
       } 

       uuidSet = new UUID[2]; 

       //標志我們的響應服務的UUID集合 
       uuidSet[0] = new UUID(0x1101); 
       uuidSet[1] = ECHO_SERVER_UUID; 


        
       try { 
           discoveryAgent.startInquiry(DiscoveryAgent.GIAC, this); 
       } catch (BluetoothStateException e) { 

       } 

       try { 
           //阻塞,由inquiryCompleted()回調方法喚醒 
           wait(); 
       } catch (InterruptedException e1) { 
            
           e1.printStackTrace(); 
       } 
       showInfo("設備搜索完畢,共找到"+devices.size()+"個設備,開始搜索服務"); 
       transIDs = new int[devices.size()]; 
       for (int i = 0; i < devices.size(); i++) { 
           RemoteDevice rd = (RemoteDevice) devices.elementAt(i); 
           try { 
               //記錄每一次服務搜索的事務id 
               transIDs[i] = discoveryAgent.searchServices(null, uuidSet, 
                       rd, this); 
           } catch (BluetoothStateException e) { 
               continue; 
           } 

       } 
        
       try { 
           //阻塞,由serviceSearchCompleted()回調方法在所有設備都搜索完的情況下喚醒 
           wait(); 
       } catch (InterruptedException e1) { 
           e1.printStackTrace(); 
       } 
        
       showInfo("服務搜索完畢,共找到"+records.size()+"個服務,準備發送請求"); 
       if(records.size()>0){ 
           this.append(input); 
           this.addCommand(new Command("發送",Command.OK,0)); 
       } 
        
       //刪除Gauge 
       this.delete(1); 
        
   } 
    
   /** 
    * debug 
    * @param s 
    */ 
    
   private void showInfo(String s){ 
       StringBuffer sb=new StringBuffer(result.getText()); 
       if(sb.length()>0){ 
           sb.append("\n"); 
       } 
       sb.append(s); 
       result.setText(sb.toString()); 

   } 
    
   /** 
    * 回調方法 
    */ 

   public void deviceDiscovered(RemoteDevice btDevice, DeviceClass cod) { 

       if (devices.indexOf(btDevice) == -1) { 
           devices.addElement(btDevice); 
       } 
   } 

   /** 
    * 回調方法，喚醒初始化線程 
    */ 
   public void inquiryCompleted(int discType) { 

       synchronized (this) { 
           notify(); 
       } 
   } 
   /** 
    * 回調方法 
    */ 
   public void servicesDiscovered(int transID, ServiceRecord[] servRecord) { 
       for (int i = 0; i < servRecord.length; i++) { 
           records.addElement(servRecord[i]); 
       } 
   } 
    
   /** 
    * 回調方法，喚醒初始化線程 
    */ 

   public void serviceSearchCompleted(int transID, int respCode) { 
        
       for (int i = 0; i < transIDs.length; i++) { 
           if (transIDs[i] == transID) { 
               transIDs[i] = -1; 
               break; 
           } 
       } 
        
       //如果所有的設備都已經搜索服務完畢，則喚醒初始化線程。 

       boolean finished = true; 
       for (int i = 0; i < transIDs.length; i++) { 
           if (transIDs[i] != -1) { 
               finished = false; 
               break; 
           } 
       } 

       if (finished) { 
           synchronized (this) { 
               notify(); 
           } 
       } 

   } 

}