Merge remote-tracking branch 'upstream/master'

Author: wangshub

README.md

@@ -1,8 +1,8 @@
 # codelab_adapter_extensions
-[codelab-adapter](https://codelab-adapter-docs.codelab.club/) extensions.
+![](https://adapterv2.codelab.club/img/toys_party.jpeg)
 
-[codelab-adapter](https://codelab-adapter-docs.codelab.club/)是[Scratch3 Lab](https://blog.just4fun.site/Scratch3-Lab.html)的一个子项目， 它也是[codelab.club](https://blog.just4fun.site/about-codelab-club.html)希望贡献给社区的一个基础设施。
+[Codelab Adapter](https://adapterv2.codelab.club/) extensions.
 
-Scratch3 Lab是一个将Scratch3.0接入开源硬件及AI的实验项目(Scratch3 Lab: connect Scratch3.0 to open-source hardware and AI)。
+CodeLab Adapter 是由[CodeLab](https://www.codelab.club/)构建的基础项目(v2 是最新版本)，致力于连接万物，无论是软件还是硬件，无论是 AI、开源硬件、现实世界的物体、还是虚拟世界的动画角色，在 CodeLab Adapter 的驱动下，皆可彼此互动。
 
-我们的目标是使万物积木化。 这是一些[演示案例](https://codelab-adapter-docs.codelab.club/user_guide/gallery/)。
+目前，我们在 CodeLab Neverland 中使用 CodeLab Adapter。CodeLab Neverland 是一个由 CodeLab Adapter 驱动的可编程空间，空间里的所有事物皆可编程。

extensions_v2/extension_blender.py

@@ -0,0 +1,18 @@
+from codelab_adapter.core_extension import ControllerExtension
+from codelab_adapter.utils import get_server_file_path
+
+
+class BlenderControllerExtension(ControllerExtension):
+    '''
+    use to control VectorNode(server)
+    '''
+
+    def __init__(self):
+        super().__init__()
+        self.server_extension_id = "eim/blender"
+        self.EXTENSION_ID = f"{self.server_extension_id}/control"  # default eim
+        # 分布式的节点，手动启动
+        self.server_file = None
+
+
+export = BlenderControllerExtension

extensions_v2/extension_eim.py

@@ -12,16 +12,11 @@ class EIMExtension(Extension):
 
     def __init__(self):
         super().__init__()
-        self.EXTENSION_ID = "eim"
+        self.EXTENSION_ID = "eim" # after super
 
     def extension_message_handle(self, topic, payload):
-        # print(topic, payload, type(payload))
-        if type(payload) == str:
-            self.logger.info(f'scratch eim message:{payload}')
-            return
-        elif type(payload) == dict:
-            self.logger.info(f'eim message:{payload}')
-            self.publish({"payload": payload})
+        self.logger.info(f'eim message:{payload}')
+        self.publish({"payload": payload})
 
     def run(self):
         '''
@@ -30,7 +25,7 @@ def run(self):
         i = 0
         while self._running:
             message = self.message_template()
-            message["payload"]["content"] = str(i) # topic可选
+            message["payload"]["content"] = str(i)
             self.publish(message)
             time.sleep(1)
             i += 1

extensions_v2/extension_hello_world.py

@@ -0,0 +1,26 @@
+import time
+from codelab_adapter.core_extension import Extension
+
+
+class HelloWorldExtension(Extension):
+    def __init__(self):
+        super().__init__()
+        self.EXTENSION_ID = "eim"
+
+    def send_message_to_scratch(self, content):
+        message = self.message_template()
+        message["payload"]["content"] = content
+        self.publish(message)
+
+    def extension_message_handle(self, topic, payload):
+        self.logger.info(f'the message payload from scratch: {payload}')
+        content = payload["content"]
+        if type(content) == str:
+            content_send_to_scratch = content[::-1] # 反转字符串
+            self.send_message_to_scratch(content_send_to_scratch)
+
+    def run(self):
+        while self._running:
+            time.sleep(1)
+
+export = HelloWorldExtension

extensions_v2/extension_robot_xy.py

@@ -0,0 +1,28 @@
+import time
+import random
+from codelab_adapter.core_extension import Extension
+
+
+class RobotXYExtension(Extension):
+    def __init__(self):
+        super().__init__()
+        self.EXTENSION_ID = "eim/robot"
+
+    def extension_message_handle(self, topic, payload):
+        self.logger.debug(f'the message payload from scratch: {payload}')
+        content = payload["content"]
+        if type(content) == dict:
+            x = content["x"]
+            y = content["y"]
+            self.logger.info(f'x:{x}; y:{y}')
+
+    def run(self):
+        while self._running:
+            message = self.message_template()
+            random_x = random.randint(-240,240)
+            random_y = random.randint(-180,180)
+            message["payload"]["content"] = {"x":random_x, "y":random_y}
+            self.publish(message)
+            time.sleep(1)
+
+export = RobotXYExtension

extensions_v2/extension_sync_helloworld.py

@@ -0,0 +1,28 @@
+import time
+from codelab_adapter.core_extension import Extension
+
+
+class SyncHelloWorldExtension(Extension):
+    def __init__(self):
+        super().__init__()
+        self.EXTENSION_ID = "eim"
+
+    def send_message_to_scratch(self, payload):
+        message = self.message_template()
+        message["payload"] = payload
+        self.publish(message)
+
+    def extension_message_handle(self, topic, payload):
+        self.logger.info(f'the message payload from scratch: {payload}')
+        content = payload["content"]
+        if type(content) == str:
+            content_send_to_scratch = content[::-1] # 反转字符串
+            time.sleep(1)
+            payload["content"] = content_send_to_scratch
+            self.send_message_to_scratch(payload)
+
+    def run(self):
+        while self._running:
+            time.sleep(1)
+
+export = SyncHelloWorldExtension

extensions_v2/extension_wechat.py

@@ -1,6 +1,3 @@
-'''
-构建2个管道
-'''
 import itchat, time
 from itchat.content import TEXT
 import zmq
@@ -11,15 +8,11 @@
 
 codelab_adapter_dir = pathlib.Path.home() / "codelab_adapter"
 
-class WechatGateway(Extension):
-    '''
-    todo 作为网关
-    使用插件来启停它
-    '''
 
+class WechatGateway(Extension):
     def __init__(self):
         super().__init__()
-        self.EXTENSION_ID = "eim/wechat"  # 放在内部
+        self.EXTENSION_ID = "eim/wechat"
         self.quit_code = "quit!"
 
     def extension_message_handle(self, topic, payload):
@@ -36,8 +29,8 @@ def extension_message_handle(self, topic, payload):
             if type == 'user':
                 user2SendMessage = itchat.search_friends(nickName=username)[0]
             user2SendMessage.send(text)
-        except:
-            pass
+        except Exception as e:
+            self.logger.error(str(e))
 
     def run(self):
         self.wechat_run_as_thread()
@@ -66,34 +59,33 @@ def text_reply(self, msg):
                 "content": content,
             }
             self.publish(message)
-        except:
-            pass
+        except Exception as e:
+            self.logger.error(str(e))
 
     # 群消息
     def group_text_reply(self, msg):
         '''
         将群消息发往scratch
         '''
-        
+
         content = msg.text
         username = msg.actualNickName
         try:
             # 群消息有时候会有问题 msg.User.NickName不存在
             group_name = msg.User.NickName
         except:
             return
-        # todo 主动发信息 第一条信息发两次
         try:
-            # 如果有groupname就是群消息
+            # groupname: 群消息
             message = {}
             message["payload"] = {
                 "username": username,
                 "content": content,
                 "groupname": group_name
             }
             self.publish(message)
-        except:
-            pass
+        except Exception as e:
+            self.logger.error(str(e))
 
     @threaded
     def wechat_run_as_thread(self):
@@ -106,7 +98,8 @@ def wechat_run_as_thread(self):
         itchat.msg_register(TEXT, isGroupChat=True)(self.group_text_reply)
         itchat.auto_login(
             True, picDir=picDir, statusStorageDir=statusStorageDir)
-        itchat.run(True)
+        itchat.run(True)  # todo 提示有些账号无法登录
+
 
 export = WechatGateway
 

servers_v2/blender_server.py

@@ -0,0 +1,52 @@
+# pip3 install codelab_adapter_client # blender
+from io import StringIO
+import contextlib
+import sys
+import time
+
+from codelab_adapter_client import AdapterNode
+from codelab_adapter_client.utils import threaded
+import bpy
+from loguru import logger
+
+
+class BlenderNode(AdapterNode):
+    def __init__(self):
+        super().__init__()
+        self.EXTENSION_ID = "eim/blender"
+
+    @contextlib.contextmanager
+    def stdoutIO(self, stdout=None):
+        old = sys.stdout
+        if stdout is None:
+            stdout = StringIO()
+        sys.stdout = stdout
+        yield stdout
+        sys.stdout = old
+
+    def extension_message_handle(self, topic, payload):
+        python_code = payload["content"]
+        logger.info(f'python_code: {python_code}')
+        # extension_python_kernel.py
+        try:
+            with self.stdoutIO() as s:
+                exec(python_code)
+            output = s.getvalue()
+        except Exception as e:
+            output = e
+        payload["content"] = str(output)
+        message = {"payload": payload}
+        self.publish(message)
+
+    def exit_message_handle(self, topic, payload):
+        self.terminate()
+
+    @threaded
+    def run(self):
+        while self._running:
+            time.sleep(0.5)
+
+
+node = BlenderNode()
+node.receive_loop_as_thread()
+# node.run()