ULP-ActivitySupport – commitdiff
summary | shortlog | log | commit | commitdiff | tree
raw | patch | inline | side by side (parent: 007fb1a)
raw | patch | inline | side by side (parent: 007fb1a)
| author | Julian Fietkau <git@fietkau.software> | |
| Mon, 17 Oct 2022 23:55:44 +0000 (01:55 +0200) | ||
| committer | Julian Fietkau <git@fietkau.software> | |
| Mon, 17 Oct 2022 23:55:44 +0000 (01:55 +0200) |
28 files changed:
diff --git a/microinforadiator/Audio/audio.py b/microinforadiator/Audio/audio.py
--- /dev/null
@@ -0,0 +1,28 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+import pygame
+from time import sleep
+
+def sign():
+ pygame.mixer.init()
+ pygame.mixer.music.load("glocke.mp3")
+ pygame.mixer.music.play()
+ # while pygame.mixer.music.get_busy() == True:
+ # continue
+
+def birds():
+ pygame.mixer.init()
+ pygame.mixer.music.load("birds.mp3")
+ pygame.mixer.music.play()
+ while pygame.mixer.music.get_busy() == True:
+ continue
+
+
+if __name__ == '__main__':
+ sign()
+ sleep(2)
+ birds()
diff --git a/microinforadiator/Bluetooth/__init__.py b/microinforadiator/Bluetooth/__init__.py
diff --git a/microinforadiator/Bluetooth/bluetooth_controller.py b/microinforadiator/Bluetooth/bluetooth_controller.py
--- /dev/null
@@ -0,0 +1,255 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+import sys
+import struct
+import bluetooth
+import bluetooth._bluetooth as bluez
+import csv
+from datetime import datetime
+import paho.mqtt.client as mqtt
+import fcntl
+import array
+
+import time
+import os
+import datetime
+
+#nearby_devices = bluetooth.discover_devices(lookup_names=True)
+#print("found %d devices" %len(nearby_devices))
+
+#for addr, name in nearby_devices:
+# print("[%s] %s" %(addr, name))
+
+def printpacket(pkt):
+ for c in pkt:
+ sys.stdout.write("{%02x} ".format(struct.unpack("B", c)[0]))
+
+def read_inquiry_mode(sock):
+ """returns the current mode, or -1 on failure"""
+ # save current filter
+ old_filter = sock.getsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, 14)
+
+ # Setup socket filter to receive only events related to the
+ # read_inquiry_mode command
+ flt = bluez.hci_filter_new()
+ opcode = bluez.cmd_opcode_pack(bluez.OGF_HOST_CTL,
+ bluez.OCF_READ_INQUIRY_MODE)
+ bluez.hci_filter_set_ptype(flt, bluez.HCI_EVENT_PKT)
+ bluez.hci_filter_set_event(flt, bluez.EVT_CMD_COMPLETE)
+ bluez.hci_filter_set_opcode(flt, opcode)
+ sock.setsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, flt)
+
+ # first read the current inquiry mode.
+ bluez.hci_send_cmd(sock, bluez.OGF_HOST_CTL,
+ bluez.OCF_READ_INQUIRY_MODE)
+
+ pkt = sock.recv(255)
+ status, mode = struct.unpack("xxxxxxBB", pkt)
+
+ # restore old filter
+ sock.setsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, old_filter)
+
+ return mode
+
+def write_inquiry_mode(sock, mode):
+ """returns 0 on success, -1 on failure"""
+ # save current filter
+ old_filter = sock.getsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, 14)
+
+ # Setup socket filter to receive only events related to the
+ # write_inquiry_mode command
+ flt = bluez.hci_filter_new()
+ opcode = bluez.cmd_opcode_pack(bluez.OGF_HOST_CTL,
+ bluez.OCF_WRITE_INQUIRY_MODE)
+ bluez.hci_filter_set_ptype(flt, bluez.HCI_EVENT_PKT)
+ bluez.hci_filter_set_event(flt, bluez.EVT_CMD_COMPLETE)
+ bluez.hci_filter_set_opcode(flt, opcode)
+ sock.setsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, flt)
+
+ # send the command!
+ bluez.hci_send_cmd(sock, bluez.OGF_HOST_CTL,
+ bluez.OCF_WRITE_INQUIRY_MODE,
+ struct.pack("B", mode))
+
+ pkt = sock.recv(255)
+ status = struct.unpack("xxxxxxB", pkt)[0]
+
+ # restore old filter
+ sock.setsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, old_filter)
+ if not status:
+ return -1
+
+ return 0
+
+def device_inquiry_with_with_rssi(sock):
+ # save current filter
+ old_filter = sock.getsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, 14)
+
+ # perform a device inquiry on bluetooth device #0
+ # The inquiry should last 8 * 1.28 = 10.24 seconds
+ # before the inquiry is performed, bluez should flush its cache of
+ # previously discovered devices
+ flt = bluez.hci_filter_new()
+ bluez.hci_filter_all_events(flt)
+ bluez.hci_filter_set_ptype(flt, bluez.HCI_EVENT_PKT)
+ sock.setsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, flt)
+
+ duration = 4
+ max_responses = 255
+ cmd_pkt = struct.pack("BBBBB", 0x33, 0x8b, 0x9e, duration, max_responses)
+ bluez.hci_send_cmd(sock, bluez.OGF_LINK_CTL, bluez.OCF_INQUIRY, cmd_pkt)
+
+ results = []
+
+ while True:
+ pkt = sock.recv(255)
+ ptype, event, plen = struct.unpack("BBB", pkt[:3])
+ #print("Event: {}".format(event))
+ if event == bluez.EVT_INQUIRY_RESULT_WITH_RSSI:
+ pkt = pkt[3:]
+ nrsp = bluetooth.get_byte(pkt[0])
+ for i in range(nrsp):
+ addr = bluez.ba2str(pkt[1+6*i:1+6*i+6])
+ rssi = bluetooth.byte_to_signed_int(
+ bluetooth.get_byte(pkt[1 + 13 * nrsp + i]))
+ timestamp = datetime.now()
+ #results.append(addr)
+ #results.append(rssi)
+ #results.append(timestamp)
+ results.append((addr,rssi,timestamp))
+ #print("[{}] RSSI: {}".format(addr, rssi))
+
+ elif event == bluez.EVT_INQUIRY_COMPLETE:
+ break
+ elif event == bluez.EVT_CMD_STATUS:
+ status, ncmd, opcode = struct.unpack("BBH", pkt[3:7])
+ if status:
+ print("Uh oh...")
+ printpacket(pkt[3:7])
+ break
+ elif event == bluez.EVT_INQUIRY_RESULT:
+ pkt = pkt[3:]
+ nrsp = bluetooth.get_byte(pkt[0])
+ for i in range(nrsp):
+ addr = bluez.ba2str(pkt[1+6*i:1+6*i+6])
+ #results.append((addr, -1))
+ print("[{}] (no RRSI)".format(addr))
+ else:
+ print("Unrecognized packet type 0x{:02x}.".format(ptype))
+
+ # restore old filter
+ sock.setsockopt(bluez.SOL_HCI, bluez.HCI_FILTER, old_filter)
+
+ return results
+
+def get_devices():
+ dev_id = 0
+ writer = None
+ try:
+ sock = bluez.hci_open_dev(dev_id)
+ except:
+ print("Error accessing bluetooth device.")
+ sys.exit(1)
+
+ try:
+ mode = read_inquiry_mode(sock)
+ except Exception as e:
+ print("Error reading inquiry mode.")
+ print("Are you sure this a bluetooth 1.2 device?")
+ print(e)
+ sys.exit(1)
+ print("Current inquiry mode is", mode)
+
+ if mode != 1:
+ print("Writing inquiry mode...")
+ try:
+ result = write_inquiry_mode(sock, 1)
+ except Exception as e:
+ print("Error writing inquiry mode. Are you sure you're root?")
+ print(e)
+ sys.exit(1)
+ if result:
+ print("Error while setting inquiry mode")
+ print("Result:", result)
+
+
+ #get detected devices (MAC address), RSSI distance and timestamp
+ detected_devices = device_inquiry_with_with_rssi(sock)
+ #if len(detected_devices) >= 1:
+ #for i in detected_devices:
+ #print("NOW")
+ #print(detected_devices[0])
+ #print(i)
+
+ return detected_devices
+
+
+def write_BT_toCSV(results):
+
+ with open('bt-test.csv',mode='w') as file:
+ file_writer = csv.writer(file,delimiter=',',quotechar='"',quoting=csv.QUOTE_MINIMAL)
+ file_writer.writerow(['ADDR','RSSI','Timestamp'])
+
+ for x,y,z in results:
+ write_to_log = file_writer.writerow((x,y,z))
+ return(write_to_log)
+
+
+def start_BTdetection():
+
+ results = get_devices()
+ return results
+
+#get only RSSI value for a specific BD_ADDR
+def bluetooth_rssi(addr):
+ # Open hci socket
+ hci_sock = bluez.hci_open_dev()
+ hci_fd = hci_sock.fileno()
+
+ # Connect to device (to whatever you like)
+ bt_sock = bluetooth.BluetoothSocket(bluetooth.L2CAP)
+ bt_sock.settimeout(10)
+ result = bt_sock.connect_ex((addr, 1)) # PSM 1 - Service Discovery
+#
+# try:
+ # Get ConnInfo
+ frmt = "6sB17s"
+ t = bluez.str2ba(addr)
+ s = bytes(('\0'),encoding ='utf8')
+ reqstr = struct.pack(frmt, t, bluez.ACL_LINK, s * 17)
+ request = array.array("b", reqstr )
+ try:
+ handle = fcntl.ioctl(hci_fd, bluez.HCIGETCONNINFO, request, 1)
+ handle = struct.unpack("8xH14x", request.tostring())[0]
+ frmt = "H"
+ # Get RSSI
+ cmd_pkt = struct.pack(frmt, handle)
+ rssi = bluez.hci_send_req(hci_sock, bluez.OGF_STATUS_PARAM,
+ bluez.OCF_READ_RSSI, bluez.EVT_CMD_COMPLETE, 4, cmd_pkt)
+ rssi = rssi[3]
+ except:
+ print("Could not detect Bluetooth device")
+ rssi = 99999
+
+ bt_sock.close()
+ hci_sock.close()
+
+ return rssi
+#
+# except:
+# return None
+
+
+if __name__=='__main__':
+
+ res = get_devices()
+ #bdaddr = "54:B1:21:F0:80:A3"
+ #for x,y,z in res:
+ # if x == bdaddr:
+ #res = bluetooth.lookup_name( bdaddr )
+ #print((x,y,z))
+ #write_BT_toCSV(res)
diff --git a/microinforadiator/LED/__init__.py b/microinforadiator/LED/__init__.py
diff --git a/microinforadiator/LED/arrows.py b/microinforadiator/LED/arrows.py
--- /dev/null
@@ -0,0 +1,76 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+r = (255,0,0)
+b = (0,0,255)
+g = (0,255,0)
+y = (255,255,0)
+m = (255,0,255)
+c = (0,255,255)
+bk = (0,0,0)
+w = (255,255,255) #150,150,150
+cb = bk
+ca = b
+
+def arrow_up (cb, ca):
+ arrow_up = [
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,ca,ca,ca,cb,cb,cb,
+ cb,ca,cb,ca,cb,ca,cb,cb,
+ ca,cb,cb,ca,cb,cb,ca,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb
+ ]
+
+ return arrow_up
+
+def arrow_left (cb, ca):
+
+ arrow_l = [
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,ca,cb,cb,cb,cb,cb,
+ cb,ca,cb,cb,cb,cb,cb,cb,
+ ca,ca,ca,ca,ca,ca,ca,ca,
+ cb,ca,cb,cb,cb,cb,cb,cb,
+ cb,cb,ca,cb,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,cb,cb,cb,cb,cb
+ ]
+
+ return arrow_l
+
+def arrow_down (cb, ca):
+
+ arrow_d = [
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ ca,cb,cb,ca,cb,cb,ca,cb,
+ cb,ca,cb,ca,cb,ca,cb,cb,
+ cb,cb,ca,ca,ca,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb
+ ]
+
+ return arrow_d
+
+ #def arrow_right (color_background, color_arrow):
+def arrow_right (cb, ca):
+
+ arrow_r = [
+ cb,cb,cb,cb,ca,cb,cb,cb,
+ cb,cb,cb,cb,cb,ca,cb,cb,
+ cb,cb,cb,cb,cb,cb,ca,cb,
+ ca,ca,ca,ca,ca,ca,ca,ca,
+ cb,cb,cb,cb,cb,cb,ca,cb,
+ cb,cb,cb,cb,cb,ca,cb,cb,
+ cb,cb,cb,cb,ca,cb,cb,cb,
+ cb,cb,cb,cb,cb,cb,cb,cb
+ ]
+
+ return arrow_r
diff --git a/microinforadiator/LED/led_activities.py b/microinforadiator/LED/led_activities.py
--- /dev/null
@@ -0,0 +1,72 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+from arrows import arrow_up, arrow_down, arrow_left, arrow_right
+from symbols import hook, bee
+from time import sleep
+import os
+
+if os.getenv('ENABLE_SENSEHAT') == 'true':
+ from sense_hat import SenseHat
+ sense = SenseHat()
+
+def blinkingArrow(direction,cb,ca):
+ a = []
+ if(direction == "right"):
+ a = arrow_right(cb,ca)
+ elif(direction =="left"):
+ a = arrow_left(cb,ca)
+ elif(direction =="up"):
+ a = arrow_up(cb,ca)
+ elif(direction == "down"):
+ a = arrow_down(cb,ca)
+
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.set_pixels(a)
+ sleep(1)
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.clear()
+ sleep(1)
+
+def lighting(color):
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.clear(color)
+ sleep(15)
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.clear()
+
+def blinking(color):
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.clear(color)
+ sleep(1)
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.clear()
+ sleep(1)
+
+def show_hook(ca):
+
+ pixels = hook(ca)
+
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+
+ sense.set_pixels(pixels)
+ sleep(1)
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.clear()
+ sleep(1)
+
+
+def show_bee():
+
+ pixels = bee()
+
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.set_pixels(pixels)
+ sleep(1)
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ sense.clear()
+ sleep(1)
+
diff --git a/microinforadiator/LED/symbols.py b/microinforadiator/LED/symbols.py
--- /dev/null
@@ -0,0 +1,145 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+r = (255,0,0)
+b = (0,0,255)
+g = (0,255,0)
+y = (255,255,0)
+m = (255,0,255)
+c = (0,255,255)
+bk = (0,0,0)
+w = (255,255,255) #150,150,150
+
+
+def rainy_cloud():
+ cb = bk
+ ca = b
+ c = [
+
+ cb,cb,cb,cb,cb,cb,cb,cb,
+ cb,cb,ca,ca,cb,cb,cb,ca,
+ cb,ca,cb,cb,ca,cb,cb,cb,
+ ca,cb,cb,cb,ca,cb,ca,cb,
+ ca,cb,cb,cb,ca,cb,cb,cb,
+ cb,ca,cb,cb,ca,cb,cb,ca,
+ cb,ca,cb,cb,ca,cb,cb,cb,
+ cb,cb,ca,ca,cb,cb,ca,cb
+
+ ]
+
+ cr = [
+
+ cb,cb,cb,cb,cb,cb,cb,cb,
+ cb,cb,ca,ca,cb,cb,ca,cb,
+ cb,ca,ca,ca,ca,cb,cb,cb,
+ ca,ca,ca,ca,ca,cb,cb,ca,
+ ca,ca,ca,ca,ca,cb,cb,cb,
+ cb,ca,ca,ca,ca,cb,ca,cb,
+ cb,ca,ca,ca,ca,cb,cb,cb,
+ cb,cb,ca,ca,cb,cb,cb,ca
+
+ ]
+
+ return [c, cr]
+
+def sun():
+ sun = [
+
+ y,b,b,b,b,b,b,y,
+ b,y,b,b,b,b,y,b,
+ b,b,b,y,y,b,b,b,
+ b,b,y,y,y,y,b,b,
+ b,b,y,y,y,y,b,b,
+ b,b,b,y,y,b,b,b,
+ b,y,b,b,b,b,y,b,
+ y,b,b,b,b,b,b,y
+
+ ]
+ sun2 = [
+
+ y,b,b,b,y,b,b,y,
+ b,y,b,b,y,b,y,b,
+ b,b,y,y,y,y,b,b,
+ y,y,y,y,y,y,b,b,
+ b,b,y,y,y,y,y,y,
+ b,b,y,y,y,y,b,b,
+ b,y,b,y,b,b,y,b,
+ y,b,b,y,b,b,b,y
+
+ ]
+
+ return [sun, sun2]
+
+def escooter():
+ e = [
+
+ b,b,b,b,b,b,y,b,
+ b,b,y,y,b,y,y,y,
+ b,y,b,b,b,b,y,b,
+ b,b,b,y,b,b,y,b,
+ b,b,b,y,b,b,y,b,
+ b,y,y,y,b,y,y,y,
+ b,b,b,b,b,b,y,b,
+ b,b,b,b,b,b,b,b
+
+ ]
+
+ return e
+
+def warning():
+ b = bk
+
+ w = [
+
+ b,b,r,r,r,r,b,b,
+ b,r,b,b,b,b,r,b,
+ r,b,b,b,b,b,b,r,
+ r,b,r,r,b,r,b,r,
+ r,b,r,r,b,r,b,r,
+ r,b,b,b,b,b,b,r,
+ b,r,b,b,b,b,r,b,
+ b,b,r,r,r,r,b,b
+
+ ]
+ return w
+
+def hook(ca):
+ cb = bk
+
+ hook = [
+ cb,cb,cb,cb,cb,cb,cb,cb,
+ cb,cb,cb,cb,cb,cb,cb,ca,
+ cb,cb,cb,cb,cb,cb,ca,ca,
+ cb,cb,cb,cb,cb,ca,ca,cb,
+ ca,cb,cb,cb,ca,ca,cb,cb,
+ ca,ca,cb,ca,ca,cb,cb,cb,
+ cb,ca,ca,ca,cb,cb,cb,cb,
+ cb,cb,ca,cb,cb,cb,cb,cb
+ ]
+
+ return hook
+
+def bee():
+ cb = bk
+ cb = (5,5,5)
+ ca = y
+
+ bee = [
+ ca,cb,ca,cb,ca,cb,ca,cb,
+ ca,cb,ca,cb,ca,cb,ca,cb,
+ ca,cb,ca,cb,ca,cb,ca,cb,
+ ca,cb,ca,cb,ca,cb,ca,cb,
+ ca,cb,ca,cb,ca,cb,ca,cb,
+ ca,cb,ca,cb,ca,cb,ca,cb,
+ ca,cb,ca,cb,ca,cb,ca,cb,
+ ca,cb,ca,cb,ca,cb,ca,cb
+ ]
+ return bee
+
+
+if __name__ == '__main__':
+ print(bee())
+
diff --git a/microinforadiator/MiR01.env b/microinforadiator/MiR01.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 1
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:15.7,25.8
+ROTATION=270
diff --git a/microinforadiator/MiR02.env b/microinforadiator/MiR02.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 2
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:15.7,19.0
+ROTATION=270
diff --git a/microinforadiator/MiR03.env b/microinforadiator/MiR03.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 3
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:14.4,14.6
+ROTATION=180
diff --git a/microinforadiator/MiR04.env b/microinforadiator/MiR04.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 4
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:26.1,6.0
+ROTATION=190
diff --git a/microinforadiator/MiR05.env b/microinforadiator/MiR05.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 5
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:38.0,6.9
+ROTATION=200
diff --git a/microinforadiator/MiR06.env b/microinforadiator/MiR06.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 6
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:28.1,16.1
+ROTATION=195
diff --git a/microinforadiator/MiR07.env b/microinforadiator/MiR07.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 7
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:36.6,18.9
+ROTATION=0
diff --git a/microinforadiator/MiR08.env b/microinforadiator/MiR08.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 8
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:44.9,17.4
+ROTATION=270
diff --git a/microinforadiator/MiR09.env b/microinforadiator/MiR09.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 9
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:28.1,30.3
+ROTATION=0
diff --git a/microinforadiator/MiR10.env b/microinforadiator/MiR10.env
--- /dev/null
@@ -0,0 +1,7 @@
+MICROINFORADIATOR_ID=Micro information radiator 10
+ENABLE_SENSEHAT=false
+ENABLE_BLUETOOTH=false
+MQTT_BROKER_URL=127.0.0.1
+BLUETOOTH_ADDR=ac:f6:f7:96:35:09
+POSITION=Point:43.3,30.3
+ROTATION=0
diff --git a/microinforadiator/__init__.py b/microinforadiator/__init__.py
diff --git a/microinforadiator/env.example b/microinforadiator/env.example
--- /dev/null
@@ -0,0 +1,4 @@
+MICROINFORADIATOR_ID=micro-0
+ENABLE_SENSEHAT=true
+ENABLE_BLUETOOTH=true
+MQTT_BROKER_URL=192.168.2.105
diff --git a/microinforadiator/interaction.py b/microinforadiator/interaction.py
--- /dev/null
@@ -0,0 +1,233 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+from datetime import datetime,timedelta
+import json
+import math
+import os
+import threading
+#from threading import Thread
+import queue
+from time import sleep
+from proximity import get_devices, get_rssi
+#from LED.led_activities import blinkingArrow, lighting, blinking, show_hook, show_bee
+
+import state_factory
+
+
+INTERACTION_THREAD = "activities/interaction"
+################# ADD correct MAC Address ####################
+BD_ADDR = os.getenv('BLUETOOTH_ADDR')
+MY_ID = os.getenv('MICROINFORADIATOR_ID')
+duration = 12 #in seconds
+count = 0
+
+
+class InteractionController:
+
+ def __init__(self, incoming_messages, outgoing_messages):
+ self.incoming_messages = incoming_messages
+ self.outgoing_messages = outgoing_messages
+ self.current_state = None
+ self.rssi_pipe = []
+ self.last_known_user_state = {}
+ self.last_known_user_proximity = {}
+ self.sense_hat_worker = None
+ self.last_outgoing_message = None
+ self.current_content_start_time = datetime.utcnow()
+
+ def interaction_loop(self, ):
+ if self.current_state is None:
+ self.current_state = state_factory.get_idle_state()
+ try:
+ message = self.incoming_messages.get_nowait()
+ self.parse_incoming_message(message)
+ self.incoming_messages.task_done()
+ except queue.Empty:
+ pass
+ result = self.decide_on_interaction()
+ if json.dumps(result) != json.dumps(self.last_outgoing_message):
+ self.outgoing_messages.put(result)
+ self.last_outgoing_message = result
+ sleep(0.1)
+
+ def parse_incoming_message(self, message):
+ # for each user, store the last thing we know about them
+ # TODO: anything more useful to be done here?
+ if 'routing' in message['activity']:
+ self.last_known_user_state[message['user']] = message
+ elif 'proximity' in message['activity']:
+ self.last_known_user_proximity[message['user']] = message
+
+ def decide_on_interaction(self):
+ future_users = []
+ proximity_users = []
+ # look for users that are either in proximity or who are currently on the way according to the activity support service
+ for user_id in self.last_known_user_proximity:
+ proximity_time = datetime.fromisoformat(self.last_known_user_proximity[user_id]['time_to_action'])
+ now = datetime.utcnow()
+ if proximity_time + timedelta(seconds=3) > now and proximity_time - timedelta(seconds=3) < now:
+ proximity_users.append(user_id)
+
+ for user_id in self.last_known_user_state:
+ action_time = datetime.fromisoformat(self.last_known_user_state[user_id]['time_to_action'])
+ now = datetime.utcnow()
+ #print(action_time)
+ #print(now)
+ # a user counts as "active" if they will reach this device in the next 20 seconds or if they left less than 3 seconds ago
+ if action_time + timedelta(seconds=3) > now and action_time - timedelta(seconds=20) < now:
+ future_users.append(user_id)
+
+ active_users = list(proximity_users) + [u for u in future_users if u not in proximity_users]
+
+ new_state = self.current_state
+ if len(active_users) == 0:
+ # no one using the display? switch it off!
+ new_state = state_factory.get_idle_state()
+ else:
+ message = None
+ if active_users[0] in self.last_known_user_state:
+ message = self.last_known_user_state[active_users[0]]
+ else:
+ message = self.last_known_user_proximity[active_users[0]]
+ rec = message['user']
+ info = message['activity']
+ ttA = message['time_to_action']
+ color = message['color']
+ symbol = message['symbol']
+
+ direction = None
+ if 'route' in message and symbol == 'arrow':
+ direction = self.decide_signal_direction(message['route'])
+ if direction is None and os.getenv('FALLBACK_SIGNAL_DIRECTION', None) is not None:
+ direction = os.getenv('FALLBACK_SIGNAL_DIRECTION')
+
+ if BD_ADDR is not None:
+ avg_rssi = self.check_rssi(BD_ADDR)
+ #print("average rssi:"+avg_rssi)
+ else:
+ avg_rssi = 9999 # if no BT address is configured, create no proximity events
+
+ #print(avg_rssi)
+
+ #conduct interaction
+ if avg_rssi <= 10:
+ if symbol == 'arrow' and direction is not None:
+ new_state = state_factory.get_arrow_state(direction=direction, fg_color=color, bg_color=(0,0,0), blinking=True)
+ elif symbol in ['hook', 'bee']:
+ new_state = state_factory.get_symbol_state(symbol, color=color, blinking = True)
+ else:
+ new_state = state_factory.get_color_state(color=color, blinking=True)
+
+ if avg_rssi > 10:
+ new_state = state_factory.get_idle_state()
+
+ # Only change state if it is different from the currently active one
+ if json.dumps(new_state) != json.dumps(self.current_state):
+ self.current_state = new_state
+ self.current_content_start_time = datetime.utcnow()
+
+ print("Changed to new state:", new_state["id"])
+ if os.getenv('ENABLE_SENSEHAT') == 'true':
+ if self.sense_hat_worker is not None and self.sense_hat_worker.is_alive():
+ self.sense_hat_worker.obsolete = True
+ self.sense_hat_worker.join()
+ self.sense_hat_worker = threading.Thread(target=self.load_new_sense_hat_state, args=(0,), name="Thread-SenseHAT")
+ self.sense_hat_worker.daemon = True
+ self.sense_hat_worker.obsolete = False
+ self.sense_hat_worker.start()
+
+ return (self.current_state, self.current_content_start_time.isoformat(), proximity_users)
+
+ def load_new_sense_hat_state(self, sub_state_index):
+ from sense_hat import SenseHat
+ sense = SenseHat()
+ sense.set_rotation(270) # we deploy MiRs with the HDMI port pointing to the left
+ if self.sense_hat_worker.obsolete:
+ return
+ sub_state = self.current_state["states"][sub_state_index]
+ if sub_state["function"] == "clear":
+ if "color" in sub_state:
+ #print("SenseHAT: clear", sub_state["color"])
+ sense.clear(sub_state["color"])
+ else:
+ #print("SenseHAT: clear")
+ sense.clear()
+ if sub_state["function"] == "set_pixels":
+ #print("SenseHAT: new pixels")
+ sense.set_pixels(sub_state["pixels"])
+ if "duration" in sub_state:
+ sleep(sub_state["duration"])
+
+ # only jump to next state if the current state is not the last one
+ next_sub_state_index = None
+ if sub_state_index < len(self.current_state["states"]) - 1:
+ next_sub_state_index = sub_state_index + 1
+ elif "loop" in self.current_state and self.current_state["loop"]:
+ # or jump back to the beginning of the state sequence if loop is true
+ next_sub_state_index = 0
+ if next_sub_state_index is not None:
+ self.load_new_sense_hat_state(next_sub_state_index)
+
+ def decide_signal_direction(self, route):
+ signal_range = 3.0
+ if route is None:
+ return None
+ my_position = os.getenv('POSITION', None)
+ if my_position is None or not my_position.startswith('Point:'):
+ return None
+ my_rotation = os.getenv('ROTATION', None)
+ if my_rotation is None:
+ return None
+ my_position = [float(coord) for coord in my_position.split(':')[1].split(',')]
+ my_rotation = float(my_rotation)
+ initial_far_point = (float(route[0]['x']), float(route[0]['y']))
+ next_far_point = None
+ in_range_from_here = False
+ for point in route:
+ point = (float(point['x']), float(point['y']))
+ distance = math.sqrt((point[0] - my_position[0]) ** 2 + (point[1] - my_position[1]) ** 2)
+ if distance < signal_range:
+ in_range_from_here = True
+ if in_range_from_here and distance > signal_range:
+ next_far_point = point
+ break
+ if next_far_point is None:
+ next_far_point = initial_far_point
+ angle = math.atan2(next_far_point[1] - my_position[1], next_far_point[0] - my_position[0])
+ angle *= 180 / math.pi
+ angle -= my_rotation
+ angle += 270
+ while angle < 0:
+ angle += 360
+ while angle >= 360:
+ angle -= 360
+ if angle >= 315 or angle < 45:
+ direction = 'up'
+ elif angle >= 45 and angle < 135:
+ direction = 'right'
+ elif angle >= 135 and angle < 225:
+ direction = 'down'
+ else:
+ direction = 'left'
+ return direction
+
+ def check_rssi(self, addr):
+ rssi_real = get_rssi(addr)
+ if rssi_real == None:
+ self.check_rssi(addr)
+ else:
+ rssi = abs(rssi_real)
+
+ #print("MAC: "+rec+" RSSI:"+str(rssi_real))
+ if len(self.rssi_pipe) >= 5:
+ self.rssi_pipe.pop(0)
+ self.rssi_pipe.append(rssi)
+ avg_rssi = sum(self.rssi_pipe) / len(self.rssi_pipe)
+ #print("Average RSSI value is: "+str(avg_rssi))
+
+ return avg_rssi
+
diff --git a/microinforadiator/joystick_control.py b/microinforadiator/joystick_control.py
--- /dev/null
@@ -0,0 +1,175 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+from sense_hat import SenseHat
+from time import sleep
+from random import randint, choice
+import pygame, sys
+
+sense = SenseHat()
+red = (255,0,0)
+blue = (0,0,255)
+green = (0,255,0)
+yellow = (255,255,0)
+magenta = (255,0,255)
+cyan = (0,255,255)
+black = (0,0,0)
+cb = black
+ca = blue
+
+
+#Arrows
+def arrow_up ():
+
+ arrow_up = [
+
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,ca,cb,cb,cb,cb,cb,
+ cb,ca,cb,cb,cb,cb,cb,cb,
+ ca,ca,ca,ca,ca,ca,ca,ca,
+ cb,ca,cb,cb,cb,cb,cb,cb,
+ cb,cb,ca,cb,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,cb,cb,cb,cb,cb
+
+ ]
+
+ return arrow_up
+
+def arrow_left ():
+
+ arrow_l = [
+
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ ca,cb,cb,ca,cb,cb,ca,cb,
+ cb,ca,cb,ca,cb,ca,cb,cb,
+ cb,cb,ca,ca,ca,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb
+
+ ]
+
+ return arrow_l
+
+def arrow_down ():
+
+ arrow_d = [
+
+ cb,cb,cb,cb,ca,cb,cb,cb,
+ cb,cb,cb,cb,cb,ca,cb,cb,
+ cb,cb,cb,cb,cb,cb,ca,cb,
+ ca,ca,ca,ca,ca,ca,ca,ca,
+ cb,cb,cb,cb,cb,cb,ca,cb,
+ cb,cb,cb,cb,cb,ca,cb,cb,
+ cb,cb,cb,cb,ca,cb,cb,cb,
+ cb,cb,cb,cb,cb,cb,cb,cb
+
+ ]
+
+ return arrow_d
+
+ #def arrow_right (color_background, color_arrow):
+def arrow_right ():
+
+ arrow_r = [
+
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,ca,ca,ca,cb,cb,cb,
+ cb,ca,cb,ca,cb,ca,cb,cb,
+ ca,cb,cb,ca,cb,cb,ca,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb,
+ cb,cb,cb,ca,cb,cb,cb,cb
+
+ ]
+
+ return arrow_r
+
+def blinking():
+ sense.clear(0,0,255)
+ sleep(1)
+ sense.clear()
+ sleep(1)
+ sense.clear(0,0,255)
+ sleep(1)
+ sense.clear()
+#
+
+#AUDIO
+def audio():
+ pygame.mixer.init()
+ pygame.mixer.music.load("./Audio/glocke.mp3")
+ pygame.mixer.music.play()
+ while pygame.mixer.music.get_busy() == True:
+
+ continue
+
+def Setup():
+ prev_dir = 0
+ new_dir = 0
+
+ while True:
+
+
+ for event in sense.stick.get_events():
+ print(event.direction, event.action)
+ if event.action == "pressed" or event.action == "held" or event.action == "released":
+
+ if event.direction == "up" and event.action == "released":
+ new_dir = "up"
+ if(prev_dir == new_dir):
+ sense.clear()
+ else:
+ a = arrow_right()
+ sense.set_pixels(a)
+ prev_dir = "up"
+
+ if event.direction == "down" and event.action == "released":
+ new_dir = "down"
+ if(prev_dir == new_dir):
+ sense.clear()
+ else:
+ a = arrow_left()
+ sense.set_pixels(a)
+ prev_dir = "down"
+
+ if event.direction == "left" and event.action == "released":
+ new_dir = "left"
+ if(prev_dir == new_dir):
+ sense.clear()
+ else:
+ a = arrow_up()
+ sense.set_pixels(a)
+ prev_dir = "left"
+
+ if event.direction == "right" and event.action == "released":
+ new_dir = "right"
+ if(prev_dir == new_dir):
+ sense.clear()
+ else:
+ a = arrow_down()
+ sense.set_pixels(a)
+ prev_dir = "right"
+
+ if event.direction == "middle" and event.action == "released":
+ new_dir = "middle"
+ if(prev_dir == new_dir):
+ sense.clear()
+ else:
+ #audio()
+ blinking()
+ prev_dir = "middle"
+
+ pass
+
+if __name__=='__main__':
+ sense.show_letter('O')
+ sleep(1)
+ sense.clear()
+ Setup()
diff --git a/microinforadiator/main.py b/microinforadiator/main.py
--- /dev/null
@@ -0,0 +1,72 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+# initialize Micro-Information Radiator functions
+# set up IoT-Service (register, get ID, listen for actions) / MQTT pub and sub
+# Set-Up: create an IoT-device on IoT-Service Platform with Raspberry Pi data
+# Maintain: inform about your status (e.g. current location), identify Bluetooth Devices nearby and inform Platform about it (POST), check for activities for yourself (GET)
+
+from dotenv import load_dotenv
+import datetime
+import json
+import os
+import threading
+import queue
+import time
+
+import interaction
+
+if os.getenv('ENV_FILE_LOCATION') is not None:
+ load_dotenv(dotenv_path=os.getenv('ENV_FILE_LOCATION'))
+else:
+ load_dotenv()
+
+def notify_service_directory():
+ import requests, socket
+ try:
+ s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+ s.connect(("8.8.8.8", 80))
+ ip = s.getsockname()[0]
+ s.close()
+ requests.get('http://localhost/mir.php?name=' + os.getenv('MICROINFORADIATOR_ID') + '&value=' + ip)
+ except:
+ pass
+
+notify_service_directory()
+
+from time import sleep
+from mqtt_service import start_mqtt, handle_publish
+
+
+incoming_messages = queue.Queue()
+outgoing_messages = queue.Queue()
+
+#set up MQTT (subscribe to topics, publish commands, listen on messages(receive information about seniors: persons-Bluetooth-ID, timestamp, seconds_until, activity[]))
+mqtt_client = start_mqtt(incoming_messages, outgoing_messages)
+mqtt_thread = threading.Thread(target=mqtt_client.loop_forever, name="Thread-MQTT")
+mqtt_thread.daemon = True
+mqtt_thread.start()
+
+interaction_controller = interaction.InteractionController(incoming_messages, outgoing_messages)
+try:
+ while True:
+ interaction_controller.interaction_loop()
+ try:
+ outgoing = outgoing_messages.get_nowait()
+ message = {
+ 'mir_id': os.getenv('MICROINFORADIATOR_ID'),
+ 'content': outgoing[0],
+ 'start_time': outgoing[1],
+ 'proximity_users': outgoing[2],
+ }
+ print(message)
+ mqtt_client.publish("activities/interaction", json.dumps(message))
+ outgoing_messages.task_done()
+ except queue.Empty:
+ pass
+except KeyboardInterrupt:
+ print('Received SIGINT, exiting...')
+
diff --git a/microinforadiator/mqtt_service.py b/microinforadiator/mqtt_service.py
--- /dev/null
@@ -0,0 +1,86 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+import paho.mqtt.client as mqtt
+from threading import Thread
+from time import sleep
+import os
+import json
+
+##########################################################
+MY_THREAD = os.getenv('MICROINFORADIATOR_ID')
+##########################################################
+
+INTERACTION_THREAD = "activities/interaction"
+ACTIVITY_THREAD = "activities/info/muc"
+MiR_THREAD = "mir/status"
+TEST_PATH = "test_channel"
+
+
+def on_connect(client, userdata, flags, rc):
+ client.subscribe(MY_THREAD)
+ client.subscribe(INTERACTION_THREAD)
+ client.subscribe(ACTIVITY_THREAD)
+ client.subscribe(MiR_THREAD)
+ client.subscribe(TEST_PATH)
+
+def on_message(client, userdata, msg):
+ message = json.loads(msg.payload.decode("utf-8"))
+ if msg.topic == MY_THREAD:
+ #print("message topic: ",msg.topic)
+ #print("message received: ",message)
+ client.incoming_messages.put(message)
+
+ #send information about interaction to MiR-Controller via mqtt channel activities/interaction (my ID, the persons ID, interaction conducted, timestamp, duration)
+ #Thread(target=handle_publish,args=(client,INTERACTION_THREAD,interaction)).start()
+
+def handle_publish(client,thread,msg):
+ client.publish(thread,str(msg))
+
+def on_publish(client,userdata,result):
+ print("data published")#create function for callback
+ pass
+
+def on_disconnect(client, userdata, rc):
+ if rc != 0:
+ print("Unexpected disconnection.")
+
+def start_mqtt(incoming_messages, outgoing_messages):
+
+ incoming_message_queue = incoming_messages
+ outgoing_message_queue = outgoing_messages
+
+ client = mqtt.Client()
+ client.on_connect = on_connect
+ client.on_message = on_message
+ client.on_publish = on_publish
+ client.on_disconnect = on_disconnect
+
+ client.incoming_messages = incoming_messages
+ client.outgoing_messages = outgoing_messages
+
+ mqtt_broker_ips = []
+ if os.getenv('MQTT_BROKER_URL') is not None:
+ mqtt_broker_ips.append(os.getenv('MQTT_BROKER_URL'))
+
+ while len(mqtt_broker_ips) > 0:
+ ip = mqtt_broker_ips[0]
+ del mqtt_broker_ips[0]
+ try:
+ client.connect(ip, 1883, 60)
+ print("connected to mqtt broker at " + ip)
+ break
+ except:
+ pass
+ if len(mqtt_broker_ips) == 0:
+ print("could not connect to any known mqtt broker")
+
+ return client
+
+
+if __name__=='__main__':
+
+ start_mqtt()
diff --git a/microinforadiator/proximity.py b/microinforadiator/proximity.py
--- /dev/null
@@ -0,0 +1,40 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Laura Stojko
+
+from dotenv import load_dotenv
+import os
+
+if os.getenv('ENV_FILE_LOCATION') is not None:
+ load_dotenv(dotenv_path=os.getenv('ENV_FILE_LOCATION'))
+else:
+ load_dotenv()
+
+if os.getenv('ENABLE_BLUETOOTH') == 'true':
+ print(os.getenv('ENABLE_BLUETOOTH'))
+ from Bluetooth.bluetooth_controller import bluetooth_rssi,get_devices
+
+
+def get_devices():
+ detected_devices = []
+
+ if os.getenv('ENABLE_BLUETOOTH') == 'true':
+ bt_devices = get_devices()
+ detected_devices.extend(bt_devices)
+
+ # TODO: This is where support for simulated proximity events would probably be added.
+
+ return detected_devices
+
+def get_rssi(bd_addr):
+ rssi = None
+
+ if os.getenv('ENABLE_BLUETOOTH') == 'true':
+ rssi = bluetooth_rssi(bd_addr)
+ else:
+ # TODO: Do we need fictional RSSI values for simulated users?
+ rssi = 1
+
+ return rssi
diff --git a/microinforadiator/requirements.txt b/microinforadiator/requirements.txt
--- /dev/null
@@ -0,0 +1,5 @@
+python-dotenv
+mercurial
+gattlib
+pybluez
+paho-mqtt
\ No newline at end of file
diff --git a/microinforadiator/run.sh b/microinforadiator/run.sh
--- /dev/null
+++ b/microinforadiator/run.sh
@@ -0,0 +1,4 @@
+#!/bin/sh
+export ENV_FILE_LOCATION='./MiR05.env'
+python3 main.py
+
diff --git a/microinforadiator/run_multi.py b/microinforadiator/run_multi.py
--- /dev/null
@@ -0,0 +1,79 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Julian Fietkau, Laura Stojko
+
+import collections
+import fcntl
+import glob
+import json
+import os
+import subprocess
+import sys
+import time
+
+if len(sys.argv) > 1:
+ if '--create-configs' in sys.argv:
+ defaults_filename = 'defaults.env'
+ defaults = collections.OrderedDict()
+ if os.path.isfile(defaults_filename):
+ with open(defaults_filename, 'r') as fp:
+ for line in fp.read().splitlines():
+ if len(line) == 0:
+ continue
+ key, value = line.split('=')
+ defaults[key] = value
+ with open('mir_evaluation_2020_09.json', 'r') as fp:
+ mir_data = json.load(fp)
+ for mir in mir_data["microinforadiators"]:
+ values = defaults.copy()
+ values['POSITION'] = mir['location']['type'] + ':' + ','.join([str(c) for c in mir['location']['coordinates']])
+ values['ROTATION'] = str(mir['rotation'])
+ values['MICROINFORADIATOR_ID'] = mir['name']
+ values.move_to_end('MICROINFORADIATOR_ID', last=False) # misleading method name: this actually moves the ID to the beginning
+ with open(mir['name'] + '.env', 'w') as fp:
+ for key in values:
+ fp.write(key + '=' + values[key] + '\n')
+ sys.exit(0)
+ else:
+ mir_names = sys.argv[1:]
+else:
+ mir_names = [os.path.splitext(os.path.basename(conf))[0] for conf in glob.glob('*.env')]
+ if 'defaults' in mir_names:
+ mir_names.remove('defaults')
+
+mir_names.sort()
+processes = {}
+python_executable = '/usr/bin/python3' # TODO Windows compatibility?
+for mir_name in mir_names:
+ env = { 'ENV_FILE_LOCATION': './' + mir_name + '.env' }
+ print('Starting', mir_name, '...')
+ processes[mir_name] = subprocess.Popen([python_executable, '-u', 'main.py'], bufsize=0, env=env, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+ flags = fcntl.fcntl(processes[mir_name].stdout, fcntl.F_GETFL) # get current p.stdout flags
+ fcntl.fcntl(processes[mir_name].stdout, fcntl.F_SETFL, flags | os.O_NONBLOCK)
+try:
+ while len(processes) > 0:
+ exited_processes = []
+ for mir_name in processes:
+ for pipe in 'stdout', 'stderr':
+ output = getattr(processes[mir_name], pipe).read()
+ if output is None:
+ continue
+ for line in output.decode('utf-8').splitlines():
+ if len(line) > 0:
+ print('[' + mir_name + ']', line)
+ result = processes[mir_name].poll()
+ if result is not None:
+ exited_processes.append(mir_name)
+ for mir_name in exited_processes:
+ del processes[mir_name]
+ print(mir_name, 'terminated itself.')
+ time.sleep(0.1)
+ print('All child processes have terminated, exiting...')
+except KeyboardInterrupt:
+ print('Detected SIGINT, exiting...')
+ for mir_name in processes:
+ print('Terminating', mir_name, '...')
+ processes[mir_name].terminate()
+
diff --git a/microinforadiator/state_factory.py b/microinforadiator/state_factory.py
--- /dev/null
@@ -0,0 +1,98 @@
+#!/usr/bin/env python3
+
+# SPDX-License-Identifier: GPL-3.0-or-later
+# This file is part of UrbanLife+ Activity Support. <https://fietkau.software/ulp_activity_support>
+# Copyright (C) 2019-2020 Julian Fietkau, Laura Stojko
+
+from LED.arrows import arrow_up, arrow_down, arrow_left, arrow_right
+from LED.symbols import hook, bee
+import os
+
+def get_idle_state():
+ return {
+ "id": "idle",
+ "states": [
+ {
+ "function": "clear"
+ }
+ ]
+ }
+
+def get_color_state(color, blinking):
+
+ result = {
+ "id": "color_"+','.join(map(str, color)),
+ "states": [
+ {
+ "function": "clear",
+ "color": color
+ }
+ ]
+ }
+
+ if blinking:
+ result["id"] += "_blink"
+ result["states"][0]["duration"] = 1.0
+ result['states'].append({"function": "clear", "duration": 1.0 })
+ result["loop"] = True
+
+ return result
+
+def get_arrow_state(direction, fg_color, bg_color, blinking):
+ if direction not in ["up", "down", "left", "right"]:
+ raise ValueError(direction)
+
+ result = {
+ "id": "arrow_"+direction+"_"+",".join(map(str,fg_color)),
+ "states": [
+ {
+ "function": "set_pixels",
+ }
+ ]
+ }
+
+ pixels = None
+ if direction == "up":
+ pixels = arrow_up(bg_color, fg_color)
+ if direction == "down":
+ pixels = arrow_down(bg_color, fg_color)
+ if direction == "left":
+ pixels = arrow_left(bg_color, fg_color)
+ if direction == "right":
+ pixels = arrow_right(bg_color, fg_color)
+ result["states"][0]["pixels"] = pixels
+
+ if blinking:
+ result["id"] += "_blink"
+ result["states"][0]["duration"] = 1.0
+ result['states'].append({"function": "clear", "duration": 1.0 })
+ result["loop"] = True
+
+ return result
+
+def get_symbol_state(symbol, color, blinking):
+ pixels = None
+
+ if symbol == "hook":
+ pixels = hook(color)
+ elif symbol == "bee":
+ pixels = bee()
+
+ result = {
+ "id": "symbol_"+symbol+"_"+",".join(map(str,color)),
+ "states": [
+ {
+ "function": "set_pixels",
+ }
+ ]
+ }
+
+ result["states"][0]["pixels"] = pixels
+
+ if blinking:
+ result["id"] += "_blink"
+ result["states"][0]["duration"] = 1.0
+ result['states'].append({"function": "clear", "duration": 1.0 })
+ result["loop"] = True
+
+ return result