chg: [chat feeder] add matrix feeder

bin/importer/feeders/Matrix.py

@@ -0,0 +1,38 @@
+#!/usr/bin/env python3
+# -*-coding:UTF-8 -*
+"""
+The Telegram Feeder Importer Module
+================
+
+Process Telegram JSON
+
+"""
+import os
+import sys
+import datetime
+
+sys.path.append(os.environ['AIL_BIN'])
+##################################
+# Import Project packages
+##################################
+from importer.feeders.abstract_chats_feeder import AbstractChatFeeder
+from lib.ConfigLoader import ConfigLoader
+from lib.objects import ail_objects
+from lib.objects.Chats import Chat
+from lib.objects import Messages
+from lib.objects import UsersAccount
+from lib.objects.Usernames import Username
+
+import base64
+
+class MatrixFeeder(AbstractChatFeeder):
+
+    def __init__(self, json_data):
+        super().__init__('matrix', json_data)
+
+    # def get_obj(self):.
+    #     obj_id = Messages.create_obj_id('telegram', chat_id, message_id, timestamp)
+    #     obj_id = f'message:telegram:{obj_id}'
+    #     self.obj = ail_objects.get_obj_from_global_id(obj_id)
+    #     return self.obj
+

bin/importer/feeders/abstract_chats_feeder.py

@@ -62,10 +62,10 @@ def get_chat_protocol(self):  # TODO # # # # # # # # # # # # #
         return self.name
 
     def get_chat_network(self):
-        self.json_data['meta'].get('network', None)
+        return self.json_data['meta'].get('network', None)
 
     def get_chat_address(self):
-        self.json_data['meta'].get('address', None)
+        return self.json_data['meta'].get('address', None)
 
     def get_chat_instance_uuid(self):
         chat_instance_uuid = chats_viewer.create_chat_service_instance(self.get_chat_protocol(),

bin/lib/objects/DomHashs.py

@@ -78,7 +78,6 @@ def get_misp_object(self):
             for tag in self.get_tags():
                 obj_attr.add_tag(tag)
         return obj
-        return None
 
     def get_nb_seen(self):
         return self.get_nb_correlation('domain')

bin/lib/objects/Messages.py

@@ -168,7 +168,7 @@ def get_user_account(self, meta=False):
         if user_account.get('user-account'):
             user_account = f'user-account:{user_account["user-account"].pop()}'
             if meta:
-                _, user_account_subtype, user_account_id = user_account.split(':', 3)
+                _, user_account_subtype, user_account_id = user_account.split(':', 2)
                 user_account = UsersAccount.UserAccount(user_account_id, user_account_subtype).get_meta(options={'icon', 'username', 'username_meta'})
         return user_account
 

bin/lib/objects/UsersAccount.py

@@ -171,7 +171,7 @@ def get_meta(self, options=set(), translation_target=None): # TODO Username time
         if 'username' in options:
             meta['username'] = self.get_username()
             if meta['username']:
-                _, username_account_subtype, username_account_id = meta['username'].split(':', 3)
+                _, username_account_subtype, username_account_id = meta['username'].split(':', 2)
                 if 'username_meta' in options:
                     meta['username'] = Usernames.Username(username_account_id, username_account_subtype).get_meta(options={'icon'})
                 else: