Update amb-comments.yml

Author: reginankenchor

.github/workflows/amb-comments.yml

@@ -1,28 +1,13 @@
-name: "Ambassador comments (decisions only)"
+name: "Ambassador Accepted: Post + Export"
 
 on:
   workflow_dispatch:
     inputs:
-      private_repo:
-        description: "Private repo containing the CSVs (owner/name)"
+      label_name:
+        description: "Target label"
         required: true
-        default: pytorch-fdn/ambassador-program-management
+        default: Accepted
         type: string
-      private_ref:
-        description: "Branch/tag/sha of the private repo"
-        required: true
-        default: main
-        type: string
-      decision_csv_path:
-        description: "Path to decision CSV (Submission ID, Decision, Candidate)"
-        required: true
-        default: .github/ISSUE_TEMPLATE/dmsap.csv
-        type: string
-      unlock_locked_issues:
-        description: "Temporarily unlock locked issues to post, then re-lock"
-        required: true
-        default: true
-        type: boolean
       dry_run:
         description: "Preview without posting"
         required: true
@@ -33,218 +18,177 @@ permissions:
   contents: read
   issues: write
 
-concurrency:
-  group: ambassador-comments
-  cancel-in-progress: true
-
 jobs:
-  comment:
+  post-and-export:
     runs-on: ubuntu-latest
     steps:
-      - name: Checkout PUBLIC repo
+      - name: Checkout repo
         uses: actions/checkout@v4
 
-      - name: Checkout PRIVATE repo
-        uses: actions/checkout@v4
-        with:
-          repository: ${{ inputs.private_repo }}
-          ref: ${{ inputs.private_ref }}
-          token: ${{ secrets.PRIVATE_REPO_TOKEN }}
-          path: private-src
-
       - name: Set up Python
         uses: actions/setup-python@v5
         with:
           python-version: "3.11"
 
-      - name: Install dependencies
+      - name: Install deps
         run: pip install requests
 
-      - name: Post comments from decision.csv
+      - name: Post message and export CSV
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
           REPO_FULL: ${{ github.repository }}
-          DEC_CSV_ABS: ${{ github.workspace }}/private-src/${{ inputs.decision_csv_path }}
-          UNLOCK_LOCKED: ${{ inputs.unlock_locked_issues }}
+          LABEL_NAME: ${{ inputs.label_name }}
           DRY_RUN: ${{ inputs.dry_run }}
         run: |
           python - <<'PY'
-          import os, csv, re, sys, urllib.parse
-          import requests
+          import os, re, csv, sys, requests
           from requests.adapters import HTTPAdapter, Retry
 
           token = os.getenv("GITHUB_TOKEN")
           repo_full = os.getenv("REPO_FULL")
-          dec_csv = os.getenv("DEC_CSV_ABS")
-          dry_run = (os.getenv("DRY_RUN","false").lower() == "true")
-          UNLOCK_LOCKED = (os.getenv("UNLOCK_LOCKED","false").lower() == "true")
+          label_name = os.getenv("LABEL_NAME","Accepted")
+          dry_run = (os.getenv("DRY_RUN","false").lower()=="true")
 
           if not token or not repo_full:
               print("Missing GITHUB_TOKEN or REPO_FULL", file=sys.stderr); sys.exit(1)
+          owner, repo = repo_full.split("/",1)
 
-          owner, repo = repo_full.split("/", 1)
-
-          # session with retries
           s = requests.Session()
-          retries = Retry(total=8, backoff_factor=0.7,
-                          status_forcelist=[429,500,502,503,504],
-                          allowed_methods=["GET","POST","PATCH","DELETE","HEAD","OPTIONS"])
-          s.mount("https://", HTTPAdapter(max_retries=retries))
-          s.headers.update({"Authorization": f"Bearer {token}",
-                            "Accept": "application/vnd.github+json",
-                            "X-GitHub-Api-Version": "2022-11-28"})
-
-          def norm_key(x): return re.sub(r"[^a-z0-9]+","",(x or "").strip().lower())
-
-          def get_issue_labels(num):
-              r = s.get(f"https://api.github.com/repos/{owner}/{repo}/issues/{num}/labels?per_page=100")
-              if r.status_code==200: return {x["name"] for x in r.json()}
-              print(f"Warn: get labels #{num} failed: {r.status_code} {r.text}"); return set()
-
-          def is_locked(num):
-              r = s.get(f"https://api.github.com/repos/{owner}/{repo}/issues/{num}")
-              if r.status_code == 200:
-                  j = r.json()
-                  return bool(j.get("locked")), j.get("active_lock_reason")
-              print(f"Warn: GET issue #{num} failed: {r.status_code} {r.text}")
-              return False, None
-
-          def unlock_issue(num):
-              if dry_run:
-                  print(f"DRY-RUN: would UNLOCK issue #{num}")
-                  return True
-              r = s.delete(f"https://api.github.com/repos/{owner}/{repo}/issues/{num}/lock")
-              if r.status_code in (200,204):
-                  return True
-              print(f"Warn: UNLOCK failed for #{num}: {r.status_code} {r.text}")
-              return False
-
-          def relock_issue(num, reason):
-              if dry_run:
-                  print(f"DRY-RUN: would RE-LOCK issue #{num} (reason={reason or 'none'})")
-                  return True
-              payload = {"lock_reason": reason} if reason else {}
-              r = s.put(f"https://api.github.com/repos/{owner}/{repo}/issues/{num}/lock", json=payload)
-              if r.status_code in (200,204):
-                  return True
-              print(f"Warn: RE-LOCK failed for #{num}: {r.status_code} {r.text}")
-              return False
-
-          def add_comment_once(num, body, marker):
-              # 1) avoid duplicate comments using hidden marker
-              url = f"https://api.github.com/repos/{owner}/{repo}/issues/{num}/comments?per_page=100"
+          s.headers.update({
+              "Authorization": f"Bearer {token}",
+              "Accept": "application/vnd.github+json",
+              "X-GitHub-Api-Version": "2022-11-28"
+          })
+          s.mount("https://", HTTPAdapter(max_retries=Retry(
+              total=8, backoff_factor=0.7,
+              status_forcelist=[429,500,502,503,504],
+              allowed_methods=["GET","POST","HEAD","OPTIONS"]
+          )))
+
+          MESSAGE_TEMPLATE = """Hello {first_name}
+
+You’ve been invited to join the private **Ambassador Program Management Repository**:
+👉 [pytorch-fdn/ambassador-program-management](https://github.com/pytorch-fdn/ambassador-program-management/)
+
+Once you accept the invitation, you’ll find important information in the discussion thread — including instructions to submit a new issue using the **“Ambassador Confirmation & Details”** template.
+
+To confirm your participation in the 2025 PyTorch Ambassador Program, please open a new issue using the **“Ambassador Confirmation & Details”** template here:
+👉 [Create your confirmation issue](https://github.com/pytorch-fdn/ambassador-program-management/issues/new/choose)
+
+_Completing this step will confirm your role and get you ready for onboarding 🚀_
+
+As part of onboarding, we’ll be hosting a **Kick-Off Call** where we’ll share important program details, expectations, and next steps:
+
+📅 **Date:** Monday, September 8
+🕒 **Time:** 5:30 PM CEST / 8:30 AM PDT
+
+Once you confirm your role, you will also receive a calendar invite with the meeting link.
+
+We’re truly excited to welcome you into the PyTorch Ambassador Program and look forward to the impact you’ll continue to make in the community.
+
+Best regards,
+The PyTorch PMO
+"""
+
+          # ---------- Helpers ----------
+          def get_accepted_open_issues():
+              url = f"https://api.github.com/repos/{owner}/{repo}/issues"
+              params = {"state":"open", "labels":label_name, "per_page":100}
               while url:
-                  r = s.get(url)
-                  if r.status_code!=200:
-                      print(f"Warn: list comments #{num} failed: {r.status_code} {r.text}")
-                      break
-                  if any(marker in (c.get("body") or "") for c in r.json()):
-                      print(f"Skip duplicate comment on #{num}")
-                      return
+                  r = s.get(url, params=params if 'params' in locals() else None)
+                  if r.status_code != 200:
+                      print(f"Failed to list issues: {r.status_code} {r.text}", file=sys.stderr); sys.exit(1)
+                  for it in r.json():
+                      if "pull_request" not in it:
+                          yield it
                   url = r.links.get("next",{}).get("url")
-
-              # 2) try to comment
+                  params = None
+
+          def parse_after_label(body:str, label:str):
+              """
+              Finds the line immediately following a label header block:
+                Label
+                value
+              Returns '' if not found.
+              """
+              pat = rf"{re.escape(label)}\s*\r?\n([^\n\r]+)"
+              m = re.search(pat, body, re.IGNORECASE)
+              return m.group(1).strip() if m else ""
+
+          def extract_fields(issue):
+              body = issue.get("body") or ""
+              nominee_name = parse_after_label(body, "Nominee Name")
+              nominee_email = parse_after_label(body, "Nominee Email")
+              location = parse_after_label(body, "City, State/Province, Country")
+              gh_handle = parse_after_label(body, "Nominee's GitHub or GitLab Handle")
+
+              # Normalize handle: if it's a URL like https://github.com/user -> take last path segment
+              if gh_handle.startswith("http"):
+                  m = re.search(r"github\.com/([^/\s]+)", gh_handle, re.IGNORECASE)
+                  if m:
+                      gh_handle = m.group(1)
+
+              # First name: from nominee_name first token; fallback to profile name; then login
+              first_name = ""
+              if nominee_name:
+                  first_name = nominee_name.split()[0].strip()
+              if not first_name:
+                  user = issue.get("user") or {}
+                  prof_name = (user.get("name") or "").strip()
+                  if prof_name:
+                      first_name = prof_name.split()[0]
+                  else:
+                      first_name = (user.get("login") or "there")
+
+              return {
+                  "issue_number": issue["number"],
+                  "first_name": first_name,
+                  "nominee_name": nominee_name,
+                  "nominee_email": nominee_email,
+                  "location": location,
+                  "github_handle": gh_handle
+              }
+
+          def post_comment(issue_number, body):
               if dry_run:
-                  print(f"DRY-RUN: would comment on #{num}:\n{body}\n---")
+                  print(f"DRY-RUN: would post to #{issue_number}:\n{body[:300]}...\n---")
                   return
-              r = s.post(f"https://api.github.com/repos/{owner}/{repo}/issues/{num}/comments", json={"body": body})
-              if r.status_code in (200,201):
-                  return
-
-              # 3) if locked and allowed, unlock -> comment -> re-lock
-              if r.status_code == 403 and "locked" in (r.text or "").lower():
-                  if not UNLOCK_LOCKED:
-                      print(f"Locked: #{num} (skipping; set UNLOCK_LOCKED=true to unlock temporarily).")
-                      return
-                  locked, reason = is_locked(num)
-                  if not locked:
-                      print(f"Comment 403 but issue #{num} not reported locked; skipping.")
-                      return
-                  if unlock_issue(num):
-                      r2 = s.post(f"https://api.github.com/repos/{owner}/{repo}/issues/{num}/comments", json={"body": body})
-                      if r2.status_code not in (200,201):
-                          print(f"Warn: comment after UNLOCK failed for #{num}: {r2.status_code} {r2.text}")
-                      relock_issue(num, reason)  # re-lock regardless
-                  return
-
-              # 4) other failures
-              print(f"Warn: comment #{num} failed: {r.status_code} {r.text}")
-
-          # messages + markers
-          ACCEPT_MARKER = "<!-- ambassador-decision:accepted-2025 -->"
-          REJECT_MARKER = "<!-- ambassador-decision:rejected-2025 -->"
-
-          ACCEPT_MSG = (
-            "Hello {name},\n\n"
-            "Congratulations! 🎉 We're excited to inform you that you have been selected as a 2025 PyTorch Ambassador. "
-            "Your contributions, impact, and commitment to the PyTorch community stood out during the review process.\n\n"
-            "You should also have received an invitation to join our private program management repository, "
-            "where onboarding details and next steps will be shared. If you do not see the invite, please comment here and we will assist you.\n\n"
-            "Best regards,\n"
-            "The PyTorch PMO\n\n" + ACCEPT_MARKER
-          )
-          REJECT_MSG = (
-            "Hello {name},\n\n"
-            "Thank you for applying to the 2025 PyTorch Ambassador Program and for the valuable contributions you make in the PyTorch community. "
-            "After careful consideration, we regret to inform you that your application was not selected in this cycle.\n\n"
-            "We encourage you to apply again in the future — the next application cycle will open in early 2026. "
-            "Please keep an eye on our website for updates on the timeline: https://pytorch.org/programs/ambassadors/\n\n"
-            "We truly appreciate the time, effort, and passion you bring to the PyTorch community, and we hope to see your application again in the future.\n\n"
-            "If you have any questions in the meantime, please feel free to reach out to us at [email protected].\n\n"
-            "Best regards,\n"
-            "The PyTorch PMO\n\n" + REJECT_MARKER
-          )
-
-          # ---- Iterate decision.csv rows and post per-row messages with Candidate name ----
-          counts={"rows":0,"accept_commented":0,"reject_commented":0,"skipped":0}
-          try:
-              with open(dec_csv, newline="", encoding="utf-8") as f:
-                  rdr = csv.DictReader(f)
-                  hdr = {norm_key(h): h for h in (rdr.fieldnames or [])}
-                  sid_key = hdr.get("submissionid") or hdr.get("issue") or hdr.get("issuenumber") or hdr.get("id")
-                  decision_key = hdr.get("decision")
-                  name_key = hdr.get("candidate")
-                  if not sid_key or not decision_key or not name_key:
-                      print("decision.csv must contain 'Submission ID', 'Decision', and 'Candidate' columns.", file=sys.stderr); sys.exit(1)
-
-                  for idx,row in enumerate(rdr, start=2):
-                      counts["rows"] += 1
-                      raw_id = (row.get(sid_key) or "").strip()
-                      decision_raw = (row.get(decision_key) or "").strip().lower()
-                      candidate = (row.get(name_key) or "").strip() or "there"
-
-                      if not raw_id:
-                          counts["skipped"] += 1; continue
-                      try:
-                          num = int(float(raw_id))
-                      except:
-                          print(f"Row {idx}: invalid Submission ID '{raw_id}'; skipping.")
-                          counts["skipped"] += 1; continue
-
-                      labels = get_issue_labels(num)
-
-                      if decision_raw in ("accept","accepted","approve","approved"):
-                          if "Accepted" in labels:
-                              add_comment_once(num, ACCEPT_MSG.format(name=candidate), ACCEPT_MARKER)
-                              counts["accept_commented"] += 1
-                          else:
-                              print(f"Row {idx}: issue #{num} lacks 'Accepted' label; skipping.")
-                              counts["skipped"] += 1
-
-                      elif decision_raw in ("reject","rejected","decline","declined"):
-                          if "Rejected" in labels:
-                              add_comment_once(num, REJECT_MSG.format(name=candidate), REJECT_MARKER)
-                              counts["reject_commented"] += 1
-                          else:
-                              print(f"Row {idx}: issue #{num} lacks 'Rejected' label; skipping.")
-                              counts["skipped"] += 1
-                      else:
-                          print(f"Row {idx}: unknown decision '{decision_raw}'; skipping.")
-                          counts["skipped"] += 1
-          except FileNotFoundError:
-              print(f"decision.csv not found at: {dec_csv}", file=sys.stderr); sys.exit(1)
-
-          print(f"Decisions: accept_commented={counts['accept_commented']}, reject_commented={counts['reject_commented']}, skipped={counts['skipped']} (rows={counts['rows']})")
-          if dry_run: print("DRY-RUN complete (no changes were made).")
+              r = s.post(
+                  f"https://api.github.com/repos/{owner}/{repo}/issues/{issue_number}/comments",
+                  json={"body": body}
+              )
+              if r.status_code not in (200,201):
+                  print(f"Failed to comment on #{issue_number}: {r.status_code} {r.text}", file=sys.stderr)
+
+          # ---------- Process ----------
+          rows = []
+          count = 0
+          for issue in get_accepted_open_issues():
+              data = extract_fields(issue)
+              msg = MESSAGE_TEMPLATE.format(first_name=data["first_name"])
+              post_comment(data["issue_number"], msg)
+              count += 1
+              rows.append([
+                  data["issue_number"],
+                  data["nominee_name"],
+                  data["nominee_email"],
+                  data["location"],
+                  data["github_handle"]
+              ])
+
+          # Export CSV
+          out = "accepted_export.csv"
+          with open(out, "w", newline="", encoding="utf-8") as f:
+              w = csv.writer(f)
+              w.writerow(["Issue", "Nominee Name", "Nominee Email", "Location", "GitHub Handle"])
+              w.writerows(rows)
+
+          print(f"Posted to {count} accepted issue(s).")
+          print(f"Exported {len(rows)} row(s) -> {out}")
           PY
 
+      - name: Upload export artifact
+        uses: actions/upload-artifact@v4
+        with:
+          name: accepted_export
+          path: accepted_export.csv