when a gitea issue is created, create the cooresponding github one

bridge/__init__.py

@@ -4,6 +4,7 @@ from flask import redirect
 from flask import abort
 
 import requests
+import base64
 
 app = Flask(__name__)
 app.config.from_envvar('GIT_BRIDGE_SETTINGS')
@@ -184,3 +185,132 @@ def gitea_handle_repo_action():
         abort(500)
 
     return ''
+
+@app.route("/bridge/endpoints/gitea/issue", methods=["POST"])
+def gitea_handle_issue_action():
+    data = request.json
+
+    try:
+        event_type = data["action"]
+
+        repo_owner = data["repository"]["owner"]["login"]
+        repo_name = data["repository"]["name"]
+        issue_user = data["issue"]["user"]["login"]
+        issue_user_url = "https://{}/{}".format(
+            app.config["GITEA_INSTANCE_DOMAIN"],
+            issue_user,
+        )
+        issue_number = data["issue"]["number"]
+
+        if event_type == "opened": # new issue created
+            event_title = data["issue"]["title"]
+            event_body = data["issue"]["body"]
+        elif event_type == "created": # new comment on that issue
+            event_title = None
+            event_body = data["comment"]["body"]
+        elif event_type == "closed": # issue closed
+            event_title = None
+            event_body = data["issue"]["body"]
+
+        event_url = data["issue"]["url"]
+
+    except KeyError as e:
+        print(e, type(e))
+        abort(400) # the data isn't formatted correctly
+
+    """
+        firstly, check if the sentinal is in the issue body
+            - if it is, then stop processing the event
+              (we don't want infinite loops)
+        if we've opened an issue:
+            - create a new one on the Github side
+            - make it relate to the Gitea one
+            - make the Gitea one related to the Github one
+        
+        if we've commented:
+            - add a comment to the cooresponding Github issue
+
+        if we've closed:
+            - add a cooresponding comment and close the Github issue
+    """
+
+    if "GITEA_GITHUB_ISSUE_SYNC_SENTINAL" in event_body:
+        return ''
+
+    if event_type == "opened":
+        issue_header = "*This issue has automatically been created by [`gitea-github-sync`](https://{}/bridge/about) on behalf of [{}]({}).*".format(
+            app.config["GITEA_INSTANCE_DOMAIN"],
+            issue_user,
+            issue_user_url,
+        )
+
+        issue_footer = """
+<details>
+    <summary>Internal issue metadata</summary>
+
+    GITEA_GITHUB_ISSUE_SYNC_SENTINAL {}
+</details>
+        """.format(base64.b64encode(event_url.encode("utf-8")).decode("utf-8"))
+
+        issue_body = "\n\n".join([
+            issue_header,
+            event_body,
+            issue_footer
+        ])
+        
+        github_create_issue_result = requests.post(
+            "https://api.github.com/repos/{}/{}/issues".format(
+                repo_owner,
+                repo_name,
+            ),
+            json={
+                "title": event_title,
+                "body": issue_body,
+            },
+            headers={
+                "Accept": "application/vnd.github+json",
+                "Authorization": "token " + app.config["GITHUB_ACCESS_TOKEN"],
+                "X-GitHub-Api-Version": "2022-11-28",
+            },
+        )
+        
+        try:
+            github_create_issue_result.raise_for_status()
+        except requests.exceptions.HTTPError:
+            abort(500)
+
+        returned_data = github_create_issue_result.json()
+        issue_comment_body = """
+*This issue is being mirrored on Github [here]({}).*
+
+<details>
+    <summary>Internal issue metadata</summary>
+
+    GITEA_GITHUB_ISSUE_SYNC_SENTINEL {}
+</details>
+        """.format(
+            returned_data["html_url"],
+            base64.b64encode(returned_data["url"].encode("utf-8")).decode("utf-8")
+        )
+
+        gitea_issue_comment_result = requests.post(
+            "https://{}/api/v1/repos/{}/{}/issues/{}/comments".format(
+                app.config["GITEA_INSTANCE_DOMAIN"],
+                repo_owner,
+                repo_name,
+                issue_number,
+            ),
+            json={
+                "body": issue_comment_body,
+            },
+            headers={
+                "Authorization": "token " + app.config["GITEA_ACCESS_TOKEN"],
+            },
+        )
+
+        try:
+            gitea_issue_comment_result.raise_for_status()
+        except requests.exceptions.HTTPError:
+            abort(500)
+
+        return ''