Refactor import statements to use iop instead of grongier.pex

Author: grongierisc

pyproject.toml

@@ -39,7 +39,7 @@ repository = "https://github.com/grongierisc/interoperability-embedded-python"
 issues = "https://github.com/grongierisc/interoperability-embedded-python/issues"
 
 [project.scripts]
-iop = "grongier.pex._cli:main"
+iop = "iop._cli:main"
 
 [tool.setuptools.packages.find]
 where = ["src"]

src/iop/_director.py

@@ -255,7 +255,7 @@ def test_component(target,message=None,classname=None,body=None):
             # else create a python object
             else:
                 # python message are casted to Grongier.PEX.Message
-                message = iris.cls("Grongier.PEX.Message")._New()
+                message = iris.cls("IOP.Message")._New()
                 message.classname = classname
                 if body:
                     message.jstr = _Utils.string_to_stream(body)
@@ -264,7 +264,7 @@ def test_component(target,message=None,classname=None,body=None):
         # serialize the message
         business_host = _BusinessHost()
         serial_message = business_host._dispatch_serializer(message)
-        response = iris.cls('Grongier.PEX.Utils').dispatchTestComponent(target,serial_message)
+        response = iris.cls('IOP.Utils').dispatchTestComponent(target,serial_message)
         try:
             deserialized_response = business_host._dispatch_deserializer(response)
         except ImportError as e:

src/tests/registerFiles/bo.py

@@ -1,6 +1,6 @@
 
 
-from iop import BusinessOperation
+from grongier.pex import BusinessOperation
 
 import iris
 

src/tests/registerFiles/bp.py

@@ -1,4 +1,4 @@
-from iop import BusinessProcess
+from grongier.pex import BusinessProcess
 
 from message import PostMessage
 

src/tests/registerFiles/bs.py

@@ -1,4 +1,4 @@
-from iop import BusinessService
+from grongier.pex import BusinessService
 
 import iris
 

src/tests/registerFilesIop/adapter.py

@@ -0,0 +1,56 @@
+import iop
+import requests
+import iris
+import json
+
+class RedditInboundAdapter(iop.InboundAdapter):
+    
+    def OnInit(self):
+        
+        if not hasattr(self,'Feed'):
+            self.Feed = "/new/"
+        
+        if self.Limit is None:
+            raise TypeError('no Limit field')
+        
+        self.LastPostName = ""
+        
+        return 1
+
+    def OnTask(self):
+        self.LOGINFO(f"LIMIT:{self.Limit}")
+        if self.Feed == "" :
+            return 1
+        
+        tSC = 1
+        # HTTP Request
+        try:
+            server = "https://www.reddit.com"
+            requestString = self.Feed+".json?before="+self.LastPostName+"&limit="+self.Limit
+            self.LOGINFO(server+requestString)
+            response = requests.get(server+requestString)
+            response.raise_for_status()
+
+            data = response.json()
+            updateLast = 0
+
+            for key, value in enumerate(data['data']['children']):
+                if value['data']['selftext']=="":
+                    continue
+                post = iris.cls('dc.Reddit.Post')._New()
+                post._JSONImport(json.dumps(value['data']))
+                post.OriginalJSON = json.dumps(value)
+                if not updateLast:
+                    self.LastPostName = value['data']['name']
+                    updateLast = 1
+                response = self.BusinessHost.ProcessInput(post)
+        except requests.exceptions.HTTPError as err:
+            if err.response.status_code == 429:
+                self.LOGWARNING(err.__str__())
+            else:
+                raise err
+        except Exception as err: 
+            self.LOGERROR(err.__str__())
+            raise err
+
+        return tSC

src/tests/registerFilesIop/bo.py

@@ -0,0 +1,140 @@
+
+
+from iop import BusinessOperation
+
+import iris
+
+from message import MyResponse
+
+import os
+import datetime
+import smtplib
+from email.mime.text import MIMEText
+
+class EmailOperation(BusinessOperation):
+
+    def OnMessage(self, pRequest):
+
+        sender = 'admin@example.com'
+        receivers = [ pRequest.ToEmailAddress ]
+
+
+        port = 1025
+        msg = MIMEText('This is test mail')
+
+        msg['Subject'] = pRequest.Found+" found"
+        msg['From'] = 'admin@example.com'
+        msg['To'] = pRequest.ToEmailAddress
+
+        with smtplib.SMTP('localhost', port) as server:
+            
+            # server.login('username', 'password')
+            server.sendmail(sender, receivers, msg.as_string())
+            print("Successfully sent email")
+
+
+
+class EmailOperationWithIrisAdapter(BusinessOperation):
+
+    def get_adapter_type():
+        """
+        Name of the registred Adapter
+        """
+        return "EnsLib.EMail.OutboundAdapter"
+
+    def OnMessage(self, pRequest):
+
+        mailMessage = iris.cls("%Net.MailMessage")._New()
+        mailMessage.Subject = pRequest.Found+" found"
+        self.Adapter.AddRecipients(mailMessage,pRequest.ToEmailAddress)
+        mailMessage.Charset="UTF-8"
+
+        title = author = url = ""
+        if (pRequest.Post is not None) :
+            title = pRequest.Post.title
+            author = pRequest.Post.author
+            url = pRequest.Post.url
+        
+        mailMessage.TextData.WriteLine("More info:")
+        mailMessage.TextData.WriteLine("Title: "+title)
+        mailMessage.TextData.WriteLine("Author: "+author)
+        mailMessage.TextData.WriteLine("URL: "+url)
+
+        return self.Adapter.SendMail(mailMessage)
+
+class FileOperation(BusinessOperation):
+
+    def OnInit(self):
+        if hasattr(self,'Path'):
+            os.chdir(self.Path)
+
+    def OnMessage(self, pRequest):
+        
+        ts = title = author = url = text = ""
+
+        if (pRequest.Post is not None):
+            title = pRequest.Post.Title
+            author = pRequest.Post.Author
+            url = pRequest.Post.Url
+            text = pRequest.Post.Selftext
+            ts = datetime.datetime.fromtimestamp(pRequest.Post.CreatedUTC).__str__()
+
+        line = ts+" : "+title+" : "+author+" : "+url
+        filename = pRequest.Found+".txt"
+
+
+        self.PutLine(filename, line)
+        self.PutLine(filename, "")
+        self.PutLine(filename, text)
+        self.PutLine(filename, " * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *")
+
+        return 
+
+    def PutLine(self,filename,string):
+        try:
+            with open(filename, "a",encoding="utf-8") as outfile:
+                outfile.write(string)
+        except Exception as e:
+            raise e
+
+class FileOperationWithIrisAdapter(BusinessOperation):
+
+    def get_adapter_type():
+        """
+        Name of the registred Adapter
+        """
+        return "EnsLib.File.OutboundAdapter"
+
+    def OnMessage(self, pRequest):
+
+        ts = title = author = url = text = ""
+
+        if (pRequest.Post != ""):
+            title = pRequest.Post.Title
+            author = pRequest.Post.Author
+            url = pRequest.Post.Url
+            text = pRequest.Post.Selftext
+            ts = iris.cls("%Library.PosixTime").LogicalToOdbc(iris.cls("%Library.PosixTime").UnixTimeToLogical(pRequest.Post.CreatedUTC))
+
+        line = ts+" : "+title+" : "+author+" : "+url
+        filename = pRequest.Found+".txt" 
+        
+        self.Adapter.PutLine(filename, line)
+        self.Adapter.PutLine(filename, "")
+        self.Adapter.PutLine(filename, text)
+        self.Adapter.PutLine(filename, " * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *")
+
+        return
+
+class MyOperation(BusinessOperation):
+
+    def OnMessage(self, request):
+        self.LOGINFO('hello')
+        return MyResponse(request.StringValue)
+
+if __name__ == "__main__":
+    
+    op = FileOperation()
+    from message import PostMessage,PostClass
+    msg = PostMessage(PostClass('foo','foo','foo','foo',1,'foo'),'bar','bar')
+    op.OnMessage(msg)

src/tests/registerFilesIop/bp.py

@@ -0,0 +1,21 @@
+from iop import BusinessProcess
+
+from message import PostMessage
+
+class FilterPostRoutingRule(BusinessProcess):
+    
+    def OnInit(self):
+        
+        if not hasattr(self,'Target'):
+            self.Target = "Python.FileOperation"
+        
+        return
+
+    def OnRequest(self, request: PostMessage):
+        if 'dog'.upper() in request.Post.Selftext.upper():
+            request.ToEmailAddress = 'dog@company.com'
+            request.Found = 'Dog'
+        if 'cat'.upper() in request.Post.Selftext.upper():
+            request.ToEmailAddress = 'cat@company.com'
+            request.Found = 'Cat'
+        return self.SendRequestSync(self.Target,request)

src/tests/registerFilesIop/bs.py

@@ -0,0 +1,117 @@
+from iop import BusinessService
+
+import iris
+
+import json
+
+from message import PostMessage
+from obj import PostClass
+
+class RedditService(BusinessService):
+
+    def get_adapter_type():
+        """
+        Name of the registred Adapter
+        """
+        return "Ens.InboundAdapter"
+
+    def OnInit(self):
+        
+        if not hasattr(self,'Feed'):
+            self.Feed = "/new/"
+        
+        if not hasattr(self,'Limit'):
+            raise TypeError('no Limit field')
+
+        if not hasattr(self,'Target'):
+            self.Target = "Python.FilterPostRoutingRule"
+        
+        self.LastPostName = ""
+        
+        return 1
+
+    def OnProcessInput(self,request):
+
+        post = self.OnTask()
+        if post is not None:
+            msg = PostMessage()
+            msg.Post = post
+            self.send_request_sync("test",msg)
+
+    def OnTask(self) -> PostClass:
+          
+        try:
+            server = "https://www.reddit.com"
+            requestString = self.Feed+".json?before="+self.LastPostName+"&limit="+self.Limit
+
+            response = requests.get(server+requestString)
+            # response.raise_for_status()
+
+            # data = response.json()
+            data = json.loads("""
+                {"data":{"children":[{"kind": "t3", "data": {"approved_at_utc": null, "subreddit": "Livros", "selftext": " Ol\\u00e1 amigos do Cat Reddit; \\n\\n​\\n\\nGostaria de vir compartilhar um pensamento que venho tendo nessas \\u00faltimas semanas. \\n\\n\\u201cO incentivo \\u00e0 leitura nunca foi t\\u00e3o importante em compara\\u00e7\\u00e3o as d\\u00e9cadas anteriores.\\u201d\\n\\nNunca foi t\\u00e3o dif\\u00edcil ser brasileiro: infla\\u00e7\\u00e3o que supera 2 d\\u00edgitos, governo federal que n\\u00e3o liga pra educa\\u00e7\\u00e3o da popula\\u00e7\\u00e3o e alto n\\u00edvel de desemprego. \\n\\nDiante desse cen\\u00e1rio preocupante, digo que tenho muito orgulho do meu trabalho, exercendo ele vejo uma mudan\\u00e7a real em como a popula\\u00e7\\u00e3o est\\u00e1 cada vez mais interessada e curiosa na busca de desenvolvimento pessoal. Vejo significado e prop\\u00f3sito na minha vida exercendo minha profiss\\u00e3o. Espalho conhecimento por um pre\\u00e7o bastante acess\\u00edvel em compara\\u00e7\\u00e3o a outras livrarias. \\n\\nAl\\u00e9m disso, voc\\u00eas me ajudam muito quando compram um livro. A cada dia estou mais perto da quantia necess\\u00e1ria para come\\u00e7ar meu mestrado em Coimbra. \\n\\nObrigados a todos que v\\u00eam me apoiando e que seguem minha jornada.\\n\\n​\\n\\nGrande abra\\u00e7o a todos.", "author_fullname": "t2_1g037lor", "saved": false, "mod_reason_title": null, "gilded": 0, "clicked": false, "title": "VENDER LIVROS \\u00c9 UM DOS TRABALHO MAIS SIGNIFICANTES EM UMA \\u00c9POCA DE OBSCURANTISMO.", "link_flair_richtext": [], "subreddit_name_prefixed": "r/Livros", "hidden": false, "pwls": null, "link_flair_css_class": "", "downs": 0, "thumbnail_height": null, "top_awarded_type": null, "hide_score": true, "name": "t3_tjflyd", "quarantine": false, "link_flair_text_color": "light", "upvote_ratio": 1.0, "author_flair_background_color": null, "subreddit_type": "public", "ups": 1, "total_awards_received": 0, "media_embed": {}, "thumbnail_width": null, "author_flair_template_id": null, "is_original_content": false, "user_reports": [], "secure_media": null, "is_reddit_media_domain": false, "is_meta": false, "category": null, "secure_media_embed": {}, "link_flair_text": "Mercado editorial e pol\\u00edticas p\\u00fablicas", "can_mod_post": false, "score": 1, "approved_by": null, "is_created_from_ads_ui": false, "author_premium": false, "thumbnail": "self", "edited": false, "author_flair_css_class": null, "author_flair_richtext": [], "gildings": {}, "content_categories": null, "is_self": true, "mod_note": null, "created": 1647879710.0, "link_flair_type": "text", "wls": null, "removed_by_category": null, "banned_by": null, "author_flair_type": "text", "domain": "self.Livros", "allow_live_comments": false, "selftext_html": "<!-- SC_OFF --><div class=\\"md\\"><p>Ol\\u00e1 amigos do Reddit; </p>\\n\\n<p>​</p>\\n\\n<p>Gostaria de vir compartilhar um pensamento que venho tendo nessas \\u00faltimas semanas. </p>\\n\\n<p>\\u201cO incentivo \\u00e0 leitura nunca foi t\\u00e3o importante em compara\\u00e7\\u00e3o as d\\u00e9cadas anteriores.\\u201d</p>\\n\\n<p>Nunca foi t\\u00e3o dif\\u00edcil ser brasileiro: infla\\u00e7\\u00e3o que supera 2 d\\u00edgitos, governo federal que n\\u00e3o liga pra educa\\u00e7\\u00e3o da popula\\u00e7\\u00e3o e alto n\\u00edvel de desemprego. </p>\\n\\n<p>Diante desse cen\\u00e1rio preocupante, digo que tenho muito orgulho do meu trabalho, exercendo ele vejo uma mudan\\u00e7a real em como a popula\\u00e7\\u00e3o est\\u00e1 cada vez mais interessada e curiosa na busca de desenvolvimento pessoal. Vejo significado e prop\\u00f3sito na minha vida exercendo minha profiss\\u00e3o. Espalho conhecimento por um pre\\u00e7o bastante acess\\u00edvel em compara\\u00e7\\u00e3o a outras livrarias. </p>\\n\\n<p>Al\\u00e9m disso, voc\\u00eas me ajudam muito quando compram um livro. A cada dia estou mais perto da quantia necess\\u00e1ria para come\\u00e7ar meu mestrado em Coimbra. </p>\\n\\n<p>Obrigados a todos que v\\u00eam me apoiando e que seguem minha jornada.</p>\\n\\n<p>​</p>\\n\\n<p>Grande abra\\u00e7o a todos.</p>\\n</div><!-- SC_ON -->", "likes": null, "suggested_sort": "confidence", "banned_at_utc": null, "view_count": null, "archived": false, "no_follow": true, "is_crosspostable": false, "pinned": false, "over_18": false, "all_awardings": [], "awarders": [], "media_only": false, "link_flair_template_id": "6bfc7288-b343-11ea-99c8-0e35844b0e2f", "can_gild": false, "spoiler": false, "locked": false, "author_flair_text": null, "treatment_tags": [], "visited": false, "removed_by": null, "num_reports": null, "distinguished": null, "subreddit_id": "t5_2tlr4", "author_is_blocked": false, "mod_reason_by": null, "removal_reason": null, "link_flair_background_color": "#6b6031", "id": "tjflyd", "is_robot_indexable": true, "report_reasons": null, "author": "Afteroui", "discussion_type": null, "num_comments": 0, "send_replies": true, "whitelist_status": null, "contest_mode": false, "mod_reports": [], "author_patreon_flair": false, "author_flair_text_color": null, "permalink": "/r/Livros/comments/tjflyd/vender_livros_\\u00e9_um_dos_trabalho_mais/", "parent_whitelist_status": null, "stickied": false, "url": "https://www.reddit.com/r/Livros/comments/tjflyd/vender_livros_\\u00e9_um_dos_trabalho_mais/", "subreddit_subscribers": 12094, "created_utc": 1647879710.0, "num_crossposts": 0, "media": null, "is_video": false}}]}}
+            """)
+            updateLast = 0
+
+            for key, value in enumerate(data['data']['children']):
+                if value['data']['selftext']=="":
+                    continue
+                post = PostClass.from_dict(value['data'])
+                post.OriginalJSON = json.dumps(value)
+                
+                if not updateLast:
+                    self.LastPostName = value['data']['name']
+                    updateLast = 1
+                    return post
+
+        except requests.exceptions.HTTPError as err:
+            if err.response.status_code == 429:
+                self.LOGWARNING(err.__str__())
+            else:
+                raise err
+        except Exception as err: 
+            self.LOGERROR(err.__str__())
+            raise err
+
+        return None
+
+
+class RedditServiceWithIrisAdapter(BusinessService):
+
+    def get_adapter_type():
+        """
+        Name of the registred Adapter
+        """
+        return "dc.Reddit.InboundAdapter"
+
+    def OnProcessInput(self, messageInput):
+        msg = iris.cls("dc.Demo.PostMessage")._New()
+        msg.Post = messageInput
+        return self.SendRequestSync(self.Target,msg)
+
+    def OnInit(self):
+        
+        if not hasattr(self,'Target'):
+            self.Target = "Python.FilterPostRoutingRule"
+        
+        return
+
+class RedditServiceWithPexAdapter(BusinessService):
+
+    def get_adapter_type():
+        """
+        Name of the registred Adapter
+        """
+        return "Python.RedditInboundAdapter"
+
+    def OnProcessInput(self, messageInput):
+        msg = iris.cls("dc.Demo.PostMessage")._New()
+        msg.Post = messageInput
+        return self.SendRequestSync(self.Target,msg)
+
+    def OnInit(self):
+        
+        if not hasattr(self,'Target'):
+            self.Target = "Python.FilterPostRoutingRule"
+        
+        return

src/tests/registerFilesIop/edge/bs-dash.py

@@ -0,0 +1,7 @@
+from iop import BusinessService
+
+class BS(BusinessService):
+
+    @staticmethod
+    def get_adapter_type():
+        return 'EnsLib.File.InboundAdapter'