AWS CodeCommit 어디까지 써봤니?

{
   "type":"view_submission",
   "team":{
      "id":"T*",
      "domain":"b*"
   },
   "user":{
      "id":"U*",
      "username":"p*",
      "name":"p*",
      "team_id":"T*"
   },
   "api_app_id":"A*",
   "token":"1*",
   "trigger_id":"3*",
   "view":{
      "id":"V*",
      "team_id":"T*",
      "type":"modal",
      "blocks":[...],
      "private_metadata":"",
      "callback_id":"",
      "state":{
         "values":{
            "JqX":{
               "user-1":{
                  "type":"users_select",
                  "selected_user":"U*"
               }
            },
            "x8eSC":{
               "user-2":{
                  "type":"users_select",
                  "selected_user":"U*"
               }
            },
            "C1Bo":{
               "emergency-selct":{
                  "type":"static_select",
                  "selected_option":{
                     "text":{
                        "type":"plain_text",
                        "text":":x:",
                        "emoji":True
                     },
                     "value":"e*"
                  }
               }
            }
         }
      },
      "hash":"1*",
      "title":{...},
      "clear_on_close":False,
      "notify_on_close":False,
      "close":None,
      "submit":{
         "type":"plain_text",
         "text":"\*0",
         "emoji":True
      },
      "previous_view_id":None,
      "root_view_id":"V*",
      "app_id":"A*",
      "external_id":"",
      "app_installed_team_id":"T*",
      "bot_id":"B*"
   },
   "response_urls":[],
   "is_enterprise_install":False,
   "enterprise":None
}

answer_blocks = payload['view']['state']['values']
answer_keys = answer_blocks.keys()

first_reviewer = None
second_reviewer = None
emergency_answer = False

for key in answer_keys:
    answer_keys = answer_blocks[key]
    if answer_keys.get('user-1'):
        first_reviewer = answer_keys['user-1']['selected_user']
    elif answer_keys.get('user-2'):
        second_reviewer = answer_keys['user-2']['selected_user']

aws_client = boto3.client('codecommit')

code_commit_approver = f'arn:aws:iam::{domain_id}:user/'
first_user = USER_NAME.get(first_reviewer).get('aws_name') # aws 의 username
second_user = USER_NAME.get(second_reviewer).get('aws_name') # aws 의 username

rule_content = {
    'Version': '2018-11-08',
    'Statements': [
        {
            'Type': 'Approvers',
            'NumberOfApprovalsNeeded': 2, # 승인자 수
            'ApprovalPoolMembers': [] # 필수 승인자
        }
    ]
}

rule_content['Statements'][0]['ApprovalPoolMembers'].append(f'{code_commit_approver}{first_user}')
rule_content['Statements'][0]['ApprovalPoolMembers'].append(f'{code_commit_approver}{second_user}')

result = aws_client.create_pull_request_approval_rule(
    pullRequestId=pull_request_id,
    approvalRuleName=f'{pull_request_id}_commerce_dev_approval_rule', # 승인 룰 이름
    approvalRuleContent=json.dumps(rule_content)
)

pull_request_list = []

for repo in repo_list:
  # 오픈 되어 있는 pr 들 조회
  open_pull_requests = aws_client.list_pull_requests(
       repositoryName=repo,
       pullRequestStatus='OPEN'
  )
	
  for request in open_pull_requests['pullRequestIds']:
      # pr 정보 조회
      request_info = aws_client.get_pull_request(pullRequestId=request)
	
      pull_requests = request_info.get('pullRequest')
	
      if pull_requests['approvalRules']:
          is_need = False
          for rule in pull_requests['approvalRules']:
              # 승인 룰 조회
              if rule['approvalRuleName'] == f'{request}_commerce_dev_approval_rule':
                  approval_content = json.loads(rule['approvalRuleContent'])
                  rule_statements = approval_content['Statements'][0]['ApprovalPoolMembers']
	
                  # 리뷰어로 지정되어 있는지 체크
                  if user_id in [rule_statements[0].split('/')[1], rule_statements[1].split('/')[1]]:
                      # 현재 pr의 승인상태 체크
                      pull_request_approval_state = aws_client.get_pull_request_approval_states(
                          pullRequestId=request, revisionId=pull_requests.get('revisionId')
                      )
                      approvals = pull_request_approval_state['approvals']
                      is_need = True

                      # 내가 pr 승인했는지 체크
                      for approval in approvals:
                          if approval['userArn'].split('/')[1] == {user_id} and approval['approvalState'] == 'APPROVE':
                              is_need = False
          if is_need:
              pull_request_list.append({"pull_request": pull_requests, "repository": repo})

response = slack_client.conversations_open(users=user_id, pervent_creation=False)

if response['ok']:
    channel_id = response['channel']['id']

# 슬랙에서 요청을 보낼때 body 에 내용을 담아 보냄
body = parse_qs(event['body'])

if body.get('payload'):
    payload = json.loads(body['payload'][0])

    if payload['type'] == 'view_submission': # 리뷰어 지정 모달 제출 시 
        return send_reviewer_request(payload, slack_client)

    if payload['type'] == 'block_actions': # 버튼 클릭 시 
        if payload['actions'][0]['action_id'] == 'review-request-action': # 리뷰 요청하기
            call_result = slack_client.send_review_request_view(payload['trigger_id'], payload['actions'][0]['value'], payload['user']['id'])
            if not call_result:
                return {'statusCode': 500}
            return call_result
        elif payload['actions'][0]['action_id'] == 'rereview-request-action':  # 재리뷰 요청하기
            call_result = slack_client.send_rereview_reqeust(payload['actions'][0]['value'], payload['user']['id'])
            if not call_result:
                return {'statusCode': 500}
            return {'statusCode': 200}
        elif payload['actions'][0]['action_id'] in ['first-reviewer-start', 'second-reviewer-start']: # 리뷰 시작 버튼
            call_result = slack_client.send_reviewer_start(payload['actions'][0]['value'], payload['channel']['id'], payload['user']['id'])
            if not call_result:
                return {'statusCode': 500}
            return {'statusCode': 200}
        elif payload['actions'][0]['action_id'] == 'reviewer-end': # 리뷰 끝 버튼
            call_result = slack_client.send_reviewer_end(payload['actions'][0]['value'], payload['channel']['id'], payload['user']['id'])
            if not call_result:
                return {'statusCode': 500}
            return {'statusCode': 200}