feat: 新版挂件-支持博客园快速发布

src/adaptors/api/base/metaweblog/metaweblogBlogApi.ts

@@ -0,0 +1,277 @@
+/*
+ * Copyright (c) 2023, Terwer . All rights reserved.
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
+ *
+ * This code is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License version 2 only, as
+ * published by the Free Software Foundation.  Terwer designates this
+ * particular file as subject to the "Classpath" exception as provided
+ * by Terwer in the LICENSE file that accompanied this code.
+ *
+ * This code is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
+ * version 2 for more details (a copy is included in the LICENSE file that
+ * accompanied this code).
+ *
+ * You should have received a copy of the GNU General Public License version
+ * 2 along with this work; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * Please contact Terwer, Shenzhen, Guangdong, China, youweics@163.com
+ * or visit www.terwer.space if you need additional information or have any
+ * questions.
+ */
+
+import { BlogApi, CategoryInfo, Post, PostStatusEnum, UserBlog } from "zhi-blog-api"
+import { AppInstance } from "~/src/appInstance.ts"
+import { CnblogsConfig } from "~/src/adaptors/api/cnblogs/config/cnblogsConfig.ts"
+import { createAppLogger } from "~/src/utils/appLogger.ts"
+import { CommonXmlrpcClient } from "zhi-xmlrpc-middleware"
+import { MetaweblogConfig } from "~/src/adaptors/api/base/metaweblog/config/MetaweblogConfig.ts"
+import { MetaweblogConstants } from "~/src/adaptors/api/base/metaweblog/metaweblogConstants.ts"
+import { StrUtil } from "zhi-common"
+import { BrowserUtil } from "zhi-device"
+
+/**
+ * MetaweblogBlogApi 类继承自 BlogApi 类，并为 Metaweblog API 提供了额外的功能
+ *
+ * @author terwer
+ * @version 0.9.0
+ * @since 0.9.0
+ */
+class MetaweblogBlogApi extends BlogApi {
+  protected readonly cfg: MetaweblogConfig
+  protected logger
+  private readonly commonXmlrpcClient
+
+  /**
+   * 初始化 metaweblog API 适配器
+   *
+   * @param appInstance 应用实例
+   * @param cfg 配置项
+   */
+  constructor(appInstance: AppInstance, cfg: CnblogsConfig) {
+    super()
+
+    this.cfg = cfg
+    this.cfg.blogid = "metaweblog"
+    this.logger = createAppLogger("metaweblog-api-adaptor")
+    this.commonXmlrpcClient = new CommonXmlrpcClient(appInstance, cfg.apiUrl)
+  }
+
+  public override async getUsersBlogs(): Promise<Array<UserBlog>> {
+    let result: UserBlog[] = []
+    result = await this.metaweblogCall(MetaweblogConstants.METHOD_GET_USERS_BLOGS, [
+      this.cfg.blogid,
+      this.cfg.username,
+      this.cfg.password,
+    ])
+    this.logger.debug("getUsersBlogs=>", result)
+    return result
+  }
+
+  /**
+   * Not supported
+   *
+   * @param keyword
+   */
+  public override async getRecentPostsCount(keyword?: string): Promise<number> {
+    return 0
+  }
+
+  public override async getRecentPosts(numOfPosts: number): Promise<Post[]> {
+    const result: Post[] = []
+    const blogPosts = await this.metaweblogCall(MetaweblogConstants.METHOD_GET_RECENT_POSTS, [
+      this.cfg.blogid,
+      this.cfg.username,
+      this.cfg.password,
+      numOfPosts,
+    ])
+
+    for (let i = 0; i < blogPosts.length; i++) {
+      const blogPost = blogPosts[i]
+
+      // 适配公共属性
+      const commonPost = new Post()
+      commonPost.postid = blogPost.postid
+      commonPost.title = blogPost.title
+      commonPost.mt_keywords = blogPost.mt_keywords
+      commonPost.permalink = blogPost.permalink
+      commonPost.description = blogPost.description
+      commonPost.wp_slug = blogPost.wp_slug
+      commonPost.dateCreated = blogPost.dateCreated
+      commonPost.categories = blogPost.categories
+      result.push(commonPost)
+    }
+
+    return result
+  }
+
+  public async getPost(postid: string): Promise<Post> {
+    const data = await this.metaweblogCall(MetaweblogConstants.METHOD_GET_POST, [
+      postid,
+      this.cfg.username,
+      this.cfg.password,
+    ])
+    return data
+  }
+
+  /**
+   * 新建文章
+   * @param post
+   * @param publish
+   */
+  public async newPost(post: Post, publish: boolean = true): Promise<string> {
+    // 草稿
+    if (!publish) {
+      post.post_status = PostStatusEnum.PostStatusEnum_Draft
+    }
+
+    const postStruct = this.createPostStruct(post)
+    this.logger.debug("postStruct=>", postStruct)
+    let ret = await this.metaweblogCall(MetaweblogConstants.METHOD_NEW_POST, [
+      this.cfg.blogid,
+      this.cfg.username,
+      this.cfg.password,
+      postStruct,
+      publish,
+    ])
+    ret = ret + ""
+    ret = ret.replace(/"/g, "")
+    this.logger.debug("ret=>", ret)
+
+    return ret
+  }
+
+  public async editPost(postid: string, post: Post, publish: boolean = true): Promise<boolean> {
+    // 草稿
+    if (!publish) {
+      post.post_status = PostStatusEnum.PostStatusEnum_Draft
+    }
+
+    const postStruct = this.createPostStruct(post)
+    this.logger.debug("postStruct=>", postStruct)
+    const ret = await this.metaweblogCall(MetaweblogConstants.METHOD_EDIT_POST, [
+      postid,
+      this.cfg.username,
+      this.cfg.password,
+      postStruct,
+      publish,
+    ])
+    this.logger.debug("ret=>", ret)
+    return ret
+  }
+
+  public async deletePost(postid: string): Promise<boolean> {
+    const ret = await this.metaweblogCall(MetaweblogConstants.METHOD_DELETE_POST, [
+      this.cfg.blogid,
+      postid,
+      this.cfg.username,
+      this.cfg.password,
+    ])
+    this.logger.debug("ret=>", ret)
+
+    return ret
+  }
+
+  public async getCategories(): Promise<CategoryInfo[]> {
+    const result = [] as CategoryInfo[]
+
+    try {
+      const ret = await this.metaweblogCall(MetaweblogConstants.METHOD_GET_CATEGORIES, [
+        this.cfg.blogid,
+        this.cfg.username,
+        this.cfg.password,
+      ])
+      const dataArr = ret
+      this.logger.debug("获取的分类信息，dataArr=>", dataArr)
+
+      dataArr.forEach((item: any) => {
+        const cat = new CategoryInfo()
+        cat.description = item.description
+        cat.categoryId = item.categoryId
+        result.push(cat)
+      })
+    } catch (e) {
+      this.logger.error("分类获取失败", e)
+    }
+
+    return result
+  }
+
+  protected async metaweblogCall(method: string, params: any[]) {
+    return await this.commonXmlrpcClient.methodCall(method, params, this.cfg.middlewareUrl)
+  }
+
+  /**
+   * 适配文章字段
+   * @param post 原始文章
+   * @private
+   */
+  private createPostStruct(post: Post): object {
+    const postObj = {}
+
+    if (!StrUtil.isEmptyString(post.title)) {
+      Object.assign(postObj, {
+        title: post.title,
+      })
+    }
+
+    if (!StrUtil.isEmptyString(post.mt_keywords)) {
+      Object.assign(postObj, {
+        mt_keywords: post.mt_keywords,
+      })
+    }
+
+    if (!StrUtil.isEmptyString(post.description)) {
+      Object.assign(postObj, {
+        description: post.description,
+      })
+    }
+
+    if (!StrUtil.isEmptyString(post.wp_slug)) {
+      Object.assign(postObj, {
+        wp_slug: post.wp_slug,
+      })
+    }
+
+    // 浏览器端的date转换有问题
+    if (!BrowserUtil.isInBrowser) {
+      Object.assign(postObj, {
+        // 这里要注意时间格式
+        // http://www.ab-weblog.com/en/create-new-posts-with-publishing-date-in-wordpress-using-xml-rpc-and-php/
+        // dateCreated: post.dateCreated.toISOString() || new Date().toISOString()
+        dateCreated: post.dateCreated || new Date(),
+      })
+    }
+
+    Object.assign(postObj, {
+      categories: post.categories || [],
+    })
+
+    Object.assign(postObj, {
+      post_status: post.post_status ?? PostStatusEnum.PostStatusEnum_Publish,
+    })
+
+    if (!StrUtil.isEmptyString(post.wp_password)) {
+      Object.assign(postObj, {
+        wp_password: post.wp_password,
+      })
+    }
+
+    return postObj
+    // return {
+    //     title: post.title || '',
+    //     mt_keywords: post.mt_keywords || '',
+    //     description: post.description || '',
+    //     wp_slug: post.wp_slug || '',
+    //     dateCreated: post.dateCreated.toISOString() || new Date().toISOString(),
+    //     categories: post.categories || [],
+    //     post_status: post.post_status || POST_STATUS_CONSTANTS.POST_STATUS_PUBLISH,
+    //     wp_password: post.wp_password || ''
+    // }
+  }
+}
+
+export { MetaweblogBlogApi }

src/adaptors/api/base/metaweblog/metaweblogConstants.ts

@@ -0,0 +1,43 @@
+/*
+ * Copyright (c) 2023, Terwer . All rights reserved.
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
+ *
+ * This code is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License version 2 only, as
+ * published by the Free Software Foundation.  Terwer designates this
+ * particular file as subject to the "Classpath" exception as provided
+ * by Terwer in the LICENSE file that accompanied this code.
+ *
+ * This code is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
+ * version 2 for more details (a copy is included in the LICENSE file that
+ * accompanied this code).
+ *
+ * You should have received a copy of the GNU General Public License version
+ * 2 along with this work; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * Please contact Terwer, Shenzhen, Guangdong, China, youweics@163.com
+ * or visit www.terwer.space if you need additional information or have any
+ * questions.
+ */
+
+/**
+ * 预定义 Metaweblog 变量
+ *
+ * @author terwer
+ * @version 0.9.0
+ * @since 0.9.0
+ */
+class MetaweblogConstants {
+  public static METHOD_GET_USERS_BLOGS = "metaWeblog.getUsersBlogs"
+  public static METHOD_NEW_POST = "metaWeblog.newPost"
+  public static METHOD_EDIT_POST = "metaWeblog.editPost"
+  public static METHOD_DELETE_POST = "blogger.deletePost"
+  public static METHOD_GET_RECENT_POSTS = "metaWeblog.getRecentPosts"
+  public static METHOD_GET_POST = "metaWeblog.getPost"
+  public static METHOD_GET_CATEGORIES = "metaWeblog.getCategories"
+}
+
+export { MetaweblogConstants }

src/adaptors/api/cnblogs/adaptor/cnblogsApiAdaptor.ts

@@ -23,12 +23,12 @@
  * questions.
  */
 
-import { BlogApi, UserBlog } from "zhi-blog-api"
+import { UserBlog } from "zhi-blog-api"
 import { CnblogsConfig } from "~/src/adaptors/api/cnblogs/config/cnblogsConfig.ts"
-import { CommonXmlrpcClient } from "zhi-xmlrpc-middleware"
 import { AppInstance } from "~/src/appInstance.ts"
 import { createAppLogger } from "~/src/utils/appLogger.ts"
 import { CnblogsConstants } from "~/src/adaptors/api/cnblogs/cnblogsConstants.ts"
+import { MetaweblogBlogApi } from "~/src/adaptors/api/base/metaweblog/metaweblogBlogApi.ts"
 
 /**
  * 博客园 API 适配器
@@ -39,36 +39,45 @@ import { CnblogsConstants } from "~/src/adaptors/api/cnblogs/cnblogsConstants.ts
  * @version 0.9.0
  * @since 0.9.0
  */
-class CnblogsApiAdaptor extends BlogApi {
-  private readonly logger
-  private readonly cfg: CnblogsConfig
-  private readonly commonXmlrpcClient
-
+class CnblogsApiAdaptor extends MetaweblogBlogApi {
   /**
    * 初始化博客园 API 适配器
    *
    * @param appInstance 应用实例
    * @param cfg 配置项
    */
   constructor(appInstance: AppInstance, cfg: CnblogsConfig) {
-    super()
-
-    this.cfg = cfg
+    super(appInstance, cfg)
     this.logger = createAppLogger("cnblogs-api-adaptor")
-    this.commonXmlrpcClient = new CommonXmlrpcClient(appInstance, cfg.apiUrl)
+    this.cfg.blogid = "cnblogs"
   }
 
   public override async getUsersBlogs(): Promise<Array<UserBlog>> {
     let result: UserBlog[] = []
-    result = await this.cnblogsCall(CnblogsConstants.METHOD_GET_USERS_BLOGS, [])
+    result = await this.metaweblogCall(CnblogsConstants.METHOD_GET_USERS_BLOGS, [
+      this.cfg.blogid,
+      this.cfg.username,
+      this.cfg.password,
+    ])
     this.logger.debug("getUsersBlogs=>", result)
     return result
   }
 
-  private async cnblogsCall(method: string, params: string[]) {
-    const parameters = ["cnblogs", this.cfg.username, this.cfg.password]
-    params.forEach((param) => parameters.push(param))
-    return await this.commonXmlrpcClient.methodCall(method, parameters, this.cfg.middlewareUrl)
+  public override async getPreviewUrl(postid: string): Promise<string> {
+    return this.cfg.previewUrl.replace(/\[postid\]/g, postid)
+  }
+
+  public override async deletePost(postid: string): Promise<boolean> {
+    const ret = await this.metaweblogCall(CnblogsConstants.METHOD_DELETE_POST, [
+      this.cfg.blogid,
+      postid,
+      this.cfg.username,
+      this.cfg.password,
+      false,
+    ])
+    this.logger.debug("ret=>", ret)
+
+    return ret
   }
 }
 export { CnblogsApiAdaptor }