Merge pull request #405 from tapdata/feat/TAP-5855-incremental-verification

Feat/tap 5855 incremental verification

Author: cn-xufei

apps/daas/src/vuex/modules/feature.js

@@ -1,5 +1,4 @@
 import { licensesApi } from '@tap/api'
-import { SettingList } from '@/router/menu'
 
 const MENU_FEATURE_MAP = {
   dataService: 'dataService',

packages/api/src/TaskInspect.ts

@@ -0,0 +1,81 @@
+import Http from './Http'
+
+interface TaskInspectConfig {
+  custom: {
+    cdc: {
+      enable: boolean
+      sample: {
+        interval: number
+        limit: number
+      }
+      type: 'CLOSE' | 'SAMPLE'
+    }
+    full?: {
+      enable: boolean
+      cron: string
+      diffEnable: boolean
+      diffLimit: number
+      diffRetryTimes: number
+      sampleLimit: number
+      samplePercent: number
+      trigger: string
+      type: string
+    }
+    recover?: {
+      enable: boolean
+    }
+  }
+  intelligent?: {
+    cdcSampleInterval: number
+    cdcSampleLimit: number
+    enableRecover: boolean
+    fullDiffLimit: number
+    fullSampleLimit: number
+  }
+  mode: 'CLOSE' | 'INTELLIGENT' | 'CUSTOM'
+}
+
+interface TaskInspectHistory {
+  id: string
+  taskId: string
+  createdAt: string
+  status: string
+  type: string
+  [key: string]: any
+}
+
+export default class TaskInspect extends Http {
+  constructor() {
+    super('/api/task-inspect')
+  }
+
+  async getConfig(taskId: string, params?: any): Promise<TaskInspectConfig> {
+    const response = (await this.axios.get(`${this.url}/${taskId}`, {
+      params,
+    })) as unknown as TaskInspectConfig
+
+    return (
+      response || {
+        mode: 'CLOSE',
+        custom: {
+          cdc: {
+            enable: true,
+            sample: { interval: 10, limit: 1 },
+            type: 'SAMPLE',
+          },
+        },
+      }
+    )
+  }
+
+  putConfig(taskId: string, params: TaskInspectConfig) {
+    return this.axios.put<TaskInspectConfig>(`${this.url}/${taskId}`, params)
+  }
+
+  getHistories(taskId: string, params: any) {
+    return this.axios.get<TaskInspectHistory[]>(
+      `${this.url}/${taskId}/histories`,
+      { params },
+    )
+  }
+}

packages/api/src/index.ts

@@ -250,6 +250,9 @@ const agentGroupApi = new AgentGroup()
 import Webhook from './Webhook'
 const webhookApi = new Webhook()
 
+import TaskInspect from './TaskInspect'
+const taskInspectApi = new TaskInspect()
+
 export {
   connectionsApi,
   databaseTypesApi,
@@ -313,7 +316,8 @@ export {
   connectorRecordApi,
   alarmMailApi,
   agentGroupApi,
-  webhookApi
+  webhookApi,
+  taskInspectApi
 }
 export * from './ApiClient'
 

packages/assets/icons/svg/ArrowToTopRightLinear.svg

@@ -408,17 +408,17 @@
     margin-left: 0;
   }
 
-  &.is-text.el-button--small:has(> i:only-child) {
+  &.is-text.el-button--small:has(> i:only-child), &.is-text.el-button--small:has(> i + span:empty) {
     --el-border-radius-base: var(--el-border-radius-small);
     font-size: 16px;
   }
 
   // 这里的default 介于按钮的 sm/default 之间
-  &.is-text.el-button--default:has(> i:only-child) {
+  &.is-text.el-button--default:has(> i:only-child), &.is-text.el-button--default:has(> i + span:empty) {
     font-size: 18px;
   }
 
-  &.is-text.el-button--large:has(> i:only-child) {
+  &.is-text.el-button--large:has(> i:only-child), &.is-text.el-button--large:has(> i + span:empty) {
     font-size: 24px;
   }
 }