Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
10 changed files
with
422 additions
and
31 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
17 changes: 13 additions & 4 deletions
17
...-Core/src/plugins/uploader/aliyun-node.ts → ...-Core/src/plugins/uploader/aliyun/node.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
17 changes: 13 additions & 4 deletions
17
...o-Core/src/plugins/uploader/aliyun-web.ts → ...o-Core/src/plugins/uploader/aliyun/web.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
22 changes: 22 additions & 0 deletions
22
libs/Universal-PicGo-Core/src/plugins/uploader/qiniu/digest.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,22 @@ | ||
| /* | ||
| * GNU GENERAL PUBLIC LICENSE | ||
| * Version 3, 29 June 2007 | ||
| * | ||
| * Copyright (C) 2024 Terwer, Inc. <https://terwer.space/> | ||
| * Everyone is permitted to copy and distribute verbatim copies | ||
| * of this license document, but changing it is not allowed. | ||
| */ | ||
|
|
||
| class Mac { | ||
| accessKey: string | ||
| secretKey: string | ||
| options: any | ||
|
|
||
| constructor(accessKey: string, secretKey: string, options?: Partial<any>) { | ||
| this.accessKey = accessKey | ||
| this.secretKey = secretKey | ||
| this.options = { ...options } | ||
| } | ||
| } | ||
|
|
||
| export { Mac } |
210 changes: 210 additions & 0 deletions
210
libs/Universal-PicGo-Core/src/plugins/uploader/qiniu/index.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,210 @@ | ||
| /* | ||
| * GNU GENERAL PUBLIC LICENSE | ||
| * Version 3, 29 June 2007 | ||
| * | ||
| * Copyright (C) 2024 Terwer, Inc. <https://terwer.space/> | ||
| * Everyone is permitted to copy and distribute verbatim copies | ||
| * of this license document, but changing it is not allowed. | ||
| */ | ||
|
|
||
| import { ILocalesKey } from "../../../i18n/zh-CN" | ||
| import { IPicGo, IPluginConfig, IQiniuConfig } from "../../../types" | ||
| import { IBuildInEvent } from "../../../utils/enums" | ||
| import { bufferToBase64, safeParse } from "../../../utils/common" | ||
| import mime from "mime-types" | ||
| import { AxiosRequestConfig } from "axios" | ||
| import { Mac } from "./digest" | ||
| import { PutPolicy } from "./rs" | ||
|
|
||
| function postOptions(options: IQiniuConfig, fileName: string, token: string, imgBase64: string): AxiosRequestConfig { | ||
| const area = selectArea(options.area || "z0") | ||
| const path = options.path || "" | ||
| const base64FileName = Buffer.from(path + fileName, "utf-8") | ||
| .toString("base64") | ||
| .replace(/\+/g, "-") | ||
| .replace(/\//g, "_") | ||
| return { | ||
| method: "POST", | ||
| url: `http://upload${area}.qiniup.com/putb64/-1/key/${base64FileName}`, | ||
| headers: { | ||
| Authorization: `UpToken ${token}`, | ||
| "Content-Type": mime.lookup(fileName) || "application/octet-stream", | ||
| }, | ||
| data: imgBase64, | ||
| proxy: false, | ||
| } | ||
| } | ||
|
|
||
| function selectArea(area: string): string { | ||
| return area === "z0" ? "" : "-" + area | ||
| } | ||
|
|
||
| function getToken(qiniuOptions: any): string { | ||
| const accessKey = qiniuOptions.accessKey | ||
| const secretKey = qiniuOptions.secretKey | ||
| const mac = new Mac(accessKey, secretKey) | ||
| const options = { | ||
| scope: qiniuOptions.bucket, | ||
| } | ||
| const putPolicy = new PutPolicy(options) | ||
| return putPolicy.uploadToken(mac) | ||
| } | ||
|
|
||
| const handle = async (ctx: IPicGo): Promise<IPicGo> => { | ||
| const qiniuOptions = ctx.getConfig<IQiniuConfig>("picBed.qiniu") | ||
| if (!qiniuOptions) { | ||
| throw new Error("Can't find qiniu config") | ||
| } | ||
|
|
||
| const imgList = ctx.output | ||
| for (const img of imgList) { | ||
| if (img.fileName && img.buffer) { | ||
| try { | ||
| let base64Image = img.base64Image | ||
| if (!base64Image && img.buffer) { | ||
| base64Image = bufferToBase64(img.buffer) | ||
| } | ||
| if (!base64Image) { | ||
| ctx.log.error("Can not find image base64") | ||
| throw new Error("Can not find image base64") | ||
| } | ||
| const options = postOptions(qiniuOptions, img.fileName, getToken(qiniuOptions), base64Image) | ||
| const res: any = await ctx.request(options) | ||
| const body = safeParse<any>(res) | ||
|
|
||
| if (body?.key) { | ||
| delete img.base64Image | ||
| delete img.buffer | ||
| const baseUrl = qiniuOptions.url | ||
| const options = qiniuOptions.options | ||
| img.imgUrl = `${baseUrl}/${body.key as string}${options}` | ||
| } else { | ||
| ctx.emit(IBuildInEvent.NOTIFICATION, { | ||
| title: ctx.i18n.translate<ILocalesKey>("UPLOAD_FAILED"), | ||
| body: body.msg, | ||
| }) | ||
| ctx.log.error("qiniu error", body) | ||
| throw new Error("Upload failed") | ||
| } | ||
| } catch (e: any) { | ||
| if (e.message !== "Upload failed") { | ||
| // err.response maybe undefined | ||
| if (e.error) { | ||
| const errMsg = e.error | ||
| ctx.emit(IBuildInEvent.NOTIFICATION, { | ||
| title: ctx.i18n.translate<ILocalesKey>("UPLOAD_FAILED"), | ||
| body: errMsg, | ||
| }) | ||
| throw errMsg | ||
| } | ||
| } | ||
| throw e | ||
| } | ||
| } | ||
| } | ||
| return ctx | ||
| } | ||
|
|
||
| const config = (ctx: IPicGo): IPluginConfig[] => { | ||
| const userConfig = ctx.getConfig<IQiniuConfig>("picBed.qiniu") || {} | ||
| const config: IPluginConfig[] = [ | ||
| { | ||
| name: "accessKey", | ||
| type: "input", | ||
| get alias() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_ACCESSKEY") | ||
| }, | ||
| default: userConfig.accessKey || "", | ||
| required: true, | ||
| }, | ||
| { | ||
| name: "secretKey", | ||
| type: "password", | ||
| get alias() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_SECRETKEY") | ||
| }, | ||
| default: userConfig.secretKey || "", | ||
| required: true, | ||
| }, | ||
| { | ||
| name: "bucket", | ||
| type: "input", | ||
| get alias() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_BUCKET") | ||
| }, | ||
| default: userConfig.bucket || "", | ||
| required: true, | ||
| }, | ||
| { | ||
| name: "url", | ||
| type: "input", | ||
| get prefix() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_URL") | ||
| }, | ||
| get alias() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_URL") | ||
| }, | ||
| get message() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_MESSAGE_URL") | ||
| }, | ||
| default: userConfig.url || "", | ||
| required: true, | ||
| }, | ||
| { | ||
| name: "area", | ||
| type: "input", | ||
| get prefix() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_AREA") | ||
| }, | ||
| get alias() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_AREA") | ||
| }, | ||
| get message() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_MESSAGE_AREA") | ||
| }, | ||
| default: userConfig.area || "", | ||
| required: true, | ||
| }, | ||
| { | ||
| name: "options", | ||
| type: "input", | ||
| get prefix() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_OPTIONS") | ||
| }, | ||
| get alias() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_OPTIONS") | ||
| }, | ||
| get message() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_MESSAGE_OPTIONS") | ||
| }, | ||
| default: userConfig.options || "", | ||
| required: false, | ||
| }, | ||
| { | ||
| name: "path", | ||
| type: "input", | ||
| get prefix() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_PATH") | ||
| }, | ||
| get alias() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_PATH") | ||
| }, | ||
| get message() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU_MESSAGE_PATH") | ||
| }, | ||
| default: userConfig.path || "", | ||
| required: false, | ||
| }, | ||
| ] | ||
| return config | ||
| } | ||
|
|
||
| export default function register(ctx: IPicGo): void { | ||
| ctx.helper.uploader.register("qiniu", { | ||
| get name() { | ||
| return ctx.i18n.translate<ILocalesKey>("PICBED_QINIU") | ||
| }, | ||
| handle, | ||
| config, | ||
| }) | ||
| } |
Oops, something went wrong.