Updated example scripts

Author: scaryghost

examples/data_fuser.py

@@ -1,3 +1,5 @@
+# usage: python data_fuser.py [mac1] [mac2] ... [mac(n)]
+from __future__ import print_function
 from ctypes import c_void_p, cast, POINTER
 from mbientlab.metawear import MetaWear, libmetawear, parse_value, cbindings
 from time import sleep
@@ -38,6 +40,7 @@ def processor_created(context, pointer):
         libmetawear.mbl_mw_datasignal_subscribe(self.processor, None, self.callback)
 
     def start(self):
+    
         libmetawear.mbl_mw_gyro_bmi160_enable_rotation_sampling(self.device.board)
         libmetawear.mbl_mw_acc_enable_acceleration_sampling(self.device.board)
 
@@ -51,15 +54,15 @@ def start(self):
     states.append(State(d))
 
 for s in states:
-    print("configuring %s" % (s.device.address))
+    print("Configuring %s" % (s.device.address))
     s.setup()
 
 for s in states:
     s.start()
 
 sleep(10.0)
 
-print("resetting devices")
+print("Resetting devices")
 events = []
 for s in states:
     e = Event()

examples/data_processor.py

@@ -0,0 +1,66 @@
+# usage: python data_processor.py [mac1] [mac2] ... [mac(n)]
+from __future__ import print_function
+from ctypes import c_void_p, cast, POINTER
+from mbientlab.metawear import MetaWear, libmetawear, parse_value, cbindings
+from time import sleep
+from threading import Event
+from sys import argv
+
+states = []
+
+class State:
+    def __init__(self, device):
+        self.device = device
+        self.callback = cbindings.FnVoid_VoidP_DataP(self.data_handler)
+        self.processor = None
+        
+    def data_handler(self, ctx, data):
+        print("%s -> %s" % (self.device.address, parse_value(data)))
+
+    def setup(self):
+        libmetawear.mbl_mw_settings_set_connection_parameters(self.device.board, 7.5, 7.5, 0, 6000)
+        sleep(1.5)
+
+        e = Event()
+
+        def processor_created(context, pointer):
+            self.processor = pointer
+            e.set()
+        fn_wrapper = cbindings.FnVoid_VoidP_VoidP(processor_created)
+        
+        acc = libmetawear.mbl_mw_acc_get_acceleration_data_signal(self.device.board)
+        libmetawear.mbl_mw_dataprocessor_average_create(acc, 4, None, fn_wrapper)
+        e.wait()
+        libmetawear.mbl_mw_datasignal_subscribe(self.processor, None, self.callback)
+
+    def start(self):
+    
+        libmetawear.mbl_mw_acc_enable_acceleration_sampling(self.device.board)
+        libmetawear.mbl_mw_acc_start(self.device.board)
+        
+for i in range(len(argv) - 1):
+    d = MetaWear(argv[i + 1])
+    d.connect()
+    print("Connected to " + d.address)
+    states.append(State(d))
+
+for s in states:
+    print("Configuring %s" % (s.device.address))
+    s.setup()
+
+for s in states:
+    s.start()
+
+sleep(5.0)
+
+print("Resetting devices")
+events = []
+for s in states:
+    e = Event()
+    events.append(e)
+
+    s.device.on_disconnect = lambda s: e.set()
+    libmetawear.mbl_mw_debug_reset(s.device.board)
+
+for e in events:
+    e.wait()

examples/firmware_build.py

@@ -0,0 +1,25 @@
+# usage: python firmware_build.py [mac]
+from ctypes import *
+from mbientlab.metawear import MetaWear, libmetawear
+from mbientlab.metawear.cbindings import *
+from time import sleep
+from threading import Event
+
+import sys
+
+m = MetaWear(sys.argv[1])
+m.connect()
+print("Connected")
+
+size= c_uint(0)
+info = libmetawear.mbl_mw_metawearboard_get_module_info(m.board, byref(size))
+
+i = 15
+#print(info[i].name == b'Settings')
+
+if (info[i].extra_len >= 2):
+    print(info[i].extra[1])
+else:
+    print("Firmware build not available")
+
+libmetawear.mbl_mw_memory_free(info)

examples/led.py

@@ -1,4 +1,5 @@
 # usage: python led.py [mac]
+from __future__ import print_function
 from mbientlab.metawear import MetaWear, libmetawear
 from mbientlab.metawear.cbindings import *
 from time import sleep

examples/log_acc.py

@@ -0,0 +1,87 @@
+# usage: python log_acc [mac]
+from __future__ import print_function
+from mbientlab.metawear import MetaWear, libmetawear, parse_value
+from mbientlab.metawear.cbindings import *
+from time import sleep
+from threading import Event
+
+import platform
+import sys
+
+if sys.version_info[0] == 2:
+    range = xrange
+
+class State:
+    def __init__(self, device):
+        self.device = device
+        
+    def setup_logger(self):
+        e = Event()
+        result = [None]
+
+        def logger_handler(ctx, pointer):
+            result[0] = RuntimeError("Could not create logger") if pointer == None else pointer
+            e.set()
+        fn_wrapper = FnVoid_VoidP_VoidP(logger_handler)
+
+        signal = libmetawear.mbl_mw_acc_get_acceleration_data_signal(self.device.board)
+        libmetawear.mbl_mw_datasignal_log(signal, None, fn_wrapper)
+        e.wait()
+        
+        if (result[0] is RuntimeError):
+            raise result[0]
+
+        self.logger = result[0]
+        
+        libmetawear.mbl_mw_acc_enable_acceleration_sampling(self.device.board)
+        libmetawear.mbl_mw_acc_start(self.device.board)
+        libmetawear.mbl_mw_logging_start(self.device.board, 0);
+
+    def download_data(self):
+        libmetawear.mbl_mw_acc_stop(self.device.board)
+        libmetawear.mbl_mw_acc_disable_acceleration_sampling(self.device.board)
+        libmetawear.mbl_mw_logging_stop(self.device.board)
+
+        e = Event()
+        def progress_update_handler(context, entries_left, total_entries):
+            if (entries_left == 0):
+                e.set()
+        
+        fn_wrapper = FnVoid_VoidP_UInt_UInt(progress_update_handler)
+        download_handler= LogDownloadHandler(context = None, \
+            received_progress_update = fn_wrapper, \
+            received_unknown_entry = cast(None, FnVoid_VoidP_UByte_Long_UByteP_UByte), \
+            received_unhandled_entry = cast(None, FnVoid_VoidP_DataP))
+
+        callback = FnVoid_VoidP_DataP(lambda ctx, p: print("%s -> %s" % (self.device.address, parse_value(p))))
+        libmetawear.mbl_mw_logger_subscribe(self.logger, None, callback)
+        libmetawear.mbl_mw_logging_download(self.device.board, 0, byref(download_handler))
+        e.wait()
+
+print("Searching for device...")
+d = MetaWear(sys.argv[1])
+d.connect()
+print("Connected to " + d.address)
+s = State(d) 
+
+print("Configuring device")
+libmetawear.mbl_mw_settings_set_connection_parameters(s.device.board, 7.5, 7.5, 0, 6000)
+sleep(1.0)
+
+try:
+    s.setup_logger()
+
+    print("Logging data for 15s")
+    sleep(15.0)
+
+    s.download_data()
+	
+except RuntimeError as e:
+    print(e)
+
+finally:
+    print("Resetting device")
+    e = Event()
+    s.device.on_disconnect = lambda status: e.set()
+    libmetawear.mbl_mw_debug_reset(s.device.board)
+    e.wait()

examples/log_temp.py

@@ -0,0 +1,124 @@
+# usage: python log_temp [mac]
+from __future__ import print_function
+from mbientlab.metawear import MetaWear, libmetawear, parse_value
+from mbientlab.metawear.cbindings import *
+from time import sleep
+from threading import Event
+
+import platform
+import sys
+
+if sys.version_info[0] == 2:
+    range = xrange
+
+class State:
+    def __init__(self, device):
+        self.device = device
+        
+    def setup_logger(self):
+        e = Event()
+        result = [None]
+
+        def logger_handler(ctx, pointer):
+            result[0] = RuntimeError("Could not create logger") if pointer == None else pointer
+            e.set()
+        fn_wrapper = FnVoid_VoidP_VoidP(logger_handler)
+
+        #streaming and logging
+        signal = libmetawear.mbl_mw_multi_chnl_temp_get_temperature_data_signal(self.device.board, \
+            MetaWearRProChannel.ON_BOARD_THERMISTOR)
+        libmetawear.mbl_mw_datasignal_log(signal, None, fn_wrapper)
+        e.wait()
+        
+        if (result[0] is RuntimeError):
+            raise result[0]
+
+        self.logger = result[0]
+        self.timer = self._setup_timer()
+        self._setup_read_event(self.timer, signal)
+
+        libmetawear.mbl_mw_logging_start(self.device.board, 0);
+        libmetawear.mbl_mw_timer_start(self.timer)
+
+    def _setup_timer(self):
+        e = Event()
+        result = [None]
+
+        def timer_handler(ctx, pointer):
+            result[0] = RuntimeError("Could not create timer") if pointer == None else pointer
+            e.set()
+        fn_wrapper = FnVoid_VoidP_VoidP(timer_handler)
+
+        libmetawear.mbl_mw_timer_create_indefinite(self.device.board, 1000, 0, None, fn_wrapper)
+        e.wait()
+
+        if (result[0] is RuntimeError):
+            raise result[0]
+
+        return result[0]
+
+    def _setup_read_event(self, timer, signal):
+        e = Event()
+        result = [None]
+
+        def commands_recorded(ctx, event, status):
+            result[0] = RuntimeError("Could not create read event") if status != Const.STATUS_OK else None
+            e.set()
+        fn_wrapper = FnVoid_VoidP_VoidP_Int(commands_recorded)
+
+        libmetawear.mbl_mw_event_record_commands(timer)
+        libmetawear.mbl_mw_datasignal_read(signal)
+        libmetawear.mbl_mw_event_end_record(timer, None, fn_wrapper)
+        e.wait()
+        
+        if (result[0] is RuntimeError):
+            raise result[0]
+
+    def download_data(self):
+        libmetawear.mbl_mw_timer_remove(self.timer)
+        libmetawear.mbl_mw_logging_stop(self.device.board)
+
+        e = Event()
+        def progress_update_handler(context, entries_left, total_entries):
+            if (entries_left == 0):
+                e.set()
+        
+        fn_wrapper = FnVoid_VoidP_UInt_UInt(progress_update_handler)
+        download_handler= LogDownloadHandler(context = None, \
+            received_progress_update = fn_wrapper, \
+            received_unknown_entry = cast(None, FnVoid_VoidP_UByte_Long_UByteP_UByte), \
+            received_unhandled_entry = cast(None, FnVoid_VoidP_DataP))
+
+        callback = FnVoid_VoidP_DataP(lambda ctx, p: print("%f" % (parse_value(p))))
+        libmetawear.mbl_mw_logger_subscribe(self.logger, None, callback)
+        libmetawear.mbl_mw_logging_download(self.device.board, 0, byref(download_handler))
+        e.wait()
+
+
+
+print("Searching for device...")
+d = MetaWear(sys.argv[1])
+d.connect()
+print("Connected to " + d.address)
+s = State(d) 
+
+print("Configuring device")
+libmetawear.mbl_mw_settings_set_connection_parameters(s.device.board, 7.5, 7.5, 0, 6000)
+sleep(1.0)
+
+try:
+    #logging
+    s.setup_logger()
+
+    print("Logging data for 15s")
+    sleep(15.0)
+
+    s.download_data()
+except RuntimeError as e:
+    print(e)
+finally:
+    print("Resetting device")
+    e = Event()
+    s.device.on_disconnect = lambda status: e.set()
+    libmetawear.mbl_mw_debug_reset(s.device.board)
+    e.wait()

examples/multi_device.py

@@ -1,4 +1,5 @@
 # usage: python multi_device [mac1] [mac2] ... [mac(n)]
+from __future__ import print_function
 from mbientlab.metawear import MetaWear, libmetawear, parse_value
 from mbientlab.metawear.cbindings import *
 from time import sleep
@@ -28,7 +29,7 @@ def data_handler(self, ctx, data):
     states.append(State(d))
 
 for s in states:
-    print("configuring device")
+    print("Configuring device")
     libmetawear.mbl_mw_settings_set_connection_parameters(s.device.board, 7.5, 7.5, 0, 6000)
     sleep(1.5)
 

examples/scan_connect.py

@@ -1,4 +1,5 @@
 # usage: python scan_connect.py
+from __future__ import print_function
 from mbientlab.metawear import MetaWear
 from mbientlab.metawear.cbindings import *
 from mbientlab.warble import *