feat: support ai chat

Author: qinluhe

deploy/nginx.conf

@@ -85,6 +85,9 @@ http {
             root /usr/share/nginx/html;
             expires 30d;
             access_log off;
+
+            add_header 'Access-Control-Allow-Origin' '*' always;
+            add_header 'Access-Control-Allow-Methods' 'GET' always;
         }
 
         location /.well-known/apple-app-site-association {

package.json

@@ -18,7 +18,8 @@
     "coverage": "pnpm run test:unit && pnpm run test:components"
   },
   "dependencies": {
-    "@appflowyinc/editor": "^0.0.40",
+    "@appflowyinc/ai-chat": "0.0.14",
+    "@appflowyinc/editor": "^0.1.5",
     "@atlaskit/primitives": "^5.5.3",
     "@emoji-mart/data": "^1.1.2",
     "@emoji-mart/react": "^1.1.1",

pnpm-lock.yaml

@@ -2695,7 +2695,8 @@
     "error": {
       "pageNameIsEmpty": "The page name is empty, please try another one"
     },
-    "visitOurWebsite": "Visit our official website"
+    "visitOurWebsite": "Visit our official website",
+    "addMessagesToPage": "Add messages to page"
   },
   "globalComment": {
     "comments": "Comments",

src/@types/translations/en.json

@@ -51,6 +51,10 @@ export * from './gotrue';
 
 let axiosInstance: AxiosInstance | null = null;
 
+export function getAxiosInstance() {
+  return axiosInstance;
+}
+
 export function initAPIService(config: AFCloudConfig) {
   if(axiosInstance) {
     return;

src/application/services/js-services/http/http_api.ts

@@ -72,6 +72,10 @@ export class AFClientService implements AFService {
     APIService.initAPIService(config.cloudConfig);
   }
 
+  getAxiosInstance() {
+    return APIService.getAxiosInstance();
+  }
+
   getClientId() {
     return this.clientId;
   }

src/application/services/js-services/index.ts

@@ -17,7 +17,7 @@ export class SyncManager {
 
   private isSending = false;
 
-  constructor (private doc: Y.Doc, private context: {
+  constructor(private doc: Y.Doc, private context: {
     userId: string, workspaceId: string, objectId: string, collabType: Types
   }) {
     this.versionVector = this.loadVersionVector();
@@ -26,41 +26,41 @@ export class SyncManager {
     this.setupListener();
   }
 
-  private setupListener () {
+  private setupListener() {
     this.doc.on('update', (_update: Uint8Array, origin: CollabOrigin) => {
-      if (origin === CollabOrigin.Remote) return;
+      if(origin === CollabOrigin.Remote) return;
       console.log('Local changes detected. Sending update...', origin);
       this.debouncedSendUpdate();
     });
   }
 
-  private getStorageKey (baseKey: string): string {
+  private getStorageKey(baseKey: string): string {
     return `${this.context.userId}_${baseKey}_${this.context.workspaceId}_${this.context.objectId}`;
   }
 
-  private loadVersionVector (): number {
+  private loadVersionVector(): number {
     const storedVector = localStorage.getItem(this.getStorageKey(VERSION_VECTOR_KEY));
 
     return storedVector ? parseInt(storedVector, 10) : 0;
   }
 
-  private saveVersionVector () {
+  private saveVersionVector() {
     localStorage.setItem(this.getStorageKey(VERSION_VECTOR_KEY), this.versionVector.toString());
   }
 
-  private loadUnsyncedFlag (): boolean {
+  private loadUnsyncedFlag(): boolean {
     return localStorage.getItem(this.getStorageKey(UNSYNCED_FLAG_KEY)) === 'true';
   }
 
-  private saveUnsyncedFlag () {
+  private saveUnsyncedFlag() {
     localStorage.setItem(this.getStorageKey(UNSYNCED_FLAG_KEY), this.hasUnsyncedChanges.toString());
   }
 
-  private loadLastSyncedAt (): string {
+  private loadLastSyncedAt(): string {
     return localStorage.getItem(this.getStorageKey(LAST_SYNCED_AT_KEY)) || '';
   }
 
-  private saveLastSyncedAt () {
+  private saveLastSyncedAt() {
     localStorage.setItem(this.getStorageKey(LAST_SYNCED_AT_KEY), this.lastSyncedAt);
   }
 
@@ -71,8 +71,8 @@ export class SyncManager {
     void this.sendUpdate();
   }, 1000);  // 1 second debounce
 
-  private async sendUpdate () {
-    if (this.isSending) return;
+  private async sendUpdate() {
+    if(this.isSending) return;
     this.isSending = true;
 
     try {
@@ -85,14 +85,14 @@ export class SyncManager {
 
       const response = await updateCollab(this.context.workspaceId, this.context.objectId, this.context.collabType, update, context);
 
-      if (response) {
+      if(response) {
         console.log(`Update sent successfully. Server version: ${response.version_vector}`);
 
         // Update last synced time
         this.lastSyncedAt = String(Date.now());
         this.saveLastSyncedAt();
 
-        if (response.version_vector === this.versionVector) {
+        if(response.version_vector === this.versionVector) {
           // Our update was the latest
           this.hasUnsyncedChanges = false;
           this.saveUnsyncedFlag();
@@ -106,7 +106,7 @@ export class SyncManager {
       } else {
         return Promise.reject(response);
       }
-    } catch (error) {
+    } catch(error) {
       console.error('Failed to send update:', error);
       // Keep the unsynced flag as true
       this.hasUnsyncedChanges = true;
@@ -116,23 +116,23 @@ export class SyncManager {
     }
   }
 
-  public initialize () {
-    if (this.hasUnsyncedChanges) {
+  public initialize() {
+    if(this.hasUnsyncedChanges) {
       console.log('Unsynced changes found. Sending update...');
       // Send an update if there are unsynced changes
       this.debouncedSendUpdate();
     }
   }
 
-  public getUnsyncedStatus (): boolean {
+  public getUnsyncedStatus(): boolean {
     return this.hasUnsyncedChanges;
   }
 
-  public getLastSyncedAt (): string {
+  public getLastSyncedAt(): string {
     return this.lastSyncedAt;
   }
 
-  public getCurrentVersionVector (): number {
+  public getCurrentVersionVector(): number {
     return this.versionVector;
   }
 }

src/application/services/js-services/sync.ts

@@ -35,9 +35,11 @@ import {
   TemplateCreator, TemplateCreatorFormValues, TemplateSummary,
   UploadTemplatePayload,
 } from '@/application/template.type';
+import { AxiosInstance } from 'axios';
 
 export type AFService = PublishService & AppService & WorkspaceService & TemplateService & QuickNoteService & {
   getClientId: () => string;
+  getAxiosInstance: () => AxiosInstance | null;
 };
 
 export interface AFServiceConfig {
@@ -163,7 +165,7 @@ export interface PublishService {
   updatePublishHomepage: (workspaceId: string, viewId: string) => Promise<void>;
   removePublishHomepage: (workspaceId: string) => Promise<void>;
 
-  getPublishOutline (namespace: string): Promise<View[]>;
+  getPublishOutline(namespace: string): Promise<View[]>;
 
   getPublishViewGlobalComments: (viewId: string) => Promise<GlobalComment[]>;
   createCommentOnPublishView: (viewId: string, content: string, replyCommentId?: string) => Promise<void>;

src/application/services/services.type.ts

@@ -102,23 +102,23 @@ export function withYjs<T extends Editor>(
   const initializeDocumentContent = () => {
     const content = yDocToSlateContent(doc);
 
-    if (!content) {
+    if(!content) {
       return;
     }
 
     const selection = e.selection;
 
-    if (readSummary) {
+    if(readSummary) {
       e.children = content.children.slice(0, 10);
     } else {
       e.children = content.children;
     }
 
-    if (selection && !ReactEditor.hasRange(editor, selection)) {
+    if(selection && !ReactEditor.hasRange(editor, selection)) {
       try {
         Transforms.select(e, Editor.start(editor, [0]));
 
-      } catch (e) {
+      } catch(e) {
         console.error(e);
         editor.deselect();
       }
@@ -130,7 +130,7 @@ export function withYjs<T extends Editor>(
   };
 
   const applyIntercept = (op: Operation) => {
-    if (YjsEditor.connected(e) && !e.interceptLocalChange) {
+    if(YjsEditor.connected(e) && !e.interceptLocalChange) {
       YjsEditor.storeLocalChange(e, op);
     }
 
@@ -145,7 +145,7 @@ export function withYjs<T extends Editor>(
     e.interceptLocalChange = true;
 
     // Initialize or update the document content to ensure it is in the correct state before applying remote events
-    if (transaction.origin === CollabOrigin.Remote) {
+    if(transaction.origin === CollabOrigin.Remote) {
 
       initializeDocumentContent();
     } else {
@@ -154,8 +154,8 @@ export function withYjs<T extends Editor>(
       Editor.withoutNormalizing(e, () => {
         translateYEvents(e, events);
       });
-      if (selection) {
-        if (!ReactEditor.hasRange(editor, selection)) {
+      if(selection) {
+        if(!ReactEditor.hasRange(editor, selection)) {
           editor.deselect();
         } else {
           e.select(selection);
@@ -169,13 +169,13 @@ export function withYjs<T extends Editor>(
   };
 
   const handleYEvents = (events: Array<YEvent>, transaction: Transaction) => {
-    if (transaction.origin === CollabOrigin.Local) return;
+    if(transaction.origin === CollabOrigin.Local) return;
     YjsEditor.applyRemoteEvents(e, events, transaction);
 
   };
 
   e.connect = () => {
-    if (YjsEditor.connected(e)) {
+    if(YjsEditor.connected(e)) {
       throw new Error('Already connected');
     }
 
@@ -186,7 +186,7 @@ export function withYjs<T extends Editor>(
   };
 
   e.disconnect = () => {
-    if (!YjsEditor.connected(e)) {
+    if(!YjsEditor.connected(e)) {
       throw new Error('Not connected');
     }
 
@@ -215,7 +215,8 @@ export function withYjs<T extends Editor>(
   e.apply = applyIntercept;
 
   e.onChange = () => {
-    if (YjsEditor.connected(e)) {
+    console.log('===onChange', e.operations);
+    if(YjsEditor.connected(e)) {
       YjsEditor.flushLocalChanges(e);
     }