Skip to content

Commit 49a0d6f

Browse files
committed
services/object: use storage GetStream in Get service
Refactor the code for using the storage 'GetStream' in the 'Get' object service to further implement its logic. Signed-off-by: Andrey Butusov <[email protected]>
1 parent ed21d3d commit 49a0d6f

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

pkg/services/object/get/util.go

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,18 @@ func (e *storageEngineWrapper) get(exec *execCtx) (*object.Object, error) {
219219
return o, nil
220220
}
221221

222-
return e.engine.Get(exec.address())
222+
header, reader, err := e.engine.GetStream(exec.address())
223+
if err != nil {
224+
return nil, err
225+
}
226+
defer func() { _ = reader.Close() }()
227+
228+
payload, err := io.ReadAll(reader)
229+
if err != nil {
230+
return nil, fmt.Errorf("can't read object payload: %w", err)
231+
}
232+
header.SetPayload(payload)
233+
return header, nil
223234
}
224235

225236
func (w *partWriter) WriteChunk(p []byte) error {

0 commit comments

Comments
 (0)