Method _github_osgint_enrich

IntelOSINT.py:17326–17440

(self, username, user_data=None)

        return out

    def _github_osgint_enrich(self, username, user_data=None):
        info = {"OSGINT": "Arricchimento GitHub attivo"}
        emails = set()
        repos_checked = []
        try:
            headers = {"User-Agent": "IntelOSINT-OSGINT"}
            token = os.environ.get("GITHUB_TOKEN") or os.environ.get("GH_TOKEN")
            if token:
                headers["Authorization"] = f"Bearer {token}"

            if isinstance(user_data, dict) and user_data.get("email"):
                emails.add(str(user_data.get("email")))

            try:
                events_url = f"https://api.github.com/users/{urllib.parse.quote(username)}/events/public?per_page=100"
                er = requests.get(events_url, headers=headers, timeout=10)
                events = er.json() if er.status_code == 200 else []
                if isinstance(events, list):
                    for ev in events:
                        payload = (ev or {}).get("payload") or {}
                        commits = payload.get("commits") or []
                        if not isinstance(commits, list):
                            continue
                        for c in commits:
                            author = (c or {}).get("author") or {}
                            em = str(author.get("email") or "").strip()
                            if em and "@" in em and "noreply.github.com" not in em:
                                emails.add(em)
            except Exception:
                pass

            repos_url = f"https://api.github.com/users/{urllib.parse.quote(username)}/repos?per_page=30&sort=pushed&type=owner"
            repos_r = requests.get(repos_url, headers=headers, timeout=10)
            repos = repos_r.json() if repos_r.status_code == 200 else []
            if isinstance(repos, list):
                for repo in repos:
                    if len(repos_checked) >= 10:
                        break
                    if not isinstance(repo, dict) or repo.get("fork"):
                        continue
                    name = repo.get("name")
                    if not name:
                        continue
                    repos_checked.append(str(name))
                    try:
                        commits_url = f"https://api.github.com/repos/{urllib.parse.quote(username)}/{urllib.parse.quote(str(name))}/commits?author={urllib.parse.quote(username)}&per_page=3"
                        cr = requests.get(commits_url, headers=headers, timeout=8)
                        if cr.status_code != 200:
                            continue
                        commits = cr.json()
                        if not isinstance(commits, list):
                            continue
                        for commit in commits[:3]:
                            c = (commit or {}).get("commit") or {}
                            for who in ("author", "committer"):
                                em = ((c.get(who) or {}).get("email") or "").strip()
                                if em and "@" in em and "noreply.github.com" not in em:
                                    emails.add(em)