issue #165: work above ProtectedStorage, Input part

octopot · Sep 5, 2018 · 9b2e9bd · 9b2e9bd
1 parent a77c57c
commit 9b2e9bd
Show file tree

Hide file tree

Showing 3 changed files with 51 additions and 1 deletion.
diff --git a/pkg/server/grpc/contract.go b/pkg/server/grpc/contract.go
@@ -2,8 +2,8 @@ package grpc
 
 import (
 	"context"
-	"github.com/kamilsk/form-api/pkg/domain"
 
+	"github.com/kamilsk/form-api/pkg/domain"
 	"github.com/kamilsk/form-api/pkg/storage/query"
 	"github.com/kamilsk/form-api/pkg/storage/types"
 )
@@ -19,4 +19,6 @@ type ProtectedStorage interface {
 	ReadTemplate(context.Context, *types.Token, query.ReadTemplate) (types.Template, error)
 	UpdateTemplate(context.Context, *types.Token, query.UpdateTemplate) (types.Template, error)
 	DeleteTemplate(context.Context, *types.Token, query.DeleteTemplate) (types.Template, error)
+	ReadInputByID(context.Context, *types.Token, domain.ID) (types.Input, error)
+	ReadInputByFilter(context.Context, *types.Token, query.InputFilter) ([]types.Input, error)
 }
diff --git a/pkg/server/grpc/mock_storage_test.go b/pkg/server/grpc/mock_storage_test.go
diff --git a/pkg/storage/protected.go b/pkg/storage/protected.go
@@ -106,3 +106,25 @@ func (storage *Storage) DeleteTemplate(ctx context.Context, token *types.Token,
 
 	return storage.exec.TemplateEditor(ctx, conn).Delete(token, data)
 }
+
+// ReadInputByID TODO
+func (storage *Storage) ReadInputByID(ctx context.Context, token *types.Token, id domain.ID) (types.Input, error) {
+	conn, closer, err := storage.connection(ctx)
+	if err != nil {
+		return types.Input{}, err
+	}
+	defer closer()
+
+	return storage.exec.InputReader(ctx, conn).ReadByID(token, id)
+}
+
+// ReadInputByFilter TODO
+func (storage *Storage) ReadInputByFilter(ctx context.Context, token *types.Token, filter query.InputFilter) ([]types.Input, error) {
+	conn, closer, err := storage.connection(ctx)
+	if err != nil {
+		return nil, err
+	}
+	defer closer()
+
+	return storage.exec.InputReader(ctx, conn).ReadByFilter(token, filter)
+}