add accept decorator for subscription

Author: tomvictor

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "iotcore"
-version = "0.2.1"
+version = "0.3.0"
 edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

Cargo.toml

@@ -71,9 +71,9 @@ async def lifespan(app: FastAPI):
 app = FastAPI(lifespan=lifespan)
 
 
-@app.get("/")
-def home():
-    return {"Hello": "World"}
+@iot.accept(topic="temperature")
+def temperature_data(request):
+    print(f"Temperature data : {request}")
 
 
 def mqtt_callback(data):
@@ -88,10 +88,13 @@ def sub():
 
 @app.get("/pub")
 def pub():
-    iot.publish("iot", "test")
+    iot.publish("temperature", "{'temp': 18}")
     return {"response": "published"}
 
 
+@app.get("/")
+def home():
+    return {"Hello": "World"}
 
 ```
 

README.md

@@ -71,9 +71,9 @@ async def lifespan(app: FastAPI):
 app = FastAPI(lifespan=lifespan)
 
 
-@app.get("/")
-def home():
-    return {"Hello": "World"}
+@iot.accept(topic="temperature")
+def temperature_data(request):
+    print(f"Temperature data : {request}")
 
 
 def mqtt_callback(data):
@@ -88,10 +88,13 @@ def sub():
 
 @app.get("/pub")
 def pub():
-    iot.publish("iot", "test")
+    iot.publish("temperature", "{'temp': 18}")
     return {"response": "published"}
 
 
+@app.get("/")
+def home():
+    return {"Hello": "World"}
 
 ```
 

docs/index.md

@@ -14,9 +14,9 @@ async def lifespan(app: FastAPI):
 app = FastAPI(lifespan=lifespan)
 
 
-@app.get("/")
-def home():
-    return {"Hello": "World"}
+@iot.accept(topic="temperature")
+def temperature_data(request):
+    print(f"Temperature data : {request}")
 
 
 def mqtt_callback(data):
@@ -31,10 +31,10 @@ def sub():
 
 @app.get("/pub")
 def pub():
-    iot.publish("iot", "test")
+    iot.publish("temperature", "{'temp': 18}")
     return {"response": "published"}
 
 
-@iot.accept(topic="request/temperature/data")
-def temperature_data(request):
-    print(request)
+@app.get("/")
+def home():
+    return {"Hello": "World"}

examples/fastapi/main.py

@@ -46,12 +46,11 @@ def iot_core_callback(self, topic, data):
 
     def accept(self, topic):
         def decorator(func):
-            self.subscribed_topics[hash(topic)] = func  # Store the topic and callback function in the dictionary
+            self.subscribe(topic, func)
 
             def wrapper(request):
                 func(request)
 
             return wrapper
 
         return decorator
-