add Django MQTT support

Author: tomvictor

examples/django/develop/settings.py

@@ -37,7 +37,8 @@
     "django.contrib.sessions",
     "django.contrib.messages",
     "django.contrib.staticfiles",
-    "iotcore.djangoiot"
+    # "iotcore.djangoiot", # Broker only
+    "iot"
 ]
 
 MIDDLEWARE = [

examples/django/develop/urls.py

@@ -16,7 +16,10 @@
 """
 from django.contrib import admin
 from django.urls import path
+from iot import views
 
 urlpatterns = [
     path("admin/", admin.site.urls),
+    path("sub", views.subscribe),
+    path("pub", views.publish),
 ]

examples/django/iot/__init__.py

@@ -0,0 +1,3 @@
+from django.contrib import admin
+
+# Register your models here.

examples/django/iot/admin.py

@@ -0,0 +1,6 @@
+from django.apps import AppConfig
+
+
+class IotConfig(AppConfig):
+    default_auto_field = "django.db.models.BigAutoField"
+    name = "iot"

examples/django/iot/apps.py

@@ -0,0 +1,3 @@
+from django.db import models
+
+# Create your models here.

examples/django/iot/migrations/__init__.py

@@ -0,0 +1,3 @@
+from django.test import TestCase
+
+# Create your tests here.

examples/django/iot/models.py

@@ -0,0 +1,19 @@
+from django.http import JsonResponse
+from iotcore import IotCore
+
+iot = IotCore()
+iot.background_loop_forever()
+
+
+def mqtt_callback(data):
+    print(f"Django >: {data}")
+
+
+def subscribe(request):
+    iot.subscribe("iot", mqtt_callback)
+    return JsonResponse({"response": "subscribed"})
+
+
+def publish(request):
+    iot.publish("iot", "demo")
+    return JsonResponse({"response": "published"})

examples/django/iot/tests.py

@@ -6,13 +6,14 @@
 class IotConfig(AppConfig):
     default_auto_field = "django.db.models.BigAutoField"
     name = "iotcore.djangoiot"
+    iotcore_instance = None
 
     def ready(self):
         server_status = os.environ.get("MQTT_SERVER_RUNNING", None)
         if server_status is None:
             print("Starting MQTT server!")
             os.environ["MQTT_SERVER_RUNNING"] = "true"
-            iot = IotCore()
-            iot.background_loop_forever()
+            self.iotcore_instance = IotCore()
+            self.iotcore_instance.background_loop_forever()
         else:
             print("Server already running!")