🔨 Refactor(custom): refactored imports

This commit is contained in:
Kuingsmile
2024-06-09 18:39:12 +08:00
parent e87e3999b4
commit 19c12b6b02
30 changed files with 207 additions and 216 deletions
+3 -16
View File
@@ -12,15 +12,11 @@ import path from 'path'
import { Stream } from 'stream'
import { promisify } from 'util'
import UpDownTaskQueue,
{
uploadTaskSpecialStatus,
commonTaskStatus,
downloadTaskSpecialStatus
} from '~/manage/datastore/upDownTaskQueue'
import UpDownTaskQueue from '~/manage/datastore/upDownTaskQueue'
import { ManageLogger } from '~/manage/utils/logger'
import { formatHttpProxy, IHTTPProxy } from '@/manage/utils/common'
import { commonTaskStatus, downloadTaskSpecialStatus, uploadTaskSpecialStatus } from '#/types/enum'
import { formatHttpProxy } from '#/utils/common'
export const getFSFile = async (
filePath: string,
@@ -218,8 +214,6 @@ export const formatError = (err: any, params:IStringKeyMap) => {
return `${String(err)}${JSON.stringify(params)}`
}
export const trimPath = (path: string) => path.replace(/^\/+|\/+$/g, '').replace(/\/+/g, '/')
const commonOptions = {
keepAlive: true,
keepAliveMsecs: 1000,
@@ -309,13 +303,6 @@ export function getOptions (
}
}
export const formatEndpoint = (endpoint: string, sslEnabled: boolean): string =>
!/^https?:\/\//.test(endpoint)
? `${sslEnabled ? 'https' : 'http'}://${endpoint}`
: sslEnabled
? endpoint.replace('http://', 'https://')
: endpoint.replace('https://', 'http://')
export class ConcurrencyPromisePool {
limit: number
queue: any[]