From 3c773cfa6765eeee6126616ea2a5c851325d95d4 Mon Sep 17 00:00:00 2001
From: Leonard Lyubich <leonard@nspcc.ru>
Date: Tue, 25 Aug 2020 18:58:31 +0300
Subject: [PATCH] [#13] neofs-node: Implement Object.GetRange executor

Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
---
 cmd/neofs-node/object.go | 24 ++++++++++++++++++++++--
 1 file changed, 22 insertions(+), 2 deletions(-)

diff --git a/cmd/neofs-node/object.go b/cmd/neofs-node/object.go
index d0b53986..6eaf7a15 100644
--- a/cmd/neofs-node/object.go
+++ b/cmd/neofs-node/object.go
@@ -23,6 +23,10 @@ type simpleGetBodyStreamer struct {
 
 type simplePutBodyStreamer struct{}
 
+type simpleRangeBodyStreamer struct {
+	count int
+}
+
 type objectExecutor struct{}
 
 func (s *simpleGetBodyStreamer) Recv() (*object.GetResponseBody, error) {
@@ -86,8 +90,24 @@ func (*objectExecutor) Delete(context.Context, *object.DeleteRequestBody) (*obje
 	panic("implement me")
 }
 
-func (*objectExecutor) GetRange(context.Context, *object.GetRangeRequestBody) (objectService.GetRangeObjectBodyStreamer, error) {
-	panic("implement me")
+func (s *simpleRangeBodyStreamer) Recv() (*object.GetRangeResponseBody, error) {
+	body := new(object.GetRangeResponseBody)
+
+	if s.count == 0 {
+		body.SetChunk([]byte{1, 2, 2, 1})
+	} else if s.count == 1 {
+		body.SetChunk([]byte{4, 2, 4, 2})
+	} else {
+		return nil, io.EOF
+	}
+
+	s.count++
+
+	return body, nil
+}
+
+func (*objectExecutor) GetRange(_ context.Context, body *object.GetRangeRequestBody) (objectService.GetRangeObjectBodyStreamer, error) {
+	return new(simpleRangeBodyStreamer), nil
 }
 
 func (*objectExecutor) GetRangeHash(context.Context, *object.GetRangeHashRequestBody) (*object.GetRangeHashResponseBody, error) {