fix missing await

nostr_dvm/tasks/content_discovery_currently_latest_longform.py

@@ -96,7 +96,7 @@ class DicoverContentLatestLongForm(DVMTaskInterface):
     async def process(self, request_form):
         # if the dvm supports individual results, recalculate it every time for the request
         if self.personalized:
-            return self.calculate_result(request_form)
+            return await self.calculate_result(request_form)
         # else return the result that gets updated once every scheduled update. In this case on database update.
         else:
             return self.result

nostr_dvm/tasks/content_discovery_currently_popular.py

@@ -98,7 +98,7 @@ class DicoverContentCurrentlyPopular(DVMTaskInterface):
     async def process(self, request_form):
         # if the dvm supports individual results, recalculate it every time for the request
         if self.personalized:
-            return self.calculate_result(request_form)
+            return await self.calculate_result(request_form)
         # else return the result that gets updated once every scheduled update. In this case on database update.
         else:
             return self.result

nostr_dvm/tasks/content_discovery_currently_popular_by_top_zaps.py

@@ -98,7 +98,7 @@ class DicoverContentCurrentlyPopularZaps(DVMTaskInterface):
     async def process(self, request_form):
         # if the dvm supports individual results, recalculate it every time for the request
         if self.personalized:
-            return self.calculate_result(request_form)
+            return await self.calculate_result(request_form)
         # else return the result that gets updated once every scheduled update. In this case on database update.
         else:
             return self.result

nostr_dvm/utils/nostr_utils.py

@@ -42,7 +42,7 @@ def get_event_by_id(event_id: str, client: Client, config=None) -> Event | None:
         return None
 
 async def get_events_async(client, filter, timeout):
-    events = client.get_events_of([filter], timedelta(seconds=timeout))
+    events = await client.get_events_of([filter], timedelta(seconds=timeout))
     return events
 
 

setup.py

@@ -1,6 +1,6 @@
 from setuptools import setup, find_packages
 
-VERSION = '0.6.6'
+VERSION = '0.6.7'
 DESCRIPTION = 'A framework to build and run Nostr NIP90 Data Vending Machines'
 LONG_DESCRIPTION = ('A framework to build and run Nostr NIP90 Data Vending Machines. See the github repository for more information')