Added examples: https, bluetooth, I2C, threading and added start command to aws demo

Author: RalphHogenbirk

.gitignore

@@ -0,0 +1,4 @@
+*.e6t
+*.e4q
+*.e4p
+*.1

examples/aws/demo.py

@@ -0,0 +1,54 @@
+import time
+from mqttclient import MQTTClient
+
+DISCONNECTED = 0
+CONNECTING = 1
+CONNECTED = 2
+DEVICE_ID = "12345"
+HOST = "random_id.us-west-2.amazonaws.com"
+TOPIC_DOWNLOAD = "Download"
+TOPIC_UPLOAD = "Upload"
+
+
+state = DISCONNECTED
+connection = None
+
+def _recv_msg_callback(topic, msg):
+    print("Received: {} from Topic: {}".format(msg, topic))
+
+def _send_msg(msg):
+    global connection
+    connection.publish(TOPIC_UPLOAD, msg)
+
+def run():
+    global state
+    global connection
+
+    while True:
+        # Wait for connection
+        while state != CONNECTED:
+            try:
+                state = CONNECTING
+                connection = MQTTClient(DEVICE_ID, server=HOST, port=8883)
+                connection.connect(ssl=True, certfile='/flash/cert/certificate.crt', keyfile='/flash/cert/privateKey.key', ca_certs='/flash/cert/root-CA.cer')
+                state = CONNECTED
+            except:
+                print('Error connecting to the server')
+                time.sleep(0.5)
+                continue
+
+        print('Connected!')
+
+        # Subscribe for messages
+        connection.set_callback(_recv_msg_callback)
+        connection.subscribe(TOPIC_DOWNLOAD)
+
+        while state == CONNECTED:
+            connection.check_msg()
+            msg = '{"Name":"Pycom", "Data":"Test"}'
+            print('Sending: ' + msg)
+            _send_msg(msg)
+            time.sleep(2.0)
+
+
+run()

examples/aws/main.py

@@ -1,54 +1,2 @@
-import time
-from mqttclient import MQTTClient
-
-DISCONNECTED = 0
-CONNECTING = 1
-CONNECTED = 2
-DEVICE_ID = "12345"
-HOST = "random_id.us-west-2.amazonaws.com"
-TOPIC_DOWNLOAD = "Download"
-TOPIC_UPLOAD = "Upload"
-
-
-state = DISCONNECTED
-connection = None
-
-def _recv_msg_callback(topic, msg):
-    print("Received: {} from Topic: {}".format(msg, topic))
-
-def _send_msg(msg):
-    global connection
-    connection.publish(TOPIC_UPLOAD, msg)
-
-def run():
-    global state
-    global connection
-
-    while True:
-        # Wait for connection
-        while state != CONNECTED:
-            try:
-                state = CONNECTING
-                connection = MQTTClient(DEVICE_ID, server=HOST, port=8883)
-                connection.connect(ssl=True, certfile='/flash/cert/certificate.crt', keyfile='/flash/cert/privateKey.key', ca_certs='/flash/cert/root-CA.cer')
-                state = CONNECTED
-            except:
-                print('Error connecting to the server')
-                time.sleep(0.5)
-                continue
-
-        print('Connected!')
-
-        # Subscribe for messages
-        connection.set_callback(_recv_msg_callback)
-        connection.subscribe(TOPIC_DOWNLOAD)
-
-        while state == CONNECTED:
-            connection.check_msg()
-            msg = '{"Name":"Pycom", "Data":"Test"}'
-            print('Sending: ' + msg)
-            _send_msg(msg)
-            time.sleep(2.0)
-
-
-run()
+import demo
+demo.run()

examples/bluetooth/boot.py

@@ -0,0 +1,8 @@
+from machine import UART
+import machine
+import os
+
+uart = UART(0, baudrate=115200)
+os.dupterm(uart)
+
+machine.main('main.py')

examples/bluetooth/main.py

@@ -0,0 +1,32 @@
+from network import Bluetooth
+import time
+bt = Bluetooth()
+bt.start_scan(-1)
+
+while True:
+    adv = bt.get_adv()
+    if adv 
+        # try to get the complete name
+        print(bluetooth.resolve_adv_data(adv.data, Bluetooth.ADV_NAME_CMPL))
+
+        # try to get the manufacturer data (Apple's iBeacon data is sent here)
+        print(binascii.hexlify(bluetooth.resolve_adv_data(adv.data, Bluetooth.ADV_MANUFACTURER_DATA)))
+
+        
+        if bt.resolve_adv_data(adv.data, Bluetooth.ADV_NAME_CMPL) == 'Heart Rate':
+            conn = bt.connect(adv.mac)
+            services = conn.services()
+            for service in services:
+                time.sleep(0.050)
+                if type(service.uuid()) == bytes:
+                    print('Reading chars from service = {}'.format(service.uuid()))
+                else:
+                    print('Reading chars from service = %x' % service.uuid())
+                chars = service.characteristics()
+                for char in chars:
+                    if (char.properties() & Bluetooth.PROP_READ):
+                        print('char {} value = {}'.format(char.uuid(), char.read()))
+            conn.disconnect()
+            break
+    else:
+        time.sleep(0.050)

examples/https/boot.py

@@ -0,0 +1,8 @@
+from machine import UART
+import machine
+import os
+
+uart = UART(0, baudrate=115200)
+os.dupterm(uart)
+
+machine.main('main.py')

examples/https/main.py

@@ -0,0 +1,12 @@
+import socket
+import ssl
+
+# Connect without a certificate
+s = socket()
+ss = ssl.wrap_socket(s)
+ss.connect(socket.getaddrinfo('www.google.com', 443)[0][-1])
+
+# Connect with a certificate
+s = socket.socket()
+ss = ssl.wrap_socket(s, cert_reqs=ssl.CERT_REQUIRED, ca_certs='/flash/cert/ca.pem')
+ss.connect(socket.getaddrinfo('cloud.blynk.cc', 8441)[0][-1])

examples/i2c/bh1750fvi.py

@@ -0,0 +1,20 @@
+# Simple driver for the BH1750FVI digital light sensor
+
+class BH1750FVI:
+    MEASUREMENT_TIME = const(120)
+
+    def __init__(self, i2c, addr=0x23, period=150):
+        self.i2c = i2c
+        self.period = period
+        self.addr = addr
+        self.time = 0
+        self.value = 0
+        self.i2c.writeto(addr, bytes([0x10])) # start continuos 1 Lux readings every 120ms
+
+    def read(self):
+        self.time += self.period
+        if self.time >= MEASUREMENT_TIME:
+            self.time = 0
+            data = self.i2c.readfrom(self.addr, 2)
+            self.value = (((data[0] << 8) + data[1]) * 1200) // 1000
+        return self.value

examples/i2c/boot.py

@@ -0,0 +1,8 @@
+from machine import UART
+import machine
+import os
+
+uart = UART(0, baudrate=115200)
+os.dupterm(uart)
+
+machine.main('main.py')

examples/i2c/main.py

@@ -0,0 +1,42 @@
+import socket
+import time
+import pycom
+import struct
+from network import LoRa
+from machine import I2C
+import bh1750fvi
+
+LORA_PKG_FORMAT = "!BH"
+LORA_CONFIRM_FORMAT = "!BB"
+
+DEVICE_ID = 1
+
+pycom.heartbeat(False)
+
+lora = LoRa(mode=LoRa.LORA, tx_iq=True, frequency = 863000000)
+lora_sock = socket.socket(socket.AF_LORA, socket.SOCK_RAW)
+lora_sock.setblocking(False)
+
+i2c = I2C(0, I2C.MASTER, baudrate=100000)
+light_sensor = bh1750fvi.BH1750FVI(i2c, addr=i2c.scan()[0])
+
+while(True):
+    msg = struct.pack(LORA_PKG_FORMAT, DEVICE_ID, light_sensor.read())
+    lora_sock.send(msg)
+
+    pycom.rgbled(0x150000)
+
+    wait = 5
+    while (wait > 0):
+        wait = wait - 0.1
+        time.sleep(0.1)
+        recv_data = lora_sock.recv(64)
+        
+        if (len (recv_data) >= 2):
+            status, device_id = struct.unpack(LORA_CONFIRM_FORMAT, recv_data)
+            
+            if (device_id == DEVICE_ID and status == 200):
+                pycom.rgbled(0x001500)
+                wait = 0
+
+    time.sleep(1)