package tree import ( "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/api/rpc/grpc" "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/api/rpc/message" tree "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/pool/tree/service" ) func metaToGRPC(m []*KeyValue) (res []*tree.KeyValue) { if m != nil { res = make([]*tree.KeyValue, 0, len(m)) for i := range m { res = append(res, m[i].ToGRPCMessage().(*tree.KeyValue)) } } return } func metaFromGRPC(m []*tree.KeyValue) (res []*KeyValue, err error) { if m != nil { res = make([]*KeyValue, len(m)) for i := range m { res[i] = new(KeyValue) err = res[i].FromGRPCMessage(m[i]) if err != nil { return } } } return } func (r *AddResponse) ToGRPCMessage() grpc.Message { var m *tree.AddResponse if r != nil { m = new(tree.AddResponse) m.Body = r.body.ToGRPCMessage().(*tree.AddResponse_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *AddResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.AddResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(AddResponseBody) } err = r.body.FromGRPCMessage(body) } return err } func (r *AddResponseBody) ToGRPCMessage() grpc.Message { var m *tree.AddResponse_Body if r != nil { m = new(tree.AddResponse_Body) m.NodeId = r.nodeID } return m } func (r *AddResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.AddResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } r.nodeID = v.GetNodeId() return nil } func (r *AddByPathRequest) ToGRPCMessage() grpc.Message { var m *tree.AddByPathRequest if r != nil { m = new(tree.AddByPathRequest) m.Body = r.body.ToGRPCMessage().(*tree.AddByPathRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *AddByPathRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.AddByPathRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(AddByPathRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *AddByPathRequestBody) ToGRPCMessage() grpc.Message { var m *tree.AddByPathRequest_Body if r != nil { m = new(tree.AddByPathRequest_Body) m.ContainerId = r.containerID m.Path = r.path m.BearerToken = r.bearerToken m.PathAttribute = r.pathAttribute m.TreeId = r.treeID m.Meta = metaToGRPC(r.meta) } return m } func (r *AddByPathRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.AddByPathRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error meta := v.GetMeta() if meta == nil { r.meta = nil } else { r.meta, err = metaFromGRPC(meta) if err != nil { return err } } r.containerID = v.GetContainerId() r.bearerToken = v.GetBearerToken() r.path = v.GetPath() r.pathAttribute = v.GetPathAttribute() r.treeID = v.GetTreeId() return err } func (r *MoveResponse) ToGRPCMessage() grpc.Message { var m *tree.MoveResponse if r != nil { m = new(tree.MoveResponse) m.Body = r.body.ToGRPCMessage().(*tree.MoveResponse_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *MoveResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.MoveResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(MoveResponseBody) } err = r.body.FromGRPCMessage(body) } return err } func (r *MoveResponseBody) ToGRPCMessage() grpc.Message { return new(tree.MoveResponse_Body) } func (r *MoveResponseBody) FromGRPCMessage(grpc.Message) error { return nil } func (r *MoveRequest) ToGRPCMessage() grpc.Message { var m *tree.MoveRequest if r != nil { m = new(tree.MoveRequest) m.Body = r.body.ToGRPCMessage().(*tree.MoveRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *MoveRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.MoveRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(MoveRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) if err != nil { return err } } return nil } func (r *MoveRequestBody) ToGRPCMessage() grpc.Message { var m *tree.MoveRequest_Body if r != nil { m = new(tree.MoveRequest_Body) m.ContainerId = r.containerID m.Meta = metaToGRPC(r.meta) m.TreeId = r.treeID m.ParentId = r.parentID m.BearerToken = r.bearerToken m.NodeId = r.nodeID } return m } func (r *MoveRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.MoveRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error r.meta, err = metaFromGRPC(v.GetMeta()) if err != nil { return err } r.treeID = v.GetTreeId() r.nodeID = v.GetNodeId() r.containerID = v.GetContainerId() r.parentID = v.GetParentId() r.bearerToken = v.GetBearerToken() return nil } func (r *RemoveRequest) ToGRPCMessage() grpc.Message { var m *tree.RemoveRequest if r != nil { m = new(tree.RemoveRequest) m.Body = r.body.ToGRPCMessage().(*tree.RemoveRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *RemoveRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.RemoveRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(RemoveRequestBody) } err = r.body.FromGRPCMessage(body) } return err } func (r *RemoveRequestBody) ToGRPCMessage() grpc.Message { var m *tree.RemoveRequest_Body if r != nil { m = new(tree.RemoveRequest_Body) m.NodeId = r.nodeID m.TreeId = r.treeID m.BearerToken = r.bearerToken m.ContainerId = r.containerID } return m } func (r *RemoveRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.RemoveRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } r.nodeID = v.GetNodeId() r.treeID = v.GetTreeId() r.containerID = v.GetContainerId() r.bearerToken = v.GetBearerToken() return nil } func (r *AddByPathResponse) ToGRPCMessage() grpc.Message { var m *tree.AddByPathResponse if r != nil { m = new(tree.AddByPathResponse) m.Body = r.body.ToGRPCMessage().(*tree.AddByPathResponse_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *AddByPathResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.AddByPathResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(AddByPathResponseBody) } err = r.body.FromGRPCMessage(body) } return err } func (r *AddByPathResponseBody) ToGRPCMessage() grpc.Message { var m *tree.AddByPathResponse_Body if r != nil { m = new(tree.AddByPathResponse_Body) m.ParentId = r.parentID m.Nodes = r.nodes } return m } func (r *AddByPathResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.AddByPathResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } r.nodes = v.GetNodes() r.parentID = v.GetParentId() return nil } func (r *AddRequest) ToGRPCMessage() grpc.Message { var m *tree.AddRequest if r != nil { m = new(tree.AddRequest) m.Body = r.body.ToGRPCMessage().(*tree.AddRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *AddRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.AddRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(AddRequestBody) } err = r.body.FromGRPCMessage(body) } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *AddRequestBody) ToGRPCMessage() grpc.Message { var m *tree.AddRequest_Body if r != nil { m = new(tree.AddRequest_Body) m.Meta = metaToGRPC(r.meta) m.TreeId = r.treeID m.ParentId = r.parentID m.ContainerId = r.containerID m.BearerToken = r.bearerToken } return m } func (r *AddRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.AddRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error r.meta, err = metaFromGRPC(v.GetMeta()) if err != nil { return err } r.bearerToken = v.GetBearerToken() r.treeID = v.GetTreeId() r.containerID = v.GetContainerId() r.parentID = v.GetParentId() return err } func (r *RemoveResponse) ToGRPCMessage() grpc.Message { var m *tree.RemoveResponse if r != nil { m = new(tree.RemoveResponse) m.Body = r.body.ToGRPCMessage().(*tree.RemoveResponse_Body) } return m } func (r *RemoveResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.RemoveResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(RemoveResponseBody) } err = r.body.FromGRPCMessage(body) } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *RemoveResponseBody) ToGRPCMessage() grpc.Message { return new(tree.RemoveResponse_Body) } func (r *RemoveResponseBody) FromGRPCMessage(grpc.Message) error { return nil } func (r *GetNodeByPathRequest) ToGRPCMessage() grpc.Message { var m *tree.GetNodeByPathRequest if r != nil { m = new(tree.GetNodeByPathRequest) m.Body = r.body.ToGRPCMessage().(*tree.GetNodeByPathRequest_Body) m.Signature = r.signature.ToGRPCMessage().(*tree.Signature) } return m } func (r *GetNodeByPathRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetNodeByPathRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(GetNodeByPathRequestBody) } err = r.body.FromGRPCMessage(body) } return err } func (r *GetNodeByPathRequestBody) ToGRPCMessage() grpc.Message { var m *tree.GetNodeByPathRequest_Body if r != nil { m = new(tree.GetNodeByPathRequest_Body) m.TreeId = r.treeID m.Path = r.path m.BearerToken = r.bearerToken m.ContainerId = r.containerID m.Attributes = r.attributes m.PathAttribute = r.pathAttribute m.AllAttributes = r.allAttributes m.LatestOnly = r.latestOnly } return m } func (r *GetNodeByPathRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetNodeByPathRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } r.treeID = v.GetTreeId() r.path = v.GetPath() r.attributes = v.GetAttributes() r.latestOnly = v.GetLatestOnly() r.allAttributes = v.GetAllAttributes() r.pathAttribute = v.GetPathAttribute() r.containerID = v.GetContainerId() r.bearerToken = v.GetBearerToken() return nil } func (r *GetNodeByPathResponse) ToGRPCMessage() grpc.Message { var m *tree.GetNodeByPathResponse if r != nil { m = new(tree.GetNodeByPathResponse) m.Body = r.body.ToGRPCMessage().(*tree.GetNodeByPathResponse_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *GetNodeByPathResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetNodeByPathResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(GetNodeByPathResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *GetNodeByPathResponseBody) ToGRPCMessage() grpc.Message { var m *tree.GetNodeByPathResponse_Body if r != nil { m = new(tree.GetNodeByPathResponse_Body) m.Nodes = GetNodeByPathInfoToGRPC(r.nodes) } return m } func (r *GetNodeByPathResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetNodeByPathResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error r.nodes, err = GetNodeByPathInfoFromGRPC(v.GetNodes()) return err } func GetNodeByPathInfoToGRPC(m []*GetNodeByPathResponseInfo) (res []*tree.GetNodeByPathResponse_Info) { if m != nil { res = make([]*tree.GetNodeByPathResponse_Info, 0, len(m)) for i := range m { res = append(res, m[i].ToGRPCMessage().(*tree.GetNodeByPathResponse_Info)) } } return } func GetNodeByPathInfoFromGRPC(m []*tree.GetNodeByPathResponse_Info) (res []*GetNodeByPathResponseInfo, err error) { if m != nil { res = make([]*GetNodeByPathResponseInfo, len(m)) for i := range m { res[i] = new(GetNodeByPathResponseInfo) err = res[i].FromGRPCMessage(m[i]) if err != nil { return } } } return } func (r *GetNodeByPathResponseInfo) ToGRPCMessage() grpc.Message { var m *tree.GetNodeByPathResponse_Info if r != nil { m = new(tree.GetNodeByPathResponse_Info) m.Meta = metaToGRPC(r.meta) m.NodeId = r.nodeID m.Timestamp = r.timestamp m.ParentId = r.parentID } return m } func (r *GetNodeByPathResponseInfo) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetNodeByPathResponse_Info) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error r.meta, err = metaFromGRPC(v.GetMeta()) if err != nil { return err } r.timestamp = v.GetTimestamp() r.nodeID = v.GetNodeId() r.parentID = v.GetParentId() return err } func (r *ListRequest) ToGRPCMessage() grpc.Message { var m *tree.TreeListRequest if r != nil { m = new(tree.TreeListRequest) m.Body = r.body.ToGRPCMessage().(*tree.TreeListRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *ListRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.TreeListRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(ListRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *ListRequestBody) ToGRPCMessage() grpc.Message { var m *tree.TreeListRequest_Body if r != nil { m = new(tree.TreeListRequest_Body) m.ContainerId = r.containerID } return m } func (r *ListRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.TreeListRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } r.containerID = v.GetContainerId() return nil } func (r *ListResponse) ToGRPCMessage() grpc.Message { var m *tree.TreeListResponse if r != nil { m = new(tree.TreeListResponse) m.Body = r.body.ToGRPCMessage().(*tree.TreeListResponse_Body) m.Signature = r.signature.ToGRPCMessage().(*tree.Signature) } return m } func (r *ListResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.TreeListResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(ListResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *ListResponseBody) ToGRPCMessage() grpc.Message { var m *tree.TreeListResponse_Body if r != nil { m = new(tree.TreeListResponse_Body) m.Ids = r.ids } return m } func (r *ListResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.TreeListResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } r.ids = v.GetIds() return nil } func (r *ApplyRequest) ToGRPCMessage() grpc.Message { var m *tree.ApplyRequest if r != nil { m = new(tree.ApplyRequest) m.Body = r.body.ToGRPCMessage().(*tree.ApplyRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *ApplyRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.ApplyRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(ApplyRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *ApplyRequestBody) ToGRPCMessage() grpc.Message { var m *tree.ApplyRequest_Body if r != nil { m = new(tree.ApplyRequest_Body) m.TreeId = r.treeID m.ContainerId = r.containerID m.Operation = r.operation.ToGRPCMessage().(*tree.LogMove) } return m } func (r *ApplyRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.ApplyRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error r.treeID = v.GetTreeId() r.containerID = v.GetContainerId() op := v.GetOperation() if op == nil { r.operation = nil } else { if r.operation == nil { r.operation = new(LogMove) } err = r.operation.FromGRPCMessage(op) } return err } func (r *ApplyResponse) ToGRPCMessage() grpc.Message { var m *tree.ApplyResponse if r != nil { m = new(tree.ApplyResponse) m.Body = r.body.ToGRPCMessage().(*tree.ApplyResponse_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *ApplyResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.ApplyResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(ApplyResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *ApplyResponseBody) ToGRPCMessage() grpc.Message { return new(tree.ApplyResponse_Body) } func (r *ApplyResponseBody) FromGRPCMessage(grpc.Message) error { return nil } func (r *HealthcheckRequest) ToGRPCMessage() grpc.Message { var m *tree.HealthcheckRequest if r != nil { m = new(tree.HealthcheckRequest) m.Body = r.body.ToGRPCMessage().(*tree.HealthcheckRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *HealthcheckRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.HealthcheckRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(HealthcheckRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *HealthcheckRequestBody) ToGRPCMessage() grpc.Message { return new(tree.HealthcheckRequest_Body) } func (r *HealthcheckRequestBody) FromGRPCMessage(grpc.Message) error { return nil } func (r *HealthcheckResponse) ToGRPCMessage() grpc.Message { var m *tree.HealthcheckResponse if r != nil { m = new(tree.HealthcheckResponse) m.Body = r.body.ToGRPCMessage().(*tree.HealthcheckResponse_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *HealthcheckResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.HealthcheckResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(HealthcheckResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *HealthcheckResponseBody) ToGRPCMessage() grpc.Message { return new(tree.HealthcheckResponse_Body) } func (r *HealthcheckResponseBody) FromGRPCMessage(grpc.Message) error { return nil } func (r *GetSubTreeResponse) ToGRPCMessage() grpc.Message { var m *tree.GetSubTreeResponse if r != nil { m = new(tree.GetSubTreeResponse) m.Body = r.body.ToGRPCMessage().(*tree.GetSubTreeResponse_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *GetSubTreeResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetSubTreeResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(GetSubTreeResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *GetOpLogRequest) ToGRPCMessage() grpc.Message { var m *tree.GetOpLogRequest if r != nil { m = new(tree.GetOpLogRequest) m.Body = r.body.ToGRPCMessage().(*tree.GetOpLogRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *GetOpLogRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetOpLogRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(GetOpLogRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *GetOpLogRequestBody) ToGRPCMessage() grpc.Message { var m *tree.GetOpLogRequest_Body if r != nil { m = new(tree.GetOpLogRequest_Body) m.TreeId = r.treeID m.Count = r.count m.ContainerId = r.containerID m.Height = r.height } return m } func (r *GetOpLogRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetOpLogRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error r.count = v.GetCount() r.containerID = v.GetContainerId() r.height = v.GetHeight() r.treeID = v.GetTreeId() return err } func (r *GetOpLogResponse) ToGRPCMessage() grpc.Message { var m *tree.GetOpLogResponse if r != nil { m = new(tree.GetOpLogResponse) m.Body = r.body.ToGRPCMessage().(*tree.GetOpLogResponse_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *GetOpLogResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetOpLogResponse) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(GetOpLogResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *GetOpLogResponseBody) ToGRPCMessage() grpc.Message { var m *tree.GetOpLogResponse_Body if r != nil { m = new(tree.GetOpLogResponse_Body) m.Operation = r.operation.ToGRPCMessage().(*tree.LogMove) } return m } func (r *GetOpLogResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetOpLogResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error oper := v.GetOperation() if oper == nil { r.operation = nil } else { if r.operation == nil { r.operation = new(LogMove) } err = r.operation.FromGRPCMessage(oper) } return err } func (s *Signature) ToGRPCMessage() grpc.Message { var m *tree.Signature if s != nil { m = new(tree.Signature) m.Sign = s.sign m.Key = s.key } return m } func (s *Signature) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.Signature) if !ok { return message.NewUnexpectedMessageType(m, v) } s.sign = v.GetSign() s.key = v.GetKey() return nil } func (k *KeyValue) ToGRPCMessage() grpc.Message { var m *tree.KeyValue if k != nil { m = new(tree.KeyValue) m.Key = k.key m.Value = k.value } return m } func (k *KeyValue) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.KeyValue) if !ok { return message.NewUnexpectedMessageType(m, v) } k.key = v.GetKey() k.value = v.GetValue() return nil } func (g *LogMove) ToGRPCMessage() grpc.Message { var m *tree.LogMove if g != nil { m = new(tree.LogMove) m.Meta = g.meta m.ParentId = g.parentID m.ChildId = g.childID } return m } func (g *LogMove) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.LogMove) if !ok { return message.NewUnexpectedMessageType(m, v) } g.meta = v.GetMeta() g.parentID = v.GetParentId() g.childID = v.GetChildId() return nil } func (r *GetSubTreeRequest) ToGRPCMessage() grpc.Message { var m *tree.GetSubTreeRequest if r != nil { m = new(tree.GetSubTreeRequest) m.Body = r.body.ToGRPCMessage().(*tree.GetSubTreeRequest_Body) m.SetSignature(r.signature.ToGRPCMessage().(*tree.Signature)) } return m } func (r *GetSubTreeRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetSubTreeRequest) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error body := v.GetBody() if body == nil { r.body = nil } else { if r.body == nil { r.body = new(GetSubTreeRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.signature = nil } else { if r.signature == nil { r.signature = new(Signature) } err = r.signature.FromGRPCMessage(sig) } return err } func (r *GetSubTreeRequestBody) ToGRPCMessage() grpc.Message { var m *tree.GetSubTreeRequest_Body if r != nil { m = new(tree.GetSubTreeRequest_Body) m.TreeId = r.treeID m.BearerToken = r.bearerToken m.Depth = r.depth m.RootId = r.rootID m.ContainerId = r.containerID m.OrderBy = r.orderBy.ToGRPCMessage().(*tree.GetSubTreeRequest_Body_Order) } return m } func (r *GetSubTreeRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetSubTreeRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } r.rootID = v.GetRootId() r.depth = v.GetDepth() r.containerID = v.GetContainerId() r.bearerToken = v.GetBearerToken() r.treeID = v.GetTreeId() var err error order := v.GetOrderBy() if order == nil { r.orderBy = nil } else { if r.orderBy == nil { r.orderBy = new(GetSubTreeRequestBodyOrder) } err = r.orderBy.FromGRPCMessage(order) if err != nil { return err } } return err } func (r *GetSubTreeRequestBodyOrder) ToGRPCMessage() grpc.Message { var m *tree.GetSubTreeRequest_Body_Order if r != nil { m = new(tree.GetSubTreeRequest_Body_Order) m.Direction = tree.GetSubTreeRequest_Body_Order_Direction(r.direction) } return m } func (r *GetSubTreeRequestBodyOrder) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetSubTreeRequest_Body_Order) if !ok { return message.NewUnexpectedMessageType(m, v) } r.direction = GetSubTreeRequestBodyOrderDirection(v.GetDirection()) return nil } func (r *GetSubTreeResponseBody) ToGRPCMessage() grpc.Message { var m *tree.GetSubTreeResponse_Body if r != nil { m = new(tree.GetSubTreeResponse_Body) m.Meta = metaToGRPC(r.meta) m.ParentId = r.parentID m.NodeId = r.nodeID m.Timestamp = r.timestamp } return m } func (r *GetSubTreeResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*tree.GetSubTreeResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error r.nodeID = v.GetNodeId() r.timestamp = v.GetTimestamp() r.parentID = v.GetParentId() r.meta, err = metaFromGRPC(v.GetMeta()) return err }