f7163afb8a
This backports to CE changes that allow the recording of the repository_type in the table lfs_objects_projects. This is in order to allow future pruning of unreferenced LFS objects, as we will need to know which repository to look in for the LFS pointer file. The EE MR that contains the original code and a full explanation of the changes is https://gitlab.com/gitlab-org/gitlab-ee/merge_requests/13894 EE Issue https://gitlab.com/gitlab-org/gitlab-ee/issues/9490 Note that there was a lot of CE code changed in the EE MR because we want to allow the wiki repository to also use LFS. See https://gitlab.com/gitlab-org/gitlab-ce/issues/43721. As the wiki is an unlicensed feature, a full backport is required to enable this.
43 lines
1.3 KiB
Ruby
43 lines
1.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class LfsObject < ApplicationRecord
|
|
include AfterCommitQueue
|
|
include ObjectStorage::BackgroundMove
|
|
|
|
has_many :lfs_objects_projects, dependent: :destroy # rubocop:disable Cop/ActiveRecordDependent
|
|
has_many :projects, -> { distinct }, through: :lfs_objects_projects
|
|
|
|
scope :with_files_stored_locally, -> { where(file_store: LfsObjectUploader::Store::LOCAL) }
|
|
|
|
validates :oid, presence: true, uniqueness: true
|
|
|
|
mount_uploader :file, LfsObjectUploader
|
|
|
|
after_save :update_file_store, if: :saved_change_to_file?
|
|
|
|
def update_file_store
|
|
# The file.object_store is set during `uploader.store!`
|
|
# which happens after object is inserted/updated
|
|
self.update_column(:file_store, file.object_store)
|
|
end
|
|
|
|
def project_allowed_access?(project)
|
|
projects.exists?(project.lfs_storage_project.id)
|
|
end
|
|
|
|
def local_store?
|
|
file_store == LfsObjectUploader::Store::LOCAL
|
|
end
|
|
|
|
# rubocop: disable DestroyAll
|
|
def self.destroy_unreferenced
|
|
joins("LEFT JOIN lfs_objects_projects ON lfs_objects_projects.lfs_object_id = #{table_name}.id")
|
|
.where(lfs_objects_projects: { id: nil })
|
|
.destroy_all
|
|
end
|
|
# rubocop: enable DestroyAll
|
|
|
|
def self.calculate_oid(path)
|
|
Digest::SHA256.file(path).hexdigest
|
|
end
|
|
end
|