feat: use KFS interface

K-nto · Oct 10, 2022 · fd1a851 · fd1a851
1 parent cbd73c0
commit fd1a851
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/src/files/files.controller.ts b/src/files/files.controller.ts
@@ -1,7 +1,7 @@
 import fileUpload from 'express-fileupload';
 import {StorageOperationController} from '../hyperledger/StorageOperationController';
 import ipfsService from '../ipfs/ipfs.service';
-import {MFSEntry} from 'ipfs-core-types/src/files';
+import {KFSEntry} from './files.interfaces';
 
 class FilesController {
   async createFile(userId: string, file: fileUpload.UploadedFile) {
@@ -11,13 +11,13 @@ class FilesController {
     try {
       return await ipfsService
         .createFile(userId, file)
-        .then((files: MFSEntry[]) => {
+        .then((files: KFSEntry[]) => {
           console.log('[DEBUG] files.controller - createFile: files', files);
 
-          files.forEach((file: MFSEntry) => {
+          files.forEach((file: KFSEntry) => {
             new StorageOperationController().createFileOperation(
               userId,
-              file.cid.toString(),
+              file.id,
               'WRITE'
             );
           });
@@ -36,13 +36,13 @@ class FilesController {
       `[INFO] files.controller - listFiles: Listing files for userId ${userId}`
     );
     try {
-      return await ipfsService.listFiles().then((files: MFSEntry[]) => {
+      return await ipfsService.listFiles().then((files: KFSEntry[]) => {
         console.log('[DEBUG] files.controller - listFiles: files', files);
 
-        files.forEach((file: MFSEntry) => {
+        files.forEach((file: KFSEntry) => {
           new StorageOperationController().createFileOperation(
             userId,
-            file.cid.toString(),
+            file.id,
             'READ'
           );
         });

diff --git a/src/ipfs/ipfs.service.ts b/src/ipfs/ipfs.service.ts
@@ -34,7 +34,7 @@ class IPFSService {
   public async createFile(
     userId: string,
     file: UploadedFile
-  ): Promise<MFSEntry[]> {
+  ): Promise<KFSEntry[]> {
     const filePath = `/${file.name}`;
     console.log('[DEBUG] IPFSService - createFile', userId, file);
 
@@ -83,7 +83,7 @@ class IPFSService {
    * @returns
    */
   public async updateFile(file: File) {
-    const result: Array<MFSEntry> = [];
+    const result: Array<KFSEntry> = [];
     // IPFSService.ipfsHttpClient.files.write('/' + file.name, file);
     // result.push(...(await all(IPFSService.ipfsHttpClient.files.ls(file.name))));
     return result;