From 301efd6aaa37abccbd0c72ca5dcd2282e75bd2cc Mon Sep 17 00:00:00 2001
From: Anton Shepilov <anton.shepilov@gmail.com>
Date: Thu, 7 Mar 2024 20:04:49 +0100
Subject: [PATCH] Check files that are missing in storage(add more information)
 (#424)

* Check files that are missing in storage(add more information)
---
 .../documents/entities/missed-drive-file.ts   | 16 ++++++++++++++++
 .../node/src/services/files/services/index.ts | 19 +++++++++++++++++--
 2 files changed, 33 insertions(+), 2 deletions(-)

diff --git a/tdrive/backend/node/src/services/documents/entities/missed-drive-file.ts b/tdrive/backend/node/src/services/documents/entities/missed-drive-file.ts
index 651298c9..40839199 100644
--- a/tdrive/backend/node/src/services/documents/entities/missed-drive-file.ts
+++ b/tdrive/backend/node/src/services/documents/entities/missed-drive-file.ts
@@ -24,6 +24,10 @@ export class MissedDriveFile {
   @Column("is_in_trash", "boolean")
   is_in_trash: boolean;
 
+  @Type(() => Boolean)
+  @Column("is_from_nextcloud", "boolean")
+  is_from_nextcloud: boolean;
+
   @Type(() => String)
   @Column("name", "string")
   name: string;
@@ -36,6 +40,14 @@ export class MissedDriveFile {
   @Column("added", "number")
   added: number;
 
+  @Type(() => Number)
+  @Column("version", "number")
+  version: number;
+
+  @Type(() => Number)
+  @Column("size", "number")
+  size: number;
+
   @Type(() => Number)
   @Column("last_modified", "number")
   last_modified: number;
@@ -47,4 +59,8 @@ export class MissedDriveFile {
   @Type(() => String)
   @Column("creator", "uuid")
   creator: string;
+
+  @Type(() => String)
+  @Column("path", "string")
+  path: string;
 }
diff --git a/tdrive/backend/node/src/services/files/services/index.ts b/tdrive/backend/node/src/services/files/services/index.ts
index 2ef67c4a..21d8ffa2 100644
--- a/tdrive/backend/node/src/services/files/services/index.ts
+++ b/tdrive/backend/node/src/services/files/services/index.ts
@@ -20,11 +20,12 @@ import {
   PreviewMessageQueueRequest,
 } from "../../../services/previews/types";
 import { PreviewFinishedProcessor } from "./preview";
-import _ from "lodash";
+import _, { isNull, isUndefined } from "lodash";
 import User from "../../user/entities/user";
 import { DriveFile } from "../../documents/entities/drive-file";
 import { MissedDriveFile } from "../../documents/entities/missed-drive-file";
 import { FileVersion } from "../../documents/entities/file-version";
+import { getPath } from "../../documents/utils";
 
 export class FileServiceImpl {
   version: "1";
@@ -342,6 +343,7 @@ export class FileServiceImpl {
   }
 
   async checkConsistency(): Promise<any> {
+    const ver = new Date().getTime();
     const data = [];
     if (!this.checkConsistencyInProgress) {
       this.checkConsistencyInProgress = true;
@@ -369,7 +371,16 @@ export class FileServiceImpl {
                       id: version.drive_item_id,
                       company_id: "00000000-0000-4000-0000-000000000000",
                     });
-                    const user = await this.userRepository.findOne({ id: doc.creator });
+                    let user = await this.userRepository.findOne({ id: doc.creator });
+                    const isFromNextcloud = isUndefined(user) || isNull(user);
+                    const path = await getPath(doc.id, this.documentRepository, true, {
+                      company: { id: "00000000-0000-4000-0000-000000000000" },
+                    } as CompanyExecutionContext);
+                    if (isFromNextcloud) {
+                      if (path[0].id.startsWith("user_")) {
+                        user = await this.userRepository.findOne({ id: path[0].id.substring(5) });
+                      }
+                    }
                     const missedFile = new MissedDriveFile();
                     Object.assign(missedFile, {
                       id: version.file_metadata.external_id,
@@ -380,6 +391,10 @@ export class FileServiceImpl {
                       name: doc.name,
                       is_in_trash: doc.is_in_trash,
                       user_email: user?.email_canonical,
+                      is_from_nextcloud: isFromNextcloud,
+                      path: path.map(e => e?.name).join("/"),
+                      size: doc.size,
+                      version: ver,
                     });
                     await this.missedFileRepository.save(missedFile);
                     logger.info(`Missing file:: ${JSON.stringify(missedFile)}`);