package container import ( "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/acl" aclGRPC "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/acl/grpc" container "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/container/grpc" "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/netmap" netmapGRPC "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/netmap/grpc" "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/refs" refsGRPC "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/refs/grpc" "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/grpc" "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/rpc/message" "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/session" sessionGRPC "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/session/grpc" ) func (a *Attribute) ToGRPCMessage() grpc.Message { var m *container.Container_Attribute if a != nil { m = new(container.Container_Attribute) m.SetKey(a.key) m.SetValue(a.val) } return m } func (a *Attribute) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.Container_Attribute) if !ok { return message.NewUnexpectedMessageType(m, v) } a.key = v.GetKey() a.val = v.GetValue() return nil } func AttributesToGRPC(xs []Attribute) (res []*container.Container_Attribute) { if xs != nil { res = make([]*container.Container_Attribute, 0, len(xs)) for i := range xs { res = append(res, xs[i].ToGRPCMessage().(*container.Container_Attribute)) } } return } func AttributesFromGRPC(xs []*container.Container_Attribute) (res []Attribute, err error) { if xs != nil { res = make([]Attribute, len(xs)) for i := range xs { if xs[i] != nil { err = res[i].FromGRPCMessage(xs[i]) if err != nil { return } } } } return } func (c *Container) ToGRPCMessage() grpc.Message { var m *container.Container if c != nil { m = new(container.Container) m.SetVersion(c.version.ToGRPCMessage().(*refsGRPC.Version)) m.SetOwnerId(c.ownerID.ToGRPCMessage().(*refsGRPC.OwnerID)) m.SetPlacementPolicy(c.policy.ToGRPCMessage().(*netmapGRPC.PlacementPolicy)) m.SetAttributes(AttributesToGRPC(c.attr)) m.SetBasicAcl(c.basicACL) m.SetNonce(c.nonce) } return m } func (c *Container) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.Container) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error version := v.GetVersion() if version == nil { c.version = nil } else { if c.version == nil { c.version = new(refs.Version) } err = c.version.FromGRPCMessage(version) if err != nil { return err } } ownerID := v.GetOwnerId() if ownerID == nil { c.ownerID = nil } else { if c.ownerID == nil { c.ownerID = new(refs.OwnerID) } err = c.ownerID.FromGRPCMessage(ownerID) if err != nil { return err } } policy := v.GetPlacementPolicy() if policy == nil { c.policy = nil } else { if c.policy == nil { c.policy = new(netmap.PlacementPolicy) } err = c.policy.FromGRPCMessage(policy) if err != nil { return err } } c.attr, err = AttributesFromGRPC(v.GetAttributes()) if err != nil { return err } c.basicACL = v.GetBasicAcl() c.nonce = v.GetNonce() return nil } func toSignatureRFC6979(s *refs.Signature) *refsGRPC.SignatureRFC6979 { var res *refsGRPC.SignatureRFC6979 if s != nil { res = new(refsGRPC.SignatureRFC6979) res.SetKey(s.GetKey()) res.SetSign(s.GetSign()) } return res } func (r *PutRequestBody) ToGRPCMessage() grpc.Message { var m *container.PutRequest_Body if r != nil { m = new(container.PutRequest_Body) m.SetContainer(r.cnr.ToGRPCMessage().(*container.Container)) m.SetSignature(toSignatureRFC6979(r.sig)) } return m } func (r *PutRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.PutRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error cnr := v.GetContainer() if cnr == nil { r.cnr = nil } else { if r.cnr == nil { r.cnr = new(Container) } err = r.cnr.FromGRPCMessage(cnr) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.sig = nil } else { if r.sig == nil { r.sig = new(refs.Signature) } r.sig.SetKey(sig.GetKey()) r.sig.SetSign(sig.GetSign()) } return err } func (r *PutRequest) ToGRPCMessage() grpc.Message { var m *container.PutRequest if r != nil { m = new(container.PutRequest) m.SetBody(r.body.ToGRPCMessage().(*container.PutRequest_Body)) r.RequestHeaders.ToMessage(m) } return m } func (r *PutRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.PutRequest) 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(PutRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } return r.RequestHeaders.FromMessage(v) } func (r *PutResponseBody) ToGRPCMessage() grpc.Message { var m *container.PutResponse_Body if r != nil { m = new(container.PutResponse_Body) m.SetContainerId(r.cid.ToGRPCMessage().(*refsGRPC.ContainerID)) } return m } func (r *PutResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.PutResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error cid := v.GetContainerId() if cid == nil { r.cid = nil } else { if r.cid == nil { r.cid = new(refs.ContainerID) } err = r.cid.FromGRPCMessage(cid) } return err } func (r *PutResponse) ToGRPCMessage() grpc.Message { var m *container.PutResponse if r != nil { m = new(container.PutResponse) m.SetBody(r.body.ToGRPCMessage().(*container.PutResponse_Body)) r.ResponseHeaders.ToMessage(m) } return m } func (r *PutResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.PutResponse) 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(PutResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } return r.ResponseHeaders.FromMessage(v) } func (r *GetRequestBody) ToGRPCMessage() grpc.Message { var m *container.GetRequest_Body if r != nil { m = new(container.GetRequest_Body) m.SetContainerId(r.cid.ToGRPCMessage().(*refsGRPC.ContainerID)) } return m } func (r *GetRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.GetRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error cid := v.GetContainerId() if cid == nil { r.cid = nil } else { if r.cid == nil { r.cid = new(refs.ContainerID) } err = r.cid.FromGRPCMessage(cid) } return err } func (r *GetRequest) ToGRPCMessage() grpc.Message { var m *container.GetRequest if r != nil { m = new(container.GetRequest) m.SetBody(r.body.ToGRPCMessage().(*container.GetRequest_Body)) r.RequestHeaders.ToMessage(m) } return m } func (r *GetRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.GetRequest) 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(GetRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } return r.RequestHeaders.FromMessage(v) } func (r *GetResponseBody) ToGRPCMessage() grpc.Message { var m *container.GetResponse_Body if r != nil { m = new(container.GetResponse_Body) m.SetContainer(r.cnr.ToGRPCMessage().(*container.Container)) m.SetSessionToken(r.token.ToGRPCMessage().(*sessionGRPC.SessionToken)) m.SetSignature(toSignatureRFC6979(r.sig)) } return m } func (r *GetResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.GetResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error cnr := v.GetContainer() if cnr == nil { r.cnr = nil } else { if r.cnr == nil { r.cnr = new(Container) } err = r.cnr.FromGRPCMessage(cnr) } sig := v.GetSignature() if sig == nil { r.sig = nil } else { if r.sig == nil { r.sig = new(refs.Signature) } r.sig.SetKey(sig.GetKey()) r.sig.SetSign(sig.GetSign()) } token := v.GetSessionToken() if token == nil { r.token = nil } else { if r.token == nil { r.token = new(session.Token) } err = r.token.FromGRPCMessage(token) } return err } func (r *GetResponse) ToGRPCMessage() grpc.Message { var m *container.GetResponse if r != nil { m = new(container.GetResponse) m.SetBody(r.body.ToGRPCMessage().(*container.GetResponse_Body)) r.ResponseHeaders.ToMessage(m) } return m } func (r *GetResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.GetResponse) 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(GetResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } return r.ResponseHeaders.FromMessage(v) } func (r *DeleteRequestBody) ToGRPCMessage() grpc.Message { var m *container.DeleteRequest_Body if r != nil { m = new(container.DeleteRequest_Body) m.SetContainerId(r.cid.ToGRPCMessage().(*refsGRPC.ContainerID)) m.SetSignature(toSignatureRFC6979(r.sig)) } return m } func (r *DeleteRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.DeleteRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error cid := v.GetContainerId() if cid == nil { r.cid = nil } else { if r.cid == nil { r.cid = new(refs.ContainerID) } err = r.cid.FromGRPCMessage(cid) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.sig = nil } else { if r.sig == nil { r.sig = new(refs.Signature) } r.sig.SetKey(sig.GetKey()) r.sig.SetSign(sig.GetSign()) } return err } func (r *DeleteRequest) ToGRPCMessage() grpc.Message { var m *container.DeleteRequest if r != nil { m = new(container.DeleteRequest) m.SetBody(r.body.ToGRPCMessage().(*container.DeleteRequest_Body)) r.RequestHeaders.ToMessage(m) } return m } func (r *DeleteRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.DeleteRequest) 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(DeleteRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } return r.RequestHeaders.FromMessage(v) } func (r *DeleteResponseBody) ToGRPCMessage() grpc.Message { var m *container.DeleteResponse_Body if r != nil { m = new(container.DeleteResponse_Body) } return m } func (r *DeleteResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.DeleteResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } return nil } func (r *DeleteResponse) ToGRPCMessage() grpc.Message { var m *container.DeleteResponse if r != nil { m = new(container.DeleteResponse) m.SetBody(r.body.ToGRPCMessage().(*container.DeleteResponse_Body)) r.ResponseHeaders.ToMessage(m) } return m } func (r *DeleteResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.DeleteResponse) 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(DeleteResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } return r.ResponseHeaders.FromMessage(v) } func (r *ListRequestBody) ToGRPCMessage() grpc.Message { var m *container.ListRequest_Body if r != nil { m = new(container.ListRequest_Body) m.SetOwnerId(r.ownerID.ToGRPCMessage().(*refsGRPC.OwnerID)) } return m } func (r *ListRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.ListRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error ownerID := v.GetOwnerId() if ownerID == nil { r.ownerID = nil } else { if r.ownerID == nil { r.ownerID = new(refs.OwnerID) } err = r.ownerID.FromGRPCMessage(ownerID) } return err } func (r *ListRequest) ToGRPCMessage() grpc.Message { var m *container.ListRequest if r != nil { m = new(container.ListRequest) m.SetBody(r.body.ToGRPCMessage().(*container.ListRequest_Body)) r.RequestHeaders.ToMessage(m) } return m } func (r *ListRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.ListRequest) 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 } } return r.RequestHeaders.FromMessage(v) } func (r *ListResponseBody) ToGRPCMessage() grpc.Message { var m *container.ListResponse_Body if r != nil { m = new(container.ListResponse_Body) m.SetContainerIds(refs.ContainerIDsToGRPCMessage(r.cidList)) } return m } func (r *ListResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.ListResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error r.cidList, err = refs.ContainerIDsFromGRPCMessage(v.GetContainerIds()) return err } func (r *ListResponse) ToGRPCMessage() grpc.Message { var m *container.ListResponse if r != nil { m = new(container.ListResponse) m.SetBody(r.body.ToGRPCMessage().(*container.ListResponse_Body)) r.ResponseHeaders.ToMessage(m) } return m } func (r *ListResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.ListResponse) 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 } } return r.ResponseHeaders.FromMessage(v) } func (r *GetExtendedACLRequestBody) ToGRPCMessage() grpc.Message { var m *container.GetExtendedACLRequest_Body if r != nil { m = new(container.GetExtendedACLRequest_Body) m.SetContainerId(r.cid.ToGRPCMessage().(*refsGRPC.ContainerID)) } return m } func (r *GetExtendedACLRequestBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.GetExtendedACLRequest_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error cid := v.GetContainerId() if cid == nil { r.cid = nil } else { if r.cid == nil { r.cid = new(refs.ContainerID) } err = r.cid.FromGRPCMessage(cid) } return err } func (r *GetExtendedACLRequest) ToGRPCMessage() grpc.Message { var m *container.GetExtendedACLRequest if r != nil { m = new(container.GetExtendedACLRequest) m.SetBody(r.body.ToGRPCMessage().(*container.GetExtendedACLRequest_Body)) r.RequestHeaders.ToMessage(m) } return m } func (r *GetExtendedACLRequest) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.GetExtendedACLRequest) 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(GetExtendedACLRequestBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } return r.RequestHeaders.FromMessage(v) } func (r *GetExtendedACLResponseBody) ToGRPCMessage() grpc.Message { var m *container.GetExtendedACLResponse_Body if r != nil { m = new(container.GetExtendedACLResponse_Body) m.SetEacl(r.eacl.ToGRPCMessage().(*aclGRPC.EACLTable)) m.SetSignature(toSignatureRFC6979(r.sig)) m.SetSessionToken(r.token.ToGRPCMessage().(*sessionGRPC.SessionToken)) } return m } func (r *GetExtendedACLResponseBody) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.GetExtendedACLResponse_Body) if !ok { return message.NewUnexpectedMessageType(m, v) } var err error eacl := v.GetEacl() if eacl == nil { r.eacl = nil } else { if r.eacl == nil { r.eacl = new(acl.Table) } err = r.eacl.FromGRPCMessage(eacl) if err != nil { return err } } sig := v.GetSignature() if sig == nil { r.sig = nil } else { if r.sig == nil { r.sig = new(refs.Signature) } r.sig.SetKey(sig.GetKey()) r.sig.SetSign(sig.GetSign()) } token := v.GetSessionToken() if token == nil { r.token = nil } else { if r.token == nil { r.token = new(session.Token) } err = r.token.FromGRPCMessage(token) } return err } func (r *GetExtendedACLResponse) ToGRPCMessage() grpc.Message { var m *container.GetExtendedACLResponse if r != nil { m = new(container.GetExtendedACLResponse) m.SetBody(r.body.ToGRPCMessage().(*container.GetExtendedACLResponse_Body)) r.ResponseHeaders.ToMessage(m) } return m } func (r *GetExtendedACLResponse) FromGRPCMessage(m grpc.Message) error { v, ok := m.(*container.GetExtendedACLResponse) 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(GetExtendedACLResponseBody) } err = r.body.FromGRPCMessage(body) if err != nil { return err } } return r.ResponseHeaders.FromMessage(v) }