reportData["isFirstTimeUser"] = isFirstTimeUser(event)
  reportData["paymentLinkClicked"] = giveAgainPayNowClicked(event)
  reportData["profileChangeMade"] = profileChangeMade(event)
  reportData["feedbackSubmitted"] = feedbackSubmitted(event)

from multiprocessing import Process, Pipe

def doProspectReport(event, context):
  reportData = {'crmId': event["crmId"], 'username': event["username"], 'logincount': event["logincount"] }
  processes = []

  parent_conn1, child_conn1 = Pipe()
  parent_conn2, child_conn2 = Pipe()
  parent_conn3, child_conn3 = Pipe()
  parent_conn4, child_conn4 = Pipe()

  processes.append(Process(target=isFirstTimeUser,    args=(event, child_conn1,)))
  processes.append(Process(target=paymentLinkClicked, args=(event, child_conn2,)))
  processes.append(Process(target=profileChangeMade,  args=(event, child_conn3,)))
  processes.append(Process(target=feedbackSubmitted,  args=(event, child_conn4,)))

  for p in processes:
    p.start()

  reportData["isFirstTimeUser"]    = parent_conn1.recv()
  reportData["paymentLinkClicked"] = parent_conn2.recv()
  reportData["profileChangeMade"]  = parent_conn3.recv()
  reportData["feedbackSubmitted"]  = parent_conn4.recv()

  for p in processes:
    p.join()

  return reportData

def paymentLinkClicked(event, conn): 
  logGroup = '/aws/lambda/dp-util-dev-getCookies'
  queryString = 'fields event.ConstituentLookupId as CrmId, event.target as target, event.cognitoEmail as email, event.cognitoPhone as phone, @timestamp' \
                '| filter (event.ConstituentLookupId=\'' + event["crmId"] + '\' and name like /\\w+/)' 
  
  queryResult = doQuery(logGroup, queryString)

  gapnResult = {"giveagain": 0, "paynow": 0}
  for r in queryResult:
    gapnResult[r["target"]] += 1

  conn.send(gapnResult) 
  conn.close()

  for p in processes:
    p.start()