tubearchivist/tubearchivist-server
1
0
Fork 0
mirror of https://github.com/tubearchivist/tubearchivist-server.git synced 2024-12-22 18:00:17 +00:00
Code Issues Projects Releases Wiki Activity

implement sync_es task to update bbilly1/tubearchivist-es

Browse Source
This commit is contained in:
simon 2022-07-03 13:11:35 +07:00
parent 79bab9d9fb
commit 87a8fdb7ff
No known key found for this signature in database
GPG Key ID: 2C15AA5E89985DD4
2 changed files with 59 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tubearchivist/web/src/webhook_base.py
View File

@ -24,6 +24,13 @@ class WebhookBase:
"-t", "bbilly1/tubearchivist:unstable",
"-t", "bbilly1/tubearchivist:$VERSION", "--push"
],
"sync_es": [
"docker", "image", "pull", "elasticsearch:$VERSION", "&&",
"docker", "tag", "elasticsearch:$VERSION", "bbilly1/tubearchivist-es", "&&",
"docker", "tag", "elasticsearch:$VERSION", "bbilly1/tubearchivist-es:$VERSION", "&&",
"docker", "push", "bbilly1/tubearchivist-es", "&&",
"docker", "push", "bbilly1/tubearchivist-es:$VERSION"
],
"discord_unstable_hook": environ.get("DOCKER_UNSTABLE_HOOK_URL"),
"discord_release_hook": environ.get("GITHUB_RELEASE_HOOK_URL"),
}

56
tubearchivist/web/src/webhook_github.py
View File

@ -62,7 +62,7 @@ class GithubHook(WebhookBase):
print("commit not on master")
return
self._check_roadmap()
self._check_readme()
build_message = self.check_commit_message()
if not build_message:
@ -85,14 +85,16 @@ class GithubHook(WebhookBase):
first_line = message.split("\n")[0]
return first_line.endswith(self.repo_conf["unstable_keyword"])
def _check_roadmap(self):
"""check if roadmap update needed"""
def _check_readme(self):
"""check readme if roadmap or es update needed"""
modified = [i["modified"] for i in self.hook["commits"]]
for i in modified:
if "README.md" in i:
print("README updated, check roadmap")
RoadmapHook(self.repo_conf, self.ROADMAP_HOOK_URL).update()
break
if "docker-compose.yml" in i:
print("docker-compose updated, check es version")
EsVersionSync(self.repo_conf).run()
def process_release_hook(self):
"""build and process for new release"""
@ -327,6 +329,52 @@ class RoadmapHook:
handler.db_close()
class EsVersionSync:
"""check if bbilly1/tubearchivist-es needs updating"""
REPO = "repos/tubearchivist/tubearchivist"
COMPOSE = f"https://api.github.com/{REPO}/contents/docker-compose.yml"
IMAGE = "bbilly1/tubearchivist-es"
TAGS = f"https://hub.docker.com/v2/repositories/{IMAGE}/tags"
def __init__(self, repo_conf):
self.repo_conf = repo_conf
self.expected = False
self.current = False
def run(self):
"""run check, send task if needed"""
self.get_expected()
self.get_current()
if self.expected == self.current:
print(f"{self.IMAGE} on expected {self.expected}")
else:
print(f"bump {self.IMAGE} {self.current} - {self.expected}")
self.build_task()
def get_expected(self):
"""get expected es version from readme"""
response = requests.get(self.COMPOSE).json()
content = base64.b64decode(response["content"]).decode()
line = [i for i in content.split("\n") if self.IMAGE in i][0]
self.expected = line.split()[-1]
def get_current(self):
"""get current version from docker hub"""
response = requests.get(self.TAGS).json()
all_tags = [i.get("name") for i in response["results"]]
all_tags.pop(0)
all_tags.sort()
self.current = all_tags[-1]
def build_task(self):
"""build task for builder"""
task = TaskHandler(self.repo_conf, tag_name=self.expected)
task.create_task("sync_es")
class RedisBase:
"""connection base for redis"""