feat: 添加推送到Bing支持

.gitignore

@@ -51,3 +51,5 @@ bin/process-reporter
 
 dist
 dev/
+
+.eslintcache

apps/core/readme.md

@@ -166,6 +166,7 @@ ResponseInterceptor -> ResponseFilterInterceptor -> JSONTransformInterceptor ->
   1. [CronService] 维护管理计划任务
      - 自动备份
      - 推送百度搜索
+     - 推送Bing搜索
      - 清除缓存
      - etc.
   1. [EmailService] 送信服务

apps/core/src/constants/error-code.constant.ts

@@ -25,6 +25,11 @@ export enum ErrorCodeEnum {
   // system
   MasterLost = 99998,
   BanInDemo = 999999,
+
+  //Bing
+  BingAPIFailed = 300002,
+  BingKeyInvalid = 300003,
+  BingDomainInvalid = 300004,
 }
 
 export const ErrorCode = Object.freeze<Record<ErrorCodeEnum, [string, number]>>(
@@ -53,5 +58,9 @@ export const ErrorCode = Object.freeze<Record<ErrorCodeEnum, [string, number]>>(
     [ErrorCodeEnum.AIResultParsingError]: ['AI 结果解析错误', 500],
 
     [ErrorCodeEnum.EmailTemplateNotFound]: ['邮件模板不存在', 400],
+
+    [ErrorCodeEnum.BingAPIFailed]: ['Bing API请求失败', 503],
+    [ErrorCodeEnum.BingKeyInvalid]: ['Bing API密钥无效', 401],
+    [ErrorCodeEnum.BingDomainInvalid]: ['Bing API域名无效', 400],
   },
 )

apps/core/src/modules/configs/configs.default.ts

@@ -51,6 +51,7 @@ export const generateDefaultConfig: () => IConfig = () => ({
     secretKey: null!,
   },
   baiduSearchOptions: { enable: false, token: null! },
+  bingSearchOptions: { enable: false, token: null! },
   algoliaSearchOptions: {
     enable: false,
     apiKey: '',

apps/core/src/modules/configs/configs.dto.ts

@@ -3,11 +3,9 @@ import {
   ArrayUnique,
   IsBoolean,
   IsEmail,
-  isInt,
   IsInt,
   IsIP,
   IsNotEmpty,
-  IsNumber,
   IsObject,
   IsOptional,
   IsString,
@@ -210,6 +208,20 @@ export class BaiduSearchOptionsDto {
   token?: string
 }
 
+@JSONSchema({ title: 'Bing推送设定' })
+export class BingSearchOptionsDto {
+  @IsOptional()
+  @IsBoolean()
+  @JSONSchemaToggleField('开启推送')
+  enable?: boolean
+
+  @IsOptional()
+  @IsString()
+  @SecretField
+  @JSONSchemaPasswordField('Bing API密钥')
+  token?: string
+}
+
 @JSONSchema({ title: 'Algolia Search' })
 export class AlgoliaSearchOptionsDto {
   @IsBoolean()

apps/core/src/modules/configs/configs.interface.ts

@@ -15,6 +15,7 @@ import {
   BackupOptionsDto,
   BaiduSearchOptionsDto,
   BarkOptionsDto,
+  BingSearchOptionsDto,
   CommentOptionsDto,
   FeatureListDto,
   FriendLinkOptionsDto,
@@ -67,6 +68,8 @@ export abstract class IConfig {
   backupOptions: Required<BackupOptionsDto>
   @ConfigField(() => BaiduSearchOptionsDto)
   baiduSearchOptions: Required<BaiduSearchOptionsDto>
+  @ConfigField(() => BingSearchOptionsDto)
+  bingSearchOptions: Required<BingSearchOptionsDto>
   @ConfigField(() => AlgoliaSearchOptionsDto)
   algoliaSearchOptions: Required<AlgoliaSearchOptionsDto>
 

apps/core/src/modules/update/update.service.ts

@@ -65,7 +65,7 @@ export class UpdateService {
           return
         }
 
-        const cdnDownloadUrl = `https://mirror.ghproxy.com/${downloadUrl}`
+        const cdnDownloadUrl = `https://ghfast.top/${downloadUrl}`
         // const cdnDownloadUrl = downloadUrl
 
         subscriber.next(

apps/core/src/processors/helper/helper.cron.service.ts

@@ -21,7 +21,6 @@ import { ConfigsService } from '~/modules/configs/configs.service'
 import { InjectModel } from '~/transformers/model.transformer'
 import { getRedisKey } from '~/utils/redis.util'
 
-import { CacheService } from '../redis/cache.service'
 import { RedisService } from '../redis/redis.service'
 import { HttpService } from './helper.http.service'
 import { JWTService } from './helper.jwt.service'
@@ -160,6 +159,52 @@ export class CronService {
     return null
   }
 
+  @CronOnce(CronExpression.EVERY_DAY_AT_1AM, { name: 'pushToBingSearch' })
+  @CronDescription('推送到Bing')
+  async pushToBingSearch() {
+    const {
+      url: { webUrl },
+      bingSearchOptions: configs,
+    } = await this.configs.waitForConfigReady()
+
+    if (!configs.enable) {
+      return
+    }
+    const apiKey = configs.token
+    if (!apiKey) {
+      this.logger.error('[BingSearchPushTask] API key 为空')
+      return
+    }
+
+    const pushUrls = await this.aggregateService.getSiteMapContent()
+    const urls = pushUrls.map((item) => item.url)
+
+    try {
+      const res = await this.http.axiosRef.post(
+        `https://ssl.bing.com/webmaster/api.svc/json/SubmitUrlbatch?apikey=${apiKey}`,
+        {
+          siteUrl: webUrl,
+          urlList: urls,
+        },
+        {
+          headers: {
+            'Content-Type': 'application/json',
+            charset: 'utf-8',
+          },
+        },
+      )
+      if (res?.data?.d === null) {
+        this.logger.log('Bing站长提交成功')
+      } else {
+        this.logger.log(`Bing站长提交结果：${JSON.stringify(res.data)}`)
+      }
+      return res.data
+    } catch (error) {
+      this.logger.error(`Bing推送错误：${error.message}`)
+    }
+    return null
+  }
+
   @CronDescription('扫表：删除过期 JWT')
   @CronOnce(CronExpression.EVERY_DAY_AT_1AM, {
     name: 'deleteExpiredJWT',

packages/api-client/models/setting.ts

@@ -37,6 +37,11 @@ export declare class BaiduSearchOptionsModel {
   enable: boolean
   token?: string
 }
+export declare class BingSearchOptionsModel {
+  enable: boolean
+  token?: string
+}
+
 export declare class AlgoliaSearchOptionsModel {
   enable: boolean
   apiKey?: string

scripts/server-deploy.js

@@ -16,7 +16,7 @@ const { homedir } = os
 const { repository } = require('../package.json')
 
 const argv = process.argv.slice(2)
-const scpPath = av['scp_path']
+const scpPath = av.scp_path
 function getOsBuildAssetName() {
   return `release-linux.zip`
 }