Allow duplicated documents

app/DocumentDescriptor.php

@@ -212,6 +212,14 @@ public function owner()
         return $this->belongsTo('KBox\User', 'owner_id', 'id');
     }
 
+    /**
+     * All duplicates of the document in the system
+     */
+    public function duplicates()
+    {
+        return $this->hasMany('KBox\DuplicateDocument', 'duplicate_document_id', 'id');
+    }
+
     /**
      * Get the Projects that contain this document descriptor
      *
@@ -503,7 +511,24 @@ public function getCopyrightOwnerAttribute($value = null)
         return $this->castAttribute('copyright_owner', $value);
     }
 
-
+    public function getDocumentUriAttribute($value = null)
+    {
+        if (! $value) {
+            return route('documents.preview', ['uuid' => $this->uuid]);
+        }
+
+        return $value;
+    }
+
+    public function getThumbnailUriAttribute($value = null)
+    {
+        if (! $value) {
+            return route('documents.thumbnail', ['uuid' => $this->uuid]);
+        }
+
+        return $value;
+    }
+
     // --- convert to/from KlinkDocumentDescriptor
 
     /**

app/DuplicateDocument.php

@@ -0,0 +1,183 @@
+<?php
+
+namespace KBox;
+
+use Carbon\Carbon;
+use Illuminate\Support\HtmlString;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Contracts\Support\Htmlable;
+
+class DuplicateDocument extends Model implements Htmlable
+{
+    protected $table = 'duplicate_descriptors';
+
+    protected $dates = ['notification_sent_at', 'resolved_at'];
+
+    protected $fillable = ['user_id','duplicate_document_id', 'document_id', 'resolved_at'];
+
+    /**
+     * Set if the user has been notified
+     *
+     * @param  bool  $started
+     * @return void
+     */
+    public function setSentAttribute($sent)
+    {
+        if ($sent && ! $this->notification_sent_at) {
+            $this->attributes['notification_sent_at'] = Carbon::now();
+        }
+
+        if (! $sent && $this->notification_sent_at) {
+            $this->attributes['notification_sent_at'] = null;
+        }
+    }
+
+    /**
+     * Get if user has been notified
+     *
+     * @param  mixed  $value not taken into account
+     * @return bool
+     */
+    public function getSentAttribute($value = null)
+    {
+        return isset($this->attributes['notification_sent_at']) && ! is_null($this->attributes['notification_sent_at']);
+    }
+
+    /**
+     * Set if the user has resolved the duplication with an action
+     *
+     * @param  bool  $started
+     * @return void
+     */
+    public function setResolvedAttribute($resolved)
+    {
+        if ($resolved && ! $this->resolved_at) {
+            $this->attributes['resolved_at'] = Carbon::now();
+        }
+
+        if (! $resolved && $this->resolved_at) {
+            $this->attributes['resolved_at'] = null;
+        }
+    }
+
+    /**
+     * Get if user has resolved the duplication
+     *
+     * @param  mixed  $value not taken into account
+     * @return bool
+     */
+    public function getResolvedAttribute($value = null)
+    {
+        return isset($this->attributes['resolved_at']) && ! is_null($this->attributes['resolved_at']);
+    }
+
+    /**
+     * Get a message representing the duplicate.
+     *
+     * @param  mixed  $value not taken into account
+     * @return bool
+     */
+    public function getMessageAttribute($value = null)
+    {
+        if (is_null($this->document) || is_null($this->duplicateOf)) {
+            return '';
+        }
+
+        $args = [
+            'duplicate_link' => RoutingHelpers::preview($this->document),
+            'duplicate_title' => e($this->document->title),
+            'existing_link' => RoutingHelpers::preview($this->duplicateOf),
+            'existing_title' => e($this->duplicateOf->title),
+        ];
+
+        if ($this->document->owner_id === $this->user_id && $this->duplicateOf->owner_id === $this->user_id) {
+            return trans('documents.duplicates.message_me_owner', $args);
+        }
+
+        $service = app('Klink\DmsDocuments\DocumentsService');
+
+        $collections = $service->getDocumentCollections($this->duplicateOf, $this->user);
+
+        if (! $collections->isEmpty()) {
+            return trans('documents.duplicates.message_in_collection', array_merge($args, [
+                'owner' => e($this->duplicateOf->owner->name),
+                'collections' => $collections->map(function ($c) {
+                    return '<a href="'.route('documents.groups.show', [ 'id' => $c->id, 'highlight' => $this->duplicateOf->id]).'">'.e($c->name).'</a>';
+                })->implode(', ')
+            ]));
+        } else {
+            return trans('documents.duplicates.message_with_owner', array_merge($args, [
+                'owner' => e($this->duplicateOf->owner->name)
+            ]));
+        }
+
+        return '';
+    }
+
+    /**
+     * Return the HTML short message representation of this duplicate
+     */
+    public function toHtml()
+    {
+        return new HtmlString($this->message);
+    }
+
+    /**
+     * The user that uploaded, and therefore triggered, the duplicate document finding
+     *
+     * @return \KBox\User
+     */
+    public function user()
+    {
+        return $this->belongsTo('KBox\User', 'user_id', 'id');
+    }
+
+    /**
+     * The document that caused the duplicate finding
+     *
+     * @return \Kbox\DocumentDescriptor
+     */
+    public function document()
+    {
+        return $this->belongsTo('KBox\DocumentDescriptor', 'duplicate_document_id', 'id')->withTrashed();
+    }
+
+    /**
+     * The existing document in the system
+     *
+     * @return \Kbox\DocumentDescriptor
+     */
+    public function duplicateOf()
+    {
+        return $this->belongsTo('KBox\DocumentDescriptor', 'document_id', 'id')->withTrashed();
+    }
+
+    /**
+     * Filter by user
+     * @param KBox\User|in $user
+     */
+    public function scopeOf($query, $user)
+    {
+        $id = is_a($user, 'KBox\User') ? $user->id : $user;
+
+        return $query->where('user_id', $id);
+    }
+
+    /**
+     * Filter for not sent notifications
+     *
+     */
+    public function scopeNotSent($query)
+    {
+        return $query->whereNull('notification_sent_at');
+    }
+
+    /**
+     * Filter for not sent notifications
+     *
+     */
+    public function scopeNotResolved($query)
+    {
+        return $query->whereNull('resolved_at');
+    }
+}

app/Events/FileDuplicateFoundEvent.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace KBox\Events;
+
+use KBox\User;
+use KBox\DuplicateDocument;
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Bus\Queueable;
+use Illuminate\Queue\InteractsWithQueue;
+
+class FileDuplicateFoundEvent
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels, InteractsWithQueue, Queueable;
+
+    /**
+     * @var \KBox\User;
+     */
+    public $user;
+
+    /**
+     * @var \KBox\DuplicateDocument
+     */
+    public $duplicateDocument;
+
+    /**
+     * Create a new event instance.
+     *
+     * @return void
+     */
+    public function __construct(User $user, DuplicateDocument $duplicateDocument)
+    {
+        $this->user = $user;
+        $this->duplicateDocument = $duplicateDocument;
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return Channel|array
+     */
+    public function broadcastOn()
+    {
+        return new PrivateChannel('channel-name');
+    }
+}

app/File.php

@@ -9,7 +9,6 @@
 use Carbon\Carbon;
 use Illuminate\Support\Facades\Storage;
 use Dyrynda\Database\Support\GeneratesUuid;
-use KBox\Exceptions\FileAlreadyExistsException;
 use Klink\DmsAdapter\KlinkDocumentUtils;
 use Illuminate\Support\Facades\Crypt;
 
@@ -608,7 +607,6 @@ public function videoResources()
      * @param \KBox\User $uploader The user that perfomed the upload
      * @param \KBox\File $revision_of The file that will be replaced with this new uploaded version
      * @return \KBox\File
-     * @throws \KBox\Exceptions\FileAlreadyExistsException if a file with the same hash already exists in the system
      */
     public static function createFromUploadedFile(UploadedFile $upload, User $uploader, File $revision_of = null)
     {
@@ -643,16 +641,6 @@ public static function createFromUploadedFile(UploadedFile $upload, User $upload
 
             $hash = KlinkDocumentUtils::generateDocumentHash($file_absolute_path);
 
-            if (static::existsByHash($hash)) {
-                $storage->deleteDirectory($destination_path);
-
-                $f = static::findByHash($hash);
-
-                $descr = $f->getLastVersion()->document;
-
-                throw new FileAlreadyExistsException($filename, $descr, $f);
-            }
-
             $file_model->name = $filename;
             $file_model->uuid = $uuid;
             $file_model->hash = $hash;

app/Http/Composers/DocumentsComposer.php

@@ -126,6 +126,8 @@ public function descriptor(View $view)
                 } else {
                     $view->with('badge_error', false);
                 }
+
+                $view->with('badge_duplicate', $document->duplicates()->of($auth_user)->exists());
             }
         }
     }
@@ -196,6 +198,8 @@ public function descriptorPanel(View $view)
                 } else {
                     $view->with('show_versions', false);
                 }
+
+                $view->with('badge_duplicate', $document->duplicates()->of($auth_user)->exists());
             }
         }
     }

app/Http/Composers/DuplicateDocumentsComposer.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace KBox\Http\Composers;
+
+use KBox\DocumentDescriptor;
+use Illuminate\Contracts\View\View;
+use Klink\DmsDocuments\DocumentsService;
+
+class DuplicateDocumentsComposer
+{
+
+    /**
+     * @var \Klink\DmsDocuments\DocumentsService
+     */
+    private $documents = null;
+
+
+
+    /**
+     * Create a new profile composer.
+     *
+     * @param  UserRepository  $users
+     * @return void
+     */
+    public function __construct(DocumentsService $documentsService)
+    {
+        $this->documents = $documentsService;
+    }
+
+    public function duplicatePartial(View $view)
+    {
+        $document = isset($view['duplicate']) ? $view['duplicate']->duplicateOf : null;
+
+        $auth_check = \Auth::check();
+
+        if (! $auth_check) {
+            return;
+        }
+
+        if (! is_a($document, DocumentDescriptor::class)) {
+            return;
+        }
+
+        $auth_user = \Auth::user();
+
+        $collections = $this->documents->getDocumentCollections($document, $auth_user);
+
+        $view->with('is_in_collection', ! $collections->isEmpty());
+
+        $view->with('collections', $collections);
+    }
+}