Added emit function

Author: Jeroen van der Heijden

sample_lego.py

@@ -47,6 +47,14 @@ async def example():
         await lego.load(client)
 
         # ... now the collection will be watched for 100 seconds
+        while True:
+            await asyncio.sleep(3)
+            if lego and lego.bricks:
+                brick = lego.bricks[0]
+                await brick.emit('new-color', 'RED')
+                break
+            await lego.query('.bricks.push(Brick{});')
+
         await asyncio.sleep(300)
 
     finally:

thingsdb/model/thing.py

@@ -94,6 +94,16 @@ def unwatch(self):
         collection = self._collection
         return collection._client.unwatch(self._id, scope=collection._scope)
 
+    def emit(self, event, *args):
+        data = {f'd{i}': v for i, v in enumerate(args)}
+        dstr = "".join((f", {k}" for k in data.keys()))
+
+        return self._collection.query(
+            f'thing(id).emit(event{dstr});',
+            id=self._id,
+            event=event,
+            **data)
+
     @checkevent
     def on_init(self, event, data):
         self._job_set(data)