fixed materialized view

Author: DevAlone

main.py

@@ -1,5 +1,5 @@
 #!/usr/bin/env python3
-
+import materialized_view_updater
 from proxy_py import settings
 from processor import Processor
 from server.proxy_provider_server import ProxyProviderServer
@@ -107,6 +107,7 @@ def main():
         loop.run_until_complete(asyncio.gather(*[
             proxy_processor.worker(),
             statistics.worker(),
+            materialized_view_updater.worker(),
         ]))
         BaseChecker.clean()
     except KeyboardInterrupt:

materialized_view_updater.py

@@ -0,0 +1,17 @@
+import asyncio
+import sys
+
+import peewee
+import peewee_async
+
+from models import db, Proxy, raw_db
+
+
+async def worker():
+    while True:
+        try:
+            raw_db.execute_sql('REFRESH MATERIALIZED VIEW working_proxies')
+            await asyncio.sleep(60)
+        except BaseException as ex:
+            sys.stderr.write(str(ex) + "\n")
+            await asyncio.sleep(60 * 10)

models.py

@@ -7,11 +7,6 @@
     **settings.DATABASE_CONNECTION_KWARGS,
 )
 
-# TODO: make it work
-# raw_db.execute_sql('CREATE EXTENSION IF NOT EXISTS tsm_system_rows;')
-raw_db.execute_sql('''CREATE MATERIALIZED VIEW IF NOT EXISTS working_proxies 
-AS SELECT * FROM proxies WHERE number_of_bad_checks = 0;''')
-
 class Proxy(peewee.Model):
     class Meta:
         database = raw_db
@@ -180,3 +175,9 @@ class Meta:
 ProcessorProxiesQueueSize.create_table(_silent)
 
 db = peewee_async.Manager(raw_db)
+
+# TODO: make it work
+# raw_db.execute_sql('CREATE EXTENSION IF NOT EXISTS tsm_system_rows;')
+raw_db.execute_sql('''CREATE MATERIALIZED VIEW IF NOT EXISTS working_proxies 
+AS SELECT * FROM proxies WHERE number_of_bad_checks = 0;''')
+db.allow_sync()