spec/runners/unified/grid_fs_operations.rb in mongo-2.18.0.beta1 vs spec/runners/unified/grid_fs_operations.rb in mongo-2.18.0
- old
+ new
@@ -18,15 +18,36 @@
stream = bucket.open_download_stream(args.use!('id'))
stream.read
end
end
+ def download_by_name(op)
+ bucket = entities.get(:bucket, op.use!('object'))
+ use_arguments(op) do |args|
+ opts = {}
+ if revision = args.use('revision')
+ opts[:revision] = revision
+ end
+ stream = bucket.open_download_stream_by_name(args.use!('filename'), opts)
+ stream.read
+ end
+ end
+
def upload(op)
bucket = entities.get(:bucket, op.use!('object'))
use_arguments(op) do |args|
opts = {}
if chunk_size = args.use('chunkSizeBytes')
opts[:chunk_size] = chunk_size
+ end
+ if metadata = args.use('metadata')
+ opts[:metadata] = metadata
+ end
+ if content_type = args.use('contentType')
+ opts[:content_type] = content_type
+ end
+ if disable_md5 = args.use('disableMD5')
+ opts[:disable_md5] = disable_md5
end
contents = transform_contents(args.use!('source'))
file_id = nil
bucket.open_upload_stream(args.use!('filename'), **opts) do |stream|
stream.write(contents)