process-pr-stats

#!/usr/bin/env python3
from github import Github
from argparse import ArgumentParser
from os.path import exists, expanduser
from os import makedirs, rename, remove
from datetime import datetime
from time import mktime
import re

DIRECTORY_NAME = "data/stats/prs/"

STATES = {
  "pending": "P",
  "approved": "A",
  "rejected": "R",
  "started": "S",
  "hold": "H",
}

POSITIONS = {
  "alca": 0,
  "analysis": 1,
  "db": 2,
  "daq": 3,
  "docs": 4,
  "dqm": 5,
  "core": 6,
  "fastsim": 7,
  "generators": 8,
  "geometry": 9,
  "l1": 10,
  "operations": 11,
  "pdmv": 12,
  "reconstruction": 13,
  "simulation": 14,
  "tests": 15,
  "visualization": 16,
  }

def labelsToState(labels):

  allParts = [x.split("-", 1)
              for x in labels
              if "-" in x]

  validParts = [x
                for x in allParts
                if x[0] in POSITIONS.keys()]


  states = [(STATES[x[1]], POSITIONS[x[0]])
            for x in validParts]

  iniValue = ["N" for i in range(len(POSITIONS))]

  for x in states:
    iniValue[x[1]] = x[0]
  return "".join(iniValue)

if __name__ == "__main__":
  parser = ArgumentParser(usage="%(prog)s <pull-request-id>")
  parser.add_argument("--ignore-issues", dest="ignoreIssues", action="store_true", default=False,
            help="Ignore not Closed issues")
  args = parser.parse_args()

  gh = Github(login_or_token=open(expanduser("~/.github-token")).read().strip())


  if not exists(DIRECTORY_NAME):
    makedirs(DIRECTORY_NAME)

  # This is the header of the files and will force a rewrite of the file
  # if a mismatching is found.
  schema = "Creation,MergeTime,id,isPr,N. of Comments,Closed,N. Labels,author, labelStatus, lastUpdateTime, milestoneTitle"

  # Filenames is <page>.csv so that we can avoid
  # parsing ancient PRs.

  repo = gh.get_organization("cms-sw").get_repo("cmssw")
  iterator = repo.get_issues(sort="created", state="all", direction="asc")

  notClosedPR = []
  notClosedIssue = []
  issueArray = []
  prArray = []
  try:
    with open(DIRECTORY_NAME + "issue.txt", "r") as ins:
      issueArray = [x for x in ins.read().split("\n") if x]
  except IOError as ex:
    pass

  try:
    with open(DIRECTORY_NAME + "pr.txt", "r") as ins:
      prArray = [x for x in ins.read().split("\n") if x]
  except IOError as ex:
    pass

  deleteFiles = args.ignoreIssues and prArray or set(prArray + issueArray)

  for i in deleteFiles:
    try:
      remove(DIRECTORY_NAME + i +".csv")
      print ("removing %s%s.csv" % (DIRECTORY_NAME, i))
    except OSError as ex:
      pass

  # checking if csv file exist
  REnotcomp= re.compile('^\d+,NA,.+')
  for i in range(0, 10000):
    beforeBegin = []
    filename = DIRECTORY_NAME + "%s.csv" % i
    if exists(filename):
      f = open(filename, "r")
      lines = f.read().split("\n")
      f.close()
      if len(lines) != 32:
        print (filename + " is too short.")
      elif lines[0] == schema:
        all_comp = True
        for l in lines:
          if REnotcomp.match(l):
            all_comp = False
            break
        if all_comp:
          print ("%s exists and has the same schema, skipping." % filename)
          continue
    try:
      page = iterator.get_page(i)
    except:
      print ("Page %s does not exists." % i)
      break
    if not len(page):
      break

    # proceesing data if <page>.csv file isn't full
    print ("Processing page %s" % i)
    for issue in page:
      labels = [l.name for l in issue.labels]
      decodedLabels = labelsToState(labels)
      createdAt = int(issue.created_at.strftime("%s"))
      closedAt = issue.closed_at and int(issue.closed_at.strftime("%s")) or "NA"
      isClosed = issue.closed_at and 1 or 0
      isPr = issue.pull_request and 1 or 0
      updateAt = int(mktime(datetime.strptime(str(issue.updated_at), "%Y-%m-%d %H:%M:%S").timetuple()))

      if (issue.milestone is not None):
        milestone = str(issue.milestone.title)
      else:
        milestone = "-"

      if (not isClosed) and (isPr == 1):
        notClosedPR.append(i)
      elif not isClosed:
        notClosedIssue.append(i)
          
      p = [createdAt, closedAt, issue.number, isPr, issue.comments, isClosed, len(labels), issue.user.login, decodedLabels, updateAt, milestone]
      beforeBegin.append(p)

    print ("Saving %s" % filename)
    f = open(filename + ".tmp", "w")
    f.write(schema + "\n")
    for p in beforeBegin:
      l = ",".join(str(x) for x in p) + "\n"
      f.write(l)
    f.close()
    rename(filename + ".tmp", filename)

  notClosedPR = set(notClosedPR)
  notClosedIssue = set(notClosedIssue)

  try:
    with open(DIRECTORY_NAME + "pr.tmp", "w") as f:
      f.write("\n".join(str(x) for x in notClosedPR))
    rename(DIRECTORY_NAME + "pr.tmp", DIRECTORY_NAME + "pr.txt")
  except IOError as ex:
    print ("Something went wrong with %spr.txt file. The reason is %s." % (DIRECTORY_NAME, ex.strerror))

  if args.ignoreIssues:
    notClosedIssue = set(issueArray + notClosedIssue)

  try:
    with open(DIRECTORY_NAME + "issue.tmp", "w") as f:
      f.write("\n".join(str(x) for x in notClosedIssue))
    rename(DIRECTORY_NAME + "issue.tmp", DIRECTORY_NAME + "issue.txt")
  except IOError as ex:
    print ("Something went wrong with %sissue.txt file. The reason is %s." % (DIRECTORY_NAME, ex.strerror))