Update gradle.properties

Fix findUrlSuffix NPE when upgrading from old version (#94 )
fixes https://github.com/halo-dev/plugin-s3/issues/93 ```release-note 修复从旧版本升级后上传文件的NPE错误 ``` /kind bug
2025-10-15 14:40:46 +00:00 · 2023-10-27 02:18:56 -05:00 · 2023-10-27 02:34:15 +00:00 · 2023-10-26 06:38:14 +00:00 · 2023-10-26 05:44:12 +00:00 · 2023-10-26 05:42:17 +00:00
51 changed files with 5219 additions and 64 deletions
--- a/.github/workflows/workflow.yaml
+++ b/.github/workflows/workflow.yaml
@@ -2,10 +2,20 @@ name: Build Plugin JAR File

 on:
  push:
-    branches: [ main ]
+    branches:
+      - main
+    paths:
+      - "**"
+      - "!**.md"
  release:
    types:
      - created
+  pull_request:
+    branches:
+      - main
+    paths:
+      - "**"
+      - "!**.md"

 jobs:
  build:
@@ -20,6 +30,30 @@ jobs:
          distribution: 'temurin'
          cache: 'gradle'
          java-version: 17
+      - name: Set up Node.js
+        uses: actions/setup-node@v3
+        with:
+          node-version: 18
+      - uses: pnpm/action-setup@v2.0.1
+        name: Install pnpm
+        id: pnpm-install
+        with:
+          version: 8
+          run_install: false
+      - name: Get pnpm store directory
+        id: pnpm-cache
+        run: |
+          echo "::set-output name=pnpm_cache_dir::$(pnpm store path)"
+      - uses: actions/cache@v3
+        name: Setup pnpm cache
+        with:
+          path: ${{ steps.pnpm-cache.outputs.pnpm_cache_dir }}
+          key: ${{ runner.os }}-pnpm-store-${{ hashFiles('**/widget/pnpm-lock.yaml') }}
+          restore-keys: |
+            ${{ runner.os }}-pnpm-store-
+      - name: Install Frontend Dependencies
+        run: |
+          ./gradlew pnpmInstall
      - name: Build with Gradle
        run: |
          # Set the version with tag name when releasing
@@ -79,3 +113,26 @@ jobs:
              name: artifactName,
              data: await fs.readFile(artifactPathName)
            });
+
+  app-store-release:
+    runs-on: ubuntu-latest
+    needs: build
+    if: github.event_name == 'release'
+    steps:
+      - uses: actions/checkout@v3
+        with:
+          submodules: true
+      - name: Download plugin-s3 jar
+        uses: actions/download-artifact@v2
+        with:
+          name: plugin-s3
+          path: build/libs
+      - name: Sync to Halo App Store
+        uses: halo-sigs/app-store-release-action@main
+        with:
+          github-token: ${{secrets.GITHUB_TOKEN}}
+          app-id: ${{secrets.APP_ID}}
+          release-id: ${{ github.event.release.id }}
+          assets-dir: "build/libs"
+          halo-username: ${{ secrets.HALO_USERNAME }}
+          halo-password: ${{ secrets.HALO_PASSWORD }}
--- a/README.md
+++ b/README.md
@@ -4,8 +4,10 @@

 ## 使用方法

-1. 在 [Releases](https://github.com/halo-sigs/plugin-s3/releases) 下载最新的 JAR 文件。
-2. 在 Halo 后台的插件管理上传 JAR 文件进行安装。
+1. 下载，目前提供以下两个下载方式：
+    - GitHub Releases：访问 [Releases](https://github.com/halo-dev/plugin-s3/releases) 下载 Assets 中的 JAR 文件。
+    - Halo 应用市场：<https://halo.run/store/apps/app-Qxhpp>
+2. 安装，插件安装和更新方式可参考：<https://docs.halo.run/user-guide/plugins>
 3. 进入后台附件管理。
 4. 点击右上角的存储策略，在存储策略弹框的右上角可新建 S3 Object Storage 存储策略。
 5. 创建完成之后即可在上传的时候选择新创建的 S3 Object Storage 存储策略。
@@ -53,20 +55,20 @@

 |服务商|文档|兼容访问风格|兼容性|
 | ----- | ---- | ----- | ----- |
-|阿里云|https://help.aliyun.com/document_detail/410748.html|Virtual Hosted Style|✅|
-|腾讯云|[https://cloud.tencent.com/document/product/436/41284](https://cloud.tencent.com/document/product/436/41284)|Virtual Hosted Style / <br>Path Style|✅|
-|七牛云|https://developer.qiniu.com/kodo/4088/s3-access-domainname|Virtual Hosted Style / <br>Path Style|✅|
-|百度云|https://cloud.baidu.com/doc/BOS/s/Fjwvyq9xo|Virtual Hosted Style / <br>Path Style|✅|
-|京东云| https://docs.jdcloud.com/cn/object-storage-service/api/regions-and-endpoints |Virtual Hosted Style|✅|
-|金山云|https://docs.ksyun.com/documents/6761|Virtual Hosted Style|✅|
-|青云|https://docsv3.qingcloud.com/storage/object-storage/s3/intro/|Virtual Hosted Style / <br>Path Style|✅|
-|网易数帆|[https://sf.163.com/help/documents/89796157866430464](https://sf.163.com/help/documents/89796157866430464)|Virtual Hosted Style|✅|
-|Cloudflare|Cloudflare S3 兼容性API<br>[https://developers.cloudflare.com/r2/data-access/s3-api/](https://developers.cloudflare.com/r2/data-access/s3-api/)|Virtual Hosted Style / <br>Path Style|✅|
-| Oracle Cloud |[https://docs.oracle.com/en-us/iaas/Content/Object/Tasks/s3compatibleapi.htm](https://docs.oracle.com/en-us/iaas/Content/Object/Tasks/s3compatibleapi.htm)|Virtual Hosted Style / <br>Path Style|✅|
+|阿里云|<https://help.aliyun.com/document_detail/410748.html>|Virtual Hosted Style|✅|
+|腾讯云|<https://cloud.tencent.com/document/product/436/41284>|Virtual Hosted Style / <br>Path Style|✅|
+|七牛云|<https://developer.qiniu.com/kodo/4088/s3-access-domainname>|Virtual Hosted Style / <br>Path Style|✅|
+|百度云|<https://cloud.baidu.com/doc/BOS/s/xjwvyq9l4>|Virtual Hosted Style / <br>Path Style|✅|
+|京东云|<https://docs.jdcloud.com/cn/object-storage-service/api/regions-and-endpoints>|Virtual Hosted Style|✅|
+|金山云|<https://docs.ksyun.com/documents/6761>|Virtual Hosted Style|✅|
+|青云|<https://docsv3.qingcloud.com/storage/object-storage/s3/intro/>|Virtual Hosted Style / <br>Path Style|✅|
+|网易数帆|<https://sf.163.com/help/documents/89796157866430464>|Virtual Hosted Style|✅|
+|Cloudflare|<https://developers.cloudflare.com/r2/data-access/s3-api/>|Virtual Hosted Style / <br>Path Style|✅|
+| Oracle Cloud |<https://docs.oracle.com/en-us/iaas/Content/Object/Tasks/s3compatibleapi.htm>|Virtual Hosted Style / <br>Path Style|✅|
+|又拍云|<https://help.upyun.com/knowledge-base/aws-s3%e5%85%bc%e5%ae%b9/>|Virtual Hosted Style / <br>Path Style|✅|
 |自建minio|\-|Path Style|✅|
 |华为云|文档未说明是否兼容，工单反馈不保证兼容性，实际测试可以使用|Virtual Hosted Style|❓|
-|Ucloud|只支持 8MB 大小的分片，本插件暂不支持<br>[https://docs.ucloud.cn/ufile/s3/s3\_introduction](https://docs.ucloud.cn/ufile/s3/s3_introduction)|\-|❌|
-|又拍云|暂不支持 s3 协议|\-|❌|
+|Ucloud|只支持 8MB 大小的分片，本插件暂不支持<br><https://docs.ucloud.cn/ufile/s3/s3_introduction>|\-|❌|

 ## 开发环境

--- a/build.gradle
+++ b/build.gradle
@@ -1,43 +1,62 @@
 plugins {
-    id "io.github.guqing.plugin-development" version "0.0.7-SNAPSHOT"
-    id "io.freefair.lombok" version "8.0.0-rc2"
    id 'java'
+    id "com.github.node-gradle.node" version "5.0.0"
+    id "io.freefair.lombok" version "8.0.1"
+    id "run.halo.plugin.devtools" version "0.0.7"
 }

 group 'run.halo.s3os'
 sourceCompatibility = JavaVersion.VERSION_17

 repositories {
+    mavenCentral()
    maven { url 'https://s01.oss.sonatype.org/content/repositories/releases' }
    maven { url 'https://s01.oss.sonatype.org/content/repositories/snapshots/' }
-    mavenCentral()
-}
-
-jar {
-    enabled = true
-    duplicatesStrategy = DuplicatesStrategy.EXCLUDE
-    from {
-        configurations.runtimeClasspath.collect {
-            it.isDirectory() ? it : zipTree(it)
-        }
-    }
+    maven { url 'https://repo.spring.io/milestone' }
 }

 dependencies {
-    implementation platform('run.halo.tools.platform:plugin:2.5.0-SNAPSHOT')
+    implementation platform('run.halo.tools.platform:plugin:2.10.0-SNAPSHOT')
    compileOnly 'run.halo.app:api'

    implementation platform('software.amazon.awssdk:bom:2.19.8')
    implementation 'software.amazon.awssdk:s3'
-    implementation "javax.xml.bind:jaxb-api:2.3.1"
-    implementation "javax.activation:activation:1.1.1"
-    implementation "org.glassfish.jaxb:jaxb-runtime:2.3.3"

    testImplementation 'run.halo.app:api'
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
    testImplementation 'io.projectreactor:reactor-test'
 }

+configurations.runtimeClasspath {
+    exclude group: 'org.reactivestreams', module: 'reactive-streams'
+}
+
+
+halo {
+    version = '2.10.0'
+}
+
+haloPlugin {
+    watchDomains {
+        consoleSource {
+            files files('console/src/')
+        }
+    }
+}
+
 test {
    useJUnitPlatform()
 }
+
+node {
+    nodeProjectDir = file("${project.projectDir}/console")
+}
+
+task buildFrontend(type: PnpmTask) {
+    args = ['build']
+}
+
+build {
+    // build frontend before build
+    tasks.getByName('compileJava').dependsOn('buildFrontend')
+}
--- a/console/.editorconfig
+++ b/console/.editorconfig
@@ -0,0 +1,12 @@
+# EditorConfig is awesome: https://EditorConfig.org
+
+# top-most EditorConfig file
+root = true
+
+[*]
+indent_style = space
+indent_size = 2
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = false
+insert_final_newline = true
--- a/console/.eslintrc.cjs
+++ b/console/.eslintrc.cjs
@@ -0,0 +1,15 @@
+/* eslint-env node */
+require("@rushstack/eslint-patch/modern-module-resolution");
+
+module.exports = {
+  root: true,
+  extends: [
+    "plugin:vue/vue3-essential",
+    "eslint:recommended",
+    "@vue/eslint-config-typescript/recommended",
+    "@vue/eslint-config-prettier",
+  ],
+  env: {
+    "vue/setup-compiler-macros": true,
+  },
+};
--- a/console/.gitignore
+++ b/console/.gitignore
@@ -0,0 +1,28 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+pnpm-debug.log*
+lerna-debug.log*
+
+node_modules
+.DS_Store
+dist
+dist-ssr
+coverage
+*.local
+
+/cypress/videos/
+/cypress/screenshots/
+
+# Editor directories and files
+.vscode/*
+!.vscode/extensions.json
+.idea
+*.suo
+*.ntvs*
+*.njsproj
+*.sln
+*.sw?
--- a/console/env.d.ts
+++ b/console/env.d.ts
@@ -0,0 +1,6 @@
+/// <reference types="vite/client" />
+
+declare module "*.vue" {
+  import Vue from "vue";
+  export default Vue;
+}
--- a/console/package.json
+++ b/console/package.json
@@ -0,0 +1,45 @@
+{
+  "name": "@halo-dev/plugin-starter",
+  "version": "1.0.0",
+  "private": true,
+  "scripts": {
+    "dev": "vite build --watch",
+    "build": "vite build",
+    "preview": "vite preview --port 4173",
+    "test:unit": "vitest --environment jsdom",
+    "type-check": "vue-tsc --noEmit -p tsconfig.vitest.json --composite false",
+    "lint": "eslint . --ext .vue,.js,.jsx,.cjs,.mjs,.ts,.tsx,.cts,.mts --fix --ignore-path .gitignore"
+  },
+  "dependencies": {
+    "@halo-dev/components": "^1.5.0",
+    "@halo-dev/console-shared": "^2.8.0",
+    "axios": "^1.4.0",
+    "canvas-confetti": "^1.6.0",
+    "path-browserify": "^1.0.1",
+    "vue": "^3.2.41"
+  },
+  "devDependencies": {
+    "@iconify/json": "^2.2.18",
+    "@rushstack/eslint-patch": "^1.2.0",
+    "@types/canvas-confetti": "^1.6.0",
+    "@types/jsdom": "^20.0.0",
+    "@types/node": "^16.18.0",
+    "@vitejs/plugin-vue": "^3.1.2",
+    "@vitejs/plugin-vue-jsx": "^2.0.1",
+    "@vue/eslint-config-prettier": "^7.0.0",
+    "@vue/eslint-config-typescript": "^11.0.2",
+    "@vue/test-utils": "^2.2.0",
+    "@vue/tsconfig": "^0.1.3",
+    "eslint": "^8.26.0",
+    "eslint-plugin-vue": "^9.6.0",
+    "jsdom": "^19.0.0",
+    "npm-run-all": "^4.1.5",
+    "prettier": "^2.7.1",
+    "sass": "^1.58.0",
+    "typescript": "~4.7.4",
+    "unplugin-icons": "^0.15.2",
+    "vite": "^3.1.8",
+    "vitest": "^0.24.3",
+    "vue-tsc": "^1.0.9"
+  }
+}
--- a/console/pnpm-lock.yaml
+++ b/console/pnpm-lock.yaml
--- a/console/src/assets/logo.svg
+++ b/console/src/assets/logo.svg
--- a/console/src/controller/index.ts
+++ b/console/src/controller/index.ts
@@ -0,0 +1 @@
+export * from "./s-3-link-controller";
--- a/console/src/controller/s-3-link-controller/getApisS3OsHaloRunV1Alpha1ObjectsByPolicyName.ts
+++ b/console/src/controller/s-3-link-controller/getApisS3OsHaloRunV1Alpha1ObjectsByPolicyName.ts
@@ -0,0 +1,25 @@
+import request from "@/utils/request";
+import { S3ListResult, DeepRequired } from "../../interface";
+
+/**
+ * /apis/s3os.halo.run/v1alpha1/objects/{policyName}
+ */
+export function getApisS3OsHaloRunV1Alpha1ObjectsByPolicyName(params: GetApisS3OsHaloRunV1Alpha1ObjectsByPolicyNameParams) {
+    const paramsInput = {
+        continuationToken: params.continuationToken,
+        continuationObject: params.continuationObject,
+        pageSize: params.pageSize,
+        unlinked: params.unlinked,
+    };
+    return request.get<DeepRequired<S3ListResult>>(`/apis/s3os.halo.run/v1alpha1/objects/${params.policyName}`, {
+        params: paramsInput,
+    });
+}
+
+interface GetApisS3OsHaloRunV1Alpha1ObjectsByPolicyNameParams {
+    policyName: any;
+    continuationToken?: any;
+    continuationObject?: any;
+    pageSize: any;
+    unlinked?: any;
+}
--- a/console/src/controller/s-3-link-controller/getApisS3OsHaloRunV1Alpha1PoliciesS3.ts
+++ b/console/src/controller/s-3-link-controller/getApisS3OsHaloRunV1Alpha1PoliciesS3.ts
@@ -0,0 +1,9 @@
+import request from "@/utils/request";
+import { DeepRequired } from "../../interface";
+
+/**
+ * /apis/s3os.halo.run/v1alpha1/policies/s3
+ */
+export function getApisS3OsHaloRunV1Alpha1PoliciesS3() {
+    return request.get<DeepRequired<any>>(`/apis/s3os.halo.run/v1alpha1/policies/s3`);
+}
--- a/console/src/controller/s-3-link-controller/index.ts
+++ b/console/src/controller/s-3-link-controller/index.ts
@@ -0,0 +1,3 @@
+export * from "./postApisS3OsHaloRunV1Alpha1AttachmentsLink";
+export * from "./getApisS3OsHaloRunV1Alpha1ObjectsByPolicyName";
+export * from "./getApisS3OsHaloRunV1Alpha1PoliciesS3";
--- a/console/src/controller/s-3-link-controller/postApisS3OsHaloRunV1Alpha1AttachmentsLink.ts
+++ b/console/src/controller/s-3-link-controller/postApisS3OsHaloRunV1Alpha1AttachmentsLink.ts
@@ -0,0 +1,9 @@
+import request from "@/utils/request";
+import { LinkResult, DeepRequired, LinkRequest } from "../../interface";
+
+/**
+ * /apis/s3os.halo.run/v1alpha1/attachments/link
+ */
+export function postApisS3OsHaloRunV1Alpha1AttachmentsLink(input: LinkRequest) {
+    return request.post<DeepRequired<LinkResult>>(`/apis/s3os.halo.run/v1alpha1/attachments/link`, input);
+}
--- a/console/src/index.ts
+++ b/console/src/index.ts
@@ -0,0 +1,21 @@
+import {definePlugin} from "@halo-dev/console-shared";
+import type {PluginTab} from "@halo-dev/console-shared";
+import S3Link from "./views/S3Link.vue";
+import {markRaw} from "vue";
+
+export default definePlugin({
+  components: {},
+  routes: [],
+  extensionPoints: {
+    "plugin:self:tabs:create": () : PluginTab[] => {
+      return [
+        {
+          id: "s3-link",
+          label: "关联S3文件",
+          component: markRaw(S3Link),
+          permissions: ["plugin:s3os:link"]
+        },
+      ];
+    },
+  },
+});
--- a/console/src/interface/apiTypes/LinkRequest.ts
+++ b/console/src/interface/apiTypes/LinkRequest.ts
@@ -0,0 +1,4 @@
+export interface LinkRequest {
+    objectKeys?: string[];
+    policyName?: string;
+}
--- a/console/src/interface/apiTypes/LinkResult.ts
+++ b/console/src/interface/apiTypes/LinkResult.ts
@@ -0,0 +1,5 @@
+import { LinkResultItem } from "../../interface";
+
+export interface LinkResult {
+    items?: LinkResultItem[];
+}
--- a/console/src/interface/apiTypes/LinkResultItem.ts
+++ b/console/src/interface/apiTypes/LinkResultItem.ts
@@ -0,0 +1,5 @@
+export interface LinkResultItem {
+    message?: string;
+    objectKey?: string;
+    success?: boolean;
+}
--- a/console/src/interface/apiTypes/Metadata.ts
+++ b/console/src/interface/apiTypes/Metadata.ts
@@ -0,0 +1,20 @@
+export interface Metadata {
+    annotations?: MetadataAnnotations;
+    creationTimestamp?: string;
+    deletionTimestamp?: string;
+    finalizers?: string[];
+    /** The name field will be generated automatically according to the given generateName field */
+    generateName?: string;
+    labels?: MetadataLabels;
+    /** Metadata name */
+    name: string;
+    version?: number;
+}
+
+export interface MetadataAnnotations {
+    [key: string]: any;
+}
+
+export interface MetadataLabels {
+    [key: string]: any;
+}
--- a/console/src/interface/apiTypes/ObjectVo.ts
+++ b/console/src/interface/apiTypes/ObjectVo.ts
@@ -0,0 +1,6 @@
+export interface ObjectVo {
+    displayName?: string;
+    isLinked?: boolean;
+    key?: string;
+    lastModified?: string;
+}
--- a/console/src/interface/apiTypes/Policy.ts
+++ b/console/src/interface/apiTypes/Policy.ts
@@ -0,0 +1,8 @@
+import { Metadata, PolicySpec } from "../../interface";
+
+export interface Policy {
+    apiVersion: string;
+    kind: string;
+    metadata: Metadata;
+    spec: PolicySpec;
+}
--- a/console/src/interface/apiTypes/PolicySpec.ts
+++ b/console/src/interface/apiTypes/PolicySpec.ts
@@ -0,0 +1,8 @@
+export interface PolicySpec {
+    /** Reference name of ConfigMap extension */
+    configMapName?: string;
+    /** Display name of policy */
+    displayName: string;
+    /** Reference name of PolicyTemplate */
+    templateName: string;
+}
--- a/console/src/interface/apiTypes/S3ListResult.ts
+++ b/console/src/interface/apiTypes/S3ListResult.ts
@@ -0,0 +1,10 @@
+import { ObjectVo } from "../../interface";
+
+export interface S3ListResult {
+    currentContinuationObject?: string;
+    currentToken?: string;
+    hasMore?: boolean;
+    nextContinuationObject?: string;
+    nextToken?: string;
+    objects?: ObjectVo[];
+}
--- a/console/src/interface/index.ts
+++ b/console/src/interface/index.ts
@@ -0,0 +1,11 @@
+export * from "./apiTypes/LinkRequest";
+export * from "./apiTypes/LinkResult";
+export * from "./apiTypes/LinkResultItem";
+export * from "./apiTypes/Metadata";
+export * from "./apiTypes/ObjectVo";
+export * from "./apiTypes/Policy";
+export * from "./apiTypes/PolicySpec";
+export * from "./apiTypes/S3ListResult";
+
+export type Primitive = undefined | null | boolean | string | number | symbol;
+export type DeepRequired<T> = T extends Primitive ? T : keyof T extends never ? T : { [K in keyof T]-?: DeepRequired<T[K]> };
--- a/console/src/swagger.config.json
+++ b/console/src/swagger.config.json
@@ -0,0 +1,7 @@
+{
+  "docsUrl": "http://localhost:8090/v3/api-docs/extension-api",
+  "includeTags": ["s-3-link-controller"],
+  "excludeTags": [],
+  "axiosInstanceUrl": "@/utils/request",
+  "prefix": ""
+}
--- a/console/src/utils/request.ts
+++ b/console/src/utils/request.ts
@@ -0,0 +1,31 @@
+import axios from "axios";
+import {Toast} from "@halo-dev/components";
+
+const baseURL = import.meta.env.VITE_API_URL;
+const request = axios.create({
+  baseURL,
+  withCredentials: true,
+});
+
+// 非200状态码就弹窗
+request.interceptors.response.use(
+  (response) => {
+    return response;
+  },
+  async (error) => {
+    const errorResponse = error.response;
+    if (!errorResponse) {
+      return Promise.reject(error);
+    }
+    const { status } = errorResponse;
+    if (status !== 200) {
+      Toast.error("status: " + status);
+    }
+    return Promise.reject(error);
+  }
+);
+
+request.defaults.headers.common["X-Requested-With"] = "XMLHttpRequest";
+// TODO 使用halo console 中的axios https://github.com/halo-dev/halo/issues/3979
+export default request;
+
--- a/console/src/views/S3Link.vue
+++ b/console/src/views/S3Link.vue
@@ -0,0 +1,452 @@
+<script setup lang="ts">
+import {
+  IconRefreshLine,
+  Toast,
+  VButton,
+  VCard,
+  VEmpty,
+  VEntity,
+  VEntityField,
+  VLoading,
+  VModal,
+  VPageHeader,
+  VSpace,
+  VTag,
+} from "@halo-dev/components";
+import CarbonFolderDetailsReference from "~icons/carbon/folder-details-reference";
+import {computed, onMounted, ref, watch} from "vue";
+import {
+  getApisS3OsHaloRunV1Alpha1ObjectsByPolicyName,
+  getApisS3OsHaloRunV1Alpha1PoliciesS3,
+  postApisS3OsHaloRunV1Alpha1AttachmentsLink,
+} from "@/controller";
+import type {ObjectVo, S3ListResult, Policy, LinkResultItem} from "@/interface";
+
+const selectedFiles = ref<string[]>([]);
+const policyName = ref<string>("");
+const page = ref(1);
+const size = ref(50);
+const policyOptions = ref<{ label: string; value: string; attrs: any }[]>([{
+  label: "请选择策略",
+  value: "",
+  attrs: {disabled: true}
+}]);
+const s3Objects = ref<S3ListResult>({
+  objects: [],
+  hasMore: false,
+  currentToken: "",
+  nextToken: "",
+  currentContinuationObject: "",
+  nextContinuationObject: "",
+});
+// view state
+const isFetching = ref(false);
+const isShowModal = ref(false);
+const isLinking = ref(false);
+const isFetchingPolicies = ref(true);
+
+const linkTips = ref("");
+const linkFailedTable = ref<LinkResultItem[]>([]);
+const linkedStatusItems: { label: string; value?: boolean }[] = [
+  {label: "全部"},
+  {label: "未关联", value: true},
+];
+
+// action state
+const checkedAll = ref(false);
+const selectedLinkedStatusItem = ref<boolean | undefined>(linkedStatusItems[0].value);
+
+const emptyTips = computed(() => {
+  if (isFetchingPolicies.value) {
+    return "正在加载策略";
+  } else {
+    if (policyOptions.value.length <= 1) {
+      return "没有可用的策略，请前往【附件】添加S3策略";
+    } else {
+      if (!policyName.value) {
+        return "请在左上方选择策略";
+      } else {
+        return "该策略的 桶/文件夹 下没有文件";
+      }
+    }
+  }
+});
+
+const handleCheckAllChange = (e: Event) => {
+  const {checked} = e.target as HTMLInputElement;
+
+  if (checked) {
+    selectedFiles.value =
+      s3Objects.value.objects?.filter(file => !file.isLinked).map((file) => {
+        return file.key || "";
+      }) || [];
+  } else {
+    selectedFiles.value.length = 0;
+    checkedAll.value = false;
+  }
+};
+
+
+const fetchPolicies = async () => {
+  try {
+    const policiesData = await getApisS3OsHaloRunV1Alpha1PoliciesS3();
+    if (policiesData.status == 200) {
+      policyOptions.value = [{
+        label: "请选择策略",
+        value: "",
+        attrs: {disabled: true}
+      }];
+      policiesData.data.forEach((policy: Policy) => {
+        policyOptions.value.push({
+          label: policy.spec.displayName,
+          value: policy.metadata.name,
+          attrs: {}
+        });
+      });
+    }
+  } catch (error) {
+    console.error(error);
+  }
+  isFetchingPolicies.value = false;
+};
+
+
+onMounted(() => {
+  fetchPolicies();
+});
+
+watch(selectedFiles, (newValue) => {
+  checkedAll.value = s3Objects.value.objects?.filter(file => !file.isLinked)
+      .filter(file => !newValue.includes(file.key || "")).length == 0
+    && s3Objects.value.objects?.length != 0;
+});
+
+watch(selectedLinkedStatusItem, () => {
+  handleFirstPage();
+});
+
+const changeNextTokenAndObject = () => {
+  s3Objects.value.currentToken = s3Objects.value.nextToken;
+  s3Objects.value.currentContinuationObject = s3Objects.value.nextContinuationObject;
+  s3Objects.value.nextToken = "";
+  s3Objects.value.nextContinuationObject = "";
+};
+
+const clearTokenAndObject = () => {
+  s3Objects.value.currentToken = "";
+  s3Objects.value.currentContinuationObject = "";
+  s3Objects.value.nextToken = "";
+  s3Objects.value.nextContinuationObject = "";
+};
+
+const fetchObjects = async () => {
+  if (!policyName.value) {
+    return;
+  }
+  isFetching.value = true;
+  s3Objects.value.objects = [];
+  try {
+    const objectsData = await getApisS3OsHaloRunV1Alpha1ObjectsByPolicyName({
+      policyName: policyName.value,
+      pageSize: size.value,
+      continuationToken: s3Objects.value.currentToken,
+      continuationObject: s3Objects.value.currentContinuationObject,
+      unlinked: selectedLinkedStatusItem.value,
+    });
+    if (objectsData.status == 200) {
+      s3Objects.value = objectsData.data;
+
+      if (s3Objects.value.objects?.length == 0 && s3Objects.value.hasMore && s3Objects.value.nextToken) {
+        changeNextTokenAndObject();
+        await fetchObjects();
+      } else if (s3Objects.value.objects?.length == 0 && !s3Objects.value.hasMore && page.value > 1) {
+        page.value = 1;
+        clearTokenAndObject();
+        await fetchObjects();
+        Toast.warning("最后一页为空，已返回第一页");
+      }
+    }
+  } catch (error) {
+    console.error(error);
+  }
+  selectedFiles.value.length = 0;
+  checkedAll.value = false;
+  isFetching.value = false;
+};
+
+const checkSelection = (file: ObjectVo) => {
+  return selectedFiles.value.includes(file.key || "");
+};
+
+const handleLink = async () => {
+  isLinking.value = true;
+  isShowModal.value = true;
+  linkTips.value = `正在关联${selectedFiles.value.length}个文件`;
+  linkFailedTable.value = [];
+  const linkResult = await postApisS3OsHaloRunV1Alpha1AttachmentsLink({
+    policyName: policyName.value,
+    objectKeys: selectedFiles.value
+  });
+
+  const successCount = linkResult.data.items.filter(item => item.success).length;
+  const failedCount = linkResult.data.items.filter(item => !item.success).length;
+  linkTips.value = `关联成功${successCount}个文件，关联失败${failedCount}个文件`;
+
+  if (failedCount > 0) {
+    linkFailedTable.value = linkResult.data.items.filter(item => !item.success);
+  }
+  isLinking.value = false;
+};
+
+const selectOneAndLink = (file: ObjectVo) => {
+  selectedFiles.value = [file.key || ""];
+  handleLink();
+};
+
+const handleNextPage = () => {
+  if (!policyName.value) {
+    return;
+  }
+  if (s3Objects.value.hasMore) {
+    isFetching.value = true;
+    page.value += 1;
+    changeNextTokenAndObject();
+    fetchObjects();
+  }
+};
+
+const handleFirstPage = () => {
+  if (!policyName.value) {
+    return;
+  }
+  isFetching.value = true;
+  page.value = 1;
+  clearTokenAndObject();
+  fetchObjects();
+};
+
+const handleModalClose = () => {
+  isShowModal.value = false;
+  fetchObjects();
+};
+</script>
+
+<template>
+  <VPageHeader title="关联S3文件(Beta)">
+    <template #icon>
+      <CarbonFolderDetailsReference class="mr-2 self-center"/>
+    </template>
+  </VPageHeader>
+  <div class="m-0 md:m-4">
+    <VCard :body-class="['!p-0']">
+      <template #header>
+        <div class="block w-full bg-gray-50 px-4 py-3">
+          <div
+            class="relative flex flex-col flex-wrap items-start gap-4 sm:flex-row sm:items-center"
+          >
+            <div class="hidden items-center sm:flex">
+              <input
+                v-model="checkedAll"
+                class="h-4 w-4 rounded border-gray-300 text-indigo-600"
+                type="checkbox"
+                @change="handleCheckAllChange"
+              />
+            </div>
+            <div class="flex w-full flex-1 items-center sm:w-auto">
+              <div
+                v-if="!selectedFiles.length"
+                class="flex items-center gap-2"
+              >
+                策略:
+                <FormKit
+                  id="policyChoose"
+                  outer-class="!p-0 w-48"
+                  v-model="policyName"
+                  name="policyName"
+                  type="select"
+                  :options="policyOptions"
+                  @change="fetchObjects()"
+                ></FormKit>
+              </div>
+              <VSpace v-else>
+                <VButton type="primary" @click="handleLink">
+                  关联
+                </VButton>
+              </VSpace>
+            </div>
+            <VSpace spacing="lg" class="flex-wrap">
+              <FilterCleanButton
+                v-if="selectedLinkedStatusItem != linkedStatusItems[0].value"
+                @click="selectedLinkedStatusItem = linkedStatusItems[0].value"
+              />
+              <FilterDropdown
+                v-model="selectedLinkedStatusItem"
+                :label="$t('core.common.filters.labels.status')"
+                :items="linkedStatusItems"
+              />
+
+              <div class="flex flex-row gap-2">
+                <div
+                  class="group cursor-pointer rounded p-1 hover:bg-gray-200"
+                  @click="fetchObjects()"
+                >
+                  <IconRefreshLine
+                    v-tooltip="$t('core.common.buttons.refresh')"
+                    :class="{
+                        'animate-spin text-gray-900': isFetching,
+                      }"
+                    class="h-4 w-4 text-gray-600 group-hover:text-gray-900"
+                  />
+                </div>
+              </div>
+            </VSpace>
+          </div>
+        </div>
+      </template>
+
+      <VLoading v-if="isFetching"/>
+
+      <Transition v-else-if="!s3Objects.objects?.length" appear name="fade">
+        <VEmpty
+          message="空空如也"
+          :title="emptyTips"
+        >
+        </VEmpty>
+      </Transition>
+
+      <Transition v-else appear name="fade">
+        <ul
+          class="box-border h-full w-full divide-y divide-gray-100"
+          role="list"
+        >
+          <li v-for="(file, index) in s3Objects.objects" :key="index">
+            <VEntity :is-selected="checkSelection(file)">
+              <template
+                #checkbox
+              >
+                <input
+                  v-model="selectedFiles"
+                  :value="file.key || ''"
+                  class="h-4 w-4 rounded border-gray-300 text-indigo-600"
+                  name="post-checkbox"
+                  :disabled="file.isLinked"
+                  type="checkbox"
+                />
+              </template>
+              <template #start>
+                <VEntityField>
+                  <template #description>
+                    <AttachmentFileTypeIcon
+                      :display-ext="false"
+                      :file-name="file.displayName || ''"
+                      :width="8"
+                      :height="8"
+                    />
+                  </template>
+                </VEntityField>
+                <VEntityField
+                  :title="file.displayName || ''"
+                  :description="file.key || ''"
+                />
+              </template>
+              <template #end>
+                <VEntityField>
+                  <template #description>
+                    <VTag :theme="file.isLinked ? 'default':'primary'">
+                      {{
+                        file.isLinked ? '已关联' : '未关联'
+                      }}
+                    </VTag>
+                  </template>
+                </VEntityField>
+                <VEntityField>
+                  <template #description>
+                    <VButton
+                      :disabled="file.isLinked || false"
+                      @click="selectOneAndLink(file)"
+                    >
+                      关联
+                    </VButton>
+                  </template>
+                </VEntityField>
+              </template>
+            </VEntity>
+          </li>
+        </ul>
+      </Transition>
+
+      <template #footer>
+        <div class="bg-white sm:flex sm:items-center justify-between">
+          <div class="inline-flex items-center gap-5">
+            <span class="text-xs text-gray-500 hidden md:flex">共 {{ s3Objects.objects?.length }} 项数据</span>
+            <span class="text-xs text-gray-500 hidden md:flex">已自动过滤文件夹对象，页面实际显示数量少为正常现象</span>
+          </div>
+          <div class="inline-flex items-center gap-5">
+            <div class="inline-flex items-center gap-2">
+              <VButton size="small" @click="handleFirstPage" :disabled="!policyName">返回第一页</VButton>
+
+              <span class="text-sm text-gray-500">第 {{ page }} 页</span>
+
+              <VButton size="small" @click="handleNextPage" :disabled="!s3Objects.hasMore || isFetching || !policyName">
+                下一页
+              </VButton>
+            </div>
+            <div class="inline-flex items-center gap-2">
+              <select
+                v-model="size"
+                class="h-8 border outline-none rounded-base px-2 text-gray-800 text-sm border-gray-300"
+                @change="handleFirstPage"
+              >
+                <option
+                  v-for="(sizeOption, index) in [20, 50, 100, 200]"
+                  :key="index"
+                  :value="sizeOption"
+                >
+                  {{ sizeOption }}
+                </option>
+              </select>
+              <span class="text-sm text-gray-500">条/页</span>
+            </div>
+          </div>
+        </div>
+      </template>
+    </VCard>
+  </div>
+  <VModal
+    :visible="isShowModal"
+    :fullscreen="false"
+    :title="'关联结果'"
+    :width="500"
+    :mount-to-body="true"
+    @close="handleModalClose"
+  >
+    <template #footer>
+      <VSpace>
+        <VButton
+          :loading="isLinking"
+          type="primary"
+          @click="handleModalClose"
+        >
+          确定
+        </VButton>
+      </VSpace>
+    </template>
+    <div class="flex flex-col">
+      {{ linkTips }}
+      <table v-if="linkFailedTable.length != 0">
+        <tr>
+          <th class="border border-black font-normal">失败对象</th>
+          <th class="border border-black font-normal">失败原因</th>
+        </tr>
+        <tr v-for="failedInfo in linkFailedTable" :key="failedInfo.objectKey">
+          <th class="border border-black font-normal">{{failedInfo.objectKey}}</th>
+          <th class="border border-black font-normal">{{failedInfo.message}}</th>
+        </tr>
+      </table>
+    </div>
+  </VModal>
+</template>
+
+<style lang="scss" scoped>
+
+</style>
--- a/console/tsconfig.app.json
+++ b/console/tsconfig.app.json
@@ -0,0 +1,13 @@
+{
+  "extends": "@vue/tsconfig/tsconfig.web.json",
+  "include": ["./env.d.ts", "./src/**/*", "./src/**/*.vue"],
+  "exclude": ["./src/**/__tests__/*"],
+  "compilerOptions": {
+    "composite": true,
+    "baseUrl": ".",
+    "paths": {
+      "@/*": ["./src/*"]
+    },
+    "types": ["unplugin-icons/types/vue"]
+  }
+}
--- a/console/tsconfig.config.json
+++ b/console/tsconfig.config.json
@@ -0,0 +1,8 @@
+{
+  "extends": "@vue/tsconfig/tsconfig.node.json",
+  "include": ["vite.config.*", "vitest.config.*", "cypress.config.*"],
+  "compilerOptions": {
+    "composite": true,
+    "types": ["node"]
+  }
+}
--- a/console/tsconfig.json
+++ b/console/tsconfig.json
@@ -0,0 +1,14 @@
+{
+  "files": [],
+  "references": [
+    {
+      "path": "./tsconfig.config.json"
+    },
+    {
+      "path": "./tsconfig.app.json"
+    },
+    {
+      "path": "./tsconfig.vitest.json"
+    }
+  ]
+}
--- a/console/tsconfig.vitest.json
+++ b/console/tsconfig.vitest.json
@@ -0,0 +1,9 @@
+{
+  "extends": "./tsconfig.app.json",
+  "exclude": [],
+  "compilerOptions": {
+    "composite": true,
+    "lib": [],
+    "types": ["node", "jsdom"]
+  }
+}
--- a/console/vite.config.ts
+++ b/console/vite.config.ts
@@ -0,0 +1,47 @@
+import { fileURLToPath, URL } from "url";
+
+import { defineConfig } from "vite";
+import Vue from "@vitejs/plugin-vue";
+import VueJsx from "@vitejs/plugin-vue-jsx";
+import Icons from "unplugin-icons/vite";
+
+const pluginEntryName = "PluginS3ObjectStorage";
+
+// https://vitejs.dev/config/
+export default defineConfig({
+  plugins: [Vue(), VueJsx(), Icons({ compiler: "vue3" })],
+  resolve: {
+    alias: {
+      "@": fileURLToPath(new URL("./src", import.meta.url)),
+    },
+  },
+  build: {
+    outDir: fileURLToPath(
+      new URL("../src/main/resources/console", import.meta.url)
+    ),
+    emptyOutDir: true,
+    lib: {
+      entry: "src/index.ts",
+      name: pluginEntryName,
+      formats: ["iife"],
+      fileName: () => "main.js",
+    },
+    rollupOptions: {
+      external: [
+        "vue",
+        "@halo-dev/console-shared",
+        "@halo-dev/components",
+        "vue-router",
+      ],
+      output: {
+        globals: {
+          vue: "Vue",
+          "vue-router": "VueRouter",
+          "@halo-dev/components": "HaloComponents",
+          "@halo-dev/console-shared": "HaloConsoleShared",
+        },
+        extend: true,
+      },
+    },
+  },
+});
--- a/gradle.properties
+++ b/gradle.properties
@@ -1 +1 @@
-version=1.4.1-SNAPSHOT
+version=1.6.1-SNAPSHOT
--- a/src/main/java/run/halo/s3os/FileNameUtils.java
+++ b/src/main/java/run/halo/s3os/FileNameUtils.java
@@ -4,6 +4,10 @@ import com.google.common.io.Files;
 import org.apache.commons.lang3.RandomStringUtils;
 import org.apache.commons.lang3.StringUtils;

+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.UUID;
+
 public final class FileNameUtils {

    private FileNameUtils() {
@@ -17,6 +21,18 @@ public final class FileNameUtils {
        return filename.replaceAll(extPattern, "");
    }

+    public static String getRandomFilename(String filename, Integer length, String mode) {
+        return switch (mode) {
+//            case "none" -> filename;
+            case "withString" -> randomFilenameWithString(filename, length);
+            case "dateWithString" -> randomDateWithString(filename, length);
+            case "datetimeWithString" -> randomDatetimeWithString(filename, length);
+            case "string" -> randomString(filename, length);
+            case "uuid" -> randomUuid(filename);
+            default -> filename;
+        };
+    }
+
    /**
     * Append random string after file name.
     * <pre>
@@ -26,19 +42,67 @@ public final class FileNameUtils {
     * </pre>
     *
     * @param filename is name of file.
-     * @param length is for generating random string with specific length.
+     * @param length   is for generating random string with specific length.
     * @return File name with random string.
     */
-    public static String randomFileName(String filename, int length) {
-        var nameWithoutExt = Files.getNameWithoutExtension(filename);
-        var ext = Files.getFileExtension(filename);
-        var random = RandomStringUtils.randomAlphabetic(length).toLowerCase();
-        if (StringUtils.isBlank(nameWithoutExt)) {
-            return random + "." + ext;
+    public static String randomFilenameWithString(String filename, Integer length) {
+        String random = RandomStringUtils.randomAlphabetic(length).toLowerCase();
+        return randomFilename(filename, random, true);
+    }
+
+    private static String randomDateWithString(String filename, Integer length) {
+        String random = LocalDate.now() + "-" + RandomStringUtils.randomAlphabetic(length).toLowerCase();
+        return randomFilename(filename, random, false);
+    }
+
+    private static String randomDatetimeWithString(String filename, Integer length) {
+        String random = LocalDateTime.now() + "-" + RandomStringUtils.randomAlphabetic(length).toLowerCase();
+        return randomFilename(filename, random, false);
+    }
+
+    private static String randomString(String filename, Integer length) {
+        String random = RandomStringUtils.randomAlphabetic(length).toLowerCase();
+        return randomFilename(filename, random, false);
+    }
+
+    private static String randomUuid(String filename) {
+        String random = UUID.randomUUID().toString().toUpperCase();
+        return randomFilename(filename, random, false);
+    }
+
+    private static String randomFilename(String filename, String random, Boolean needOriginalName) {
+        String nameWithoutExtension = Files.getNameWithoutExtension(filename);
+        String extension = Files.getFileExtension(filename);
+        boolean nameIsEmpty = StringUtils.isBlank(nameWithoutExtension);
+        boolean extensionIsEmpty = StringUtils.isBlank(extension);
+        if (needOriginalName) {
+            if (nameIsEmpty) {
+                return random + "." + extension;
+            }
+            if (extensionIsEmpty) {
+                return nameWithoutExtension + "-" + random;
+            }
+            return nameWithoutExtension + "-" + random + "." + extension;
        }
-        if (StringUtils.isBlank(ext)) {
-            return nameWithoutExt + "-" + random;
+        else {
+            if (extensionIsEmpty) {
+                return random;
+            }
+            return random + "." + extension;
        }
-        return nameWithoutExt + "-" + random + "." + ext;
+    }
+
+    /**
+     * Extracts the file name from an Amazon S3 object key.
+     *
+     * @param objectKey The Amazon S3 object key from which to extract the file name.
+     * @return The extracted file name.
+     */
+    public static String extractFileNameFromS3Key(String objectKey) {
+        int lastSlashIndex = objectKey.lastIndexOf("/");
+        if (lastSlashIndex >= 0 && lastSlashIndex < objectKey.length() - 1) {
+            return objectKey.substring(lastSlashIndex + 1);
+        }
+        return objectKey;
    }
 }
--- a/src/main/java/run/halo/s3os/FilePathUtils.java
+++ b/src/main/java/run/halo/s3os/FilePathUtils.java
@@ -0,0 +1,23 @@
+package run.halo.s3os;
+
+import org.apache.commons.lang3.StringUtils;
+
+import java.time.LocalDate;
+
+public class FilePathUtils {
+    private FilePathUtils() {
+
+    }
+
+    public static String getFilePathByPlaceholder(String filename) {
+        LocalDate localDate = LocalDate.now();
+        return StringUtils.replaceEach(filename,
+            new String[] {"${year}","${month}","${day}"},
+            new String[] {
+                 String.valueOf(localDate.getYear()),
+                 String.valueOf(localDate.getMonthValue()),
+                 String.valueOf(localDate.getDayOfMonth())
+            }
+        );
+    }
+}
--- a/src/main/java/run/halo/s3os/LinkRequest.java
+++ b/src/main/java/run/halo/s3os/LinkRequest.java
@@ -0,0 +1,13 @@
+package run.halo.s3os;
+
+import lombok.Data;
+import lombok.RequiredArgsConstructor;
+
+import java.util.List;
+
+@Data
+@RequiredArgsConstructor
+public class LinkRequest {
+    private String policyName;
+    private List<String> objectKeys;
+}
--- a/src/main/java/run/halo/s3os/LinkResult.java
+++ b/src/main/java/run/halo/s3os/LinkResult.java
@@ -0,0 +1,24 @@
+package run.halo.s3os;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+@AllArgsConstructor
+public class LinkResult {
+
+    private List<LinkResultItem> items;
+
+    @Data
+    @AllArgsConstructor
+    public static class LinkResultItem {
+        private String objectKey;
+
+        private Boolean success;
+
+        private String message;
+    }
+}
--- a/src/main/java/run/halo/s3os/S3LinkController.java
+++ b/src/main/java/run/halo/s3os/S3LinkController.java
@@ -0,0 +1,85 @@
+package run.halo.s3os;
+
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import run.halo.app.core.extension.attachment.Attachment;
+import run.halo.app.core.extension.attachment.Policy;
+import run.halo.app.extension.ReactiveExtensionClient;
+import run.halo.app.plugin.ApiVersion;
+
+import java.util.Map;
+import java.util.Objects;
+import java.util.concurrent.ConcurrentHashMap;
+
+@ApiVersion("s3os.halo.run/v1alpha1")
+@RestController
+@RequiredArgsConstructor
+public class S3LinkController {
+    private final S3LinkService s3LinkService;
+    private final ReactiveExtensionClient client;
+
+    /**
+     * Map of linking file, used as a lock, key is policyName/objectKey, value is policyName/objectKey.
+     */
+    private final Map<String, Object> linkingFile = new ConcurrentHashMap<>();
+
+    @GetMapping("/policies/s3")
+    public Flux<Policy> listS3Policies() {
+        return s3LinkService.listS3Policies();
+    }
+
+    @GetMapping("/objects/{policyName}")
+    public Mono<S3ListResult> listObjects(@PathVariable String policyName,
+        @RequestParam(name = "continuationToken", required = false) String continuationToken,
+        @RequestParam(name = "continuationObject", required = false) String continuationObject,
+        @RequestParam(name = "pageSize") Integer pageSize,
+        @RequestParam(name = "unlinked", required = false, defaultValue = "false")
+        Boolean unlinked) {
+        if (unlinked) {
+            return s3LinkService.listObjectsUnlinked(policyName, continuationToken,
+                continuationObject, pageSize);
+        } else {
+            return s3LinkService.listObjects(policyName, continuationToken, pageSize);
+        }
+    }
+
+    @PostMapping("/attachments/link")
+    public Mono<LinkResult> addAttachmentRecord(@RequestBody LinkRequest linkRequest) {
+        return Flux.fromIterable(linkRequest.getObjectKeys())
+            .filter(objectKey -> linkingFile.put(linkRequest.getPolicyName() + "/" + objectKey,
+                linkRequest.getPolicyName() + "/" + objectKey) == null)
+            .collectList()
+            .flatMap(operableObjectKeys -> client.list(Attachment.class,
+                    attachment -> Objects.equals(attachment.getSpec().getPolicyName(),
+                        linkRequest.getPolicyName())
+                        && StringUtils.isNotEmpty(attachment.getMetadata().getAnnotations()
+                        .get(S3OsAttachmentHandler.OBJECT_KEY))
+                        && linkRequest.getObjectKeys().contains(attachment.getMetadata()
+                        .getAnnotations().get(S3OsAttachmentHandler.OBJECT_KEY)),
+                    null)
+                .collectList()
+                .flatMap(existingAttachments -> Flux.fromIterable(linkRequest.getObjectKeys())
+                    .flatMap((objectKey) -> {
+                        if (operableObjectKeys.contains(objectKey) && existingAttachments.stream()
+                            .noneMatch(attachment -> Objects.equals(
+                                attachment.getMetadata().getAnnotations().get(
+                                    S3OsAttachmentHandler.OBJECT_KEY), objectKey))) {
+                            return s3LinkService
+                                .addAttachmentRecord(linkRequest.getPolicyName(), objectKey)
+                                .onErrorResume((throwable) -> Mono.just(
+                                    new LinkResult.LinkResultItem(objectKey, false,
+                                        throwable.getMessage())));
+                        } else {
+                            return Mono.just(new LinkResult.LinkResultItem(objectKey, false,
+                                "附件库中已存在该对象"));
+                        }
+                    })
+                    .doOnNext(linkResultItem -> linkingFile.remove(
+                        linkRequest.getPolicyName() + "/" + linkResultItem.getObjectKey()))
+                    .collectList()
+                    .map(LinkResult::new)));
+    }
+}
--- a/src/main/java/run/halo/s3os/S3LinkService.java
+++ b/src/main/java/run/halo/s3os/S3LinkService.java
@@ -0,0 +1,18 @@
+package run.halo.s3os;
+
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import run.halo.app.core.extension.attachment.Policy;
+
+public interface S3LinkService {
+    Flux<Policy> listS3Policies();
+
+    Mono<S3ListResult> listObjects(String policyName, String continuationToken,
+        Integer pageSize);
+
+    Mono<LinkResult.LinkResultItem> addAttachmentRecord(String policyName, String objectKey);
+
+    Mono<S3ListResult> listObjectsUnlinked(String policyName, String continuationToken,
+        String continuationObject, Integer pageSize);
+}
--- a/src/main/java/run/halo/s3os/S3LinkServiceImpl.java
+++ b/src/main/java/run/halo/s3os/S3LinkServiceImpl.java
@@ -0,0 +1,215 @@
+package run.halo.s3os;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.http.HttpStatus;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.ReactiveSecurityContextHolder;
+import org.springframework.security.core.context.SecurityContext;
+import org.springframework.stereotype.Service;
+import org.springframework.web.server.ResponseStatusException;
+import org.springframework.web.util.UriUtils;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
+import run.halo.app.core.extension.attachment.Attachment;
+import run.halo.app.core.extension.attachment.Constant;
+import run.halo.app.core.extension.attachment.Policy;
+import run.halo.app.extension.ConfigMap;
+import run.halo.app.extension.Metadata;
+import run.halo.app.extension.ReactiveExtensionClient;
+import run.halo.app.infra.utils.JsonUtils;
+import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
+import software.amazon.awssdk.regions.Region;
+import software.amazon.awssdk.services.s3.S3Client;
+import software.amazon.awssdk.services.s3.S3Configuration;
+import software.amazon.awssdk.services.s3.model.HeadObjectRequest;
+import software.amazon.awssdk.services.s3.model.ListObjectsV2Request;
+import software.amazon.awssdk.services.s3.model.S3Object;
+
+import java.net.URI;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+import static run.halo.s3os.S3OsAttachmentHandler.OBJECT_KEY;
+
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class S3LinkServiceImpl implements S3LinkService {
+    private final ReactiveExtensionClient client;
+    private final S3OsAttachmentHandler handler;
+
+
+    @Override
+    public Flux<Policy> listS3Policies() {
+        return client.list(Policy.class, (policy) -> "s3os".equals(
+            policy.getSpec().getTemplateName()), null);
+    }
+
+    @Override
+    public Mono<S3ListResult> listObjects(String policyName, String continuationToken,
+        Integer pageSize) {
+        return client.fetch(Policy.class, policyName)
+            .flatMap((policy) -> {
+                var configMapName = policy.getSpec().getConfigMapName();
+                return client.fetch(ConfigMap.class, configMapName);
+            })
+            .flatMap((configMap) -> {
+                var properties = handler.getProperties(configMap);
+                var finalLocation = FilePathUtils.getFilePathByPlaceholder(properties.getLocation());
+                return Mono.using(() -> handler.buildS3Client(properties),
+                        (s3Client) -> Mono.fromCallable(
+                            () -> s3Client.listObjectsV2(ListObjectsV2Request.builder()
+                                .bucket(properties.getBucket())
+                                .prefix(StringUtils.isNotEmpty(finalLocation)
+                                    ? finalLocation + "/" : null)
+                                .delimiter("/")
+                                .maxKeys(pageSize)
+                                .continuationToken(StringUtils.isNotEmpty(continuationToken)
+                                    ? continuationToken : null)
+                                .build())).subscribeOn(Schedulers.boundedElastic()),
+                        S3Client::close)
+                    .flatMap(listObjectsV2Response -> {
+                        List<S3Object> contents = listObjectsV2Response.contents();
+                        var objectVos = contents
+                            .stream().map(S3ListResult.ObjectVo::fromS3Object)
+                            .filter(objectVo -> !objectVo.getKey().endsWith("/"))
+                            .collect(Collectors.toMap(S3ListResult.ObjectVo::getKey, o -> o));
+                        return client.list(Attachment.class,
+                                attachment -> policyName.equals(
+                                    attachment.getSpec().getPolicyName()), null)
+                            .doOnNext(attachment -> {
+                                S3ListResult.ObjectVo objectVo =
+                                    objectVos.get(attachment.getMetadata().getAnnotations()
+                                        .getOrDefault(OBJECT_KEY, ""));
+                                if (objectVo != null) {
+                                    objectVo.setIsLinked(true);
+                                }
+                            })
+                            .then()
+                            .thenReturn(new S3ListResult(new ArrayList<>(objectVos.values()),
+                                listObjectsV2Response.continuationToken(),
+                                null, null,
+                                listObjectsV2Response.nextContinuationToken(),
+                                listObjectsV2Response.isTruncated()));
+                    });
+            });
+    }
+
+    @Override
+    public Mono<S3ListResult> listObjectsUnlinked(String policyName, String continuationToken,
+        String continuationObject, Integer pageSize) {
+        // TODO 优化成查一次数据库
+        return Mono.defer(() -> {
+            List<S3ListResult.ObjectVo> s3Objects = new ArrayList<>();
+            AtomicBoolean continuationObjectMatched = new AtomicBoolean(false);
+            AtomicReference<String> currToken = new AtomicReference<>(continuationToken);
+
+            return Flux.defer(() -> Flux.just(
+                    new TokenState(null, currToken.get() == null ? "" : currToken.get())))
+                .flatMap(tokenState -> listObjects(policyName, tokenState.nextToken, pageSize))
+                .flatMap(s3ListResult -> {
+                    var filteredObjects = s3ListResult.getObjects();
+                    if (!continuationObjectMatched.get()) {
+                        // 判断s3ListResult.getObjects()里是否有continuationObject
+                        var continuationObjectVo = s3ListResult.getObjects().stream()
+                            .filter(objectVo -> objectVo.getKey().equals(continuationObject))
+                            .findFirst();
+                        if (continuationObjectVo.isPresent()) {
+                            s3Objects.clear();
+                            // 删除continuationObject及之前的所有对象
+                            filteredObjects = s3ListResult.getObjects().stream()
+                                .dropWhile(objectVo -> !objectVo.getKey()
+                                    .equals(continuationObject))
+                                .skip(1)
+                                .toList();
+                            continuationObjectMatched.set(true);
+                        }
+                    }
+                    filteredObjects = filteredObjects.stream()
+                        .filter(objectVo -> !objectVo.getIsLinked())
+                        .toList();
+                    s3Objects.addAll(filteredObjects);
+                    currToken.set(s3ListResult.getNextToken());
+                    return Mono.just(new TokenState(s3ListResult.getCurrentToken(),
+                        s3ListResult.getNextToken()));
+                })
+                .repeat()
+                .takeUntil(
+                    tokenState -> tokenState.nextToken() == null || s3Objects.size() >= pageSize)
+                .last()
+                .map(tokenState -> {
+                    var limitedObjects = s3Objects.stream().limit(pageSize).toList();
+                    return new S3ListResult(limitedObjects, continuationToken, continuationObject,
+                            !limitedObjects.isEmpty() ? limitedObjects.get(limitedObjects.size() - 1)
+                            .getKey() : null, tokenState.currToken,
+                        limitedObjects.size() == pageSize);
+                });
+        });
+    }
+
+    record TokenState(String currToken, String nextToken) {
+    }
+
+
+    @Override
+    public Mono<LinkResult.LinkResultItem> addAttachmentRecord(String policyName,
+        String objectKey) {
+        return authenticationConsumer(authentication -> client.fetch(Policy.class, policyName)
+            .flatMap((policy) -> {
+                var configMapName = policy.getSpec().getConfigMapName();
+                return client.fetch(ConfigMap.class, configMapName);
+            })
+            .flatMap(configMap -> {
+                var properties = handler.getProperties(configMap);
+                return Mono.using(() -> handler.buildS3Client(properties),
+                        (s3Client) -> Mono.fromCallable(
+                                () -> s3Client.headObject(
+                                    HeadObjectRequest.builder()
+                                        .bucket(properties.getBucket())
+                                        .key(objectKey)
+                                        .build()))
+                            .subscribeOn(Schedulers.boundedElastic()),
+                        S3Client::close)
+                    .map(headObjectResponse -> {
+                        var objectDetail = new S3OsAttachmentHandler.ObjectDetail(
+                                new S3OsAttachmentHandler.UploadState(properties,
+                                        FileNameUtils.extractFileNameFromS3Key(objectKey), false),
+                                headObjectResponse);
+                        return handler.buildAttachment(properties, objectDetail);
+                    })
+                    .doOnNext(attachment -> {
+                        var spec = attachment.getSpec();
+                        if (spec == null) {
+                            spec = new Attachment.AttachmentSpec();
+                            attachment.setSpec(spec);
+                        }
+                        spec.setOwnerName(authentication.getName());
+                        spec.setPolicyName(policyName);
+                    })
+                    .flatMap(client::create)
+                    .thenReturn(new LinkResult.LinkResultItem(objectKey, true, null));
+            }))
+            .onErrorResume(throwable ->
+                Mono.just(new LinkResult.LinkResultItem(objectKey, false, throwable.getMessage())));
+    }
+
+    private <T> Mono<T> authenticationConsumer(Function<Authentication, Mono<T>> func) {
+        return ReactiveSecurityContextHolder.getContext()
+            .switchIfEmpty(Mono.error(() -> new ResponseStatusException(HttpStatus.UNAUTHORIZED,
+                "Authentication required.")))
+            .map(SecurityContext::getAuthentication)
+            .flatMap(func);
+    }
+
+}
--- a/src/main/java/run/halo/s3os/S3ListResult.java
+++ b/src/main/java/run/halo/s3os/S3ListResult.java
@@ -0,0 +1,38 @@
+package run.halo.s3os;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import software.amazon.awssdk.services.s3.model.S3Object;
+
+import java.time.Instant;
+import java.util.List;
+
+@Data
+@AllArgsConstructor
+public class S3ListResult {
+    private List<ObjectVo> objects;
+    private String currentToken;
+    private String currentContinuationObject;
+    private String nextContinuationObject;
+    private String nextToken;
+    private Boolean hasMore;
+
+
+    @Data
+    @AllArgsConstructor
+    public static class ObjectVo {
+        private String key;
+
+        private Instant lastModified;
+
+        private Boolean isLinked;
+
+        private String displayName;
+
+        public static ObjectVo fromS3Object(S3Object s3Object) {
+            final var key = s3Object.key();
+            final var displayName = key.substring(key.lastIndexOf("/") + 1);
+            return new ObjectVo(key, s3Object.lastModified(), false, displayName);
+        }
+    }
+}
--- a/src/main/java/run/halo/s3os/S3OsAttachmentHandler.java
+++ b/src/main/java/run/halo/s3os/S3OsAttachmentHandler.java
@@ -64,8 +64,13 @@ import software.amazon.awssdk.utils.SdkAutoCloseable;
@Extension
 public class S3OsAttachmentHandler implements AttachmentHandler {

-    private static final String OBJECT_KEY = "s3os.plugin.halo.run/object-key";
-    private static final int MULTIPART_MIN_PART_SIZE = 5 * 1024 * 1024;
+    public static final String OBJECT_KEY = "s3os.plugin.halo.run/object-key";
+    public static final String URL_SUFFIX_ANNO_KEY = "s3os.plugin.halo.run/url-suffix";
+    public static final int MULTIPART_MIN_PART_SIZE = 5 * 1024 * 1024;
+
+    /**
+     * Map to store uploading file, used as a lock, key is bucket/objectKey, value is bucket/objectKey.
+     */
    private final Map<String, Object> uploadingFile = new ConcurrentHashMap<>();

    @Override
@@ -153,6 +158,10 @@ public class S3OsAttachmentHandler implements AttachmentHandler {
        }
        var properties = getProperties(configMap);
        var objectURL = getObjectURL(properties, objectKey);
+        var urlSuffix = getUrlSuffixAnnotation(attachment);
+        if (StringUtils.isNotBlank(urlSuffix)) {
+            objectURL += urlSuffix;
+        }
        return Mono.just(URI.create(objectURL));
    }

@@ -165,6 +174,15 @@ public class S3OsAttachmentHandler implements AttachmentHandler {
        return annotations.get(OBJECT_KEY);
    }

+    @Nullable
+    private String getUrlSuffixAnnotation(Attachment attachment) {
+        var annotations = attachment.getMetadata().getAnnotations();
+        if (annotations == null) {
+            return null;
+        }
+        return annotations.get(URL_SUFFIX_ANNO_KEY);
+    }
+
    S3OsProperties getProperties(ConfigMap configMap) {
        var settingJson = configMap.getData().getOrDefault("default", "{}");
        return JsonUtils.jsonToObject(settingJson, S3OsProperties.class);
@@ -172,12 +190,19 @@ public class S3OsAttachmentHandler implements AttachmentHandler {

    Attachment buildAttachment(S3OsProperties properties, ObjectDetail objectDetail) {
        String externalLink = getObjectURL(properties, objectDetail.uploadState.objectKey);
+        var urlSuffix = UrlUtils.findUrlSuffix(properties.getUrlSuffixes(),
+            objectDetail.uploadState.fileName);

        var metadata = new Metadata();
        metadata.setName(UUID.randomUUID().toString());
-        metadata.setAnnotations(new HashMap<>(
-            Map.of(OBJECT_KEY, objectDetail.uploadState.objectKey,
-                Constant.EXTERNAL_LINK_ANNO_KEY, externalLink)));
+
+        var annotations = new HashMap<>(Map.of(OBJECT_KEY, objectDetail.uploadState.objectKey));
+        if (StringUtils.isNotBlank(urlSuffix)) {
+            externalLink += urlSuffix;
+            annotations.put(URL_SUFFIX_ANNO_KEY, urlSuffix);
+        }
+        annotations.put(Constant.EXTERNAL_LINK_ANNO_KEY, externalLink);
+        metadata.setAnnotations(annotations);

        var objectMetadata = objectDetail.objectMetadata();
        var spec = new AttachmentSpec();
@@ -193,7 +218,7 @@ public class S3OsAttachmentHandler implements AttachmentHandler {
        return attachment;
    }

-    private String getObjectURL(S3OsProperties properties, String objectKey) {
+    String getObjectURL(S3OsProperties properties, String objectKey) {
        String objectURL;
        if (StringUtils.isBlank(properties.getDomain())) {
            String host;
@@ -279,7 +304,7 @@ public class S3OsAttachmentHandler implements AttachmentHandler {
    Mono<ObjectDetail> upload(UploadContext uploadContext, S3OsProperties properties) {
        return Mono.using(() -> buildS3Client(properties),
            client -> {
-                var uploadState = new UploadState(properties, uploadContext.file().filename());
+                var uploadState = new UploadState(properties, uploadContext.file().filename(), true);

                var content = uploadContext.file().content();

@@ -391,7 +416,7 @@ public class S3OsAttachmentHandler implements AttachmentHandler {
                        uploadingFile.remove(uploadState.getUploadingMapKey());
                        uploadState.needRemoveMapKey = false;
                    }
-                    uploadState.randomFileName();
+                    uploadState.randomDuplicateFileName();
                })
            )
            .onErrorMap(Exceptions::isRetryExhausted,
@@ -467,9 +492,15 @@ public class S3OsAttachmentHandler implements AttachmentHandler {
        String objectKey;
        boolean needRemoveMapKey = false;

-        public UploadState(S3OsProperties properties, String fileName) {
+        public UploadState(S3OsProperties properties, String fileName, boolean needRandomJudge) {
            this.properties = properties;
            this.originalFileName = fileName;
+
+            if (needRandomJudge) {
+                fileName = FileNameUtils.getRandomFilename(fileName,
+                    properties.getRandomStringLength(), properties.getRandomFilenameMode());
+            }
+
            this.fileName = fileName;
            this.objectKey = properties.getObjectName(fileName);
            this.contentType = MediaTypeFactory.getMediaType(fileName)
@@ -480,8 +511,8 @@ public class S3OsAttachmentHandler implements AttachmentHandler {
            return properties.getBucket() + "/" + objectKey;
        }

-        public void randomFileName() {
-            this.fileName = FileNameUtils.randomFileName(originalFileName, 4);
+        public void randomDuplicateFileName() {
+            this.fileName = FileNameUtils.randomFilenameWithString(originalFileName, 4);
            this.objectKey = properties.getObjectName(fileName);
        }
    }
--- a/src/main/java/run/halo/s3os/S3OsProperties.java
+++ b/src/main/java/run/halo/s3os/S3OsProperties.java
@@ -1,8 +1,14 @@
 package run.halo.s3os;

+import java.util.List;
+import lombok.AllArgsConstructor;
 import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.RequiredArgsConstructor;
 import org.springframework.util.StringUtils;

+import java.time.LocalDate;
+
@Data
 class S3OsProperties {

@@ -23,6 +29,10 @@ class S3OsProperties {
     */
    private String location;

+    private String randomFilenameMode = "none";
+
+    private Integer randomStringLength = 8;
+
    private Protocol protocol = Protocol.https;

    /**
@@ -33,10 +43,21 @@ class S3OsProperties {

    private String region = "Auto";

+    private List<urlSuffixItem> urlSuffixes;
+
+    @Data
+    @AllArgsConstructor
+    @NoArgsConstructor
+    public static class urlSuffixItem {
+        private String fileSuffix;
+        private String urlSuffix;
+    }
+
    public String getObjectName(String filename) {
        var objectName = filename;
-        if (StringUtils.hasText(getLocation())) {
-            objectName = getLocation() + "/" + objectName;
+        var finalName = FilePathUtils.getFilePathByPlaceholder(getLocation());
+        if (StringUtils.hasText(finalName)) {
+            objectName = finalName + "/" + objectName;
        }
        return objectName;
    }
@@ -64,6 +85,16 @@ class S3OsProperties {
        this.location = location;
    }

+    public void setRandomStringLength(String randomStringLength) {  // if you use Integer, it will throw Error.
+        try {
+            int length = Integer.parseInt(randomStringLength);
+            if (length >= 4 && length <= 16) {
+                this.randomStringLength = length;
+            }
+        }
+        catch (NumberFormatException ignored) { }
+    }
+
    public void setRegion(String region) {
        if (!StringUtils.hasText(region)) {
            this.region = "Auto";
--- a/src/main/java/run/halo/s3os/UrlUtils.java
+++ b/src/main/java/run/halo/s3os/UrlUtils.java
@@ -2,6 +2,7 @@ package run.halo.s3os;

 import java.util.Arrays;
 import java.util.List;
+import org.apache.commons.lang3.StringUtils;

 public class UrlUtils {
    private static final List<String> HTTP_PREFIXES = Arrays.asList("http://", "https://");
@@ -17,4 +18,21 @@ public class UrlUtils {
        }
        return url;
    }
+
+    public static String findUrlSuffix(List<S3OsProperties.urlSuffixItem> urlSuffixList,
+                                       String fileName) {
+        if (StringUtils.isBlank(fileName) || urlSuffixList == null) {
+            return null;
+        }
+        fileName = fileName.toLowerCase();
+        for (S3OsProperties.urlSuffixItem item : urlSuffixList) {
+            String[] fileSuffixes = item.getFileSuffix().split(",");
+            for (String suffix : fileSuffixes) {
+                if (fileName.endsWith("." + suffix.trim().toLowerCase())) {
+                    return item.getUrlSuffix();
+                }
+            }
+        }
+        return null;
+    }
 }
--- a/src/main/resources/console/main.js
+++ b/src/main/resources/console/main.js
--- a/src/main/resources/extensions/policy-template-s3os.yaml
+++ b/src/main/resources/extensions/policy-template-s3os.yaml
@@ -45,11 +45,13 @@ spec:
          help: 协议头请在上方设置，此处无需以"http://"或"https://"开头，系统会自动拼接
        - $formkit: password
          name: accessKey
-          label: Access Key
+          label: Access Key ID
+          placeholder: 存储桶用户标识(用户名)
          validation: required
        - $formkit: password
          name: accessSecret
-          label: Access Secret
+          label: Access Key Secret
+          placeholder: 存储桶密钥(密码)
          validation: required
        - $formkit: text
          name: region
@@ -60,6 +62,30 @@ spec:
          name: location
          label: 上传目录
          placeholder: 如不填写，则默认上传到根目录
+          help: 支持使用 ${year} ${month} ${day} 占位符
+        - $formkit: select
+          name: randomFilenameMode
+          label: 上传时重命名文件方式
+          options:
+            - label: 保留原文件名
+              value: none
+            - label: 使用原文件名 + 随机字符串
+              value: withString
+            - label: 使用日期 + 随机字符串
+              value: dateWithString
+            - label: 使用日期时间 + 随机字符串
+              value: datetimeWithString
+            - label: 使用随机字符串
+              value: string
+            - label: 使用UUID
+              value: uuid
+          validation: required
+        - $formkit: number
+          name: randomStringLength
+          label: 随机字符串长度
+          min: 4
+          max: 16
+          placeholder: 仅在重命名文件时需要随机字符串时填写(支持4~16位, 默认为8位)
        - $formkit: select
          name: protocol
          label: 绑定域名协议
@@ -74,3 +100,20 @@ spec:
          label: 绑定域名（CDN域名）
          placeholder: 如不设置，那么将使用 Bucket + EndPoint 作为域名
          help: 协议头请在上方设置，此处无需以"http://"或"https://"开头，系统会自动拼接
+        - $formkit: repeater
+          name: urlSuffixes
+          label: 网址后缀
+          help: 用于对指定文件类型的网址添加后缀处理参数，优先级从上到下只取第一个匹配项
+          value: [ ]
+          min: 0
+          children:
+            - $formkit: text
+              name: fileSuffix
+              label: 文件后缀
+              placeholder: 以半角逗号分隔，例如：jpg,jpeg,png,gif
+              validation: required
+            - $formkit: text
+              name: urlSuffix
+              label: 网址后缀
+              placeholder: 例如：?imageMogr2/format/webp
+              validation: required
--- a/src/main/resources/extensions/s3os-role-template.yaml
+++ b/src/main/resources/extensions/s3os-role-template.yaml
@@ -0,0 +1,23 @@
+apiVersion: v1alpha1
+kind: "Role"
+metadata:
+  name: role-template-s3os-link
+  labels:
+    halo.run/role-template: "true"
+  annotations:
+    rbac.authorization.halo.run/dependencies: |
+      [ "role-template-manage-attachments", "role-template-view-plugins" ]
+    rbac.authorization.halo.run/module: "S3 Attachments Management"
+    rbac.authorization.halo.run/display-name: "S3 Link"
+    rbac.authorization.halo.run/ui-permissions: |
+      ["plugin:s3os:link"]
+rules:
+  - apiGroups: [ "s3os.halo.run" ]
+    resources: [ "policies" ]
+    resourceNames: [ "s3" ]
+    verbs: [ "get", "list" ]
+  - apiGroups: [ "s3os.halo.run" ]
+    resources: [ "objects" ]
+    verbs: [ "get", "list" ]
+  - nonResourceURLs: ["/apis/s3os.halo.run/v1alpha1/attachments/link"]
+    verbs: [ "create" ]
--- a/src/main/resources/extensions/settings.yaml
+++ b/src/main/resources/extensions/settings.yaml
@@ -5,7 +5,7 @@ metadata:
 spec:
  forms: 
    - group: basic
-      label: 基本设置
+      label: 使用提示
      formSchema:
        - $formkit: text
          help: 请前往 “附件 - 存储策略” 添加策略
--- a/src/main/resources/plugin.yaml
+++ b/src/main/resources/plugin.yaml
@@ -4,15 +4,14 @@ metadata:
  name: PluginS3ObjectStorage
 spec:
  enabled: true
-  version: 1.4.1
-  requires: ">=2.5.0"
+  requires: ">=2.9.0"
  author:
-    name: longjuan
-    website: https://github.com/longjuan
+    name: Halo OSS Team
+    website: https://github.com/halo-dev
  logo: data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAEAAAABACAYAAACqaXHeAAAAAXNSR0IArs4c6QAABUdJREFUeF7tmmtoXFUQx3+zMYGi/RJRULRFsL6oim2klVK0CrVqKxjoJ0Vt1bR7t6lURagiFlGpFPogydklVo1i/VB84QMfqFijpflQrI+IYj7FF+0HMbUEI82O3NNtzG6y956bvXd3IXvgksCd+c/M/8w598ycFWb5kFkePw0CGhkwyxloLIFZngCNTbCxBBpLoI4Y0A6aydNKC62kaAXGSDHCv4zQzIh0MRa3uzVdAppmMSmWoVyL0IZyWUiA3wL7gI/FcCQOMmpCQCHwDpSOCoIYQOmWLK9WgFHdr4Bu4wyOsR14uBKni3SFdxhnl+T4fCaYVcsAzbCEPNsRbpiJow46u8TwkINcCX9RNWYgr2nWIrwAzJ2BehSVAVpYJbv5y1Up8QwoBL/f1aGY5JaJ4aALVqIEqMc24EkXRxKQmSeGX8JwEyNAPR4AesMcSPD9ECdpk15GgmwkQoB2spxxPgWaEwzQBfptMdxRfQI8PgJWuniYuIyyQbLlMzH2DFCPDUAu8cDcDRwWQ1s58VgJ0E7OYZyvgAXu/lVBMiAL4iXA4z5gbxVCimpiQAxLp1OKl4AMfSj3RPWuKvJ5FkmOr0ttxUuAx9/AWVUJKKoR5QnJ8nRsBOh65tJiy9nFYJ+fwB586nUcEsN1FROgHncDG2EqWIWR/wpcUCFGsPooc6SPfyYLOS8BzbAI5RlgVQJObrXdH9iZAPb/kCkul25+jEyAejboDxJyLiMG42Orx2fAioTs+LC3iOHDSARohs0oexJxStgtPWw5jZ34IUpJS7b4kBa4BDTDTSifJBI8vC+G1ZOxdQtzGGMIOD8hm1vF2I7UxAgmwLNpn8SaHyTPjZLjWGmg6tl9YCIrYiVCuVOyvOZEQGG3fzlWB06BjZJipXTbI/OUoWmuQvgmAbs+5HIxfOlKwCFgSQKOrBNDXxCuerwH3Ba77ZPMl16GQwnQjSwkxXexO6A8JdnwDpF6tANvxG1fzNQu+LR7QEKtrFfEuNcJ6vEzcHGMJEzZdH3scgRkC6e9eOwr/Qi3iuGEK6B6PAo85yofKid40oMfV9EoR8CbENxKCjVYvNCWSg8DUXQKn8TRKDqBstOs/6AMiLelVaYUDQtO0zyPcH+YnMP7d8Vw+3Ry5TLgJeBeB2BXEX8mDwDHEUZQWzafEBNcPca2FwlrpMd+WaaM6QnI8CyKX6AkN/KsmHyfZ9voQjfKUbDPOMoCxF6TVzLKzn75JZBmOcIXlVgN0y39JGka/yOVDtOL/D5g9ssS4L9Qz5aNl0Y26KZwRAzXTBZVj8PAIjd1Z6ntYoIzuWwtoBkeK9T/ztacBUurwA1cQRODzvpugvvEcFeYaHkCHuFMRvGPwwvDQCK+P0qexZLjt9N6mmE9am+P4xnKn5LlbBew4GowzTqEF12AnGXytEuOtyaC30aKY7YRcr0zRrDg92K40hUrtCWmGfajrHUFDJHzf9tzc8na9zu1j8eCL/RKj72Zch6hBPhI6tEFbHJGnV5wSEzxjVGMrbZBlB2SJXL57kRAgQS/G7wDODcyEUKX9LC5ZOb9+wO/lV5J9+c4sIsmdkoX/v+RhzMBloRNXESeB8E+4UNtSbtHsvSXCqt/1oB2xNYc88PBiiT8uuIgTeyVLn6IqFskHomAiY0rwyUoa1BWI3YGzyu8+wPld1K8Tp5+yeL/ri90aCdXM26JuBCYN/GcOjYPIwzbv3CYJg5IF/4dQixjRgTEYrlOQBoE1MlE1MyNRgbUjPo6MdzIgDqZiJq50ciAmlFfJ4YbGVAnE1EzN2Z9BvwH8mZfUOuuxhIAAAAASUVORK5CYII=
  settingName: s3os-settings
  configMapName: s3os-configMap
-  homepage: https://github.com/halo-sigs/plugin-s3
+  homepage: https://github.com/halo-dev/plugin-s3
  displayName: "对象存储（Amazon S3 协议）"
  description: "提供兼容 Amazon S3 协议的对象存储策略，兼容阿里云、腾讯云、七牛云等"
  license:
--- a/src/test/java/run/halo/s3os/UrlUtilsTest.java
+++ b/src/test/java/run/halo/s3os/UrlUtilsTest.java
@@ -1,5 +1,6 @@
 package run.halo.s3os;

+import java.util.List;
 import org.junit.jupiter.api.Test;

 import static org.junit.jupiter.api.Assertions.*;
@@ -12,4 +13,43 @@ class UrlUtilsTest {
        assert UrlUtils.removeHttpPrefix("http://www.example.com").equals("www.example.com");
        assert UrlUtils.removeHttpPrefix("https://www.example.com").equals("www.example.com");
    }
+
+    @Test
+    public void testFindUrlSuffix() {
+        List<S3OsProperties.urlSuffixItem> urlSuffixList = List.of(
+            new S3OsProperties.urlSuffixItem("jpg,png,gif", "?imageMogr2/format/webp"),
+            new S3OsProperties.urlSuffixItem("pdf", "?123=123"),
+            new S3OsProperties.urlSuffixItem("jpg", "?456=456")
+        );
+
+        // 测试文件名为"example.jpg"，期望匹配到"?imageMogr2/format/webp"，只匹配第一个后缀
+        String fileName1 = "example.jpg";
+        String result1 = UrlUtils.findUrlSuffix(urlSuffixList, fileName1);
+        assertEquals("?imageMogr2/format/webp", result1);
+
+        // 测试文件名为"Document.PDF"，期望匹配到"?123=123"，不区分大小写
+        String fileName2 = "Document.PDF";
+        String result2 = UrlUtils.findUrlSuffix(urlSuffixList, fileName2);
+        assertEquals("?123=123", result2);
+
+        // 测试文件名为"unknown.txt"，期望没有匹配项，返回null
+        String fileName3 = "unknown.txt";
+        String result3 = UrlUtils.findUrlSuffix(urlSuffixList, fileName3);
+        assertNull(result3);
+
+        // 测试无后缀文件名"example"，期望没有匹配项，返回null
+        String fileName4 = "example";
+        String result4 = UrlUtils.findUrlSuffix(urlSuffixList, fileName4);
+        assertNull(result4);
+
+        // 测试空文件名，期望返回null
+        String fileName5 = "";
+        String result5 = UrlUtils.findUrlSuffix(urlSuffixList, fileName5);
+        assertNull(result5);
+
+        // 测试urlSuffixList为null，期望返回null
+        String fileName6 = "example";
+        String result6 = UrlUtils.findUrlSuffix(null, fileName6);
+        assertNull(result6);
+    }
 }
Author	SHA1	Message	Date
John Niang	07127d7e54	Update gradle.properties	2023-10-27 02:18:56 -05:00
longjuan	565d3cfcaa	Fix findUrlSuffix NPE when upgrading from old version (#94 ) fixes https://github.com/halo-dev/plugin-s3/issues/93 ```release-note 修复从旧版本升级后上传文件的NPE错误 ``` /kind bug	2023-10-27 02:34:15 +00:00
longjuan	c0fb2b1017	fix: s3 link error when filename renaming enable (#91 ) fixes https://github.com/halo-dev/plugin-s3/issues/90 请测试 `上传时重命名文件方式` 选项为非保留原文件名时，是否能正常关联s3文件 ![image](https://github.com/halo-dev/plugin-s3/assets/28662535/22ab0467-60bd-4c4c-a486-38bc922b7f37) ```release-note 当上传时文件重命名功能开启时关联S3文件错误 ```	2023-10-26 06:38:14 +00:00
longjuan	c79fee9ba1	perf: improve s3link role permissions (#89 ) 1. 新建用户，仅赋予 s3link 权限 2. 测试关联s3文件功能是否正常使用请使用 <`ff7af9f0d9`> 之后的版本进行测试 ```release-note 完善 s3link 角色权限 ```	2023-10-26 05:44:12 +00:00
longjuan	08d6ff49c8	feat: add URL suffix to files of specified type (#79 ) 增加网址后缀功能 ![image](https://github.com/halo-dev/plugin-s3/assets/28662535/cd56ed01-70b0-44fc-ae40-110f7c2c1aea) 此功能在文件上传和关联文件均生效 Fix #77 Fix #68 ```release-note 增加给指定类型的文件加上特定的网址后缀功能 ```	2023-10-26 05:42:17 +00:00
longjuan	73112953ba	feat: improve the styles of the data list filter area on the mobile devices (#87 ) 同步 <https://github.com/halo-dev/halo/pull/4587> 中的数据列表过滤器区域的样式改进。 ```release-note 同步移动设备上数据列表过滤器区域的样式改进 ```	2023-10-16 04:14:13 +00:00
Ryan Wang	84345ef349	chore: update github action (#84 ) Signed-off-by: Ryan Wang <i@ryanc.cc>	2023-10-08 06:49:13 -05:00
longjuan	bc4de5fb8e	fix: remove v-permission to avoid checkbox disappearing (#83 ) 移除v-permission以避免复选框消失 fixes https://github.com/halo-dev/plugin-s3/issues/82 ```release-note None ```	2023-10-08 03:32:16 +00:00
John Niang	c91f9981df	Remove unused dependencies (#81 ) This PR removes unused dependencies. ```release-note None ```	2023-10-08 02:54:15 +00:00
John Niang	0116ae65d7	Exclude reactive-streams module for runtime classpath (#80 ) Halo modified the [class loading order](https://github.com/halo-dev/halo/pull/4663) of plugins in 2.10.x to P (Plugin) D (Dependencies) A (Application), resulting in a LinkageError when the current plugin is actually run. ```java java.lang.LinkageError: loader constraint violation: when resolving method 'reactor.core.publisher.Flux reactor.core.publisher.Mono.thenMany(org.reactivestreams.Publisher)' the class loader org.pf4j.PluginClassLoader @5da2e534 of the current class, run/halo/s3os/S3OsAttachmentHandler, and the class loader org.springframework.boot.loader.LaunchedURLClassLoader @87aac27 for the method's defining class, reactor/core/publisher/Mono, have different Class objects for the type org/reactivestreams/Publisher used in the signature (run.halo.s3os.S3OsAttachmentHandler is in unnamed module of loader org.pf4j.PluginClassLoader @5da2e534, parent loader org.springframework.boot.loader.LaunchedURLClassLoader @87aac27; reactor.core.publisher.Mono is in unnamed module of loader org.springframework.boot.loader.LaunchedURLClassLoader @87aac27, parent loader 'app') at run.halo.s3os.S3OsAttachmentHandler.lambda$upload$28(S3OsAttachmentHandler.java:298) ~[na:na] at reactor.core.publisher.MonoUsing.subscribe(MonoUsing.java:85) ~[reactor-core-3.5.10.jar:3.5.10] at reactor.core.publisher.Mono.subscribe(Mono.java:4495) ~[reactor-core-3.5.10.jar:3.5.10] at reactor.core.publisher.MonoSubscribeOn$SubscribeOnSubscriber.run(MonoSubscribeOn.java:126) ~[reactor-core-3.5.10.jar:3.5.10] at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84) ~[reactor-core-3.5.10.jar:3.5.10] at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37) ~[reactor-core-3.5.10.jar:3.5.10] at java.base/java.util.concurrent.FutureTask.run(Unknown Source) ~[na:na] at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source) ~[na:na] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[na:na] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[na:na] at java.base/java.lang.Thread.run(Unknown Source) ~[na:na] ``` We just remove the reactive-streams dependency that is already in Halo to resolve the problem. Fixes https://github.com/halo-dev/halo/issues/4676 /kind bug ```release-note 修复在 Halo 2.10 中无法正常上传的问题 ```	2023-10-08 02:40:16 +00:00
longjuan	0265a71c83	chore: Modify upyun compatibility and service provider document hyperlink format (#78 ) ```release-note None ```	2023-09-27 08:12:14 +00:00
AcAutomaton	217f1db0de	feat: Time placeholder of upload path (#74 ) Fixes #69 ```release-note 文件上传路径支持使用`${year}`,`${month}`,`${day}`占位符 ```	2023-09-27 08:10:17 +00:00
AcAutomaton	38f2018fb9	chore: correct typos (#76 ) ```release-note None ```	2023-09-24 09:56:11 +00:00
Ryan Wang	faa1ad59bb	chore: change repo organization to halo-dev (#73 ) 修改仓库组织为 halo-dev /kind cleanup ```release-note None ```	2023-09-19 03:24:21 +00:00
longjuan	f784e3789c	chore: Unify the author information of plugin.yaml (#72 ) ```release-note None ```	2023-09-19 03:02:20 +00:00
AcAutomaton	e2048028f6	chore: Optimize access_key description (#71 ) Fixes #67 ```release-note 优化`Access Key`相关的描述，减少误解 ```	2023-09-18 15:52:21 +00:00
longjuan	91a61fd1d2	feat: Associate files originally in s3 (#59 ) ```release-note 关联从其他渠道上传至 s3 的文件 ``` 【插件】->【对象存储（Amazon S3 协议）】->【关联s3文件】 ![image](https://github.com/halo-sigs/plugin-s3/assets/28662535/83096e23-d362-4924-b2f0-6984683d87cf) ![image](https://github.com/halo-sigs/plugin-s3/assets/28662535/6dd74842-f9a5-4e3c-9a93-36b4b188ecf6) 目前待优化的功能： - [ ] 列出未关联的文件时会查询多次数据库，期望优化成只查询一次，但是代码改动较大。	2023-09-11 16:04:09 +00:00
AcAutomaton	1b8bef991e	feat: automatic random file renaming optional feature (#60 ) 图片等文件外链往往需要呈现给用户，由于大部分时候我们都是随手创建的新文件或从别处复制粘贴，文件名会如同`无标题.png`等，上传后按照默认策略也会如同`无标题-qiks.png`等，既不美观也会给用户造成困扰。此功能可以在上传文件时将文件名自动替换为UUID、日期、随机字符串等格式。 ```release-note 增加自动随机重命名文件可选功能 ```	2023-08-29 13:08:14 +00:00
Ryan Wang	52cfa53d7c	docs: update usage documentation of readme file (#61 ) 更新 README 中下载和安装插件的说明。 /kind documentation ```release-note None ```	2023-08-12 09:02:10 +00:00