remove unused analytics

lbry/extras/daemon/analytics.py

@@ -14,18 +14,8 @@
 SERVER_STARTUP = 'Server Startup'
 SERVER_STARTUP_SUCCESS = 'Server Startup Success'
 SERVER_STARTUP_ERROR = 'Server Startup Error'
-DOWNLOAD_STARTED = 'Download Started'
-DOWNLOAD_ERRORED = 'Download Errored'
 DOWNLOAD_FINISHED = 'Download Finished'
-HEARTBEAT = 'Heartbeat'
-CLAIM_ACTION = 'Claim Action'  # publish/create/update/abandon
-NEW_CHANNEL = 'New Channel'
-CREDITS_SENT = 'Credits Sent'
 UPNP_SETUP = "UPnP Setup"
-
-BLOB_BYTES_UPLOADED = 'Blob Bytes Uploaded'
-
-
 TIME_TO_FIRST_BYTES = "Time To First Bytes"
 
 
@@ -133,7 +123,6 @@ async def run(self):
         while True:
             if self.enabled:
                 self.external_ip = await utils.get_external_ip()
-                await self._send_heartbeat()
             await asyncio.sleep(1800)
 
     def stop(self):
@@ -211,18 +200,6 @@ async def send_download_finished(self, download_id, name, sd_hash):
             )
         )
 
-    async def send_claim_action(self, action):
-        await self.track(self._event(CLAIM_ACTION, {'action': action}))
-
-    async def send_new_channel(self):
-        await self.track(self._event(NEW_CHANNEL))
-
-    async def send_credits_sent(self):
-        await self.track(self._event(CREDITS_SENT))
-
-    async def _send_heartbeat(self):
-        await self.track(self._event(HEARTBEAT))
-
     def _event(self, event, properties: typing.Optional[typing.Dict] = None):
         return {
             'userId': 'lbry',

lbry/extras/daemon/daemon.py

@@ -1501,7 +1501,6 @@ async def jsonrpc_wallet_send(
 
         if not preview:
             await self.ledger.broadcast(tx)
-            self.component_manager.loop.create_task(self.analytics_manager.send_credits_sent())
         else:
             await self.ledger.release_tx(tx)
 
@@ -2574,7 +2573,6 @@ async def jsonrpc_channel_create(
             self.component_manager.loop.create_task(self.storage.save_claims([self._old_get_temp_claim_info(
                 tx, txo, claim_address, claim, name, dewies_to_lbc(amount)
             )]))
-            self.component_manager.loop.create_task(self.analytics_manager.send_new_channel())
         else:
             await account.ledger.release_tx(tx)
 
@@ -2730,7 +2728,6 @@ async def jsonrpc_channel_update(
             self.component_manager.loop.create_task(self.storage.save_claims([self._old_get_temp_claim_info(
                 tx, new_txo, claim_address, new_txo.claim, new_txo.claim_name, dewies_to_lbc(amount)
             )]))
-            self.component_manager.loop.create_task(self.analytics_manager.send_new_channel())
         else:
             await account.ledger.release_tx(tx)
 
@@ -2789,7 +2786,6 @@ async def jsonrpc_channel_abandon(
 
         if not preview:
             await self.broadcast_or_release(tx, blocking)
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('abandon'))
         else:
             await account.ledger.release_tx(tx)
 
@@ -3110,7 +3106,6 @@ async def jsonrpc_stream_repost(self, name, bid, claim_id, allow_duplicate_name=
 
         if not preview:
             await self.broadcast_or_release(tx, blocking)
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('publish'))
         else:
             await account.ledger.release_tx(tx)
 
@@ -3272,7 +3267,6 @@ async def save_claims():
                 await self.storage.save_content_claim(file_stream.stream_hash, new_txo.id)
 
             self.component_manager.loop.create_task(save_claims())
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('publish'))
         else:
             await account.ledger.release_tx(tx)
 
@@ -3495,7 +3489,6 @@ async def save_claims():
                     await self.storage.save_content_claim(stream_hash, new_txo.id)
 
             self.component_manager.loop.create_task(save_claims())
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('publish'))
         else:
             await account.ledger.release_tx(tx)
 
@@ -3554,7 +3547,6 @@ async def jsonrpc_stream_abandon(
 
         if not preview:
             await self.broadcast_or_release(tx, blocking)
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('abandon'))
         else:
             await self.ledger.release_tx(tx)
 
@@ -3719,7 +3711,6 @@ async def jsonrpc_collection_create(
 
         if not preview:
             await self.broadcast_or_release(tx, blocking)
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('publish'))
         else:
             await account.ledger.release_tx(tx)
 
@@ -3873,7 +3864,6 @@ async def jsonrpc_collection_update(
 
         if not preview:
             await self.broadcast_or_release(tx, blocking)
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('publish'))
         else:
             await account.ledger.release_tx(tx)
 
@@ -4039,7 +4029,6 @@ async def jsonrpc_support_create(
                 'claim_id': claim_id,
                 'amount': dewies_to_lbc(amount)
             }]})
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('new_support'))
         else:
             await self.ledger.release_tx(tx)
 
@@ -4156,7 +4145,6 @@ async def jsonrpc_support_abandon(
 
         if not preview:
             await self.broadcast_or_release(tx, blocking)
-            self.component_manager.loop.create_task(self.analytics_manager.send_claim_action('abandon'))
         else:
             await self.ledger.release_tx(tx)
 

lbry/wallet/usage_payment.py

@@ -59,8 +59,6 @@ async def pay(self):
             )
 
             await self.ledger.broadcast(tx)
-            if self.analytics_manager:
-                await self.analytics_manager.send_credits_sent()
             self._on_payment_controller.add(tx)
 
     async def start(self, ledger=None, wallet=None):