add two API calls to sync ConfluenceSpaces with data_source_folders

connectors/src/connectors/confluence/index.ts

@@ -44,7 +44,12 @@ import {
   BaseConnectorManager,
   ConnectorManagerError,
 } from "@connectors/connectors/interface";
+import { dataSourceConfigFromConnector } from "@connectors/lib/api/data_source_config";
 import { concurrentExecutor } from "@connectors/lib/async_utils";
+import {
+  deleteFolderNode,
+  upsertFolderNode,
+} from "@connectors/lib/data_sources";
 import {
   ConfluenceConfiguration,
   ConfluencePage,
@@ -322,6 +327,7 @@ export class ConfluenceConnectorManager extends BaseConnectorManager<null> {
         new Error(`Connector not found with id ${this.connectorId}`)
       );
     }
+    const dataSourceConfig = dataSourceConfigFromConnector(connector);
 
     let spaces: ConfluenceSpaceType[] = [];
     // Fetch Confluence spaces only if the intention is to add new spaces to sync.
@@ -349,6 +355,11 @@ export class ConfluenceConnectorManager extends BaseConnectorManager<null> {
           },
         });
 
+        await deleteFolderNode({
+          dataSourceConfig,
+          folderId: makeSpaceInternalId(internalId),
+        });
+
         removedSpaceIds.push(confluenceId);
       } else if (permission === "read") {
         const confluenceSpace = spaces.find((s) => s.id === confluenceId);
@@ -360,6 +371,13 @@ export class ConfluenceConnectorManager extends BaseConnectorManager<null> {
           urlSuffix: confluenceSpace?._links.webui,
         });
 
+        await upsertFolderNode({
+          dataSourceConfig,
+          folderId: makeSpaceInternalId(internalId),
+          parents: [makeSpaceInternalId(internalId)],
+          title: confluenceSpace?.name ?? confluenceId,
+        });
+
         addedSpaceIds.push(confluenceId);
       } else {
         return new Err(