|
@@ -2,6 +2,7 @@ const API = require("../../lib/API")
|
|
|
const AccessControl = require("../../lib/AccessControl")
|
|
|
const { BaseStdResponse } = require("../../BaseStdResponse")
|
|
|
const db = require("../../plugin/DataBase/db")
|
|
|
+const redis = require('../../plugin/DataBase/Redis')
|
|
|
const fs = require('fs')
|
|
|
|
|
|
// 删除仓库
|
|
@@ -29,12 +30,16 @@ class DeleteRepo extends API {
|
|
|
let sql = 'SELECT path FROM repos WHRER \`create_user\` = ? AND id = ?'
|
|
|
let r = await db.query(sql, [uuid, id])
|
|
|
|
|
|
- if (r && r[0].path)
|
|
|
+ if (r && r[0].path) {
|
|
|
+ const redisKey = `gitLogs:${r[0].path}`
|
|
|
+ await redis.del(redisKey)
|
|
|
+
|
|
|
fs.rm(r[0].path, { recursive: true, force: true }, (err) => {
|
|
|
this.logger.error('删除仓库失败!' + err)
|
|
|
res.json({ ...BaseStdResponse.ERR, endpoint: 7894378, msg: '删除仓库失败!' })
|
|
|
})
|
|
|
-
|
|
|
+ }
|
|
|
+
|
|
|
sql = 'DELETE FROM repos WHERE create_user = ? AND id = ?'
|
|
|
|
|
|
let result = await db.query(sql, [uuid, id])
|