Tag helper

container-compose.yml

@@ -211,6 +211,7 @@ services:
         read_only: true
     networks:
       - denis
+      - git
   git:
     build:
       context: git

denis/Containerfile

@@ -21,6 +21,7 @@ FROM alpine:3.20 AS denis
 
 RUN apk add \
 	py3-peewee \
+	py3-gitpython \
 	;
 
 WORKDIR /usr/local/share/denis

denis/final.py

@@ -10,3 +10,5 @@
                         if sub])
 
 print(f'final subs for {assignment} released')
+
+utilities.update_tags(assignment, 'final')

denis/initial.py

@@ -57,3 +57,5 @@
 utilities.release_subs([sub for sub in usernames_to_subs.values() if sub])
 
 print(f'initial subs for {assignment} released')
+
+utilities.update_tags(assignment, 'initial')

denis/peer_review.py

@@ -13,3 +13,6 @@
 utilities.release_subs(ids)
 
 print(f'peer review subs for {assignment} released')
+
+utilities.update_tags(assignment, 'review1')
+utilities.update_tags(assignment, 'review2')

denis/utilities.py

@@ -1,9 +1,16 @@
+import git
 import subprocess
+import tempfile
 
 import orbit.db
 import mailman.db
 
 
+PUSH_URL = 'http://git:8000/cgi-bin/git-receive-pack/grading.git'
+PULL_URL = 'http://git:8000/grading.git'
+REMOTE_NAME = 'grading'
+
+
 def user_to_sub(assignment, component):
     submission_ids = {}
     grd_tbl = mailman.db.Gradeable
@@ -29,3 +36,37 @@ def release_subs(sub_ids):
     subprocess.run(['/usr/local/bin/append_journal',
                     '/var/lib/email/journal/journal'],
                    input=journal_data, check=True)
+
+
+def update_tags(assignment, component):
+    grd_tbl = mailman.db.Gradeable
+    subs = (grd_tbl.select()
+                   .order_by(-grd_tbl.timestamp)
+                   .where(grd_tbl.assignment == assignment)
+                   .where(grd_tbl.component == component))
+    with tempfile.TemporaryDirectory() as repo_path:
+        repo = git.Repo.clone_from(PULL_URL, repo_path)
+        repo.create_remote(REMOTE_NAME, PUSH_URL)
+        repo.config_writer().set_value('user', 'name', 'denis').release()
+        (repo.config_writer().set_value('user', 'email', 'denis@denis')
+                             .release())
+        if 'EMPTY' not in repo.tags:
+            repo.git.commit('--allow-empty', '-m', 'No gradeable submission.')
+            repo.create_tag('EMPTY')
+
+        for user in orbit.db.User.select():
+            new_tag_name = f'{assignment}_{component}_{user.username}'
+            if new_tag_name in repo.tags:
+                print('Potential issue? Attempted to create duplicate tag '
+                      f'{new_tag_name}')
+                continue
+            user_sub = subs.where(grd_tbl.user == user.username).first()
+            if not user_sub:
+                msg = 'No gradeable submission'
+                to_promote = repo.tags['EMPTY']
+            else:
+                msg = user_sub.status
+                to_promote = repo.tags[user_sub.submission_id]
+            repo.create_tag(new_tag_name, ref=to_promote.commit, message=msg)
+
+        repo.git.push(REMOTE_NAME, tags=True)