firepunch添加注释
This commit is contained in:
markino 2023-12-07 15:25:21 +08:00
commit e27f293336
1 changed files with 15 additions and 9 deletions

View File

@ -10,27 +10,30 @@ from commons.logUtil import logger
app = Flask(__name__)
# 测试
# 测试接口
@app.route('/hello', methods=['get'])
@cross_origin()
def hello():
# 返回JSON格式的问候语
return jsonify({
"code": 0,
"msg": "hello"
})
# 功能:每当有一个新的PR创建/关闭时,根据状态执行存储或更新操作
# 功能处理新建或关闭的PRPull Request相关的Webhook请求
@app.route('/prwelcome', methods=['POST'])
@cross_origin()
def pr_welcome():
try:
# 获取请求的JSON数据
payload = request.json
print(payload)
# 记录日志
logger.info("获取webhook信息成功:" + str(payload))
# # 判断是新创建issue还是issue的状态发生改变
# 如果是新建的PR
if payload["action"] == 'opened':
# 提取PR的相关信息
pull_id = payload["pull_request"]["id"]
index = payload["pull_request"]["number"]
time = payload["pull_request"]["created_at"][:19]
@ -39,27 +42,30 @@ def pr_welcome():
created = datetime.datetime.strptime(time, "%Y-%m-%dT%H:%M:%S")
check_time = created + datetime.timedelta(hours=2)
values = (pull_id, index, owner, repo, created, check_time, 0)
# print(values)
# 将提取的信息存储到数据库
pullService.insert_pull(values)
# 关闭 更新数据库对应pr状态 (合并或者拒绝都属于关闭)
# 如果PR被关闭
elif payload["action"] == 'closed':
# 提取PR的相关信息
index = payload["pull_request"]["number"]
owner = payload["pull_request"]["user"]["login"]
repo = payload["repository"]["full_name"]
# 更新数据库中的PR状态
pullService.update_pull(index, owner, repo)
# 返回成功的响应
return jsonify({
"code": 0,
"msg": "success"
})
except Exception as e:
# 返回异常响应
return jsonify({
"code": -1,
"msg": "exception:" + str(e)
})
if __name__ == '__main__':
# 启动Flask应用
app.run(port=3090)