DZone Snippets: bluetooth code

Using Bluetooth to control Asterisk calls.

jrobertson (James Robertson) — Tue, 17 Jun 2008 20:52:13 GMT

Redirect an Asterisk call



    de61.old_status = get_status(de61.file) # found is either true or false

    de61.old_location = get_location(de61.file) # location is either 'at home', 'gone to bed' or 'asleep'

    

    while count < 1



      puts 'old status : ' + de61.old_status.to_s

      de61.new_status = check_device(de61.id, de61.name)

      puts 'new_status: ' + de61.new_status.to_s





      if de61.new_status and de61.old_status

        if de61.old_status == false

          puts 'connecting to the bluetooth device ...'

          Thread.new{`rfcomm connect 0 #{de61.id}`}

          sleep 12

        end

        de61.new_location = check_location(de61.id) 

      end

      

      puts 'old_location: ' + de61.old_location.to_s

      puts 'new_location: ' + de61.new_location.to_s

      update_status(de61.project, de61.new_status, de61.new_location) if ((de61.old_status != de61.new_status.to_s) or (de61.old_location != de61.new_location)) 

        

      mystatus = ''

      

      if  (not de61.old_status == de61.new_status) then

        if (de61.new_status.to_s == 'true') then

            mystatus = ' has entered the building'

            callto('SIP/line1')

        elsif  (de61.new_status == false) then

          mystatus = ' has left the building'

          callto('SIP/07736668666@sipgate')

        end

        puts 'updating in or out the building'

        ms = MyStatus.new(mystatus)

      elsif (de61.old_location.to_s != de61.new_location.to_s)

        if de61.old_location.match(/sleep/) and de61.new_location.match(/home|bed/) and not old_mystatus.match(/awoken/) then

          mystatus = ' has awoken'

        elsif (de61.old_location.match(/home|bed/)) and de61.new_location.match(/sleep/) 

          mystatus = ' has gone to sleep'           

        elsif (de61.old_location.match(/home/)) and de61.new_location.match(/bed/) 

          mystatus = ' has gone to bed'

        elsif de61.old_location.match(/bed/) and de61.new_location.match(/home/) 

          mystatus = ' has got out of bed'

        end

        puts 'updating home location'

        ms = MyStatus.new(mystatus) if mystatus != ''

      end





      de61.old_location = de61.new_location

      de61.new_location = 'at home'

      de61.old_status = de61.new_status

      old_mystatus = mystatus

      sleep 7

    end

  end

    

  def callto(dialstring)

    file = File.new('/etc/asterisk/ruby/call-to.txt','w')

    file.puts 'Dial(' + dialstring + ')'

    file.close

  end

file: extensions.conf



exten => 5168666,n,ReadFile(dialplan1=/etc/asterisk/ruby/call-to.txt,130)

exten => 5168666,n,Exec(${dialplan1})

Using Ruby to detect Bluetooth proximity

jrobertson (James Robertson) — Sun, 25 May 2008 10:57:00 GMT

This Ruby script uses the hcitool and rfcomm to detect the proximity of a bluetooth enabled mobile phone. The signal strength in this script will return a value from 0 to 10, 0 is near and 10 is far, otherwise if there is no connection it will keep on trying.



deviceid = '00:12:D1:E6:57:BE' 

range = ''

count = 0

while count < 1

  # assuming the bt device is already connected get the signal strength value.

  range = `hcitool rssi #{deviceid}`.chomp

  if  range.length > 0

    puts range[/\w+$/]

  else

    puts 'connecting to the bluetooth device ...'

    Thread.new{`rfcomm connect 0 #{deviceid}`}

  end

	

  sleep 7

end

warning (11-Jul-2008): I've found Thread.new to be causing a problem, it appears not to remove itself from the process queue when it is no longer required.

Simple Bluetooth Proximity

jrobertson (James Robertson) — Tue, 20 May 2008 22:39:59 GMT

Following on from my earlier investigation into bluetooth proximity, I wanted something which returned a value which could be used to determine distance. The output from hcitool rssi ranges from 0 for close object down to -10 for far away objects.



rfcomm connect 0 00:12:D1:E6:57:BE



hcitool rssi 00:12:D1:E6:57:BE

Proximity Results:
-4 .. 0 : Bedroom - nearest to my bed
-4 .. -6 : Hallway
-8 .. -9 : Livingroom - on the computer desk
-9 .. -10 : Livingroom - nearest to the window

Detect the presence of a Bluetooth device

jrobertson (James Robertson) — Thu, 27 Dec 2007 15:11:41 GMT

This example shows how to check for the presence of a mobile phone. The code was based on the article 'Implementing Bluetooth Proximity Detection with Asterisk, Part II' http://snipr.com/1vvi5 [nerdvittles.com]



#!/usr/bin/ruby

#file: whereib.rb



deviceid = '00:0E:6D:29:38:EB'

devicename = 'Nokia 6600'



count = 0

while count < 1

  if `hcitool name #{deviceid}`.chomp == devicename 

    puts devicename + ' IN RANGE'

    puts Time.now

  else

    puts devicename + ' OUT OF RANGE'

    puts Time.now

  end

  sleep 7

end

PyS60: Bluetooth GPS polling class

ejot (Magnus Persson) — Fri, 16 Nov 2007 14:09:19 GMT

Threaded approach for reading NMEA data from a bluetooth GPS.



import thread, socket



class BTGPSPoller(object):

	def __init__(self, address):

		address, services = socket.bt_discover(address)

		self.target = (address, services.values()[0])

		self.active = True

		self.connected = False

		self.lock = thread.allocate_lock()

		self.sentances = list()

		

	def connect(self):

		if not self.connected:

			thread.start_new_thread(self.run, ())



	def run(self):

		print "BTGPSPoller thread activated"

		try:

			conn = socket.socket(socket.AF_BT, socket.SOCK_STREAM)

			conn.connect(self.target)

			self.connected = True

		except:

			print "Unable to connect"

		

		if self.connected:

			try:

				to_gps = conn.makefile("r", 0)

			except:

				print "Failure calling conn.makefile()"

			while self.active:

				#e32.ao_sleep(1)

				msg = None

				try:

					msg = to_gps.readline()

					if not msg == None and msg.startswith("$GPGGA"):

						gps_data = msg.split(",")

						if not gps_data[2] == "":

							self.lock.acquire()

							self.sentances.append(msg)

							if len(self.sentances) > 10:

								self.sentances.pop(0)

							self.lock.release()

				except:

					self.active = False



			try:

				to_gps.close()

				conn.close()

				self.connected = False

				print "Closed and disconnected"

			except:

				self.connected = False

				print "Unable to close"



	def disconnect(self):

		self.active = False

		print "Disconnecting from GPS"



	def getSentances(self):

		self.lock.acquire()

		l = self.sentances[:]

		self.lock.release()

		return l

help!.. please

esergulum (esergulum) — Thu, 29 Mar 2007 01:56:24 GMT

// description of your code here



sorry! what does it mean "Chattando" midlet ? [J2ME - Search Service Bluetooth: protected Chattando midlet;]

J2ME - Create Service Bluetooth

whitetiger () — Fri, 23 Feb 2007 14:22:23 GMT

// Create Service Bluetooth



import javax.bluetooth.DiscoveryAgent;

import javax.bluetooth.LocalDevice;

import javax.microedition.io.Connector;

import javax.microedition.io.StreamConnection;

import javax.microedition.io.StreamConnectionNotifier;



public class ServerChat

{

	private static final String CHATTANDO_UUID = "A1A2A3A4A5A6A7A8A9A0B1B2B3B4B5B6";

	private static final String CHATTANDO_SERVICE = "Chattando";

	

	private boolean isReady = false;

	

	private StreamConnection stream_connection;

	private StreamConnectionNotifier stream_connection_notifier;

	

	public ServerChat()

	{

		startServerChatBluetooth();

	}

	

	// Apre il servizio per la Chat

	public void startServerChatBluetooth()

	{

		new Thread()

		{

			public void run()

			{

				try

				{

					LocalDevice.getLocalDevice().setDiscoverable(DiscoveryAgent.GIAC);

				}

				catch(Exception error)

				{

					error.printStackTrace();

				}

				

				try

				{

					stream_connection_notifier = (StreamConnectionNotifier) Connector.open("btspp://localhost:" + CHATTANDO_UUID + ";name=" + CHATTANDO_SERVICE);

				}

				catch(Exception error)

				{

					error.printStackTrace();

				}

				

				stopServerChatBluetooth();

				

				// Mette in ascolto il Server della Chat

				isReady = true;

				

				try

				{

					while(isReady)

					{

						System.out.println("Sono in ascolto...");

						

						stream_connection = stream_connection_notifier.acceptAndOpen();

						

						System.out.println("Client Connected");

					}

				}

				catch(Exception error)

				{

					error.printStackTrace();

				}

			}

			

		}.start();

	}



	// Chiude il servizio per la Chat

	public void stopServerChatBluetooth()

	{

		if(isReady)

		{

			isReady = false;

			

			try

			{

				stream_connection_notifier.close();

			}

			catch(Exception error)

			{

				error.printStackTrace();

			}

		}

	}

}

J2ME - Search Service Bluetooth

whitetiger () — Fri, 23 Feb 2007 14:21:30 GMT

// Example Search Service Bluetooth



import java.util.Vector;



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;



public class ClientChat implements DiscoveryListener

{

	private static final String CHATTANDO_UUID = "A1A2A3A4A5A6A7A8A9A0B1B2B3B4B5B6";

	private static final String CHATTANDO_SERVICE = "Chattando";



	protected Chattando midlet;

	

	private boolean searchDone = false;

	

	private DiscoveryAgent discovery_agent;

	

	private Vector remote_device;

	private Vector device_found;

	

	public ClientChat(Chattando midlet)

	{

		this.midlet = midlet;

		

		startScanBluetoothDevices();

	}

	

	// Avvia la ricerca dei dispositivi Bluetooth

	public void startScanBluetoothDevices()

	{

		try

		{

			remote_device = new Vector();

			device_found = new Vector();

			

			discovery_agent = LocalDevice.getLocalDevice().getDiscoveryAgent();

			discovery_agent.startInquiry(DiscoveryAgent.GIAC, this);

		}

		catch(Exception error)

		{

			error.printStackTrace();

		}

	}

	

	// Stoppa la ricerca dei dispositivi Bluetooth

	public void stopScanBluetoothDevices()

	{

		discovery_agent.cancelInquiry(this);

	}



	public void deviceDiscovered(RemoteDevice btDevice, DeviceClass cod) 

	{

		// Aggiungo il dispositivo solo se e' un computer (0x0100) o un cellulare (0x0200)

		if(cod.getMajorDeviceClass() == 0x0100 || cod.getMajorDeviceClass() == 0x0200)

			remote_device.addElement(btDevice);

	}



	public void inquiryCompleted(int discType)

	{

		switch(discType)

		{

			case DiscoveryListener.INQUIRY_COMPLETED:

														System.out.println("Device Search Completed");

														

														break;

				

			case DiscoveryListener.INQUIRY_ERROR:

														System.out.println("Device Search Error");

														

														break;

				

			case DiscoveryListener.INQUIRY_TERMINATED:

														System.out.println("Device Search Terminated");

														

														break;

		}

		

		try

		{

			for(int i=0, cnt=remote_device.size(); i			{

				discovery_agent.searchServices(new int[]{ 0x0100, 0x0200 }, new UUID[]{ new UUID(0x0003), new UUID(CHATTANDO_UUID, false) }, (RemoteDevice) remote_device.elementAt(i), this);

				waitForSearchDone();

			}

		}

		catch(Exception error)

		{

			error.printStackTrace();

		}

	}



	// Aspetta che la ricerca dei servizi per il dispositivo sia terminata

	private void waitForSearchDone()

	{

		searchDone = false;

		

		try

		{

			while(!searchDone)

			{

				synchronized(this)

				{

					this.wait();

				}

			}

		}

		catch(Exception error)

		{

			

		}

	}

	

	public void serviceSearchCompleted(int transID, int respCode)

	{

		switch(respCode)

		{

			case DiscoveryListener.SERVICE_SEARCH_COMPLETED:

																		System.out.println("Service Search Completed");

																		

																		break;

				

			case DiscoveryListener.SERVICE_SEARCH_DEVICE_NOT_REACHABLE:

																		System.out.println("Service Search Device not Reachable");

																		

																		break;

				

			case DiscoveryListener.SERVICE_SEARCH_ERROR:

																		System.out.println("Service Search Error");

																		

																		break;

				

			case DiscoveryListener.SERVICE_SEARCH_NO_RECORDS:

																		System.out.println("Service Search No Records");

																		

																		break;

				

			case DiscoveryListener.SERVICE_SEARCH_TERMINATED:

																		System.out.println("Service Search Terminated");

																		

																		break;

		}

		

		searchDone = true;

		

		// Risveglia il processo in attesa del completamento della ricerca dei servizi per un dispositivo

		synchronized(this)

		{

			this.notifyAll();

		}

	}



	public void servicesDiscovered(int transID, ServiceRecord[] servRecord)

	{

		for(int i=0, cnt=servRecord.length; i		{

			if(((String) servRecord[i].getAttributeValue(0x0100).getValue()).equalsIgnoreCase(CHATTANDO_SERVICE))

			{

				device_found.addElement(servRecord[i].getHostDevice());

			}

		}

	}

}

Python - SendSMS over BT and AT

whitetiger () — Sun, 26 Nov 2006 21:31:03 GMT

// Send SMS over Bluetooth (AT Command)



import bluetooth



sockfd = bluetooth.BluetoothSocket(bluetooth.RFCOMM)

sockfd.connect(('00:00:00:00:00:00', 1)) # BT Address

sockfd.send('ATZ\r')

sockfd.send('AT+CMGF=1\r')

sockfd.send('AT+CSCA="+393359609600"\r') # Client TIM ITA

sockfd.send('AT+CMGS="+39xxxxxxxxxx"\r') # TO PhoneNumber

sockfd.send('Messaggio da mandare...\n')

sockfd.send(chr(26)) # CTRL+Z

sockfd.close()

PyS60 - SendFile

whitetiger () — Sun, 26 Nov 2006 21:12:40 GMT

// Send File over Bluetooth



from appuifw import *

from e32socket import *



try:

    phone = bt_obex_discover()

    file = query(u'File Selection', 'text')

    bt_obex_send_file(phone[0], phone[1].values()[0], file)

    note(u'File Sent')

except Exception, error:

    note(unicode(error), 'error')