2020-01-24 18:09:00 +00:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
|
|
|
module Repositories
|
|
|
|
class LfsStorageController < Repositories::GitHttpClientController
|
|
|
|
include LfsRequest
|
|
|
|
include WorkhorseRequest
|
|
|
|
include SendFileUpload
|
|
|
|
|
|
|
|
skip_before_action :verify_workhorse_api!, only: :download
|
|
|
|
|
|
|
|
def download
|
|
|
|
lfs_object = LfsObject.find_by_oid(oid)
|
|
|
|
unless lfs_object && lfs_object.file.exists?
|
|
|
|
render_lfs_not_found
|
|
|
|
return
|
|
|
|
end
|
|
|
|
|
|
|
|
send_upload(lfs_object.file, send_params: { content_type: "application/octet-stream" })
|
|
|
|
end
|
|
|
|
|
|
|
|
def upload_authorize
|
|
|
|
set_workhorse_internal_api_content_type
|
|
|
|
|
|
|
|
authorized = LfsObjectUploader.workhorse_authorize(has_length: true)
|
|
|
|
authorized.merge!(LfsOid: oid, LfsSize: size)
|
|
|
|
|
|
|
|
render json: authorized
|
|
|
|
end
|
|
|
|
|
|
|
|
def upload_finalize
|
|
|
|
if store_file!(oid, size)
|
2020-11-11 00:08:58 +00:00
|
|
|
head 200, content_type: LfsRequest::CONTENT_TYPE
|
2020-01-24 18:09:00 +00:00
|
|
|
else
|
|
|
|
render plain: 'Unprocessable entity', status: :unprocessable_entity
|
|
|
|
end
|
|
|
|
rescue ActiveRecord::RecordInvalid
|
|
|
|
render_lfs_forbidden
|
|
|
|
rescue UploadedFile::InvalidPathError
|
|
|
|
render_lfs_forbidden
|
|
|
|
rescue ObjectStorage::RemoteStoreError
|
|
|
|
render_lfs_forbidden
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def download_request?
|
|
|
|
action_name == 'download'
|
|
|
|
end
|
|
|
|
|
|
|
|
def upload_request?
|
|
|
|
%w[upload_authorize upload_finalize].include? action_name
|
|
|
|
end
|
|
|
|
|
|
|
|
def oid
|
|
|
|
params[:oid].to_s
|
|
|
|
end
|
|
|
|
|
|
|
|
def size
|
|
|
|
params[:size].to_i
|
|
|
|
end
|
|
|
|
|
2020-10-26 12:08:44 +00:00
|
|
|
def uploaded_file
|
|
|
|
params[:file]
|
|
|
|
end
|
|
|
|
|
2020-01-24 18:09:00 +00:00
|
|
|
# rubocop: disable CodeReuse/ActiveRecord
|
|
|
|
def store_file!(oid, size)
|
|
|
|
object = LfsObject.find_by(oid: oid, size: size)
|
2020-10-26 12:08:44 +00:00
|
|
|
|
|
|
|
if object
|
|
|
|
replace_file!(object) unless object.file&.exists?
|
|
|
|
else
|
2020-01-24 18:09:00 +00:00
|
|
|
object = create_file!(oid, size)
|
|
|
|
end
|
|
|
|
|
|
|
|
return unless object
|
|
|
|
|
|
|
|
link_to_project!(object)
|
|
|
|
end
|
|
|
|
# rubocop: enable CodeReuse/ActiveRecord
|
|
|
|
|
|
|
|
def create_file!(oid, size)
|
2020-08-05 21:09:40 +00:00
|
|
|
return unless uploaded_file.is_a?(UploadedFile)
|
2020-01-24 18:09:00 +00:00
|
|
|
|
|
|
|
LfsObject.create!(oid: oid, size: size, file: uploaded_file)
|
|
|
|
end
|
|
|
|
|
2020-10-26 12:08:44 +00:00
|
|
|
def replace_file!(lfs_object)
|
|
|
|
raise UploadedFile::InvalidPathError unless uploaded_file.is_a?(UploadedFile)
|
|
|
|
|
|
|
|
Gitlab::AppJsonLogger.info(message: "LFS file replaced because it did not exist", oid: oid, size: size)
|
|
|
|
lfs_object.file = uploaded_file
|
|
|
|
lfs_object.save!
|
|
|
|
end
|
|
|
|
|
2020-01-24 18:09:00 +00:00
|
|
|
def link_to_project!(object)
|
2020-02-07 12:09:13 +00:00
|
|
|
return unless object
|
|
|
|
|
|
|
|
LfsObjectsProject.safe_find_or_create_by!(
|
|
|
|
project: project,
|
|
|
|
lfs_object: object
|
|
|
|
)
|
2020-01-24 18:09:00 +00:00
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|