From a97bfbc9e48d7e68650a5bdfc7da661288db9d27 Mon Sep 17 00:00:00 2001 From: "A.Unger" Date: Tue, 4 Feb 2020 15:31:57 +0100 Subject: [PATCH] update service --- pkg/service/v0/service.go | 21 ++++++++++++++++++--- 1 file changed, 18 insertions(+), 3 deletions(-) diff --git a/pkg/service/v0/service.go b/pkg/service/v0/service.go index ee067f891d..e4db11353a 100644 --- a/pkg/service/v0/service.go +++ b/pkg/service/v0/service.go @@ -35,18 +35,33 @@ type Service struct { // Set implements the SettingsServiceHandler interface // This implementation replaces the existent data with the requested. It does not calculate diff func (s Service) Set(c context.Context, req *proto.Record, res *proto.Record) error { - s.Manager.Write(req) + r, err := s.Manager.Write(req) + if err != nil { + return err + } + + res.Payload = r.GetPayload() return nil } // Get implements the SettingsServiceHandler interface func (s Service) Get(c context.Context, req *proto.Query, res *proto.Record) error { - res.Payload = s.Manager.Read(req.Key).Payload + r, err := s.Manager.Read(req.GetKey()) + if err != nil { + return err + } + + res.Payload = r.GetPayload() return nil } // List implements the SettingsServiceHandler interface func (s Service) List(ctx context.Context, in *empty.Empty, res *proto.Records) error { - res.Records = s.Manager.List() + r, err := s.Manager.List() + if err != nil { + return err + } + + res.Records = r return nil }