syncing_needed.py 1.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. """
  2. Copyright © 2022 Noah Vogt <noah@noahvogt.com>
  3. This program is free software: you can redistribute it and/or modify
  4. it under the terms of the GNU General Public License as published by
  5. the Free Software Foundation, either version 3 of the License, or
  6. (at your option) any later version.
  7. This program is distributed in the hope that it will be useful,
  8. but WITHOUT ANY WARRANTY; without even the implied warranty of
  9. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  10. GNU General Public License for more details.
  11. You should have received a copy of the GNU General Public License
  12. along with this program. If not, see <http://www.gnu.org/licenses/>.
  13. """
  14. import os
  15. import re
  16. from utils import log
  17. import config as const
  18. def syncing_needed(slidegen) -> bool:
  19. if slidegen.offline_flag_enabled:
  20. log("skipping sync with remote", color="cyan")
  21. return False
  22. if not cachefiles_found():
  23. return True
  24. log("checking for remote changes...")
  25. os.system(
  26. "rclone md5sum {} --checkfile {} > {} 2> {}".format(
  27. const.RCLONE_REMOTE_DIR,
  28. os.path.join(const.SSYNC_CACHE_DIR, const.SSYNC_CHECKFILE_NAMING),
  29. os.devnull,
  30. os.path.join(const.SSYNC_CACHE_DIR, const.SSYNC_CACHEFILE_NAMING),
  31. )
  32. )
  33. with open(
  34. os.path.join(const.SSYNC_CACHE_DIR, const.SSYNC_CACHEFILE_NAMING),
  35. mode="r",
  36. encoding="utf-8",
  37. ) as cachefile_reader:
  38. cachefile_content = cachefile_reader.readlines()
  39. for line in cachefile_content:
  40. if re.search(": ([0-9])+ differences found$", line):
  41. diffs = int(line[line.rfind(":") + 1 : line.find("differences")])
  42. return bool(diffs)
  43. return False
  44. def cachefiles_found() -> bool:
  45. return os.path.isfile(
  46. os.path.join(const.SSYNC_CACHE_DIR, const.SSYNC_CHECKFILE_NAMING)
  47. ) and os.path.isfile(
  48. os.path.join(const.SSYNC_CACHE_DIR, const.SSYNC_CACHEFILE_NAMING)
  49. )