+
+
+
A progressive Node.js framework for building efficient and scalable server-side applications.
+
+
+
+
+
+
+
+ 
+ 
+ 
+
+
+
A progressive Node.js framework for building efficient and scalable server-side applications.
+
+
+
+
+
+
+
+
+
+
+
+
+
A progressive Node.js framework for building efficient and scalable server-side applications.
+
+
+
+
+
+
+
+
+
+
+
Last Updated: {formatDate(parsedUpdate)}
+ + {/*Information were last updated on {formatDate(parsedUpdate)}. To have more information on how they were retrieved, check our documentation
*/} +{formatDate(parsedTimestamp)}
+{message.content}
+{formatDate(parsedTimestamp)}
+ + )} +{errorData.message}
+{timestamp}
+{children};
+ }
+
+ const match = /language-(\w+)/.exec(className || "");
+ const language = match ? match[1].toUpperCase() : "TXT";
+
+ const handleCopy = () => {
+ navigator.clipboard.writeText(codeString);
+ setCopied(true);
+ setTimeout(() => setCopied(false), 2000);
+ };
+
+ return (
+
+ {/* Language Label */}
+
+ {language}
+
+
+ {children}
+
+
+
+
A progressive Node.js framework for building efficient and scalable server-side applications.
+
+
+
+
+
+
+
+
+
+
+
Test content
' + ), + ]; + + it('should successfully store all documents', async () => { + // Arrange + mockRepository.storeInformation.mockResolvedValue(Result.ok()); + + // Act + const result = await adapter.storeDocuments(mockDocuments); + + // Assert + expect(result.success).toBe(true); + expect(mockRepository.storeInformation).toHaveBeenCalledTimes(mockDocuments.length); + expect(mockRepository.storeInformation).toHaveBeenCalledWith( + expect.any(Information) + ); + }); + + it('should handle empty document array', async () => { + // Act + const result = await adapter.storeDocuments([]); + + // Assert + expect(result.success).toBe(true); + expect(mockRepository.storeInformation).not.toHaveBeenCalled(); + }); + + it('should handle storage errors for individual documents', async () => { + // Arrange + mockRepository.storeInformation + .mockResolvedValueOnce(Result.ok()) + .mockResolvedValueOnce(Result.fail('Storage error')); + + // Act + const result = await adapter.storeDocuments([...mockDocuments, ...mockDocuments]); + + // Assert + expect(result.success).toBe(false); + expect(result.error).toBeDefined(); + expect(mockRepository.storeInformation).toHaveBeenCalledTimes(2); + }); + + it('should handle repository errors', async () => { + // Arrange + mockRepository.storeInformation.mockRejectedValue(new Error('Repository error')); + + // Act + const result = await adapter.storeDocuments(mockDocuments); + + // Assert + expect(result.success).toBe(false); + expect(result.error).toBeDefined(); + expect(mockRepository.storeInformation).toHaveBeenCalledTimes(1); + }); + }); +}); \ No newline at end of file diff --git a/information-vector-db-service/src/adapter/out/ConfluenceStoreAdapter.ts b/information-vector-db-service/src/adapter/out/ConfluenceStoreAdapter.ts new file mode 100644 index 0000000..f20b9c4 --- /dev/null +++ b/information-vector-db-service/src/adapter/out/ConfluenceStoreAdapter.ts @@ -0,0 +1,26 @@ +import { Injectable } from "@nestjs/common"; +import { ConfluenceStoreInfoPort } from "../../application/port/out/ConfluenceStoreInfoPort.js"; +import { ConfluenceDocument } from "../../domain/business/ConfluenceDocument.js"; +import { QdrantInformationRepository } from "./persistance/qdrant-information-repository.js"; +import { Information } from "../../domain/business/information.js"; +import { Result } from "../../domain/business/Result.js"; + +@Injectable() +export class ConfluenceStoreAdapter implements ConfluenceStoreInfoPort { + constructor( + private readonly repository: QdrantInformationRepository + ) {} + async storeDocuments(req: ConfluenceDocument[]): PromiseTest content
' + ), + ]; + + it('should successfully fetch and store documents', async () => { + // Arrange + const cmd = new ConfluenceCmd(); + mockConfluenceAPIAdapter.fetchDocuments.mockResolvedValue(mockDocuments); + mockConfluenceStoreAdapter.storeDocuments.mockResolvedValue(Result.ok()); + + // Act + const result = await service.fetchAndStoreConfluenceInfo(cmd); + + // Assert + expect(result.success).toBe(true); + expect(mockConfluenceAPIAdapter.fetchDocuments).toHaveBeenCalledWith(cmd); + expect(mockConfluenceStoreAdapter.storeDocuments).toHaveBeenCalledWith(mockDocuments); + }); + + it('should handle API fetch errors', async () => { + // Arrange + const cmd = new ConfluenceCmd(); + const error = new Error('API Error'); + mockConfluenceAPIAdapter.fetchDocuments.mockRejectedValue(error); + + // Act + const result = await service.fetchAndStoreConfluenceInfo(cmd); + + // Assert + expect(result.success).toBe(false); + expect(result.error).toBeDefined(); + expect(mockConfluenceStoreAdapter.storeDocuments).not.toHaveBeenCalled(); + }); + + it('should handle storage errors', async () => { + // Arrange + const cmd = new ConfluenceCmd(); + mockConfluenceAPIAdapter.fetchDocuments.mockResolvedValue(mockDocuments); + mockConfluenceStoreAdapter.storeDocuments.mockResolvedValue(Result.fail('Storage error')); + + // Act + const result = await service.fetchAndStoreConfluenceInfo(cmd); + + // Assert + expect(result.success).toBe(false); + expect(result.error).toBeDefined(); + expect(mockConfluenceAPIAdapter.fetchDocuments).toHaveBeenCalledWith(cmd); + expect(mockConfluenceStoreAdapter.storeDocuments).toHaveBeenCalledWith(mockDocuments); + }); + }); +}); \ No newline at end of file diff --git a/information-vector-db-service/src/application/confluence.service.ts b/information-vector-db-service/src/application/confluence.service.ts new file mode 100644 index 0000000..e0e6bee --- /dev/null +++ b/information-vector-db-service/src/application/confluence.service.ts @@ -0,0 +1,25 @@ +import { Inject, Injectable } from '@nestjs/common'; +import { ConfluenceUseCase } from './port/in/ConfluenceUseCase.js'; +import { ConfluenceCmd } from '../domain/command/ConfluenceCmd.js'; +import { ConfluenceAPIPort, CONFLUENCE_API_PORT } from './port/out/ConfluenceAPIPort.js'; +import { ConfluenceStoreInfoPort, CONFLUENCE_STORE_INFO_PORT } from './port/out/ConfluenceStoreInfoPort.js'; +import { Result } from '../domain/business/Result.js'; + +@Injectable() +export class ConfluenceService implements ConfluenceUseCase { + constructor( + @Inject(CONFLUENCE_API_PORT) private readonly confluenceAPIAdapter: ConfluenceAPIPort, + @Inject(CONFLUENCE_STORE_INFO_PORT) private readonly confluenceStoreAdapter: ConfluenceStoreInfoPort + ) {} + + async fetchAndStoreConfluenceInfo(req: ConfluenceCmd): Promise