From d8716b71e2094952325024e974772084816ce257 Mon Sep 17 00:00:00 2001
From: Roman Timashev <roman@tmshv.ru>
Date: Mon, 5 Aug 2019 18:24:12 +0300
Subject: [PATCH] [Sync] added sync-smart (unstable)

---
 utils/Sync/sync-smart.py | 50 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 50 insertions(+)
 create mode 100644 utils/Sync/sync-smart.py

diff --git a/utils/Sync/sync-smart.py b/utils/Sync/sync-smart.py
new file mode 100644
index 00000000..d7686198
--- /dev/null
+++ b/utils/Sync/sync-smart.py
@@ -0,0 +1,50 @@
+import settings
+from sync.data.fs import FSProvider
+from sync.data.yandexdisk import YDProvider
+
+import asyncio
+
+
+async def run_check(run_interval=0):
+    run_interval = 1
+
+    from yandexdisk import YDClient
+    client = YDClient(settings.yandex_disk_access_token)
+
+    async def need_to_update():
+        res = client.last_uploaded()
+        items = res['items']
+        paths = [i['path'] for i in items]
+
+        for i in paths:
+            if i.startswith('disk:/Hudozka/Site'):
+                return True
+
+        return False
+
+    while True:
+        status = await need_to_update()
+        if status:
+            print('DO SYNC')
+            # await run(0)
+
+        if run_interval == 0:
+            break
+        else:
+            await asyncio.sleep(run_interval)
+
+
+def get_provider(provider_type, root):
+    if provider_type == 'fs':
+        return FSProvider(root)
+    elif provider_type == 'yd':
+        return YDProvider(root, settings.yandex_disk_access_token)
+    return None
+
+
+if __name__ == '__main__':
+    interval = settings.interval
+
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(run_check(interval))
+    loop.close()