readd wechat code base.

Author: drswinghead

archlinux/txagent.conf

@@ -46,6 +46,14 @@
 
     <allow send_path="/io/qtc/roundtable/WechatAgent"/>
 
+    <!-- for tx roundtable.XmppAgent -->
+    <allow own="io.qtc.roundtable.XmppAgent"/>
+
+    <allow send_destination="io.qtc.roundtable.XmppAgent"/>
+    <allow receive_sender="io.qtc.roundtable.XmppAgent"/>
+
+    <allow send_path="/io/qtc/roundtable/XmppAgent"/>
+
     <!-- for tx weixin -->
     <allow own="io.qtc.wxagent"/>
 

wxagent/baseagent.py

@@ -68,9 +68,9 @@ def SendMessageX(self, msg: dict):
 
     def makeBusMessage(self, op: str, evt: str, *args):
         if op is not None:
-            return {'op': op, 'params': args, }
+            return {'op': op, 'params': args, 'channel': '', }
         if evt is not None:
-            return {'evt': evt, 'params': args, }
+            return {'evt': evt, 'params': args, 'channel': '', }
         raise 'wtf'
         return
 
@@ -176,8 +176,8 @@ def onPushMessage(self, msg):
 
         return
 
-    def onRpcCall(self, msg):
-        qDebug(self.__class__.__name__ + ',' + str(msg))
+    def onRpcCall(self, argv):
+        qDebug(self.__class__.__name__ + ',' + str(argv))
         return
 
     def funcName(self):

wxagent/basecontroller.py

@@ -329,7 +329,6 @@ def sendQRToRelayPeer(self):
                 url = url1 + "\n" + url2
                 # self.peerRelay.sendMessage('qrcode url:' + url, self.peerRelay.peer_user)
                 args = self.rt.makeBusMessage('showpiclink', None, 'qrcode url:' + url)
-                args['channel'] = ''
                 self.rt.SendMessageX(args)
             else:
                 self.need_send_qrfile = True

wxagent/irccontroller.py

@@ -0,0 +1,72 @@
+import json
+
+from PyQt5.QtCore import *
+from PyQt5.QtDBus import *
+
+from .basecontroller import BaseController
+from .wxcommon import *
+
+from .imrelay import IMRelay
+
+
+class IRCCallProxy(QObject):
+    def __init__(self, ctrl, parent=None):
+        super(IRCCallProxy, self).__init__(parent)
+        self.ctrl = ctrl
+        return
+
+    def friendExists(self, friendId):
+        qDebug('hehree')
+        return self.ctrl.remoteCall(self.ctrl.rt.funcName(), friendId)
+
+    def send_message(self, mto, mbody):
+        qDebug('hehree')
+        return self.ctrl.remoteCall(self.ctrl.rt.funcName(), mto, mbody)
+        return
+
+
+class IRCController(BaseController):
+    def __init__(self, rt, parent=None):
+        super(IRCController, self).__init__(rt, parent)
+        self.relay = IRCRelay()
+        self.relay.xmpp = IRCCallProxy(self)
+        return
+
+    def initSession(self):
+        return
+
+    def replyMessage(self, msgo):
+        qDebug(msgo['sender']['channel'])
+        # from .secfg import peer_xmpp_user
+
+        # self.relay.sendMessage(msgo['params'][0], peer_xmpp_user)
+        return
+
+    def updateSession(self, msgo):
+        qDebug('heree')
+        evt = msgo['evt']
+        params = msgo['params']
+        if evt == 'onIRCConnected': self.relay.onIRCConnected()
+        elif evt == 'onIRCDisconnected': self.relay.onIRCDisconnected()
+        elif evt == 'onIRCNewMessage': self.relay.onIRCNewMessage(*params)
+        else: pass
+        return
+
+
+class IRCRelay(IMRelay):
+    def __init__(self, parent=None):
+        super(IRCRelay, self).__init__(parent)
+        return
+
+    # ######################
+    def onIRCConnected(self):
+        qDebug('hrerere')
+        return
+
+    def onIRCDisconnected(self):
+        qDebug('hrerere')
+        return
+
+    def onIRCNewMessage(self, msg):
+        qDebug(msg[0:32].encode())
+        return

wxagent/logiccontroller.py

@@ -0,0 +1,39 @@
+# web weixin protocol
+
+import os, sys
+import json, re
+import html
+import enum
+import time
+import magic
+import math
+
+from PyQt5.QtCore import *
+from PyQt5.QtNetwork import *
+from PyQt5.QtDBus import *
+
+
+from .imrelayfactory import IMRelayFactory
+from .wxcommon import *
+from .wxmessage import *
+from .wxsession import *
+from .unimessage import *
+from .botcmd import *
+from .filestore import QiniuFileStore, VnFileStore
+
+from .basecontroller import BaseController, Chatroom
+
+
+#
+#
+class LogicController(BaseController):
+
+    def __init__(self, rt, parent=None):
+        "docstring"
+        super(LogicController, self).__init__(rt, parent)
+
+        self.relay_src_pname = self.__class__.__name__
+
+        return
+
+

wxagent/mainrt.py

@@ -7,6 +7,7 @@
 from .wechatagent import WechatAgent
 from .ircagent import IRCAgent
 from .toxagent import ToxAgent
+from .xmppagent import XmppAgent
 from .roundtable import RoundTable
 # from .xmppagent import XmppAgent
 # from .slackagent import SlackAgent
@@ -16,6 +17,7 @@ class StartupManager(QObject):
     def __init__(self, parent=None):
         super(StartupManager, self).__init__(parent)
         self.protocols = {'wechat': WechatAgent, 'irc': IRCAgent, 'tox': ToxAgent,
+                          'xmpp': XmppAgent,
                           'roundtable': RoundTable}
         self.procs = {}
         # self.loginAllProtocols()