Revert "Add async tasks and mailer services"

Author: Jackiebibili

apps/startup/apps.py

@@ -1,40 +1,14 @@
 from django.apps import AppConfig
+from ..ticketscraping.scraping import start
 from datetime import datetime
 from threading import Thread
-from multiprocessing import Process
-
-
-def run_prepare():
-    # import module inside the child process to prevent execution in the parent process
-    print(
-        f"ticket scraping service started at {datetime.now().strftime('%d/%m/%Y %H:%M:%S')}")
-
-    # start sender socket
-    from apps.ticketscraping.schedulers.async_tasks_scheduler import async_tasks_scheduler
-    conn_thread = Thread(target=async_tasks_scheduler.connect)
-    conn_thread.start()
-    # wait for async tasks handler to connect
-    conn_thread.join()
-
-    # start itself (scraping)
-    from apps.ticketscraping.scraping import start
-    start()
-
-
-def run():
-    # starter
-    p = Process(target=run_prepare, daemon=True)
-    p.start()
-    # start receiver socket
-    from apps.ticketscraping.connection.asyn_tasks_receiver import run
-    conn_process = Process(target=run)
-    conn_process.start()
-    conn_process.join()
 
 
 class MyAppConfig(AppConfig):
    name = "apps.startup"
    verbose_name = "start tmtracker"
 
    def ready(self):
-        run()
+      print(
+          f"server started at {datetime.now().strftime('%d/%m/%Y %H:%M:%S')}")
+      Thread(target=start).start()

apps/storage/base.py

@@ -30,18 +30,12 @@ def find_one_and_update__(coll: collection.Collection, filter: dict, update=dict
 def find_one_and_delete__(coll: collection.Collection, filter: dict):
    return coll.find_one_and_delete(filter)
 
-def find_one__(coll: collection.Collection, filter: dict, projection, **kwargs):
-   return coll.find_one(filter=filter, projection=projection, **kwargs)
+def find_one__(coll: collection.Collection, filter: dict, projection):
+   return coll.find_one(filter=filter, projection=projection)
 
 def find_many__(coll: collection.Collection, filter: dict, projection, **kwargs):
    return coll.find(filter=filter, projection=projection, **kwargs)
 
-def count_docs__(coll: collection.Collection, filter: dict):
-   return coll.count_documents(filter=filter)
-
-def estimated_count_docs__(coll: collection.Collection):
-   return coll.estimated_document_count()
-
 def watch__(coll: collection.Collection, **kwargs):
    return coll.watch(**kwargs)
 

apps/storage/query.py

@@ -51,29 +51,17 @@ def find_one_and_delete(collection_name, filter: dict, db_name="tickets"):
    return find_one_and_delete__(coll, filter)
 
 # find one
-def find_one(collection_name, filter: dict, projection=None, db_name="tickets", **kwargs):
+def find_one(collection_name, filter: dict, projection=None, db_name="tickets"):
    db = get_db_handle(db_name)
    coll = db[collection_name]
-   return find_one__(coll, filter, projection, **kwargs)
+   return find_one__(coll, filter, projection)
 
 # find many
 def find_many(collection_name, filter: dict, projection=None, db_name="tickets", **kwargs):
    db = get_db_handle(db_name)
    coll = db[collection_name]
    return list(find_many__(coll, filter, projection, **kwargs))
 
-# count with filter
-def count_docs(collection_name, filter: dict, db_name="tickets"):
-   db = get_db_handle(db_name)
-   coll = db[collection_name]
-   return count_docs__(coll, filter)
-
-# count all docs in a collection
-def estimated_count_docs(collection_name, db_name="tickets"):
-   db = get_db_handle(db_name)
-   coll = db[collection_name]
-   return estimated_count_docs__(coll)
-
 # watch changes
 def watch(collection_name, db_name="tickets", **kwargs):
    db = get_db_handle(db_name)

apps/storage/storage.py

@@ -1,10 +1,5 @@
 from uuid import uuid4
 
-# services - async action handlers
-ASYNC_TASKS_RECEIVER_PORT = 8100
-MAIL_RECEIVER_PORT = 8200
-SERVICE_LOCALHOST = 'localhost'
-
 ANTIBOT_JS_CODE_URL = "https://epsf.ticketmaster.com/eps-d"
 TOKEN_INTERROGATION_URL = "https://epsf.ticketmaster.com/eps-d?d=www.ticketmaster.com"
 
@@ -22,39 +17,16 @@ def get_top_picks_url(
     "BEST_AVAILABLE_SEATS": "best-available-seats",
     "BEST_HISTORY_SEATS": "best-history-seats"
 }
-
-SUBSCRIBE_REQUEST_PROPS = {
-    'NAME': 'name',
-    'TARGET_PRICE': 'target_price',
-    'TOLERANCE': 'tolerance',
-    'TICKET_NUM': 'ticket_num',
-    'TM_EVENT_ID': 'tm_event_id'
-}
-
-def filter_obj_from_attrs(obj, atts: dict[str,str]):
-    res = {}
-    for key in atts.values():
-        if key in obj:
-            res[key] = obj[key]
-    return res
-
-
-# metric thresholds
-MINIMUM_HISTORY_DATA = 3
-PERCENT_OF_CHANGE = 0.5
-PERCENTILE_HISTORY_PRICES = 0.25
-ALERT_SEATS_MAX_COUNT = 3
-
 def get_top_picks_header(): return {
     **BASIC_REQ_HEADER,
     "tmps-correlation-id": str(uuid4())
 }
 
-def get_top_picks_query_params(qty: int, target_price: int, tolerance: int): return {
+def get_top_picks_query_params(qty, priceInterval): return {
     'show': 'places maxQuantity sections',
     'mode': 'primary:ppsectionrow resale:ga_areas platinum:all',
     'qty': qty,
-    'q': f"and(not(\'accessible\'),any(listprices,$and(gte(@,{target_price - tolerance}),lte(@,{target_price + tolerance}))))",
+    'q': f"and(not(\'accessible\'),any(listprices,$and(gte(@,{priceInterval[0]}),lte(@,{priceInterval[1]}))))",
     'includeStandard': 'true',
     'includeResale': 'true',
     'includePlatinumInventoryType': 'false',