import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.sql.SQLException;
import java.util.Map;

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;
import javax.microedition.io.Connector;
import javax.microedition.io.StreamConnection;

import org.eclipse.kura.configuration.ConfigurableComponent;
import org.osgi.framework.BundleContext;
import org.osgi.service.component.ComponentContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class GatewayConfigurator implements ConfigurableComponent  {
	private static final Logger logger = LoggerFactory.getLogger(GatewayConfigurator.class);
	private static final String APP_ID = "com.x.gateway.GatewayConfigurator";
	private BundleContext context;
	public Object lock = new Object();
	RemoteDevice hc05device;
	String hc05Url;
	boolean inq;
	protected void activate(ComponentContext componentContext) {
		logger.info("Bundle " + APP_ID + " has started! <==================");
		activate(componentContext, null);
		
	}

	protected void activate(ComponentContext componentContext, Map<String, Object> properties) {
		logger.info("Bundle " + APP_ID + " has started! <==================");
		try {
			  inq = LocalDevice.getLocalDevice().getDiscoveryAgent().startInquiry(DiscoveryAgent.GIAC, new DiscoveryListener() {
				 
				
				 @Override
		            public void deviceDiscovered(RemoteDevice btDevice, DeviceClass cod) {
					  logger.debug("deviceDiscovered1.. started");
		                try {
		                    String name = btDevice.getFriendlyName(false);
		                    System.out.format("%s (%s)\n", name, btDevice.getBluetoothAddress());
		                    if (name.matches("HC.*")) {
		                        hc05device = btDevice;
		                        logger.info("got it!");
		                    }
		                } catch (IOException e) {
		                    e.printStackTrace();
		                }
		            }

		            @Override
		            public void inquiryCompleted(int discType) {
		            	logger.info("inquiryCompleted1.. started");
		                
		                try {
		        			synchronized (lock) {
		        				lock.notify();
		        			}
		        		} catch (Exception e) {
		        			// TODO Auto-generated catch block
		        			logger.info("Notify1 complete....");
		        		}
		            }

		            @Override
		            public void serviceSearchCompleted(int transID, int respCode) {
		            	logger.info("serviceSearchCompleted1.. started");
		            }

		            @Override
		            public void servicesDiscovered(int transID, ServiceRecord[] servRecord) {
		            	logger.info("servicesDiscovered1.. started");
		            }
		        });
		} catch (BluetoothStateException e) {
			// TODO: handle exception
			
			logger.info("exception::" + e.getCause());
		}
		logger.info("Inquiry started: " + inq);
		try {
			synchronized (lock) {
				lock.wait();
			}
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			logger.info("Scan complete....");
		}
		 UUID uuid = new UUID(0x1101); //scan for btspp://... services (as HC-05 offers it)
	        UUID[] searchUuidSet = new UUID[]{uuid};
	        int[] attrIDs = new int[]{
	            0x0100 // service name
	        };
	        
	        try {
				LocalDevice.getLocalDevice().getDiscoveryAgent().searchServices(attrIDs, searchUuidSet,
				        hc05device, new DiscoveryListener() {
				            @Override
				            public void deviceDiscovered(RemoteDevice btDevice, DeviceClass cod) {
				            	logger.info("deviceDiscovered2.. started");
				            }

				            @Override
				            public void inquiryCompleted(int discType) {
				            	logger.info("inquiryCompleted2.. started");
				            }

				            @Override
				            public void serviceSearchCompleted(int transID, int respCode) {
				            	logger.info("serviceSearchCompleted2.. started");
				            	try {
				        			synchronized (lock) {
				        				lock.notify();
				        			}
				        		} catch (Exception e) {
				        			// TODO Auto-generated catch block
				        			logger.info("Notify1 complete....");
				        		}
				            }

				            @Override
				            public void servicesDiscovered(int transID, ServiceRecord[] servRecord) {
				            	logger.info("servicesDiscovered2.. started");
				                for (int i = 0; i < servRecord.length; i++) {
				                    hc05Url = servRecord[i].getConnectionURL(ServiceRecord.NOAUTHENTICATE_NOENCRYPT, false);
				                    if (hc05Url != null) {
				                        break; //take the first one
				                    }
				                }
				            }
				        });
			} catch (BluetoothStateException e) {
				// TODO Auto-generated catch block
				logger.info("exception::" + e.getCause());
			}
	        
	        try {
				synchronized (lock) {
					lock.wait();
				}
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				logger.info("Scan complete....");
			}
	        
	        System.out.println(hc05device.getBluetoothAddress());
	        System.out.println(hc05Url);
	        if(hc05Url == null) {
	        	hc05Url= "btspp://98D3321046B8:1;authenticate=false;encrypt=false;master=false";
	        }

	        try {
	        	//if you know your hc05Url this is all you need:
		        StreamConnection streamConnection = (StreamConnection) Connector.open(hc05Url);
		        OutputStream os = streamConnection.openOutputStream();
		        InputStream is = streamConnection.openInputStream();

		       // os.write("Hello arduino".getBytes()); //just send '1' to the device
		        
		        BufferedReader br = new BufferedReader(new InputStreamReader(is));
		        int i = 0;
		        String line;
		     //   while (i++ <= 10000000) {
		        	logger.info("Starting read write process");
		        	//os.write("Hello arduino".getBytes());
		        	//os.flush();
		        	line = new String(br.readLine());
		        	/*while(true) {
		        		logger.info("data:" + is.read());
		        	}*/
					//System.out.println(line);
			//	}
		        
		        //os.close();
		        //is.close();
		       // streamConnection.close();
			} catch (Exception e) {
				logger.info("exception::" + e.getCause());
			}
	}
	
	
	
	
	protected void deactivate(ComponentContext componentContext) {

	}
	
	public void updated(Map<String, Object> properties) {
		logger.info("Bundle " + APP_ID + " has been updated!");
		//handleInstruction(properties);
    }
	
	
	

}