mirror of
https://github.com/Kuingsmile/PicList.git
synced 2026-05-07 06:12:52 +08:00
✨ Feature(custom): add log for cloud delete
This commit is contained in:
@@ -15,10 +15,8 @@ interface IConfigMap {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default class AlistApi {
|
export default class AlistApi {
|
||||||
static async delete(configMap: IConfigMap): Promise<boolean> {
|
static async delete({ fileName, config: { version, url, uploadPath, token } }: IConfigMap): Promise<boolean> {
|
||||||
const { fileName, config } = configMap
|
|
||||||
try {
|
try {
|
||||||
const { version, url, uploadPath, token } = config
|
|
||||||
if (String(version) === '2') {
|
if (String(version) === '2') {
|
||||||
deleteLog(fileName, 'Alist', false, 'Alist version 2 is not supported, deletion is skipped')
|
deleteLog(fileName, 'Alist', false, 'Alist version 2 is not supported, deletion is skipped')
|
||||||
return true
|
return true
|
||||||
@@ -35,12 +33,9 @@ export default class AlistApi {
|
|||||||
names: [path.basename(fileName)]
|
names: [path.basename(fileName)]
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
if (result.data.code === 200) {
|
const ok = result.data.code === 200
|
||||||
deleteLog(fileName, 'Alist')
|
deleteLog(fileName, 'Alist', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(fileName, 'Alist', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(fileName, 'Alist', error)
|
deleteFailedLog(fileName, 'Alist', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -50,12 +50,9 @@ export default class AListplistApi {
|
|||||||
names: [path.basename(fileName)]
|
names: [path.basename(fileName)]
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
if (result.data.code === 200) {
|
const ok = result.data.code === 200
|
||||||
deleteLog(fileName, 'Alist')
|
deleteLog(fileName, 'Alist', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(fileName, 'Alist', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(fileName, 'Alist', error)
|
deleteFailedLog(fileName, 'Alist', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -19,12 +19,9 @@ export default class AliyunApi {
|
|||||||
const client = new OSS({ ...config, region: config.area })
|
const client = new OSS({ ...config, region: config.area })
|
||||||
const key = AliyunApi.#getKey(fileName, config.path)
|
const key = AliyunApi.#getKey(fileName, config.path)
|
||||||
const result = await client.delete(key)
|
const result = await client.delete(key)
|
||||||
if (result.res.status === 204) {
|
const ok = result.res.status === 204
|
||||||
deleteLog(fileName, 'Aliyun')
|
deleteLog(fileName, 'Aliyun', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(fileName, 'Aliyun', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(fileName, 'Aliyun', error)
|
deleteFailedLog(fileName, 'Aliyun', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -39,12 +39,9 @@ export default class GithubApi {
|
|||||||
sha: hash,
|
sha: hash,
|
||||||
branch
|
branch
|
||||||
})
|
})
|
||||||
if (status === 200) {
|
const ok = status === 200
|
||||||
deleteLog(fileName, 'GitHub')
|
deleteLog(fileName, 'GitHub', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(fileName, 'GitHub', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(fileName, 'GitHub', error)
|
deleteFailedLog(fileName, 'GitHub', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -30,12 +30,9 @@ export default class ImgurApi {
|
|||||||
headers: { Authorization },
|
headers: { Authorization },
|
||||||
timeout: 30000
|
timeout: 30000
|
||||||
})
|
})
|
||||||
if (response.status === 200) {
|
const ok = response.status === 200
|
||||||
deleteLog(hash, 'Imgur')
|
deleteLog(hash, 'Imgur', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(hash, 'Imgur', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(hash, 'Imgur', error)
|
deleteFailedLog(hash, 'Imgur', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -33,12 +33,9 @@ export default class LskyplistApi {
|
|||||||
timeout: 30000,
|
timeout: 30000,
|
||||||
httpsAgent: requestAgent
|
httpsAgent: requestAgent
|
||||||
})
|
})
|
||||||
if (response.status === 200 && response.data.status === true) {
|
const ok = response.status === 200 && response.data.status === true
|
||||||
deleteLog(hash, 'Lskyplist')
|
deleteLog(hash, 'Lskyplist', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(hash, 'Lskyplist', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(hash, 'Lskyplist', error)
|
deleteFailedLog(hash, 'Lskyplist', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -20,12 +20,9 @@ export default class PiclistApi {
|
|||||||
const response: AxiosResponse = await axios.post(url, {
|
const response: AxiosResponse = await axios.post(url, {
|
||||||
list: [fullResult]
|
list: [fullResult]
|
||||||
})
|
})
|
||||||
if (response.status === 200 && response.data?.success) {
|
const ok = response.status === 200 && response.data?.success
|
||||||
deleteLog(fullResult, 'Piclist')
|
deleteLog(fullResult, 'Piclist', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(fullResult, 'Piclist', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(fullResult, 'Piclist', error)
|
deleteFailedLog(fullResult, 'Piclist', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -31,12 +31,9 @@ export default class QiniuApi {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
})) as any
|
})) as any
|
||||||
if (res?.respInfo?.statusCode === 200) {
|
const ok = res?.respInfo?.statusCode === 200
|
||||||
deleteLog(fileName, 'Qiniu')
|
deleteLog(fileName, 'Qiniu', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(fileName, 'Qiniu', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(fileName, 'Qiniu', error)
|
deleteFailedLog(fileName, 'Qiniu', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -31,12 +31,9 @@ export default class SmmsApi {
|
|||||||
},
|
},
|
||||||
timeout: 30000
|
timeout: 30000
|
||||||
})
|
})
|
||||||
if (response.status === 200) {
|
const ok = response.status === 200
|
||||||
deleteLog(hash, 'Smms')
|
deleteLog(hash, 'Smms', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(hash, 'Smms', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(hash, 'Smms', error)
|
deleteFailedLog(hash, 'Smms', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -32,12 +32,9 @@ export default class TcyunApi {
|
|||||||
Region: area,
|
Region: area,
|
||||||
Key: key
|
Key: key
|
||||||
})
|
})
|
||||||
if (result.statusCode === 204) {
|
const ok = result.statusCode === 204
|
||||||
deleteLog(fileName, 'Tcyun')
|
deleteLog(fileName, 'Tcyun', ok)
|
||||||
return true
|
return ok
|
||||||
}
|
|
||||||
deleteLog(fileName, 'Tcyun', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(fileName, 'Tcyun', error)
|
deleteFailedLog(fileName, 'Tcyun', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -24,12 +24,8 @@ export default class UpyunApi {
|
|||||||
key = `${path.replace(/^\/+|\/+$/, '')}/${fileName}`
|
key = `${path.replace(/^\/+|\/+$/, '')}/${fileName}`
|
||||||
}
|
}
|
||||||
const result = await client.deleteFile(key)
|
const result = await client.deleteFile(key)
|
||||||
if (result) {
|
deleteLog(fileName, 'Upyun', !!result)
|
||||||
deleteLog(fileName, 'Upyun')
|
return !!result
|
||||||
return true
|
|
||||||
}
|
|
||||||
deleteLog(fileName, 'Upyun', false)
|
|
||||||
return false
|
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
deleteFailedLog(fileName, 'Upyun', error)
|
deleteFailedLog(fileName, 'Upyun', error)
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -89,7 +89,6 @@ async function getDogeToken(accessKey: string, secretKey: string): Promise<IObj
|
|||||||
}
|
}
|
||||||
|
|
||||||
export async function removeFileFromS3InMain(configMap: IStringKeyMap, dogeMode: boolean = false) {
|
export async function removeFileFromS3InMain(configMap: IStringKeyMap, dogeMode: boolean = false) {
|
||||||
try {
|
|
||||||
const {
|
const {
|
||||||
url: rawUrl,
|
url: rawUrl,
|
||||||
type,
|
type,
|
||||||
@@ -199,14 +198,9 @@ export async function removeFileFromS3InMain(configMap: IStringKeyMap, dogeMode:
|
|||||||
result = await client.send(command)
|
result = await client.send(command)
|
||||||
}
|
}
|
||||||
return result.$metadata.httpStatusCode === 204
|
return result.$metadata.httpStatusCode === 204
|
||||||
} catch (err: any) {
|
|
||||||
logger.error(err)
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function removeFileFromDogeInMain(configMap: IStringKeyMap) {
|
export async function removeFileFromDogeInMain(configMap: IStringKeyMap) {
|
||||||
try {
|
|
||||||
const {
|
const {
|
||||||
config: { bucketName, AccessKey, SecretKey }
|
config: { bucketName, AccessKey, SecretKey }
|
||||||
} = configMap
|
} = configMap
|
||||||
@@ -223,10 +217,6 @@ export async function removeFileFromDogeInMain(configMap: IStringKeyMap) {
|
|||||||
bucketName: bucket?.s3Bucket
|
bucketName: bucket?.s3Bucket
|
||||||
}
|
}
|
||||||
return await removeFileFromS3InMain(newConfigMap, true)
|
return await removeFileFromS3InMain(newConfigMap, true)
|
||||||
} catch (err: any) {
|
|
||||||
logger.error(err)
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function createHuaweiAuthorization(
|
function createHuaweiAuthorization(
|
||||||
@@ -250,7 +240,6 @@ export async function removeFileFromHuaweiInMain(configMap: IStringKeyMap) {
|
|||||||
path = path === '/' ? '' : path
|
path = path === '/' ? '' : path
|
||||||
const date = new Date().toUTCString()
|
const date = new Date().toUTCString()
|
||||||
const authorization = createHuaweiAuthorization(bucketName, path, fileName, accessKeyId, accessKeySecret, date)
|
const authorization = createHuaweiAuthorization(bucketName, path, fileName, accessKeyId, accessKeySecret, date)
|
||||||
try {
|
|
||||||
const res = await axios.request({
|
const res = await axios.request({
|
||||||
url: `https://${bucketName}.${endpoint}${encodeURI(path)}/${encodeURIComponent(fileName)}`,
|
url: `https://${bucketName}.${endpoint}${encodeURI(path)}/${encodeURIComponent(fileName)}`,
|
||||||
method: 'DELETE',
|
method: 'DELETE',
|
||||||
@@ -262,14 +251,9 @@ export async function removeFileFromHuaweiInMain(configMap: IStringKeyMap) {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
return res.status === 204
|
return res.status === 204
|
||||||
} catch (error: any) {
|
|
||||||
logger.error(error)
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function removeFileFromSFTPInMain(config: ISftpPlistConfig, fileName: string) {
|
export async function removeFileFromSFTPInMain(config: ISftpPlistConfig, fileName: string) {
|
||||||
try {
|
|
||||||
const client = SSHClient.instance
|
const client = SSHClient.instance
|
||||||
await client.connect(config)
|
await client.connect(config)
|
||||||
const uploadPath = `/${config.uploadPath || ''}/`.replace(/\/+/g, '/')
|
const uploadPath = `/${config.uploadPath || ''}/`.replace(/\/+/g, '/')
|
||||||
@@ -277,8 +261,4 @@ export async function removeFileFromSFTPInMain(config: ISftpPlistConfig, fileNam
|
|||||||
const deleteResult = await client.deleteFileSFTP(config, remote)
|
const deleteResult = await client.deleteFileSFTP(config, remote)
|
||||||
client.close()
|
client.close()
|
||||||
return deleteResult
|
return deleteResult
|
||||||
} catch (err: any) {
|
|
||||||
logger.error(err)
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,8 +1,10 @@
|
|||||||
|
import logger from '@core/picgo/logger'
|
||||||
|
|
||||||
export const deleteLog = (fileName?: string, type?: string, isSuccess = true, msg?: string) => {
|
export const deleteLog = (fileName?: string, type?: string, isSuccess = true, msg?: string) => {
|
||||||
console.log(`Delete ${fileName} on ${type} ${isSuccess ? 'success' : 'failed'}, message: ${msg || ''}`)
|
logger.info(`Delete ${fileName} on ${type} ${isSuccess ? 'successfully' : 'failed'} ${msg ? 'msg: ' + msg : ''}`)
|
||||||
}
|
}
|
||||||
|
|
||||||
export const deleteFailedLog = (fileName: string, type: string, error: any) => {
|
export const deleteFailedLog = (fileName: string, type: string, error: any) => {
|
||||||
deleteLog(fileName, type, false)
|
deleteLog(fileName, type, false)
|
||||||
console.error(error)
|
logger.error(error)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user