# By Alex Monk. As of writing, dies around offset 42k due to a server-side timeout.
import json, subprocess
def getAll(arcArgs, params = {}, limit = 1000, offset = 0):
print("Offset " + str(offset))
proc = subprocess.Popen(arcArgs, stdin = subprocess.PIPE, stdout = subprocess.PIPE)
resultOut, resultErr = proc.communicate(input = json.dumps(dict(params, limit = limit, offset = offset)))
dataOut = json.loads(resultOut.strip())['response']
if 'data' in dataOut:
items = dataOut['data'].values()
elif isinstance(dataOut, dict):
items = dataOut.values()
elif isinstance(dataOut, list):
items = dataOut
for item in items:
yield item
if len(items) == limit:
for item in getAll(arcArgs, params = params, limit = limit, offset = offset + limit):
yield item
arcCommand = ['arc', 'call-conduit', '--conduit-uri', 'https://phabricator.wikimedia.org/']
# Security: PHID-PROJ-koo4qqdng27q7r65x3cw
# WMF-NDA: PHID-PROJ-ibxm3v6ithf3jpqpqhl7
# {'projectPHIDs': ['PHID-PROJ-somethingsomethingsomething']}
for task in getAll(arcCommand + ['maniphest.query'], {}, limit = 1000):
for ccPHID in task['ccPHIDs']:
if 'PROJ' in ccPHID:
print('https://phabricator.wikimedia.org/T' + task['id'] + ' - ' + ccPHID + ' - ' + task['title'])
break