66 lines
2.0 KiB
Python
66 lines
2.0 KiB
Python
import argparse
|
|
import subprocess
|
|
|
|
from src.logger import logger as l
|
|
import datetime as dt
|
|
import subprocess as proc
|
|
from scheduler import Scheduler
|
|
import time
|
|
from time import localtime, strftime
|
|
|
|
delta = dt.timedelta(hours=3)
|
|
tz_msk = dt.timezone(offset=delta, name="MSK")
|
|
|
|
logger = l.getChild(__name__)
|
|
logger.info("Starting")
|
|
|
|
parser = argparse.ArgumentParser(__name__)
|
|
parser.add_argument("-w", "--watch", required=True, help="Directory to watch")
|
|
args = parser.parse_args()
|
|
|
|
directory = args.watch
|
|
|
|
if directory is None:
|
|
exit(-1)
|
|
|
|
logger.info(f"Directory to watch: {directory}")
|
|
|
|
|
|
def c(command: str) -> list[str]:
|
|
return command.split(" ")
|
|
|
|
def _watcher() -> None:
|
|
logger.info("Starting to watch")
|
|
g_status = proc.check_output(c("git status -s"), cwd=directory)
|
|
output = ''
|
|
if len(g_status) > 0:
|
|
logger.info("Changes found")
|
|
output += "\n{}".format(proc.run(c("git add ."), cwd=directory, stderr=subprocess.STDOUT))
|
|
now = strftime("%Y-%m-%dT%H:%M:%S", localtime())
|
|
output += "\n{}".format(proc.run(c(f"git commit -m '{now}'"), cwd=directory, stderr=subprocess.STDOUT))
|
|
output += "\n{}".format(proc.run(c("git fetch"), cwd=directory))
|
|
try:
|
|
out = proc.run(c("git rebase"), cwd=directory, stderr=subprocess.STDOUT)
|
|
output += "\n{}".format(out)
|
|
except subprocess.SubprocessError as ex:
|
|
output += "\n{}".format(ex.output)
|
|
if ex.output.find('--skip') > 0:
|
|
proc.run(c("git rebase --skip"), stderr=subprocess.STDOUT)
|
|
else:
|
|
logger.error("Unexpected output")
|
|
output += "\n{}".format(proc.run(c("git push"), cwd=directory))
|
|
else:
|
|
output += "\n{}".format(proc.run(c("git pull"), cwd=directory, stderr=subprocess.STDOUT))
|
|
logger.info(output)
|
|
logger.info("Done")
|
|
|
|
|
|
|
|
schedule = Scheduler()
|
|
schedule.cyclic(dt.timedelta(seconds=10), _watcher)
|
|
|
|
print(schedule)
|
|
|
|
while True:
|
|
schedule.exec_jobs()
|
|
time.sleep(1) |