package apistatus_test import ( "errors" "testing" apistatus "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/client/status" "github.com/stretchr/testify/require" ) func TestToStatusV2(t *testing.T) { type statusConstructor func() apistatus.Status for _, testItem := range [...]struct { status any // Status or statusConstructor codeV2 uint64 messageV2 string }{ { status: errors.New("some error"), codeV2: 1024, messageV2: "some error", }, { status: 1, codeV2: 0, }, { status: "text", codeV2: 0, }, { status: true, codeV2: 0, }, { status: true, codeV2: 0, }, { status: nil, codeV2: 0, }, { status: (statusConstructor)(func() apistatus.Status { var st apistatus.ServerInternal st.SetMessage("internal error message") return st }), codeV2: 1024, }, { status: (statusConstructor)(func() apistatus.Status { var st apistatus.WrongMagicNumber st.WriteCorrectMagic(322) return st }), codeV2: 1025, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.SignatureVerification) }), codeV2: 1026, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.NodeUnderMaintenance) }), codeV2: 1027, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.InvalidArgument) }), codeV2: 1028, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ObjectLocked) }), codeV2: 2050, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.LockNonRegularObject) }), codeV2: 2051, }, { status: (statusConstructor)(func() apistatus.Status { var st apistatus.ObjectAccessDenied st.WriteReason("any reason") return st }), codeV2: 2048, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ObjectNotFound) }), codeV2: 2049, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ObjectAlreadyRemoved) }), codeV2: 2052, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ObjectOutOfRange) }), codeV2: 2053, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ContainerNotFound) }), codeV2: 3072, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.EACLNotFound) }), codeV2: 3073, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.SessionTokenNotFound) }), codeV2: 4096, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.SessionTokenExpired) }), codeV2: 4097, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.APEManagerAccessDenied) }), codeV2: 5120, }, } { var st apistatus.Status if cons, ok := testItem.status.(statusConstructor); ok { st = cons() } else { st = testItem.status } stv2 := apistatus.ToStatusV2(st) // must generate the same status.Status message require.EqualValues(t, testItem.codeV2, stv2.Code()) if len(testItem.messageV2) > 0 { require.Equal(t, testItem.messageV2, stv2.Message()) } _, ok := st.(apistatus.StatusV2) if ok { // restore and convert again restored := apistatus.FromStatusV2(stv2) res := apistatus.ToStatusV2(restored) // must generate the same status.Status message require.Equal(t, stv2, res) } } } func TestFromStatusV2(t *testing.T) { type statusConstructor func() apistatus.Status for _, testItem := range [...]struct { status any // Status or statusConstructor codeV2 uint64 messageV2 string }{ { status: errors.New("some error"), codeV2: 1024, messageV2: "some error", }, { status: 1, codeV2: 0, }, { status: "text", codeV2: 0, }, { status: true, codeV2: 0, }, { status: true, codeV2: 0, }, { status: nil, codeV2: 0, }, { status: (statusConstructor)(func() apistatus.Status { var st apistatus.ServerInternal st.SetMessage("internal error message") return st }), codeV2: 1024, }, { status: (statusConstructor)(func() apistatus.Status { var st apistatus.WrongMagicNumber st.WriteCorrectMagic(322) return st }), codeV2: 1025, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ObjectLocked) }), codeV2: 2050, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.LockNonRegularObject) }), codeV2: 2051, }, { status: (statusConstructor)(func() apistatus.Status { var st apistatus.ObjectAccessDenied st.WriteReason("any reason") return st }), codeV2: 2048, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ObjectNotFound) }), codeV2: 2049, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ObjectAlreadyRemoved) }), codeV2: 2052, }, { status: statusConstructor(func() apistatus.Status { return new(apistatus.ObjectOutOfRange) }), codeV2: 2053, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.ContainerNotFound) }), codeV2: 3072, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.EACLNotFound) }), codeV2: 3073, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.SessionTokenNotFound) }), codeV2: 4096, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.SessionTokenExpired) }), codeV2: 4097, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.APEManagerAccessDenied) }), codeV2: 5120, }, { status: (statusConstructor)(func() apistatus.Status { return new(apistatus.NodeUnderMaintenance) }), codeV2: 1027, }, } { var st apistatus.Status if cons, ok := testItem.status.(statusConstructor); ok { st = cons() } else { st = testItem.status } stv2 := apistatus.ToStatusV2(st) // must generate the same status.Status message require.EqualValues(t, testItem.codeV2, stv2.Code()) if len(testItem.messageV2) > 0 { require.Equal(t, testItem.messageV2, stv2.Message()) } _, ok := st.(apistatus.StatusV2) if ok { // restore and convert again restored := apistatus.FromStatusV2(stv2) res := apistatus.ToStatusV2(restored) // must generate the same status.Status message require.Equal(t, stv2, res) } } }