#!/usr/bin/env python3

#imports
import os
import json
import argparse
from http.server import BaseHTTPRequestHandler, HTTPServer
import urllib.request

def _get_api_response(baseurl, owner, repo):
    ###https://docs.gitea.com/api/1.21/#tag/repository/operation/repoListPullRequests
    ###GET /api/v1/repos/{owner}/{repo}/pulls
    url=(f"https://{baseurl}/api/v1/repos/{owner}/{repo}/pulls?state=open")
    headers={"Accept": "application/json"}
    req=urllib.request.Request(url, headers=headers)
    with urllib.request.urlopen(req) as resp:
        return json.loads(resp.read().decode("utf-8"))

def _parse_response(baseurl, owner, repo):
    target_repo_url=f"https://{baseurl}/{owner}/{repo}.git"
    pulls: dict={}
    response=_get_api_response(baseurl, owner, repo)
    for pr in response:
        pr["target_repo_url"]=target_repo_url
        pulls[str(pr["number"])]=pr
    return pulls

class PullsHandler(BaseHTTPRequestHandler):
    _VALID_PATHS={"/", "/gitea-pulls-sorted.json"}

    # Class variables to store configuration
    baseurl = None
    owner = None
    repo = None

    def do_GET(self):
        if self.path not in self._VALID_PATHS:
            self.send_error(404, "Not Found")
            return

        answer=dict(_parse_response(self.baseurl, self.owner, self.repo))

        body=json.dumps(answer, indent=2, sort_keys=True).encode("utf-8")

        self.send_response(200)
        self.send_header("Content-Type", "application/json; charset=utf-8")
        self.send_header("Content-Length", str(len(body)))
        self.end_headers()
        self.wfile.write(body)

    def log_message(self, fmt, *args):
        print(
            f"[gitea-translator] {self.address_string()} - {fmt % args}",
            flush=True,
        )

def main():
    parser = argparse.ArgumentParser(
        description="Hydra Server to Gitea-pull-request translator"
    )
    parser.add_argument(
        "--baseurl",
        default="git.dynamicdiscord.de",
        help="Base URL of Gitea instance (default: git.dynamicdiscord.de)"
    )
    parser.add_argument(
        "--owner",
        default="malobeo",
        help="Repository owner (default: malobeo)"
    )
    parser.add_argument(
        "--repo",
        default="infrastructure",
        help="Repository name (default: infrastructure)"
    )
    parser.add_argument(
        "--host",
        default="127.0.0.1",
        help="Host to bind to (default: 127.0.0.1)"
    )
    parser.add_argument(
        "--port",
        type=int,
        default=27364,
        help="Port to bind to (default: 27364)"
    )

    args = parser.parse_args()

    # Set class variables so they're accessible in request handlers
    PullsHandler.baseurl = args.baseurl
    PullsHandler.owner = args.owner
    PullsHandler.repo = args.repo

    print(
        f"[gitea-translator] Starting, pulling from {args.baseurl}/{args.owner}/{args.repo}",
        flush=True,
    )
    server=HTTPServer((args.host, args.port), PullsHandler)
    print(
        f"[gitea-translator] online @ {args.host}:{args.port}",
        flush=True,
    )
    server.serve_forever()

if __name__ == "__main__":
    main()