# Copyright 2025 Lephenixnoir, Dark Storm
#
# Permission is hereby granted, free of charge, to any person obtaining a copy 
# of this software and associated documentation files (the “Software”), to 
# deal in the Software without restriction, including without limitation the 
# rights to use, copy, modify, merge, publish, distribute, sublicense, and/or 
# sell copies of the Software, and to permit persons to whom the Software is 
# furnished to do so, subject to the following conditions:
#
# The above copyright notice and this permission notice shall be included in 
# all copies or substantial portions of the Software.
#
# THE SOFTWARE IS PROVIDED “AS IS”, WITHOUT WARRANTY OF ANY KIND, EXPRESS 
# OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, 
# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE 
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER 
# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
# SOFTWARE.


from flask import Flask, request
import logging, requests, os
import re
import ecoplus 

LOGLEVEL = os.environ.get('LOGLEVEL', 'INFO').upper()
logging.basicConfig(level=LOGLEVEL)

app = Flask(__name__)
session = requests.Session()

def make_url_user(user):
    return f"[url=https://jackywulf.com/git/{user['username']}]{user['username']}[/url]"
def make_url_repository(repository):
    fork = " (fork)" if repository["fork"] else ""
    return f"[url={repository['html_url']}]{repository['name']}{fork}[/url]"

@app.route("/", methods=["GET", "POST"])
def main():
    global session
    data = request.json
    event = request.headers['X-Gitea-Event']
    msg = None

    if data["repository"]["private"] or data["repository"]["mirror"]:
        return "IGN"

    url_repository = make_url_repository(data["repository"])

    if event == "push" and data["commits"] != []:
        # Heuristic to handle pull request merges by detecting default merge message
        RE_MERGE = r"^Merge pull request '(.+)' \(#([0-9]+)\)"#from .* into"
        m = re.match(RE_MERGE, data["commits"][0]["message"])
        if len(data["commits"]) > 1 and m:
            pr_url = data["repository"]["html_url"] + "/pulls/" + m[2]
            pr_url = f"[url={pr_url}]{m[1]}[/url]"
            data["commits"] = data["commits"][1:]
        else:
            pr_url = None

        commits = data["commits"]
        total_commits = data.get("total_commits", len(commits))
        commit_count = f"{total_commits} commit{'s' if total_commits > 1 else ''}"
        message = "[inlinecode]" + commits[0]["message"].split('\n',1)[0] + "[/inlinecode]"

        if total_commits <= 1:
            others = ""
        elif total_commits == 2:
            others = " (et 1 autre commit)"
        else:
            others = f" (et {total_commits-1} autres commits)"

        url_user = make_url_user(data['pusher'])

        # Pull request merge
        if pr_url:
            msg = f"{url_user} a fusionné la PR {pr_url}: {message}{others}"
        # Ref doesn't have a previous commit = new branch
        elif all(c == "0" for c in data["before"]) and data["ref"].startswith("refs/heads/"):
            branch = data["ref"][11:]
            url_branch = data["repository"]["html_url"] + f"/src/branch/{branch}"
            url_branch = f"[url={url_branch}]{branch}[/url]"
            msg = f"{url_user} a créé une nouvelle branche {url_branch} dans {url_repository} : {message}{others}"
        # Pre-existing branch
        else:
            if data["ref"].startswith("refs/heads/"):
                branch = " (branche " + data["ref"][11:] + ")"
            else:
                branch = ""
            url_commits = f"[url={data['compare_url']}]{commit_count}[/url]"
            msg = f"{url_user} a poussé {url_commits} dans {url_repository}{branch} : {message}{others}"

    if event == "push" and data["ref"].startswith("refs/tags/"):
        url_user = make_url_user(data['pusher'])
        tag_name = data["ref"][10:]
        url_tag = data["repository"]["html_url"] + f"/src/tag/{tag_name}"
        url_tag = f"[url={url_tag}]{tag_name}[/url]"

        if all(c == '0' for c in data["before"]):
            msg = f"{url_user} a créé le tag {url_tag} dans {url_repository}"
        else:
            msg = f"{url_user} a mis à jour le tag {url_tag} dans {url_repository}"

    if event == "issues":
        url_user = make_url_user(data['sender'])
        url_issue = f"[url={data['issue']['html_url']}]{data['issue']['title']}[/url]"

        if data['action'] == "closed":
            msg = f"{url_user} a fermé le ticket {url_issue} dans {url_repository}"
        elif data['action'] in ["created", "opened"]:
            msg = f"{url_user} a créé un ticket {url_issue} dans {url_repository}"
        elif data['action'] == "edited":
            msg = f"{url_user} a édité le ticket {url_issue} dans {url_repository}"
        else:
            return "IGN"

    if event == "issue_comment":
        url_user = make_url_user(data['sender'])
        url_issue = f"[url={data['issue']['html_url']}]{data['issue']['title']}[/url]"

        if data['action'] == "created":
            msg = f"{url_user} a répondu au ticket {url_issue} dans {url_repository}"
        else:
            return "IGN"

    if event == "pull_request" and data["action"] == "opened":
        url_user = make_url_user(data["sender"])
        url_pr = f"[url={data['pull_request']['url']}]{data['pull_request']['title']}[/url]"

        msg = f"{url_user} a créé une PR: {url_pr} dans {url_repository}"

    if event == "repository" and data["action"] == "created":
        url_user = make_url_user(data['sender'])
        msg = f"{url_user} a créé un nouveau dépôt {url_repository}"

    if event == "repository" and data["action"] == "deleted":
        return "IGN"

    if event == "push" and all(c == '0' for c in data["after"]):
        return "IGN"

    if event == "push" and not data["ref"].startswith("refs/tags/") \
        and all(c == '0' for c in data["before"]) and data["commits"] == []:
        return "IGN"

    if event == "pull_request" and data["action"] in ["assigned", "closed", "synchronized", "edited"]:
        return "IGN"

    if event == "pull_request_approved" and data["action"] == "reviewed":
        url_user = make_url_user(data['sender'])
        url_pr = f"[url={data['pull_request']['url']}]{data['pull_request']['title']}[/url]"

        msg = f"{url_user} a approuvé la PR {url_pr} dans {url_repository}"

    if event == "pull_request_rejected" and data["action"] == "reviewed":
        url_user = make_url_user(data['sender'])
        url_pr = f"[url={data['pull_request']['url']}]{data['pull_request']['title']}[/url]"

        msg = f"{url_user} a demandé des modifications sur la PR {url_pr} dans {url_repository}"

    if event == "fork":
        return "IGN"

    if event == "create" and data["ref_type"] in ["tag", "branch"]:
        return "IGN"

    if event == "delete":
        return "IGN"

    if event == "release" and data["action"] == "updated":
        return "IGN"

    if not msg:
        msg = f"Événement {event}"
        if "repository" in data:
            msg += " sur " + make_url_repository(data["repository"])
        msg += "."

    if msg:
        msg = f"*{msg}*"
        app.logger.info(msg)
        await forgejo_send_message(msg)

    return "ACK"