Call base run() method of RestfulComponent

Tribler · Sep 28, 2021 · a449b88 · a449b88
1 parent e20030f
commit a449b88
Show file tree

Hide file tree

Showing 12 changed files with 14 additions and 11 deletions.
diff --git a/...ibler-core/tribler_core/components/bandwidth_accounting/bandwidth_accounting_component.py b/...ibler-core/tribler_core/components/bandwidth_accounting/bandwidth_accounting_component.py
@@ -23,7 +23,7 @@ class BandwidthAccountingComponent(RestfulComponent):
     _ipv8: IPv8
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
         await self.get_component(UpgradeComponent)
         config = self.session.config
 

diff --git a/src/tribler-core/tribler_core/components/gigachannel/gigachannel_component.py b/src/tribler-core/tribler_core/components/gigachannel/gigachannel_component.py
@@ -21,6 +21,7 @@ class GigaChannelComponent(RestfulComponent):
     _ipv8: IPv8
 
     async def run(self):
+        await super().run()
         await self.get_component(ReporterComponent)
 
         config = self.session.config
@@ -52,7 +53,6 @@ async def run(self):
 
         await self.init_endpoints(['remote_query', 'channels', 'collections'], [('gigachannel_community', community)])
 
-
     async def shutdown(self):
         await super().shutdown()
         if self._ipv8:

diff --git a/...tribler-core/tribler_core/components/gigachannel_manager/gigachannel_manager_component.py b/...tribler-core/tribler_core/components/gigachannel_manager/gigachannel_manager_component.py
@@ -11,7 +11,7 @@ class GigachannelManagerComponent(RestfulComponent):
     gigachannel_manager: GigaChannelManager
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
 
         config = self.session.config
         notifier = self.session.notifier

diff --git a/src/tribler-core/tribler_core/components/ipv8.py b/src/tribler-core/tribler_core/components/ipv8.py
@@ -31,7 +31,7 @@ class Ipv8Component(RestfulComponent):
     _peer_discovery_community: Optional[DiscoveryCommunity] = None
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
 
         config = self.session.config
 

diff --git a/src/tribler-core/tribler_core/components/libtorrent.py b/src/tribler-core/tribler_core/components/libtorrent.py
@@ -14,7 +14,7 @@ class LibtorrentComponent(RestfulComponent):
     download_manager: DownloadManager
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
         await self.get_component(UpgradeComponent)
         socks_servers_component = await self.require_component(SocksServersComponent)
         master_key_component = await self.require_component(MasterKeyComponent)

diff --git a/src/tribler-core/tribler_core/components/metadata_store/metadata_store_component.py b/src/tribler-core/tribler_core/components/metadata_store/metadata_store_component.py
@@ -14,7 +14,7 @@ class MetadataStoreComponent(RestfulComponent):
     mds: MetadataStore
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
         await self.get_component(UpgradeComponent)
 
         config = self.session.config

diff --git a/src/tribler-core/tribler_core/components/resource_monitor.py b/src/tribler-core/tribler_core/components/resource_monitor.py
@@ -9,7 +9,7 @@ class ResourceMonitorComponent(RestfulComponent):
     resource_monitor: CoreResourceMonitor
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
         await self.get_component(UpgradeComponent)
 
         config = self.session.config

diff --git a/src/tribler-core/tribler_core/components/restapi.py b/src/tribler-core/tribler_core/components/restapi.py
@@ -47,6 +47,9 @@ async def init_ipv8_endpoints(self, ipv8, endpoints):
                 if path in path_set:
                     endpoint.initialize(ipv8)
 
+    async def run(self):
+        await self.get_component(ReporterComponent)
+
     async def shutdown(self):
         rest_component = await self.get_component(RESTComponent)
         if not rest_component:

diff --git a/src/tribler-core/tribler_core/components/torrent_checker.py b/src/tribler-core/tribler_core/components/torrent_checker.py
@@ -15,7 +15,7 @@ class TorrentCheckerComponent(RestfulComponent):
     torrent_checker: TorrentChecker
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
 
         config = self.session.config
 

diff --git a/src/tribler-core/tribler_core/components/tunnels.py b/src/tribler-core/tribler_core/components/tunnels.py
@@ -20,7 +20,7 @@ class TunnelsComponent(RestfulComponent):
     _ipv8: IPv8
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
 
         config = self.session.config
         ipv8_component = await self.require_component(Ipv8Component)

diff --git a/src/tribler-core/tribler_core/components/upgrade.py b/src/tribler-core/tribler_core/components/upgrade.py
@@ -11,7 +11,7 @@ class UpgradeComponent(RestfulComponent):
     upgrader: TriblerUpgrader
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
         config = self.session.config
         notifier = self.session.notifier
         master_key_component = await self.require_component(MasterKeyComponent)

diff --git a/src/tribler-core/tribler_core/components/watch_folder.py b/src/tribler-core/tribler_core/components/watch_folder.py
@@ -11,7 +11,7 @@ class WatchFolderComponent(RestfulComponent):
     watch_folder: WatchFolder
 
     async def run(self):
-        await self.get_component(ReporterComponent)
+        await super().run()
         config = self.session.config
         notifier = self.session.notifier
         libtorrent_component = await self.require_component(LibtorrentComponent)