Skip to content
Snippets Groups Projects
Commit fc08b2a4 authored by Puissegur Alexis's avatar Puissegur Alexis
Browse files

observer patron

parent c66031cf
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 230 additions and 122 deletions
app/.gitignore 0 → 100644
+ 1
− 0
View file @ fc08b2a4
/.metadata/
app/src/BluetoothJavaServer/src/edu/kufpg/bluetooth/server/BluetoothManager.java 0 → 100644
+ 153
− 0
View file @ fc08b2a4
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package BluetoothJavaServer.src.edu.kufpg.bluetooth.server;
import Vue.FXMLVueController;
import app.App;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
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;
/**
*
* @author puiss
*/
public class BluetoothManager implements DiscoveryListener {
private Object lock=new Object();
private static ArrayList<RemoteDevice> devices;
private final List<ServiceRecord> serviceRecords = new ArrayList<ServiceRecord>();
private final List<BluetoothConnection> connections = new ArrayList<BluetoothConnection>();
private BluetoothThread t;
private FXMLVueController observer;
public BluetoothThread getWorkingThread(){
return t;
}
public BluetoothManager(FXMLVueController observer){
this.devices = new ArrayList<RemoteDevice>();
this.observer = observer;
}
@Override
public void deviceDiscovered(RemoteDevice btDevice, DeviceClass arg1) {
String name;
try {
name = btDevice.getFriendlyName(false);
} catch (Exception e) {
name = btDevice.getBluetoothAddress();
}
devices.add(btDevice);
System.out.println("device found: " + name);
}
@Override
public void inquiryCompleted(int arg0) {
synchronized(lock){
lock.notify();
}
}
@Override
public void serviceSearchCompleted(int arg0, int arg1) {
synchronized (lock) {
lock.notify();
}
}
@Override
public void servicesDiscovered(int transID, ServiceRecord[] servRecord) {
System.out.println("hey ! " + servRecord);
for(ServiceRecord s : servRecord) {
System.out.println("-------"+ s + "-------");
}
serviceRecords.addAll(Arrays.asList(servRecord));
}
public boolean launch(){
try{
UUID serialPortUuid = new UUID(BluetoothServiceUuids.SERIAL_PORT.getHexValue());
UUID[] desiredServiceUuids = new UUID[] { serialPortUuid };
LocalDevice localDevice = LocalDevice.getLocalDevice();
DiscoveryAgent agent = localDevice.getDiscoveryAgent();
RemoteDevice[] devices = agent.retrieveDevices(DiscoveryAgent.PREKNOWN);
for(RemoteDevice d : devices) {
if(d.getBluetoothAddress().equals("201611073171")) {
System.out.println("Thingz trouve");
synchronized(lock) {
int result = agent.searchServices(null, desiredServiceUuids, d, this);
if( DiscoveryListener.SERVICE_SEARCH_DEVICE_NOT_REACHABLE == result) {
System.out.println(" but it could not be reached");
continue;
}
lock.wait();
System.out.println("service records found");
if(null != serviceRecords && serviceRecords.size() > 0) {
System.out.println("YA DES SERVICES");
for(ServiceRecord serviceRecord: serviceRecords) {
String connectionUrl = serviceRecord.getConnectionURL(ServiceRecord.NOAUTHENTICATE_NOENCRYPT, false); // I have no idea what these args are
StreamConnection connection;
try {
connection = (StreamConnection)Connector.open(connectionUrl);
DataInputStream inputStream = new DataInputStream(connection.openDataInputStream());
BluetoothConnection bluetoothConnection = new BluetoothConnection(d.getBluetoothAddress(), inputStream);
bluetoothConnection.setOutputStream(new DataOutputStream(connection.openOutputStream()));
connections.add(bluetoothConnection);
System.out.println("Connected to " + d.getBluetoothAddress());
return true;
} catch (IOException e) {
System.out.println("Could not connect to " + d.getBluetoothAddress() + ": " + e.getMessage());
e.printStackTrace();
return false;
}
}
}
}
}
}
} catch(Exception e){
e.printStackTrace();
return false;
}
return false;
}
/**
*
*/
public void startThread() throws Exception {
try {
if(connections.size() > 0) { // we are connected
System.out.println("start");
this.t = new BluetoothThread(connections.get(0), observer);
t.start();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
app/src/BluetoothJavaServer/src/edu/kufpg/bluetooth/server/BluetoothThread.java
+ 27
− 16
View file @ fc08b2a4
package BluetoothJavaServer.src.edu.kufpg.bluetooth.server;
import Vue.FXMLVueController;
import java.io.EOFException;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.logging.Level;
import java.util.logging.Logger;
import sun.misc.IOUtils;
public class BluetoothThread extends Thread {
private BluetoothConnection connection;
private boolean keepGoing = true;
public BluetoothThread(BluetoothConnection connection) {
private String buffer;
private FXMLVueController observer;
public BluetoothThread(BluetoothConnection connection, FXMLVueController observer) {
this.connection = connection;
this.observer = observer;
}
public void notifyObserver(){
observer.update(this);
}
public String getBuffer(){
return this.buffer;
}
@Override
public void run() {
System.out.println("hey c parti");
// If there are custom settings to be written to each headset, add them at this point
// try {
// connection.getOutputStreamWriter().write(MindwaveSerialPacket.Codes.DISCONNECT.getHexValue());
// } catch (IOException e1) {
// // TODO Auto-generated catch block
// e1.printStackTrace();
// }
System.out.println("hey c parti");
while (keepGoing) {
System.out.println("hi");
byte b;
......@@ -35,11 +41,11 @@ public class BluetoothThread extends Thread {
System.out.println("New packet found");
byte[] payload = new byte[100];
connection.getInputStream().read(payload);
String str = new String(payload, StandardCharsets.UTF_8);
System.out.println("payload : " + str);
this.buffer = new String(payload, StandardCharsets.UTF_8);
System.out.println("payload : " + this.buffer);
notifyObserver();
connection.getOutputStream().write("SOUND".getBytes());
//connection.getOutputStream().write("SOUND".getBytes());
} catch (Exception e) {
System.out.println("Could not read stream" + e);
......@@ -50,7 +56,12 @@ public class BluetoothThread extends Thread {
}
public void stopThread() {
keepGoing = false;
try {
keepGoing = false;
finalize();
} catch (Throwable ex) {
Logger.getLogger(BluetoothThread.class.getName()).log(Level.SEVERE, null, ex);
}
}
@Override
......
app/src/Vue/FXMLVue.fxml
+ 2
− 2
View file @ fc08b2a4
......@@ -27,10 +27,10 @@
<Label text="La plante qui pleure" textAlignment="CENTER" GridPane.halignment="CENTER">
<font>
<Font name="Trebuchet MS Bold" size="28.0" />
</font>
</font>gggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggg
</Label>
<GridPane fx:id="accueil" style="-fx-background-color: white;" GridPane.rowIndex="1">
<columnConstraints>
<columnConstragggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggggints>
<ColumnConstraints hgrow="SOMETIMES" minWidth="10.0" prefWidth="100.0" />
<ColumnConstraints hgrow="SOMETIMES" maxWidth="-Infinity" minWidth="10.0" prefWidth="20.0" />
<ColumnConstraints hgrow="SOMETIMES" minWidth="10.0" prefWidth="100.0" />
......
app/src/Vue/FXMLVueController.java
+ 22
− 0
View file @ fc08b2a4
......@@ -5,8 +5,12 @@
*/
package Vue;
import BluetoothJavaServer.src.edu.kufpg.bluetooth.server.BluetoothManager;
import BluetoothJavaServer.src.edu.kufpg.bluetooth.server.BluetoothThread;
import java.net.URL;
import java.util.ResourceBundle;
import java.util.logging.Level;
import java.util.logging.Logger;
import javafx.beans.value.ChangeListener;
import javafx.beans.value.ObservableValue;
import javafx.event.ActionEvent;
......@@ -59,11 +63,24 @@ public class FXMLVueController implements Initializable {
@FXML
private Button buttonConfig;
private boolean isConnected = false;
/**
* Initializes the controller class.
*/
@Override
public void initialize(URL url, ResourceBundle rb) {
/**
BluetoothManager bluetoothManager = new BluetoothManager(this);
bluetoothManager.launch();
try {
bluetoothManager.startThread();
} catch (Exception ex) {
Logger.getLogger(FXMLVueController.class.getName()).log(Level.SEVERE, null, ex);
}
**/
//Put the gridPane Accueil visible
accueil.setVisible(true);
currentGridPane = accueil;
......@@ -128,4 +145,9 @@ public class FXMLVueController implements Initializable {
else arrosageAuto.setText("Désactivé");
}
public void update(BluetoothThread t){
// MAJ LA VUE
System.err.println(t.getBuffer());
}
}
app/src/app/.classpath 0 → 100644
+ 5
− 0
View file @ fc08b2a4
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
<classpathentry kind="output" path="bin"/>
</classpath>
app/src/app/.project 0 → 100644
+ 17
− 0
View file @ fc08b2a4
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
<name>app</name>
<comment></comment>
<projects>
</projects>
<buildSpec>
<buildCommand>
<name>org.eclipse.jdt.core.javabuilder</name>
<arguments>
</arguments>
</buildCommand>
</buildSpec>
<natures>
<nature>org.eclipse.jdt.core.javanature</nature>
</natures>
</projectDescription>
app/src/app/App.java
+ 3
− 104
View file @ fc08b2a4
......@@ -44,13 +44,7 @@ import javax.obex.ResponseCodes;
*
* @author invite
*/
public class App extends Application implements DiscoveryListener {
private static Object lock=new Object();
private static ArrayList<RemoteDevice> devices;
static DiscoveryListener listener = new App();
final static List<ServiceRecord> serviceRecords = new ArrayList<ServiceRecord>();
final static List<BluetoothConnection> connections = new ArrayList<BluetoothConnection>();
public class App extends Application {
@Override
public void start(Stage stage) throws Exception{
......@@ -66,101 +60,6 @@ public class App extends Application implements DiscoveryListener {
* @param args the command line arguments
*/
public static void main(String[] args) throws IOException {
devices = new ArrayList<RemoteDevice>();
try{
UUID serialPortUuid = new UUID(BluetoothServiceUuids.SERIAL_PORT.getHexValue());
UUID[] desiredServiceUuids = new UUID[] { serialPortUuid };
LocalDevice localDevice = LocalDevice.getLocalDevice();
DiscoveryAgent agent = localDevice.getDiscoveryAgent();
RemoteDevice[] devices = agent.retrieveDevices(DiscoveryAgent.PREKNOWN);
for(RemoteDevice d : devices) {
if(d.getBluetoothAddress().equals("201611073171")) {
System.out.println("Thingz trouve");
synchronized(lock) {
int result = agent.searchServices(null, desiredServiceUuids, d, listener);
if( DiscoveryListener.SERVICE_SEARCH_DEVICE_NOT_REACHABLE == result) {
System.out.println(" but it could not be reached");
continue;
}
lock.wait();
System.out.println("service records found");
if(null != serviceRecords && serviceRecords.size() > 0) {
System.out.println("YA DES SERVICES");
for(ServiceRecord serviceRecord: serviceRecords) {
String connectionUrl = serviceRecord.getConnectionURL(ServiceRecord.NOAUTHENTICATE_NOENCRYPT, false); // I have no idea what these args are
StreamConnection connection;
try {
connection = (StreamConnection)Connector.open(connectionUrl);
DataInputStream inputStream = new DataInputStream(connection.openDataInputStream());
BluetoothConnection bluetoothConnection = new BluetoothConnection(d.getBluetoothAddress(), inputStream);
bluetoothConnection.setOutputStream(new DataOutputStream(connection.openOutputStream()));
connections.add(bluetoothConnection);
System.out.println("Connected to " + d.getBluetoothAddress());
} catch (IOException e) {
System.out.println("Could not connect to " + d.getBluetoothAddress() + ": " + e.getMessage());
e.printStackTrace();
}
}
}
}
}
}
if(connections.size() > 0) { // we are connected
System.out.println("start");
BluetoothThread t = new BluetoothThread(connections.get(0));
t.start();
}
} catch (Exception e) {
e.printStackTrace();
}
launch(args);
}
@Override
public void deviceDiscovered(RemoteDevice btDevice, DeviceClass arg1) {
String name;
try {
name = btDevice.getFriendlyName(false);
} catch (Exception e) {
name = btDevice.getBluetoothAddress();
}
devices.add(btDevice);
System.out.println("device found: " + name);
}
@Override
public void inquiryCompleted(int arg0) {
synchronized(lock){
lock.notify();
}
}
@Override
public void serviceSearchCompleted(int arg0, int arg1) {
synchronized (lock) {
lock.notify();
}
}
@Override
public void servicesDiscovered(int transID, ServiceRecord[] servRecord) {
System.out.println("hey ! " + servRecord);
for(ServiceRecord s : servRecord) {
System.out.println("-------"+ s + "-------");
}
serviceRecords.addAll(Arrays.asList(servRecord));
}
launch(args);
}
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment