package audit import ( "github.com/nspcc-dev/neofs-api-go/v2/audit" "github.com/nspcc-dev/neofs-api-go/v2/refs" cid "github.com/nspcc-dev/neofs-sdk-go/container/id" oid "github.com/nspcc-dev/neofs-sdk-go/object/id" "github.com/nspcc-dev/neofs-sdk-go/version" ) // Result represents v2-compatible data audit result. type Result audit.DataAuditResult // NewFromV2 wraps v2 DataAuditResult message to Result. // // Nil audit.DataAuditResult converts to nil. func NewResultFromV2(aV2 *audit.DataAuditResult) *Result { return (*Result)(aV2) } // New creates and initializes blank Result. // // Defaults: // - version: version.Current(); // - complete: false; // - cid: nil; // - pubKey: nil; // - passSG, failSG: nil; // - failNodes, passNodes: nil; // - hit, miss, fail: 0; // - requests, retries: 0; // - auditEpoch: 0. func NewResult() *Result { r := NewResultFromV2(new(audit.DataAuditResult)) r.SetVersion(version.Current()) return r } // ToV2 converts Result to v2 DataAuditResult message. // // Nil Result converts to nil. func (r *Result) ToV2() *audit.DataAuditResult { return (*audit.DataAuditResult)(r) } // Marshal marshals Result into a protobuf binary form. func (r *Result) Marshal() ([]byte, error) { return (*audit.DataAuditResult)(r).StableMarshal(nil), nil } // Unmarshal unmarshals protobuf binary representation of Result. func (r *Result) Unmarshal(data []byte) error { return (*audit.DataAuditResult)(r).Unmarshal(data) } // MarshalJSON encodes Result to protobuf JSON format. func (r *Result) MarshalJSON() ([]byte, error) { return (*audit.DataAuditResult)(r).MarshalJSON() } // UnmarshalJSON decodes Result from protobuf JSON format. func (r *Result) UnmarshalJSON(data []byte) error { return (*audit.DataAuditResult)(r).UnmarshalJSON(data) } // Version returns Data Audit structure version. func (r *Result) Version() *version.Version { return version.NewFromV2( (*audit.DataAuditResult)(r).GetVersion()) } // SetVersion sets Data Audit structure version. func (r *Result) SetVersion(v *version.Version) { (*audit.DataAuditResult)(r).SetVersion(v.ToV2()) } // AuditEpoch returns epoch number when the Data Audit was conducted. func (r *Result) AuditEpoch() uint64 { return (*audit.DataAuditResult)(r).GetAuditEpoch() } // SetAuditEpoch sets epoch number when the Data Audit was conducted. func (r *Result) SetAuditEpoch(epoch uint64) { (*audit.DataAuditResult)(r).SetAuditEpoch(epoch) } // ContainerID returns container under audit. func (r *Result) ContainerID() *cid.ID { return cid.NewFromV2( (*audit.DataAuditResult)(r).GetContainerID()) } // SetContainerID sets container under audit. func (r *Result) SetContainerID(id *cid.ID) { (*audit.DataAuditResult)(r).SetContainerID(id.ToV2()) } // PublicKey returns public key of the auditing InnerRing node in a binary format. func (r *Result) PublicKey() []byte { return (*audit.DataAuditResult)(r).GetPublicKey() } // SetPublicKey sets public key of the auditing InnerRing node in a binary format. func (r *Result) SetPublicKey(key []byte) { (*audit.DataAuditResult)(r).SetPublicKey(key) } // Complete returns completion state of audit result. func (r *Result) Complete() bool { return (*audit.DataAuditResult)(r).GetComplete() } // SetComplete sets completion state of audit result. func (r *Result) SetComplete(v bool) { (*audit.DataAuditResult)(r).SetComplete(v) } // Requests returns number of requests made by PoR audit check to get // all headers of the objects inside storage groups. func (r *Result) Requests() uint32 { return (*audit.DataAuditResult)(r).GetRequests() } // SetRequests sets number of requests made by PoR audit check to get // all headers of the objects inside storage groups. func (r *Result) SetRequests(v uint32) { (*audit.DataAuditResult)(r).SetRequests(v) } // Retries returns number of retries made by PoR audit check to get // all headers of the objects inside storage groups. func (r *Result) Retries() uint32 { return (*audit.DataAuditResult)(r).GetRetries() } // SetRetries sets number of retries made by PoR audit check to get // all headers of the objects inside storage groups. func (r *Result) SetRetries(v uint32) { (*audit.DataAuditResult)(r).SetRetries(v) } // PassSG returns list of Storage Groups that passed audit PoR stage. func (r *Result) PassSG() []oid.ID { mV2 := (*audit.DataAuditResult)(r). GetPassSG() if mV2 == nil { return nil } m := make([]oid.ID, len(mV2)) for i := range mV2 { m[i] = *oid.NewIDFromV2(&mV2[i]) } return m } // SetPassSG sets list of Storage Groups that passed audit PoR stage. func (r *Result) SetPassSG(list []oid.ID) { mV2 := (*audit.DataAuditResult)(r). GetPassSG() if list == nil { mV2 = nil } else { ln := len(list) if cap(mV2) >= ln { mV2 = mV2[:0] } else { mV2 = make([]refs.ObjectID, ln) } for i := 0; i < ln; i++ { mV2[i] = *list[i].ToV2() } } (*audit.DataAuditResult)(r).SetPassSG(mV2) } // FailSG returns list of Storage Groups that failed audit PoR stage. func (r *Result) FailSG() []oid.ID { mV2 := (*audit.DataAuditResult)(r). GetFailSG() if mV2 == nil { return nil } m := make([]oid.ID, len(mV2)) for i := range mV2 { m[i] = *oid.NewIDFromV2(&mV2[i]) } return m } // SetFailSG sets list of Storage Groups that failed audit PoR stage. func (r *Result) SetFailSG(list []oid.ID) { mV2 := (*audit.DataAuditResult)(r). GetFailSG() if list == nil { mV2 = nil } else { ln := len(list) if cap(mV2) >= ln { mV2 = mV2[:0] } else { mV2 = make([]refs.ObjectID, ln) } for i := 0; i < ln; i++ { mV2[i] = *list[i].ToV2() } } (*audit.DataAuditResult)(r).SetFailSG(mV2) } // Hit returns number of sampled objects under audit placed // in an optimal way according to the containers placement policy // when checking PoP. func (r *Result) Hit() uint32 { return (*audit.DataAuditResult)(r).GetHit() } // SetHit sets number of sampled objects under audit placed // in an optimal way according to the containers placement policy // when checking PoP. func (r *Result) SetHit(hit uint32) { (*audit.DataAuditResult)(r).SetHit(hit) } // Miss returns number of sampled objects under audit placed // in suboptimal way according to the containers placement policy, // but still at a satisfactory level when checking PoP. func (r *Result) Miss() uint32 { return (*audit.DataAuditResult)(r).GetMiss() } // SetMiss sets number of sampled objects under audit placed // in suboptimal way according to the containers placement policy, // but still at a satisfactory level when checking PoP. func (r *Result) SetMiss(miss uint32) { (*audit.DataAuditResult)(r).SetMiss(miss) } // Fail returns number of sampled objects under audit stored // in a way not confirming placement policy or not found at all // when checking PoP. func (r *Result) Fail() uint32 { return (*audit.DataAuditResult)(r).GetFail() } // SetFail sets number of sampled objects under audit stored // in a way not confirming placement policy or not found at all // when checking PoP. func (r *Result) SetFail(fail uint32) { (*audit.DataAuditResult)(r).SetFail(fail) } // PassNodes returns list of storage node public keys that // passed at least one PDP. func (r *Result) PassNodes() [][]byte { return (*audit.DataAuditResult)(r).GetPassNodes() } // SetPassNodes sets list of storage node public keys that // passed at least one PDP. func (r *Result) SetPassNodes(list [][]byte) { (*audit.DataAuditResult)(r).SetPassNodes(list) } // FailNodes returns list of storage node public keys that // failed at least one PDP. func (r *Result) FailNodes() [][]byte { return (*audit.DataAuditResult)(r).GetFailNodes() } // SetFailNodes sets list of storage node public keys that // failed at least one PDP. func (r *Result) SetFailNodes(list [][]byte) { (*audit.DataAuditResult)(r).SetFailNodes(list) }