forked from Lesin/reposync
新增:日志token过滤
This commit is contained in:
parent
b2d03b7a43
commit
cc28da9957
|
@ -302,13 +302,20 @@ class LogDAO(BaseDAO, metaclass=Singleton):
|
||||||
do_list: List[LogDO] = (await session.execute(query)).scalars().all()
|
do_list: List[LogDO] = (await session.execute(query)).scalars().all()
|
||||||
datas = []
|
datas = []
|
||||||
for do in do_list:
|
for do in do_list:
|
||||||
|
stmt_query = select(SyncRepoMapping).where(SyncRepoMapping.repo_name == do.repo_name).limit(1)
|
||||||
|
stmt = (await session.execute(stmt_query)).scalars().all()
|
||||||
|
log_str = do.log
|
||||||
|
if stmt[0].exter_token:
|
||||||
|
log_str = log_str.replace(stmt[0].exter_token, "******")
|
||||||
|
if stmt[0].inter_token:
|
||||||
|
log_str = log_str.replace(stmt[0].inter_token, "******")
|
||||||
data = LogDTO(
|
data = LogDTO(
|
||||||
id=do.id,
|
id=do.id,
|
||||||
branch_id=do.branch_id,
|
branch_id=do.branch_id,
|
||||||
repo_name=do.repo_name,
|
repo_name=do.repo_name,
|
||||||
commit_id=do.commit_id,
|
commit_id=do.commit_id,
|
||||||
sync_direct=do.sync_direct.name,
|
sync_direct=do.sync_direct.name,
|
||||||
log=str(do.log),
|
log=str(log_str),
|
||||||
created_at=str(do.created_at),
|
created_at=str(do.created_at),
|
||||||
update_at=str(do.update_at)
|
update_at=str(do.update_at)
|
||||||
)
|
)
|
||||||
|
|
Loading…
Reference in New Issue