Fix all black errors

Author: bnmnetp

bases/rsptx/admin_server_api/routers/instructor.py

@@ -1256,7 +1256,7 @@ async def post_create_course_page(
         # if invoice is true then we need to create an invoice for the course
         if invoice == "true":
             res = await create_invoice_request(
-                user.username, projectname, 0.0,  user.email
+                user.username, projectname, 0.0, user.email
             )
         # Copy attributes from base course
         bc = await fetch_course(coursetype)

bases/rsptx/assignment_server_api/routers/assignment_summary.py

@@ -141,9 +141,11 @@ def create_assignment_summary(assignment_id, course, dburl):
     ]
     try:
         merged.iloc[0, 3:] = merged.iloc[0, 3:].apply(
-            lambda x: "{:.2f}".format(float(x.split("(")[0]))
-            if type(x) is str and "(" in x
-            else "{:.2f}".format(float(x))
+            lambda x: (
+                "{:.2f}".format(float(x.split("(")[0]))
+                if type(x) is str and "(" in x
+                else "{:.2f}".format(float(x))
+            )
         )
     except Exception as e:
         print(

bases/rsptx/assignment_server_api/routers/student.py

@@ -110,15 +110,19 @@ def sort_key(assignment):
         deadline = assignment.duedate
         if timezoneoffset:
             deadline = deadline + datetime.timedelta(hours=float(timezoneoffset))
-            return (deadline < canonical_utcnow(), abs((deadline - canonical_utcnow()).total_seconds()))
+            return (
+                deadline < canonical_utcnow(),
+                abs((deadline - canonical_utcnow()).total_seconds()),
+            )
         else:
-            return (assignment.duedate < canonical_utcnow(), abs((assignment.duedate - canonical_utcnow()).total_seconds()))    
+            return (
+                assignment.duedate < canonical_utcnow(),
+                abs((assignment.duedate - canonical_utcnow()).total_seconds()),
+            )
 
     # Sort assignments: upcoming assignments first (closest to current date), past due assignments last
     now = canonical_utcnow()
-    assignments.sort(
-        key=sort_key
-    )
+    assignments.sort(key=sort_key)
     stats_list = await fetch_all_assignment_stats(course.course_name, user.id)
     stats = {}
     for s in stats_list:

bases/rsptx/book_server_api/routers/course.py

@@ -116,9 +116,7 @@ def sort_key(assignment):
             )
 
     now = canonical_utcnow()
-    assignments.sort(
-        key=sort_key
-    )
+    assignments.sort(key=sort_key)
 
     stats_list = await fetch_all_assignment_stats(course_name, user.id)
     stats = {}

bases/rsptx/book_server_api/routers/personalized_parsons/end_to_end.py

@@ -138,10 +138,10 @@ def request_fixed_code_from_openai(
         old_fixed_code=old_fixed_code,
     )
     unittest_result, cleaned_fixed_code = unittest_evaluation(
-        language, 
-        fixed_code, 
-        default_start_code, 
-        default_test_code, 
+        language,
+        fixed_code,
+        default_start_code,
+        default_test_code,
         unittest_code,
     )
 

bases/rsptx/book_server_api/routers/personalized_parsons/evaluate_fixed_code.py

@@ -31,14 +31,17 @@ class TimeoutError(Exception):
 def handler(signum, frame):
     raise TimeoutError("Test execution exceeded time limit")
 
+
 def _runestone_file_id(filename: str, content: str) -> str:
     # Exactly: "runestone" + MD5(fileName + fileContent)
     md5 = hashlib.md5((filename + content).encode("utf-8")).hexdigest()
     return "runestone" + md5
 
+
 def _b64_text_utf8(s: str) -> str:
     return base64.b64encode(s.encode("utf-8")).decode("ascii")
 
+
 def _jobe_session():
     s = rq.Session()
     s.headers["Content-type"] = "application/json; charset=utf-8"
@@ -48,7 +51,9 @@ def _jobe_session():
     return s
 
 
-def _ensure_file_on_jobe(sess: rq.Session, base_host: str, file_id: str, content: str) -> None:
+def _ensure_file_on_jobe(
+    sess: rq.Session, base_host: str, file_id: str, content: str
+) -> None:
     """
     Mirrors JS logic:
       - HEAD /jobeCheckFile/<id>
@@ -64,7 +69,9 @@ def _ensure_file_on_jobe(sess: rq.Session, base_host: str, file_id: str, content
         return  # already there
 
     if r.status_code not in (404, 208):
-        raise RuntimeError(f"Unexpected HEAD status from JOBE checkFile: {r.status_code} {r.text[:300]}")
+        raise RuntimeError(
+            f"Unexpected HEAD status from JOBE checkFile: {r.status_code} {r.text[:300]}"
+        )
 
     put_url = base_host + PUSH_PROXY + file_id
     payload = {"file_contents": _b64_text_utf8(content)}
@@ -75,12 +82,16 @@ def _ensure_file_on_jobe(sess: rq.Session, base_host: str, file_id: str, content
         timeout=10,
     )
     if pr.status_code != 204:
-        raise RuntimeError(f"Failed to push file to JOBE: {pr.status_code} {pr.text[:300]}")
+        raise RuntimeError(
+            f"Failed to push file to JOBE: {pr.status_code} {pr.text[:300]}"
+        )
+
 
 # Match what the JS client uses
 PUSH_PROXY = "/ns/rsproxy/jobePushFile/"
 CHECK_PROXY = "/ns/rsproxy/jobeCheckFile/"
 
+
 def inject_pass_fail_prints(test_code):
     """
     Inserts System.out.println("PASS") before System.exit(0)
@@ -96,19 +107,20 @@ def inject_pass_fail_prints(test_code):
         test_code = re.sub(
             r"(TestHelper\.runAllTests\(\);\s*)(System\.exit\(0\);)",
             r'\1System.out.println("PASS");\n            \2',
-            test_code
+            test_code,
         )
 
     # Insert FAIL prints before System.exit(1) inside catch(Exception e)
     if 'System.out.println("FAIL")' not in test_code:
         test_code = re.sub(
             r"(catch\s*\(\s*Exception\s+e\s*\)\s*\{\s*)(System\.exit\(1\);)",
             r'\1System.out.println("FAIL");\n            System.out.println(e.getMessage());\n            \2',
-            test_code
+            test_code,
         )
 
     return test_code
 
+
 # modified from rsproxy.py and livecode.js logic
 def load_and_run_java_tests(java_code, test_code):
     """
@@ -126,7 +138,7 @@ def extract_class_name(code):
             return match.group(1)
         else:
             raise ValueError("Could not find a public class declaration.")
-    
+
     test_code = inject_pass_fail_prints(test_code)
     print("modified_test_code\n", test_code)
     student_class = extract_class_name(java_code)
@@ -135,12 +147,20 @@ def extract_class_name(code):
     student_filename = f"{student_class}.java"
     test_filename = f"{test_class}.java"
 
-    # Runestone-style file ids: "runestone" + md5(filename + content) 
-    student_id = "runestone" + hashlib.md5((student_filename + java_code).encode("utf-8")).hexdigest()
-    test_id = "runestone" + hashlib.md5((test_filename + test_code).encode("utf-8")).hexdigest()
+    # Runestone-style file ids: "runestone" + md5(filename + content)
+    student_id = (
+        "runestone"
+        + hashlib.md5((student_filename + java_code).encode("utf-8")).hexdigest()
+    )
+    test_id = (
+        "runestone"
+        + hashlib.md5((test_filename + test_code).encode("utf-8")).hexdigest()
+    )
 
     runs_url = settings.jobe_server + "/jobe/index.php/restapi/runs/"
-    student_file_url = settings.jobe_server + "/jobe/index.php/restapi/files/" + student_id
+    student_file_url = (
+        settings.jobe_server + "/jobe/index.php/restapi/files/" + student_id
+    )
     test_file_url = settings.jobe_server + "/jobe/index.php/restapi/files/" + test_id
 
     sess = rq.Session()
@@ -157,15 +177,25 @@ def extract_class_name(code):
         r = sess.head(student_file_url, timeout=10)
         if r.status_code != 204:
             # if not found (typically 404), push it
-            put = sess.put(student_file_url, json={"file_contents": student_b64}, timeout=10)
+            put = sess.put(
+                student_file_url, json={"file_contents": student_b64}, timeout=10
+            )
             if put.status_code != 204:
-                return False, {"error": "Failed to push student file", "status": put.status_code, "body": put.text[:500]}
+                return False, {
+                    "error": "Failed to push student file",
+                    "status": put.status_code,
+                    "body": put.text[:500],
+                }
 
         r = sess.head(test_file_url, timeout=10)
         if r.status_code != 204:
             put = sess.put(test_file_url, json={"file_contents": test_b64}, timeout=10)
             if put.status_code != 204:
-                return False, {"error": "Failed to push test file", "status": put.status_code, "body": put.text[:500]}
+                return False, {
+                    "error": "Failed to push test file",
+                    "status": put.status_code,
+                    "body": put.text[:500],
+                }
 
         # JOBE runs this, and it calls test class main()
         runner_code = f"""public class TestRunner {{
@@ -190,7 +220,11 @@ def extract_class_name(code):
         try:
             result = resp.json()
         except Exception:
-            return False, {"error": "Non-JSON JOBE response", "status": resp.status_code, "body": resp.text[:800]}
+            return False, {
+                "error": "Non-JSON JOBE response",
+                "status": resp.status_code,
+                "body": resp.text[:800],
+            }
 
         out = (result.get("stdout") or "").strip()
         passed = (result.get("outcome") == 15) and out.startswith("PASS")
@@ -199,6 +233,7 @@ def extract_class_name(code):
     except Exception:
         return False
 
+
 def load_and_run_tests(unittest_case, code_to_test, time_limit=6):
     """
     Load and run Python test cases against the provided code.

bases/rsptx/rsmanage/core.py

@@ -312,7 +312,9 @@ async def addcourse(
         basecourse = click.prompt("Base Course: ")
     bookrec = await fetch_library_book(basecourse)
     if not bookrec:
-        click.echo(f"{basecourse} Not Found: Please add the book first using `addbookauthor")
+        click.echo(
+            f"{basecourse} Not Found: Please add the book first using `addbookauthor"
+        )
         exit(1)
     if bookrec and bookrec.build_system is None:
         click.echo(
@@ -955,7 +957,9 @@ def grade(config, course, pset, enforce):
 )
 @click.option("--sample_size", help="Number of courses to sample", default=0)
 @click.option("--course_list", help="List of courses to sample", default=None)
-@click.option("--preserve_user_ids", is_flag=True, help="Preserve user ids in the datashop export")
+@click.option(
+    "--preserve_user_ids", is_flag=True, help="Preserve user ids in the datashop export"
+)
 @pass_config
 async def datashop(config, basecourse, sample_size, course_list, preserve_user_ids):
     """Export the course data to the datashop format"""

components/rsptx/build_tools/add_github_links.py

@@ -4,7 +4,9 @@
 from pathlib import Path
 
 
-def build_github_url(owner: str, repo: str, branch: str, root: Path, file_path: Path, line: int | None) -> str:
+def build_github_url(
+    owner: str, repo: str, branch: str, root: Path, file_path: Path, line: int | None
+) -> str:
     # "root" should be the repository root; we build a URL
     # relative to that so it matches the layout on GitHub.
     rel = file_path.relative_to(root).as_posix()
@@ -41,7 +43,9 @@ def find_exercise_open_line(lines: list[str], close_index: int) -> int | None:
     return None
 
 
-def process_file(path: Path, root: Path, owner: str, repo: str, branch: str, dry_run: bool) -> int:
+def process_file(
+    path: Path, root: Path, owner: str, repo: str, branch: str, dry_run: bool
+) -> int:
     text = path.read_text(encoding="utf-8")
     lines = text.splitlines(keepends=True)
 
@@ -93,7 +97,11 @@ def process_file(path: Path, root: Path, owner: str, repo: str, branch: str, dry
 
     # Build fast lookup tables for rewriting.
     close_to_ex = {e["close_idx"]: e for e in exercises}
-    url_to_ex = {e["existing_url_index"]: e for e in exercises if e["existing_url_index"] is not None}
+    url_to_ex = {
+        e["existing_url_index"]: e
+        for e in exercises
+        if e["existing_url_index"] is not None
+    }
 
     # Third pass: rebuild the file contents with corrected URLs and without
     # counting our local-only <url> lines toward GitHub line numbers.
@@ -119,8 +127,12 @@ def process_file(path: Path, root: Path, owner: str, repo: str, branch: str, dry
                 newline = "\r\n"
 
             exercise_line_number = ex["exercise_line_number"]
-            github_url = build_github_url(owner, repo, branch, root, path, exercise_line_number)
-            url_line = f'{indent}<url href="{github_url}">Source on GitHub</url>{newline}'
+            github_url = build_github_url(
+                owner, repo, branch, root, path, exercise_line_number
+            )
+            url_line = (
+                f'{indent}<url href="{github_url}">Source on GitHub</url>{newline}'
+            )
 
             new_lines.append(url_line)
 
@@ -167,7 +179,7 @@ def main():
         "--file",
         type=str,
         help="Single XML file to process (relative to --root or absolute). "
-             "If omitted, all XML files under --root are processed.",
+        "If omitted, all XML files under --root are processed.",
     )
     parser.add_argument(
         "--dry-run",
@@ -188,10 +200,14 @@ def main():
         if target.suffix != ".xml":
             print(f"Warning: file does not have .xml suffix: {target}")
 
-        inserts = process_file(target, root, args.owner, args.repo, args.branch, args.dry_run)
+        inserts = process_file(
+            target, root, args.owner, args.repo, args.branch, args.dry_run
+        )
         prefix = "[DRY-RUN] " if args.dry_run else ""
         print(f"{prefix}Updated {target}: added {inserts} <url> tag(s)")
-        print(f"Done. Files changed: {1 if inserts else 0}, <url> tags added: {inserts}")
+        print(
+            f"Done. Files changed: {1 if inserts else 0}, <url> tags added: {inserts}"
+        )
         return
 
     # No --file: process all XML files under root
@@ -208,10 +224,12 @@ def main():
             if inserts:
                 total_files += 1
                 total_inserts += inserts
-                print(f"{'[DRY-RUN] ' if args.dry_run else ''}Updated {fpath}: added {inserts} <url> tag(s)")
+                print(
+                    f"{'[DRY-RUN] ' if args.dry_run else ''}Updated {fpath}: added {inserts} <url> tag(s)"
+                )
 
     print(f"Done. Files changed: {total_files}, <url> tags added: {total_inserts}")
 
 
 if __name__ == "__main__":
-    main()
+    main()

components/rsptx/build_tools/build.py

@@ -894,7 +894,8 @@ def dev(ctx, config):
     ctx.invoke(image)
     ctx.invoke(restart)
 
-# This command should be used when you pull new code from github and want to rebuild and make 
+
+# This command should be used when you pull new code from github and want to rebuild and make
 # sure you are using the latest database schema.  Many people forget to run migrations
 # after pulling new code.
 @cli.command()