diff --git a/pkg/account/config.go b/pkg/account/config.go
index cfa3f088e56829ad3917e274f6e59938fa0098d7..b86eb543931df7d52a8e19ab8db31b59e1db4b10 100644
--- a/pkg/account/config.go
+++ b/pkg/account/config.go
@@ -9,7 +9,6 @@ type config struct {
noCache bool
noLog bool
accessLog bool
- debug bool
clientOptions []kitgrpc.ClientOption // todo: можно заменить на grpc-интерсепторы при соединении и избавиться здесь от go-kit
logger *zap.Logger
}
diff --git a/pkg/auth/anonymous.go b/pkg/auth/anonymous.go
index e000842a68b2a0a64b5ed59bc7f5bcb5b7bf6514..9fffc86351e794758a00f70218d820a3855eb95a 100644
--- a/pkg/auth/anonymous.go
+++ b/pkg/auth/anonymous.go
@@ -80,7 +80,7 @@ func (a *Anonymous) HasEnvironmentAccess(ctx context.Context, space, env string)
}
func (Anonymous) Format(f fmt.State, verb rune) {
- f.Write([]byte("AnonymousPrincipal{}"))
+ _, _ = f.Write([]byte("AnonymousPrincipal{}"))
}
func (a Anonymous) HasAccess(ctx context.Context, spaceID, orgID string) error {
diff --git a/pkg/auth/client.go b/pkg/auth/client.go
index 1e22b4b92c27ff35f21d4e866394363b39c96a98..9db7a5683681137c346f6cba91ec3d40c6a331d6 100644
--- a/pkg/auth/client.go
+++ b/pkg/auth/client.go
@@ -52,7 +52,7 @@ func (c ClientPrincipal) Format(f fmt.State, verb rune) {
id = c.client.ID
}
- f.Write([]byte(fmt.Sprintf("ClientPrincipal{ID: '%s', Identity: {%s}}", id, identity)))
+ _, _ = f.Write([]byte(fmt.Sprintf("ClientPrincipal{ID: '%s', Identity: {%s}}", id, identity)))
}
func (c *ClientPrincipal) Space(spaceID string) SpaceAccessor {
@@ -63,6 +63,7 @@ func (c *ClientPrincipal) Space(spaceID string) SpaceAccessor {
return c
}
+// nolint:unused
func (c *ClientPrincipal) getSpace(ctx context.Context, spaceID string) *spaces.Space {
if spaceID == "" {
return nil
@@ -182,8 +183,8 @@ func (c *ClientPrincipal) Role(ctx context.Context, spaceID string) *roles.Role
role, err := c.roles.Get(WithSystem(ctx), spaceID, rID)
if err == nil {
- //c.hasRole = true
- //c.role = role
+ // c.hasRole = true
+ // c.role = role
return role
}
@@ -237,6 +238,7 @@ func (c *ClientPrincipal) HasAccess(ctx context.Context, spaceID, orgID string)
return service.ErrAccessDenied
}
+// nolint:unused
func (c *ClientPrincipal) hasRole(ctx context.Context, spaceID string) (bool, error) {
if c.spaceID == "" {
return false, nil
diff --git a/pkg/auth/system.go b/pkg/auth/system.go
index b602fe114bb53d5f82ae5f6796806dc20ed75188..dd4d03984da3bcc2623f9b9d4e9a2b11695946a4 100644
--- a/pkg/auth/system.go
+++ b/pkg/auth/system.go
@@ -35,5 +35,5 @@ func (SystemPrincipal) Rules(_ context.Context, _, _ string) permission.Ruleset
}
func (SystemPrincipal) Format(f fmt.State, verb rune) {
- f.Write([]byte("SystemPrincipal{}"))
+ _, _ = f.Write([]byte("SystemPrincipal{}"))
}
diff --git a/pkg/auth/user.go b/pkg/auth/user.go
index 00c817e23b3906bb1a5dd62cfac4e73a22228728..29e879457bebc4da201ce126c6c140e02989f2c0 100644
--- a/pkg/auth/user.go
+++ b/pkg/auth/user.go
@@ -36,7 +36,7 @@ type UserPrincipal struct {
}
func (u UserPrincipal) Format(f fmt.State, verb rune) {
- f.Write([]byte(fmt.Sprintf("UserPrincipal{ID: '%s', Identity: '%s'}", u.id, u.identity)))
+ _, _ = f.Write([]byte(fmt.Sprintf("UserPrincipal{ID: '%s', Identity: '%s'}", u.id, u.identity)))
}
func (u *UserPrincipal) Space(spaceID string) SpaceAccessor {
diff --git a/pkg/cli/gracefull.go b/pkg/cli/gracefull.go
index 8fd64a3d612d2e99e3d3d255a29e4dac00ebd8ea..64ecc3713a6e06de490d22a80c3490f3008110ff 100644
--- a/pkg/cli/gracefull.go
+++ b/pkg/cli/gracefull.go
@@ -14,23 +14,20 @@ func WaitForQuit(logger *zap.Logger, finailizer func()) {
signal.Notify(sigc, syscall.SIGTERM, os.Interrupt)
var signalsReceived uint
go func() {
- for {
- select {
- case s := <-sigc:
- logger.Info("Signal received. Exiting", zap.String("Signal", s.String()))
- signalsReceived++
+ for s := range sigc {
+ logger.Info("Signal received. Exiting", zap.String("Signal", s.String()))
+ signalsReceived++
- if signalsReceived < 2 {
- // After first Ctrl+C start quitting the worker gracefully
- go func() {
- finailizer()
- close(donec)
- }()
- } else {
- // Abort the program when user hits Ctrl+C second time in a row
- logger.Info("Force exit")
+ if signalsReceived < 2 {
+ // After first Ctrl+C start quitting the worker gracefully
+ go func() {
+ finailizer()
close(donec)
- }
+ }()
+ } else {
+ // Abort the program when user hits Ctrl+C second time in a row
+ logger.Info("Force exit")
+ close(donec)
}
}
}()
diff --git a/pkg/clients/middleware/caching_middleware.go b/pkg/clients/middleware/caching_middleware.go
index 08af3a47a7cd3f23b8ae07e4050f9e18f1be1ee3..370061ccc247735763395c3f6a1ebeb22804f2fb 100644
--- a/pkg/clients/middleware/caching_middleware.go
+++ b/pkg/clients/middleware/caching_middleware.go
@@ -30,7 +30,7 @@ func (m cachingMiddleware) Create(ctx context.Context, client *service.Client) (
cl, err = m.next.Create(ctx, client)
if err == nil {
- m.cache.Remove(cl.SpaceID)
+ _ = m.cache.Remove(cl.SpaceID)
}
return cl, err
}
@@ -44,9 +44,9 @@ func (m cachingMiddleware) Get(ctx context.Context, spaceId string, id string) (
}
cl, err = m.next.Get(ctx, spaceId, id)
if err == nil {
- m.cache.Set(key, cl)
+ _ = m.cache.Set(key, cl)
for _, key := range keysFromIdentities(spaceId, cl) {
- m.cache.Set(key, cl)
+ _ = m.cache.Set(key, cl)
}
}
return cl, err
@@ -64,9 +64,9 @@ func (m cachingMiddleware) GetBy(ctx context.Context, spaceId string, params *se
}
cl, err = m.next.GetBy(ctx, spaceId, params)
if err == nil {
- m.cache.Set(makeKey(spaceId, cl.ID), cl)
+ _ = m.cache.Set(makeKey(spaceId, cl.ID), cl)
for _, key := range keysFromIdentities(spaceId, cl) {
- m.cache.Set(key, cl)
+ _ = m.cache.Set(key, cl)
}
}
return cl, err
@@ -80,7 +80,7 @@ func (m cachingMiddleware) List(ctx context.Context, spaceId string) (clients []
}
clients, err = m.next.List(ctx, spaceId)
if err == nil {
- m.cache.Set(spaceId, clients)
+ _ = m.cache.Set(spaceId, clients)
}
return clients, err
}
@@ -90,13 +90,13 @@ func (m cachingMiddleware) Update(ctx context.Context, client *service.Client) (
err = m.next.Update(ctx, client)
if err == nil {
- m.cache.Remove(client.SpaceID)
+ _ = m.cache.Remove(client.SpaceID)
value, e := m.cache.Get(makeKey(client.SpaceID, client.ID))
if e == nil {
client := value.(*service.Client)
- m.cache.Remove(makeKey(client.SpaceID, client.ID))
+ _ = m.cache.Remove(makeKey(client.SpaceID, client.ID))
for _, key := range keysFromIdentities(client.SpaceID, client) {
- m.cache.Remove(key)
+ _ = m.cache.Remove(key)
}
}
}
@@ -110,12 +110,12 @@ func (m cachingMiddleware) Delete(ctx context.Context, spaceId string, id string
value, e := m.cache.Get(makeKey(spaceId, id))
if e == nil {
client := value.(*service.Client)
- m.cache.Remove(makeKey(client.SpaceID, client.ID))
+ _ = m.cache.Remove(makeKey(client.SpaceID, client.ID))
for _, key := range keysFromIdentities(client.SpaceID, client) {
- m.cache.Remove(key)
+ _ = m.cache.Remove(key)
}
}
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
}
return err
}
@@ -127,12 +127,12 @@ func (m cachingMiddleware) Enable(ctx context.Context, spaceId string, id string
value, e := m.cache.Get(makeKey(spaceId, id))
if e == nil {
client := value.(*service.Client)
- m.cache.Remove(makeKey(client.SpaceID, client.ID))
+ _ = m.cache.Remove(makeKey(client.SpaceID, client.ID))
for _, key := range keysFromIdentities(client.SpaceID, client) {
- m.cache.Remove(key)
+ _ = m.cache.Remove(key)
}
}
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
}
return err
}
diff --git a/pkg/clients/middleware/caching_middleware_test.go b/pkg/clients/middleware/caching_middleware_test.go
index 2a90c1db2c322ca9509cb2bf9bdd63b252e67c68..02129d1772406b0d33f693d2d10ae5bc008492d7 100644
--- a/pkg/clients/middleware/caching_middleware_test.go
+++ b/pkg/clients/middleware/caching_middleware_test.go
@@ -317,6 +317,7 @@ func TestClientsCache(t *testing.T) {
assert.NotSame(t, v2, v4, "Ожидается что после активации объект был удален из кэша и запрошен у сервиса.")
v5, err := svc.GetBy(ctx, spaceID, &clients.GetByParams{OAuthClientID: clientID})
+ require.NoError(t, err)
assert.NotSame(t, v3, v5, "Ожидается что после активации объект был удален из кеша и после запроса Get в кеш попал объект запрошенный заново из сервиса.")
vl3, err := svc.List(ctx, spaceID)
diff --git a/pkg/collaborators/middleware/caching_middleware.go b/pkg/collaborators/middleware/caching_middleware.go
index 7533ae551ed47a421d3fe8ed643ce679e07fddc2..25ae89c46c7863f2143d17850513e88f1d4b68b0 100644
--- a/pkg/collaborators/middleware/caching_middleware.go
+++ b/pkg/collaborators/middleware/caching_middleware.go
@@ -30,8 +30,8 @@ func (m cachingMiddleware) Set(ctx context.Context, spaceId, subject, role strin
err = m.next.Set(ctx, spaceId, subject, role)
if err == nil {
- m.cache.Remove(spaceId)
- m.cache.Remove(subject)
+ _ = m.cache.Remove(spaceId)
+ _ = m.cache.Remove(subject)
}
return err
}
@@ -45,7 +45,7 @@ func (m cachingMiddleware) Get(ctx context.Context, spaceId, subject string) (ro
}
role, err = m.next.Get(ctx, spaceId, subject)
if err == nil {
- m.cache.Set(key, role)
+ _ = m.cache.Set(key, role)
}
return role, err
}
@@ -54,9 +54,9 @@ func (m cachingMiddleware) Remove(ctx context.Context, spaceId, subject string)
err = m.next.Remove(ctx, spaceId, subject)
if err == nil {
- m.cache.Remove(makeKey(spaceId, subject))
- m.cache.Remove(spaceId)
- m.cache.Remove(subject)
+ _ = m.cache.Remove(makeKey(spaceId, subject))
+ _ = m.cache.Remove(spaceId)
+ _ = m.cache.Remove(subject)
}
return err
}
@@ -69,7 +69,7 @@ func (m cachingMiddleware) ListCollaborators(ctx context.Context, spaceId string
}
collaborators, err = m.next.ListCollaborators(ctx, spaceId)
if err == nil {
- m.cache.Set(spaceId, collaborators)
+ _ = m.cache.Set(spaceId, collaborators)
}
return collaborators, err
}
@@ -82,7 +82,7 @@ func (m cachingMiddleware) ListSpaces(ctx context.Context, subject string) (coll
}
collaborators, err = m.next.ListSpaces(ctx, subject)
if err == nil {
- m.cache.Set(subject, collaborators)
+ _ = m.cache.Set(subject, collaborators)
}
return collaborators, err
}
diff --git a/pkg/collaborators/middleware/caching_middleware_test.go b/pkg/collaborators/middleware/caching_middleware_test.go
index ea2ccaddb2621c306e317d6d873a455489a6a2a6..2e453ae67ca574fc6a7ec54dbdb0df88bdd358d2 100644
--- a/pkg/collaborators/middleware/caching_middleware_test.go
+++ b/pkg/collaborators/middleware/caching_middleware_test.go
@@ -113,6 +113,7 @@ func TestCollaboratorsCache(t *testing.T) {
cs.On("ListSpaces", mock.Anything, userID).Return(nil, errNotFound).Once()
err = svc.Remove(ctx, spaceID, userID)
+ require.NoError(t, err)
rl, err = svc.Get(ctx, spaceID, userID)
require.Error(t, err)
@@ -167,6 +168,7 @@ func TestCollaboratorsCache(t *testing.T) {
cs.On("ListSpaces", mock.Anything, userID).Return(nil, errNotFound).Once()
err = svc.Remove(ctx, spaceID, userID)
+ require.NoError(t, err)
rl, err = svc.Get(ctx, spaceID, userID)
require.Error(t, err)
diff --git a/pkg/collections/middleware/caching_middleware.go b/pkg/collections/middleware/caching_middleware.go
index de34d42af02f7259c66aea5799210c50c0e1961e..0e329e801c4e0d7eeb6939d3fed857c023cbbc8a 100644
--- a/pkg/collections/middleware/caching_middleware.go
+++ b/pkg/collections/middleware/caching_middleware.go
@@ -52,9 +52,9 @@ func (m cachingMiddleware) Get(ctx context.Context, spaceId string, envId string
if err != nil {
return nil, err
}
- m.cache.Set(makeKey(coll.SpaceID, env.ID, coll.ID, opts.DisableSchemaIncludes), coll)
+ _ = m.cache.Set(makeKey(coll.SpaceID, env.ID, coll.ID, opts.DisableSchemaIncludes), coll)
for _, al := range env.Aliases {
- m.cache.Set(makeKey(coll.SpaceID, al, coll.ID, opts.DisableSchemaIncludes), coll)
+ _ = m.cache.Set(makeKey(coll.SpaceID, al, coll.ID, opts.DisableSchemaIncludes), coll)
}
}
@@ -73,11 +73,11 @@ func (m cachingMiddleware) Update(ctx context.Context, coll *service.Collection)
if err != nil {
return err
}
- m.cache.Remove(makeKey(env.SpaceID, env.ID, coll.ID, true))
- m.cache.Remove(makeKey(env.SpaceID, env.ID, coll.ID, false))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID, coll.ID, true))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID, coll.ID, false))
for _, al := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, al, coll.ID, true))
- m.cache.Remove(makeKey(env.SpaceID, al, coll.ID, false))
+ _ = m.cache.Remove(makeKey(env.SpaceID, al, coll.ID, true))
+ _ = m.cache.Remove(makeKey(env.SpaceID, al, coll.ID, false))
}
}
return err
@@ -90,11 +90,11 @@ func (m cachingMiddleware) SetSchema(ctx context.Context, spaceId, envId, collec
if err != nil {
return err
}
- m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, true))
- m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, false))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, true))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, false))
for _, al := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, al, collectionId, true))
- m.cache.Remove(makeKey(env.SpaceID, al, collectionId, false))
+ _ = m.cache.Remove(makeKey(env.SpaceID, al, collectionId, true))
+ _ = m.cache.Remove(makeKey(env.SpaceID, al, collectionId, false))
}
}
return err
@@ -107,11 +107,11 @@ func (m cachingMiddleware) SetState(ctx context.Context, spaceId, envId, collect
if err != nil {
return err
}
- m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, true))
- m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, false))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, true))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, false))
for _, al := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, al, collectionId, true))
- m.cache.Remove(makeKey(env.SpaceID, al, collectionId, false))
+ _ = m.cache.Remove(makeKey(env.SpaceID, al, collectionId, true))
+ _ = m.cache.Remove(makeKey(env.SpaceID, al, collectionId, false))
}
}
return err
@@ -125,11 +125,11 @@ func (m cachingMiddleware) Delete(ctx context.Context, spaceId string, envId str
if err != nil {
return err
}
- m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, true))
- m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, false))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, true))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID, collectionId, false))
for _, al := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, al, collectionId, true))
- m.cache.Remove(makeKey(env.SpaceID, al, collectionId, false))
+ _ = m.cache.Remove(makeKey(env.SpaceID, al, collectionId, true))
+ _ = m.cache.Remove(makeKey(env.SpaceID, al, collectionId, false))
}
}
return err
diff --git a/pkg/data/data.go b/pkg/data/data.go
index 0540055ad4e213f666b0cf72019b9b4b9c39fbe8..14528479855b9993e6cdce218ac087b41f334c58 100644
--- a/pkg/data/data.go
+++ b/pkg/data/data.go
@@ -120,7 +120,7 @@ func DeleteMany(paths []string, value any, delim ...string) {
return
}
for _, path := range paths {
- Delete(path, value, delim...)
+ _ = Delete(path, value, delim...)
}
}
@@ -245,7 +245,6 @@ func get(path []string, data any) (any, bool) {
// The path is the sting with delim, for eg:, parent.child.key
func Keep(paths []string, data any, delim ...string) {
if len(paths) == 0 {
- data = nil
return
}
switch val := data.(type) {
diff --git a/pkg/data/data_test.go b/pkg/data/data_test.go
index 785eefbb868a68c9d8c6b2f75b8f861ab2041e11..463a4cbc01ad7cfd5c249a026a89f733f3c54e60 100644
--- a/pkg/data/data_test.go
+++ b/pkg/data/data_test.go
@@ -63,22 +63,23 @@ func TestDelete(t *testing.T) {
}, "z": "2"},
},
// Решили что автоматически удалять пустые объекты/слайсы не нужно
- //{
+ // {
// "empty object",
// map[string]interface{}{"a": map[string]interface{}{"a": map[string]interface{}{}}},
// []string{"a", "a"},
// map[string]interface{}{},
- //}, {
+ // }, {
// "empty array",
// map[string]interface{}{"a": map[string]interface{}{"a": []interface{}{}}},
// []string{"a", "a"},
// map[string]interface{}{},
- //},
+ // },
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- Delete(tt.field, tt.in)
+ err := Delete(tt.field, tt.in)
+ assert.NoError(t, err)
assert.Equal(t, tt.out, tt.in)
})
}
diff --git a/pkg/data/translit.go b/pkg/data/translit.go
index 654ae90dd305be0ffd20bfcd58c782229a27156b..11679e37cf4da7e17f81d77c10077b7533ccef98 100644
--- a/pkg/data/translit.go
+++ b/pkg/data/translit.go
@@ -45,7 +45,7 @@ func TableEncode(s string, tlm map[rune]string) string {
}
if unicode.IsUpper(r) {
- tr = strings.Title(tr)
+ tr = strings.Title(tr) //nolint:staticcheck // Для обработки основных языков достаточно правил работы функции strings.Title
}
out.WriteString(tr)
diff --git a/pkg/environments/middleware/caching_middleware.go b/pkg/environments/middleware/caching_middleware.go
index 0801730a0e93947c847352a9710a02f85ae94ee0..7e4f46d23b49daac67d57cc33f7f81b1e836c16e 100644
--- a/pkg/environments/middleware/caching_middleware.go
+++ b/pkg/environments/middleware/caching_middleware.go
@@ -30,7 +30,7 @@ func (m cachingMiddleware) Create(ctx context.Context, env *service.Environment)
environment, err = m.next.Create(ctx, env)
if err == nil {
- m.cache.Remove(environment.SpaceID)
+ _ = m.cache.Remove(environment.SpaceID)
}
return environment, err
}
@@ -43,9 +43,9 @@ func (m cachingMiddleware) Get(ctx context.Context, spaceId string, envId string
}
environment, err = m.next.Get(ctx, spaceId, envId)
if err == nil {
- m.cache.Set(makeKey(spaceId, environment.ID), environment)
+ _ = m.cache.Set(makeKey(spaceId, environment.ID), environment)
for _, a := range environment.Aliases {
- m.cache.Set(makeKey(spaceId, a), environment)
+ _ = m.cache.Set(makeKey(spaceId, a), environment)
}
}
return environment, err
@@ -59,7 +59,7 @@ func (m cachingMiddleware) List(ctx context.Context, spaceId string) (environmen
}
environments, err = m.next.List(ctx, spaceId)
if err == nil {
- m.cache.Set(spaceId, environments)
+ _ = m.cache.Set(spaceId, environments)
}
return environments, err
}
@@ -71,12 +71,12 @@ func (m cachingMiddleware) Update(ctx context.Context, env *service.Environment)
value, e := m.cache.Get(makeKey(env.SpaceID, env.ID))
if e == nil {
env := value.(*service.Environment)
- m.cache.Remove(makeKey(env.SpaceID, env.ID))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID))
for _, a := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, a))
+ _ = m.cache.Remove(makeKey(env.SpaceID, a))
}
}
- m.cache.Remove(env.SpaceID)
+ _ = m.cache.Remove(env.SpaceID)
}
return err
}
@@ -88,12 +88,12 @@ func (m cachingMiddleware) Delete(ctx context.Context, spaceId string, envId str
value, e := m.cache.Get(makeKey(spaceId, envId))
if e == nil {
env := value.(*service.Environment)
- m.cache.Remove(makeKey(env.SpaceID, env.ID))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID))
for _, a := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, a))
+ _ = m.cache.Remove(makeKey(env.SpaceID, a))
}
}
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
}
return err
}
@@ -105,21 +105,21 @@ func (m cachingMiddleware) SetAlias(ctx context.Context, spaceId string, envId s
value, e := m.cache.Get(makeKey(spaceId, alias))
if e == nil {
env := value.(*service.Environment)
- m.cache.Remove(makeKey(env.SpaceID, env.ID))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID))
for _, a := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, a))
+ _ = m.cache.Remove(makeKey(env.SpaceID, a))
}
}
value, e = m.cache.Get(makeKey(spaceId, envId))
if e == nil {
env := value.(*service.Environment)
- m.cache.Remove(makeKey(env.SpaceID, env.ID))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID))
for _, a := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, a))
+ _ = m.cache.Remove(makeKey(env.SpaceID, a))
}
}
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
}
return err
}
@@ -128,22 +128,22 @@ func (m cachingMiddleware) RemoveAlias(ctx context.Context, spaceId string, envI
err = m.next.RemoveAlias(ctx, spaceId, envId, alias)
if err == nil {
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
value, e := m.cache.Get(makeKey(spaceId, alias))
if e == nil {
env := value.(*service.Environment)
- m.cache.Remove(makeKey(env.SpaceID, env.ID))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID))
for _, a := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, a))
+ _ = m.cache.Remove(makeKey(env.SpaceID, a))
}
}
value, e = m.cache.Get(makeKey(spaceId, envId))
if e == nil {
env := value.(*service.Environment)
- m.cache.Remove(makeKey(env.SpaceID, env.ID))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID))
for _, a := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, a))
+ _ = m.cache.Remove(makeKey(env.SpaceID, a))
}
}
}
@@ -157,11 +157,11 @@ func (m cachingMiddleware) Migrate(ctx context.Context, spaceId, envId string, o
value, e := m.cache.Get(makeKey(spaceId, envId))
if e == nil {
env := value.(*service.Environment)
- m.cache.Remove(makeKey(env.SpaceID, env.ID))
+ _ = m.cache.Remove(makeKey(env.SpaceID, env.ID))
for _, a := range env.Aliases {
- m.cache.Remove(makeKey(env.SpaceID, a))
+ _ = m.cache.Remove(makeKey(env.SpaceID, a))
}
}
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
return err
}
diff --git a/pkg/errors/code.go b/pkg/errors/code.go
index fdb94194b49508cc0f1e3610c41fc93d2c271bdf..08a87d477f66b2309ea58ad3a880a4f6e66dfdd5 100644
--- a/pkg/errors/code.go
+++ b/pkg/errors/code.go
@@ -30,7 +30,7 @@ func (e *codeError) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, e.Error())
+ _, _ = io.WriteString(s, e.Error())
case 'q':
fmt.Fprintf(s, "%q", e.Error())
}
diff --git a/pkg/errors/detail.go b/pkg/errors/detail.go
index a82ec3f8ad5fb7fd52f0ce0acdeeb833065e6ffa..556bf443ca81effa067748ac3f0f0e514d7e3665 100644
--- a/pkg/errors/detail.go
+++ b/pkg/errors/detail.go
@@ -27,7 +27,7 @@ func (w *withDetail) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, w.Error())
+ _, _ = io.WriteString(s, w.Error())
case 'q':
fmt.Fprintf(s, "%q", w.Error())
}
diff --git a/pkg/errors/domain.go b/pkg/errors/domain.go
index 35642c34e9537d236a83092855089804164a90de..20e3a25fd95ad4ff7d0b307729e4701151d6d5d3 100644
--- a/pkg/errors/domain.go
+++ b/pkg/errors/domain.go
@@ -31,7 +31,7 @@ func (w *withDomain) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, w.Error())
+ _, _ = io.WriteString(s, w.Error())
case 'q':
fmt.Fprintf(s, "%q", w.Error())
}
diff --git a/pkg/errors/field.go b/pkg/errors/field.go
index 891863f0471ab0215229f1eb848f8fb3822e1334..2c40756a65d4b7d3eb76fa907198e2fc9648ff83 100644
--- a/pkg/errors/field.go
+++ b/pkg/errors/field.go
@@ -31,7 +31,7 @@ func (w *withField) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, w.Error())
+ _, _ = io.WriteString(s, w.Error())
case 'q':
fmt.Fprintf(s, "%q", w.Error())
}
diff --git a/pkg/errors/hint.go b/pkg/errors/hint.go
index f654d4024936cdf19e65b89aaca2fef3070fb5bb..f327cd0784d3dbf40266f706cdaaa86451489b61 100644
--- a/pkg/errors/hint.go
+++ b/pkg/errors/hint.go
@@ -27,7 +27,7 @@ func (w *withHint) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, w.Error())
+ _, _ = io.WriteString(s, w.Error())
case 'q':
fmt.Fprintf(s, "%q", w.Error())
}
diff --git a/pkg/errors/id.go b/pkg/errors/id.go
index 9d9804882e0892c92998560b9be4ae7ec0fe1558..6483ced353452810b384bf8e76eb300700a168fd 100644
--- a/pkg/errors/id.go
+++ b/pkg/errors/id.go
@@ -29,7 +29,7 @@ func (w *withId) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, w.Error())
+ _, _ = io.WriteString(s, w.Error())
case 'q':
fmt.Fprintf(s, "%q", w.Error())
}
diff --git a/pkg/errors/multi.go b/pkg/errors/multi.go
index d27392c7a96ec2a8b653699052d9cbf7ee679ba8..f804cbd4420a8a8bef4ae137242dc60bb390b9b2 100644
--- a/pkg/errors/multi.go
+++ b/pkg/errors/multi.go
@@ -35,7 +35,7 @@ func (w *withMultiError) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, w.Error())
+ _, _ = io.WriteString(s, w.Error())
case 'q':
fmt.Fprintf(s, "%q", w.Error())
}
diff --git a/pkg/errors/source.go b/pkg/errors/source.go
index c43df751c063b7c2e419071e22812aa890074b42..dd5b6354aee8aea6a3ef47c6c47b8fd04c01c612 100644
--- a/pkg/errors/source.go
+++ b/pkg/errors/source.go
@@ -47,7 +47,7 @@ func (w *withSource) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, w.Error())
+ _, _ = io.WriteString(s, w.Error())
case 'q':
fmt.Fprintf(s, "%q", w.Error())
}
diff --git a/pkg/errors/status.go b/pkg/errors/status.go
index 04b8261296574fb72e5750edc100d8c2e805f9ff..952995a7147df6522b7b48243b2e9c39d71b7d8e 100644
--- a/pkg/errors/status.go
+++ b/pkg/errors/status.go
@@ -32,7 +32,7 @@ func (w *withStatusError) Format(s fmt.State, verb rune) {
}
fallthrough
case 's':
- io.WriteString(s, w.Error())
+ _, _ = io.WriteString(s, w.Error())
case 'q':
fmt.Fprintf(s, "%q", w.Error())
}
diff --git a/pkg/expr/context.go b/pkg/expr/context.go
index 4049d96f5f62a94219b247b09a4337b474112224..ef653f65d527b737b1949ca9e63987e86b37ce3d 100644
--- a/pkg/expr/context.go
+++ b/pkg/expr/context.go
@@ -51,6 +51,6 @@ func WithEnvKV(ctx context.Context, kv ...interface{}) context.Context {
}
func GetEnv(ctx context.Context) map[string]interface{} {
- ctx, c := getContext(ctx)
+ _, c := getContext(ctx)
return c.Env
}
diff --git a/pkg/extension/manager.go b/pkg/extension/manager.go
index 9de5dc4e71c1160a7277181a64085ebf6ab86032..9d4def7ce9e6c24c8e9ac257066606e16db80afb 100644
--- a/pkg/extension/manager.go
+++ b/pkg/extension/manager.go
@@ -55,7 +55,7 @@ func (e *ExtensionConnector) Connect() error {
return nil
}
- conn, err := grpc.Dial(
+ conn, err := grpc.NewClient(
e.Descriptor.Url,
grpc.WithTransportCredentials(insecure.NewCredentials()),
grpc.WithChainUnaryInterceptor(
diff --git a/pkg/extension/manager_client.go b/pkg/extension/manager_client.go
index d15d0dd0dd9eb53c5183f1faacc655c01dd494a1..3adbf804204de244552d42875edf1fdf95c06350 100644
--- a/pkg/extension/manager_client.go
+++ b/pkg/extension/manager_client.go
@@ -16,7 +16,7 @@ type ManagerClient struct {
}
func NewManagerClientWithAddr(addr string) (*ManagerClient, error) {
- cc, err := grpc.Dial(addr,
+ cc, err := grpc.NewClient(addr,
grpc.WithTransportCredentials(insecure.NewCredentials()),
grpc.WithUnaryInterceptor(auth.PrincipalClientInterceptor()),
)
diff --git a/pkg/extension/service/extension.go b/pkg/extension/service/extension.go
index 45ed0524f855f888d7baf9befb9080392185dfc1..d64590e39211619465bdca8839b9e28f4e678f23 100644
--- a/pkg/extension/service/extension.go
+++ b/pkg/extension/service/extension.go
@@ -29,7 +29,6 @@ type Extension struct {
setupFunc SetupFunc
Content *content.Content
Logger *zap.Logger
- manager extension.Manager
router extension.ActionRouter
withClient bool
@@ -184,13 +183,13 @@ func (s *Extension) Action(ctx context.Context, in *extension.ActionRequest) (*e
// мы так и не договорились, но проверка появилась
// пусть решает каждое расширение само
//
- //ok, err := extension.CheckInstalled(ctx, s.Content, in.SpaceId, in.EnvId, ext)
- //if err != nil {
+ // ok, err := extension.CheckInstalled(ctx, s.Content, in.SpaceId, in.EnvId, ext)
+ // if err != nil {
// return nil, errors.Wrap(err, "check extension installed")
- //}
- //if !ok {
+ // }
+ // if !ok {
// return nil, errors.New("extension not installed")
- //}
+ // }
if url, err := extension.NewActionURL(in.Action); s.router != nil && err == nil && url != nil && s.isCorrectExtension(ctx, url, in) {
if h, err := s.router(ctx, url, in); err == nil && h != nil {
diff --git a/pkg/extension/service/registrar.go b/pkg/extension/service/registrar.go
index 8a096ef2047058e70f355ece9136069b7d94d3af..28da7d37d7e3d5fd29d3dfc51ec8af3ecc83707f 100644
--- a/pkg/extension/service/registrar.go
+++ b/pkg/extension/service/registrar.go
@@ -8,7 +8,6 @@ import (
"git.perx.ru/perxis/perxis-go/pkg/extension"
retry "github.com/avast/retry-go/v4"
"go.uber.org/zap"
- "google.golang.org/grpc"
)
const RegistrationDelay = time.Minute
@@ -16,12 +15,11 @@ const RegistrationDelay = time.Minute
// Registrar выполняет действия по регистрации и обновления регистрации расширений в менеджере расширений. Одновременно
// выполняется регистрация одного или нескольких расширений
type Registrar struct {
- addr string
- managerConn *grpc.ClientConn
- manager extension.Manager
- exts []extension.Extension
- logger *zap.Logger
- stopFn func() error
+ addr string
+ manager extension.Manager
+ exts []extension.Extension
+ logger *zap.Logger
+ stopFn func() error
}
func NewRegistrar(addr string, man extension.Manager, exts []extension.Extension, logger *zap.Logger) *Registrar {
@@ -86,7 +84,7 @@ func (reg *Registrar) Start() error {
for {
select {
case <-time.After(registrationDelay):
- reg.register(regCtx, reg.manager, extList)
+ _ = reg.register(regCtx, reg.manager, extList)
registrationDelay = RegistrationDelay
case <-regCtx.Done():
reg.logger.Debug("Stop registration process")
diff --git a/pkg/files/downloader.go b/pkg/files/downloader.go
index 74aa91022906f794d07c314c5104011e4763caa9..2ec9f00d5feb2adaf7cf6a0d3305268b1f4f8717 100644
--- a/pkg/files/downloader.go
+++ b/pkg/files/downloader.go
@@ -50,7 +50,7 @@ func NewDummyDownloader() Downloader {
func (d *dummyDownloader) Download(dst io.Writer, file *File) error {
// png pixel 10x10
- pixel, err := base64.StdEncoding.DecodeString("iVBORw0KGgoAAAANSUhEUgAAAAoAAAAKCAYAAACNMs+9AAAAFUlEQVR42mNkYPhfz0AEYBxVSF+FAP5FDvcfRYWgAAAAAElFTkSuQmCC")
- _, err = dst.Write(pixel)
+ pixel, _ := base64.StdEncoding.DecodeString("iVBORw0KGgoAAAANSUhEUgAAAAoAAAAKCAYAAACNMs+9AAAAFUlEQVR42mNkYPhfz0AEYBxVSF+FAP5FDvcfRYWgAAAAAElFTkSuQmCC")
+ _, err := dst.Write(pixel)
return err
}
diff --git a/pkg/filter/filter.go b/pkg/filter/filter.go
index 04ebf36d2b95e7bc86018e5539a68d6fc1ddead9..d75dc99886698a14342dc4f5ad4d9423fc26d893 100644
--- a/pkg/filter/filter.go
+++ b/pkg/filter/filter.go
@@ -1,6 +1,7 @@
package filter
import (
+ "context"
"fmt"
"reflect"
"strings"
@@ -60,7 +61,7 @@ type FilterHandler struct {
func NewFilterHandler(sch ...*schema.Schema) *FilterHandler {
return &FilterHandler{
schemas: sch,
- //qbuilder: qb,
+ // qbuilder: qb,
}
}
@@ -77,9 +78,7 @@ func (h *FilterHandler) removeFieldPrefix(f string) string {
}
func (h *FilterHandler) AddSchema(sch ...*schema.Schema) *FilterHandler {
- for _, s := range sch {
- h.schemas = append(h.schemas, s)
- }
+ h.schemas = append(h.schemas, sch...)
return h
}
@@ -129,7 +128,7 @@ func (h *FilterHandler) validate(sch *schema.Schema, f *Filter) (err error) {
if f.Value, err = schema.Decode(nil, fld, f.Value); err != nil {
return h.formatErr(f.Field, f.Op, err)
}
- if err = validate.Validate(nil, fld, f.Value); err != nil {
+ if err = validate.Validate(context.Background(), fld, f.Value); err != nil {
return h.formatErr(f.Field, f.Op, err)
}
case In, NotIn:
@@ -377,7 +376,7 @@ func (b *mongoQueryBuilder) field(f string) string {
}
// $text search ??
-//func (b *mongoQueryBuilder) textSearchQuery(filters ...*Filter) string {
+// func (b *mongoQueryBuilder) textSearchQuery(filters ...*Filter) string {
// cnt, notcnt := "", ""
// for _, f := range filters {
// val, ok := f.Value.(string)
@@ -407,4 +406,4 @@ func (b *mongoQueryBuilder) field(f string) string {
// cnt += " " + notcnt
// }
// return cnt
-//}
+// }
diff --git a/pkg/invitations/middleware/caching_middleware.go b/pkg/invitations/middleware/caching_middleware.go
index 5f2a1086a15c09d55b5461e029036b091d68dcfe..698ee51195e4a958b42a0bd44dadfa125a2c0be8 100644
--- a/pkg/invitations/middleware/caching_middleware.go
+++ b/pkg/invitations/middleware/caching_middleware.go
@@ -34,7 +34,7 @@ func (m cachingMiddleware) Get(ctx context.Context, invitationId string) (inv *s
}
inv, err = m.next.Get(ctx, invitationId)
if err == nil {
- m.cache.Set(invitationId, inv)
+ _ = m.cache.Set(invitationId, inv)
}
return inv, err
}
@@ -43,7 +43,7 @@ func (m cachingMiddleware) Accept(ctx context.Context, invitationId string, user
err = m.next.Accept(ctx, invitationId, userId)
if err == nil {
- m.cache.Remove(invitationId)
+ _ = m.cache.Remove(invitationId)
}
return err
}
@@ -56,7 +56,7 @@ func (m cachingMiddleware) Delete(ctx context.Context, invitationId string) (err
err = m.next.Delete(ctx, invitationId)
if err == nil {
- m.cache.Remove(invitationId)
+ _ = m.cache.Remove(invitationId)
}
return err
}
diff --git a/pkg/locales/middleware/caching_middleware.go b/pkg/locales/middleware/caching_middleware.go
index 5b370b99d004e005b622f39eec0fa2006cd08c94..8a79a152981f95d6c61cc6177ea1900d4900c9a2 100644
--- a/pkg/locales/middleware/caching_middleware.go
+++ b/pkg/locales/middleware/caching_middleware.go
@@ -25,7 +25,7 @@ func (m cachingMiddleware) Create(ctx context.Context, locale *service.Locale) (
loc, err = m.next.Create(ctx, locale)
if err == nil {
- m.cache.Remove(loc.SpaceID)
+ _ = m.cache.Remove(loc.SpaceID)
}
return loc, err
}
@@ -47,7 +47,7 @@ func (m cachingMiddleware) List(ctx context.Context, spaceId string) (locales []
}
locales, err = m.next.List(ctx, spaceId)
if err == nil {
- m.cache.Set(spaceId, locales)
+ _ = m.cache.Set(spaceId, locales)
}
return locales, err
}
@@ -56,7 +56,7 @@ func (m cachingMiddleware) Delete(ctx context.Context, spaceId string, localeId
err = m.next.Delete(ctx, spaceId, localeId)
if err == nil {
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
}
return err
}
diff --git a/pkg/members/members.go b/pkg/members/members.go
index 77d5b1c4ff46e0c664e3c1dca6b9313e5e1aa452..3013b1ff2d4399bf627927cd1e80b9076b8b05b3 100644
--- a/pkg/members/members.go
+++ b/pkg/members/members.go
@@ -27,9 +27,9 @@ func (r Role) IsPrivileged() bool {
func (r Role) Format(s fmt.State, verb rune) {
switch verb {
case 's':
- s.Write([]byte(r.String()))
+ _, _ = s.Write([]byte(r.String()))
default:
- s.Write([]byte(strconv.Itoa(int(r))))
+ _, _ = s.Write([]byte(strconv.Itoa(int(r))))
}
}
diff --git a/pkg/members/middleware/caching_middleware.go b/pkg/members/middleware/caching_middleware.go
index 0af3f76f9e5aa1eeeee01c36f2e7509e35e951c3..00ddb61aa22b837798b6f7f46fd24525e6119adc 100644
--- a/pkg/members/middleware/caching_middleware.go
+++ b/pkg/members/middleware/caching_middleware.go
@@ -30,9 +30,9 @@ func (m cachingMiddleware) Set(ctx context.Context, orgId string, userId string,
err = m.next.Set(ctx, orgId, userId, role)
if err == nil {
- m.cache.Remove(makeKey(orgId, userId))
- m.cache.Remove(makeKey(orgId))
- m.cache.Remove(makeKey(userId))
+ _ = m.cache.Remove(makeKey(orgId, userId))
+ _ = m.cache.Remove(makeKey(orgId))
+ _ = m.cache.Remove(makeKey(userId))
}
return err
}
@@ -46,7 +46,7 @@ func (m cachingMiddleware) Get(ctx context.Context, orgId string, userId string)
}
role, err = m.next.Get(ctx, orgId, userId)
if err == nil {
- m.cache.Set(key, role)
+ _ = m.cache.Set(key, role)
}
return role, err
}
@@ -55,9 +55,9 @@ func (m cachingMiddleware) Remove(ctx context.Context, orgId string, userId stri
err = m.next.Remove(ctx, orgId, userId)
if err == nil {
- m.cache.Remove(makeKey(orgId, userId))
- m.cache.Remove(makeKey(orgId))
- m.cache.Remove(makeKey(userId))
+ _ = m.cache.Remove(makeKey(orgId, userId))
+ _ = m.cache.Remove(makeKey(orgId))
+ _ = m.cache.Remove(makeKey(userId))
}
return err
}
@@ -68,8 +68,8 @@ func (m cachingMiddleware) RemoveAll(ctx context.Context, orgId string) (err err
if err == nil {
members, _ := m.ListMembers(ctx, orgId)
for _, member := range members {
- m.cache.Remove(member.UserId)
- m.cache.Remove(makeKey(orgId, member.UserId))
+ _ = m.cache.Remove(member.UserId)
+ _ = m.cache.Remove(makeKey(orgId, member.UserId))
}
}
return err
@@ -83,7 +83,7 @@ func (m cachingMiddleware) ListMembers(ctx context.Context, orgId string) (membe
}
members, err = m.next.ListMembers(ctx, orgId)
if err == nil {
- m.cache.Set(makeKey(orgId), members)
+ _ = m.cache.Set(makeKey(orgId), members)
}
return members, err
}
@@ -96,7 +96,7 @@ func (m cachingMiddleware) ListOrganizations(ctx context.Context, userId string)
}
members, err = m.next.ListOrganizations(ctx, userId)
if err == nil {
- m.cache.Set(makeKey(userId), members)
+ _ = m.cache.Set(makeKey(userId), members)
}
return members, err
}
diff --git a/pkg/members/middleware/caching_middleware_test.go b/pkg/members/middleware/caching_middleware_test.go
index eda7eb3a2a85123d36d20f09e9bd0c5188b609a9..ea09d522188857ee841336e4d8dbdf9cad7ff55c 100644
--- a/pkg/members/middleware/caching_middleware_test.go
+++ b/pkg/members/middleware/caching_middleware_test.go
@@ -129,6 +129,7 @@ func TestMembersCache(t *testing.T) {
mbrs.On("Get", mock.Anything, orgId, userId).Return(members.RoleOwner, nil).Once()
v1, err := svc.Get(ctx, orgId, userId)
+ require.NoError(t, err)
v2, err := svc.Get(ctx, orgId, userId)
require.NoError(t, err)
diff --git a/pkg/operation/service.go b/pkg/operation/service.go
index 7561b52ac3ef0e7df521164b32e247a3c96b30f2..5456e56a9e853fb45242393d048de652937f5c64 100644
--- a/pkg/operation/service.go
+++ b/pkg/operation/service.go
@@ -129,7 +129,7 @@ func (s *service) Create(ctx context.Context, desc string, fn func(ctx context.C
// Создаем новый контекст для фоновой операции без Deadline
opCtx, cancel := context.WithCancel(auth.WithPrincipal(context.Background(), principal))
op.SetCancelFunc(cancel)
- s.Set(opCtx, op)
+ _ = s.Set(opCtx, op)
go func() {
response, err := fn(opCtx)
@@ -137,11 +137,11 @@ func (s *service) Create(ctx context.Context, desc string, fn func(ctx context.C
op.SetError(err)
}
if response != nil {
- op.SetResponse(response)
+ _ = op.SetResponse(response)
}
op.SetModifiedAt(time.Now())
op.SetDone(true)
- s.Set(opCtx, op)
+ _ = s.Set(opCtx, op)
}()
return op, nil
diff --git a/pkg/organizations/middleware/caching_middleware.go b/pkg/organizations/middleware/caching_middleware.go
index 18649df9511f12a658cbb3966d507a76108939d8..ecee27276835402a0381086d9032ebd22acedcf1 100644
--- a/pkg/organizations/middleware/caching_middleware.go
+++ b/pkg/organizations/middleware/caching_middleware.go
@@ -34,7 +34,7 @@ func (m cachingMiddleware) Get(ctx context.Context, orgId string) (organization
}
organization, err = m.next.Get(ctx, orgId)
if err == nil {
- m.cache.Set(orgId, organization)
+ _ = m.cache.Set(orgId, organization)
}
return organization, err
}
@@ -43,7 +43,7 @@ func (m cachingMiddleware) Update(ctx context.Context, org *service.Organization
err = m.next.Update(ctx, org)
if err == nil {
- m.cache.Remove(org.ID)
+ _ = m.cache.Remove(org.ID)
}
return err
}
@@ -52,7 +52,7 @@ func (m cachingMiddleware) Delete(ctx context.Context, orgId string) (err error)
err = m.next.Delete(ctx, orgId)
if err == nil {
- m.cache.Remove(orgId)
+ _ = m.cache.Remove(orgId)
}
return err
}
diff --git a/pkg/organizations/middleware/caching_middleware_test.go b/pkg/organizations/middleware/caching_middleware_test.go
index 19cd14d5b2e808f3d4c22f77d8b115a27a9025cf..3f30262041b3dfdd24b40810656e9478cc53a688 100644
--- a/pkg/organizations/middleware/caching_middleware_test.go
+++ b/pkg/organizations/middleware/caching_middleware_test.go
@@ -58,6 +58,7 @@ func TestOrganizationsCache(t *testing.T) {
orgs.On("Update", mock.Anything, mock.Anything).Return(nil).Once()
err = svc.Update(ctx, &organizations.Organization{ID: orgId, Name: "OrganizationUPD"})
+ require.NoError(t, err)
orgs.On("Get", mock.Anything, orgId).Return(&organizations.Organization{ID: orgId, Name: "OrganizationUPD"}, nil).Once()
@@ -83,6 +84,7 @@ func TestOrganizationsCache(t *testing.T) {
orgs.On("Delete", mock.Anything, mock.Anything).Return(nil).Once()
err = svc.Delete(ctx, orgId)
+ require.NoError(t, err)
orgs.On("Get", mock.Anything, orgId).Return(nil, errNotFound).Once()
diff --git a/pkg/references/field.go b/pkg/references/field.go
index c98ed2298150e012545d55d5364f62c4f44eac1b..85482b9e526c502f24005329522e3690d803c283 100644
--- a/pkg/references/field.go
+++ b/pkg/references/field.go
@@ -22,9 +22,7 @@ func (p ReferenceParameters) Type() field.Type { return &ReferenceType{} }
func (p ReferenceParameters) Clone(reset bool) field.Parameters {
if p.AllowedCollections != nil {
cols := make([]string, 0, len(p.AllowedCollections))
- for _, c := range p.AllowedCollections {
- cols = append(cols, c)
- }
+ cols = append(cols, p.AllowedCollections...)
p.AllowedCollections = cols
}
return &p
diff --git a/pkg/references/field_test.go b/pkg/references/field_test.go
index a51cb2ac65a3483cbe58169421734f17b6dce20c..8891c5a41307a2d568ae22e314785281da550174 100644
--- a/pkg/references/field_test.go
+++ b/pkg/references/field_test.go
@@ -255,7 +255,7 @@ func TestReferenceField_Validate(t *testing.T) {
refs := []*Reference{
{ID: "111", CollectionID: "media"},
}
- err := validate.Validate(nil, f, refs)
+ err := validate.Validate(context.Background(), f, refs)
require.NoError(t, err)
})
t.Run("Limit exceeded", func(t *testing.T) {
@@ -264,7 +264,7 @@ func TestReferenceField_Validate(t *testing.T) {
{ID: "111", CollectionID: "media"},
{ID: "222", CollectionID: "media"},
}
- err := validate.Validate(nil, f, refs)
+ err := validate.Validate(context.Background(), f, refs)
require.Error(t, err)
require.Contains(t, err.Error(), "validation error: maximum elements number is 1")
})
@@ -273,13 +273,13 @@ func TestReferenceField_Validate(t *testing.T) {
t.Run("Correct", func(t *testing.T) {
f := Field(nil, validate.Required())
ref := &Reference{ID: "111", CollectionID: "media"}
- err := validate.Validate(nil, f, ref)
+ err := validate.Validate(context.Background(), f, ref)
require.NoError(t, err)
})
t.Run("Empty", func(t *testing.T) {
f := Field(nil, validate.Required())
ref := &Reference{}
- err := validate.Validate(nil, f, ref)
+ err := validate.Validate(context.Background(), f, ref)
require.Error(t, err)
require.Contains(t, err.Error(), "validation error: value is required")
})
diff --git a/pkg/roles/middleware/caching_middleware.go b/pkg/roles/middleware/caching_middleware.go
index 3f46087ec59e3ee71cd441b87e16a995d82eb7ea..8537544fcf3809f6dbfafe3860a8b7f0c0a9de28 100644
--- a/pkg/roles/middleware/caching_middleware.go
+++ b/pkg/roles/middleware/caching_middleware.go
@@ -29,7 +29,7 @@ type cachingMiddleware struct {
func (m cachingMiddleware) Create(ctx context.Context, role *service.Role) (rl *service.Role, err error) {
rl, err = m.next.Create(ctx, role)
if err == nil {
- m.cache.Remove(rl.SpaceID)
+ _ = m.cache.Remove(rl.SpaceID)
}
return rl, err
}
@@ -42,7 +42,7 @@ func (m cachingMiddleware) Get(ctx context.Context, spaceId string, roleId strin
}
rl, err = m.next.Get(ctx, spaceId, roleId)
if err == nil {
- m.cache.Set(key, rl)
+ _ = m.cache.Set(key, rl)
}
return rl, err
}
@@ -54,7 +54,7 @@ func (m cachingMiddleware) List(ctx context.Context, spaceId string) (roles []*s
}
roles, err = m.next.List(ctx, spaceId)
if err == nil {
- m.cache.Set(spaceId, roles)
+ _ = m.cache.Set(spaceId, roles)
}
return roles, err
}
@@ -63,8 +63,8 @@ func (m cachingMiddleware) Update(ctx context.Context, role *service.Role) (err
err = m.next.Update(ctx, role)
if err == nil {
key := makeKey(role.SpaceID, role.ID)
- m.cache.Remove(key)
- m.cache.Remove(role.SpaceID)
+ _ = m.cache.Remove(key)
+ _ = m.cache.Remove(role.SpaceID)
}
return err
}
@@ -73,8 +73,8 @@ func (m cachingMiddleware) Delete(ctx context.Context, spaceId string, roleId st
err = m.next.Delete(ctx, spaceId, roleId)
if err == nil {
key := makeKey(spaceId, roleId)
- m.cache.Remove(key)
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(key)
+ _ = m.cache.Remove(spaceId)
}
return err
}
diff --git a/pkg/schema/field/array_test.go b/pkg/schema/field/array_test.go
index 964075c3e70b046b942057e837dd59c0421aecfe..b2948e1b12161da604ed22da96e4b8a092c0a99f 100644
--- a/pkg/schema/field/array_test.go
+++ b/pkg/schema/field/array_test.go
@@ -54,7 +54,7 @@ func TestArrayField_Decode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Decode(nil, tt.field, tt.data)
+ got, err := Decode(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.want.(string), fmt.Sprintf("Decode() error = %v, want %v", err, tt.want.(string)))
@@ -92,7 +92,7 @@ func TestArrayField_Encode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Encode(nil, tt.field, tt.data)
+ got, err := Encode(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.want.(string), fmt.Sprintf("Decode() error = %v, want %v", err, tt.want.(string)))
diff --git a/pkg/schema/field/boolean_test.go b/pkg/schema/field/boolean_test.go
index aaa09dcec353d7648a976759bb4fcc98d0fe0d7a..857201f325680902a2c970010c8da5cc4ab6cadc 100644
--- a/pkg/schema/field/boolean_test.go
+++ b/pkg/schema/field/boolean_test.go
@@ -1,6 +1,7 @@
package field
import (
+ "context"
"fmt"
"testing"
@@ -27,7 +28,7 @@ func TestBooleanField_Decode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Decode(nil, tt.field, tt.data)
+ got, err := Decode(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.want.(string), fmt.Sprintf("Decode() error = %v, want %v", err, tt.want.(string)))
@@ -59,7 +60,7 @@ func TestBooleanField_Encode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Encode(nil, tt.field, tt.data)
+ got, err := Encode(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.want.(string), fmt.Sprintf("Encode() error = %v, want %v", err, tt.want.(string)))
diff --git a/pkg/schema/field/field.go b/pkg/schema/field/field.go
index 32b17574e071e8d72eae3eba789c2bb2c6177faa..6edf18f57ce36bc1569446502cc3ba05332252c8 100644
--- a/pkg/schema/field/field.go
+++ b/pkg/schema/field/field.go
@@ -63,8 +63,6 @@ type Field struct {
Options Options `json:"options,omitempty"` // Дополнительные опции
Condition string `json:"condition,omitempty"` // Условие отображения поля
AdditionalValues bool `json:"additional_values,omitempty"` // Разрешает дополнительные значения вне ограничений правил
-
- prepared bool
}
// TODO: Replace with Named field???
@@ -477,7 +475,7 @@ func (f *Field) mergeField(fld *Field) error {
func (f *Field) Merge(fields ...*Field) error {
for _, fld := range fields {
- f.mergeField(fld)
+ _ = f.mergeField(fld)
}
return nil
}
diff --git a/pkg/schema/field/field_json.go b/pkg/schema/field/field_json.go
index dfb212044838d66da90436b127594427d3f842da..dfd7f85aebafe2f6c1008db1c45b40df65c27b9d 100644
--- a/pkg/schema/field/field_json.go
+++ b/pkg/schema/field/field_json.go
@@ -63,7 +63,7 @@ func (f *Field) UnmarshalJSON(b []byte) error {
*f = Field(j.FieldData)
f.Params = params
- f.Prepare()
+ _ = f.Prepare()
return nil
}
diff --git a/pkg/schema/field/loader.go b/pkg/schema/field/loader.go
index 583ecc2c7c6bdc0d278819d2327280ec87858117..3beb0ddef0d68bdad2ec8f099dbfd5f853873c14 100644
--- a/pkg/schema/field/loader.go
+++ b/pkg/schema/field/loader.go
@@ -22,7 +22,7 @@ type multiLoader struct {
func (c *multiLoader) Load(ctx context.Context, ref string) (fs []*Field, err error) {
for _, l := range c.loaders {
- if f, err := l.Load(nil, ref); err == nil {
+ if f, err := l.Load(ctx, ref); err == nil {
return f, nil
}
}
diff --git a/pkg/schema/field/location_test.go b/pkg/schema/field/location_test.go
index 5b8206b6128ae7f4bf8f4042cedc0540bf357992..2680dec74e3f312abdaaf88d97a6ab6a255c1c8f 100644
--- a/pkg/schema/field/location_test.go
+++ b/pkg/schema/field/location_test.go
@@ -1,6 +1,7 @@
package field
import (
+ "context"
"reflect"
"testing"
)
@@ -114,7 +115,7 @@ func TestLocationField_Decode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Decode(nil, tt.field, tt.data)
+ got, err := Decode(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Decode() error = %v, wantErr %v", err, tt.wantErr)
return
@@ -196,7 +197,7 @@ func TestLocationField_Encode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Encode(nil, tt.field, tt.data)
+ got, err := Encode(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Encode() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/field/object_test.go b/pkg/schema/field/object_test.go
index 2ada594bcdeba09fab5dfcc95eb947e2028766d9..a85d4488c74997f2e665489fb86a870a64aa96c0 100644
--- a/pkg/schema/field/object_test.go
+++ b/pkg/schema/field/object_test.go
@@ -1,6 +1,7 @@
package field
import (
+ "context"
"fmt"
"testing"
"time"
@@ -77,7 +78,7 @@ func TestObjectField_Decode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Decode(nil, tt.field, tt.data)
+ got, err := Decode(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.want.(string), fmt.Sprintf("Decode() error = %v, want %v", err, tt.want.(string)))
@@ -152,7 +153,7 @@ func TestObjectField_Encode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Encode(nil, tt.field, tt.data)
+ got, err := Encode(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.want.(string), fmt.Sprintf("Encode() error = %v, want %v", err, tt.want.(string)))
diff --git a/pkg/schema/field/primary_key_test.go b/pkg/schema/field/primary_key_test.go
index f74f32cafc72612d9b1575561718e6c625334d53..5e11ff00f62f95306bf302da8ae8ba9a5a94fd30 100644
--- a/pkg/schema/field/primary_key_test.go
+++ b/pkg/schema/field/primary_key_test.go
@@ -1,6 +1,7 @@
package field
import (
+ "context"
"reflect"
"testing"
)
@@ -18,7 +19,7 @@ func TestPrimaryKeyField_Decode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Decode(nil, tt.field, tt.data)
+ got, err := Decode(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Decode() error = %v, wantErr %v", err, tt.wantErr)
return
@@ -43,7 +44,7 @@ func TestPrimaryKeyField_Encode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Encode(nil, tt.field, tt.data)
+ got, err := Encode(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Decode() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/field/string_test.go b/pkg/schema/field/string_test.go
index d0fca29b8ed3f0c4ec987bf6705b7ea435116e40..16b7538fb86797946a4a3c3ba709e6e30cf4d5d8 100644
--- a/pkg/schema/field/string_test.go
+++ b/pkg/schema/field/string_test.go
@@ -1,6 +1,7 @@
package field
import (
+ "context"
"reflect"
"testing"
)
@@ -18,7 +19,7 @@ func TestStringField_Decode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Decode(nil, tt.field, tt.data)
+ got, err := Decode(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Decode() error = %v, wantErr %v", err, tt.wantErr)
return
@@ -43,7 +44,7 @@ func TestStringField_Encode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Encode(nil, tt.field, tt.data)
+ got, err := Encode(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Decode() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/field/time_test.go b/pkg/schema/field/time_test.go
index f9a8fb44552a0e0a704f7baae7ab10019c889bec..d315850f7352c706fe9ae34a699795f892a558f4 100644
--- a/pkg/schema/field/time_test.go
+++ b/pkg/schema/field/time_test.go
@@ -1,6 +1,7 @@
package field
import (
+ "context"
"reflect"
"testing"
"time"
@@ -21,7 +22,7 @@ func TestTimeField_Decode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Decode(nil, tt.field, tt.data)
+ got, err := Decode(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Decode() error = %v, wantErr %v", err, tt.wantErr)
return
@@ -48,7 +49,7 @@ func TestTimeField_Encode(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := Encode(nil, tt.field, tt.data)
+ got, err := Encode(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Encode() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/field/unknown.go b/pkg/schema/field/unknown.go
index f28a51cd1fbdc20a6b026d4504872149c939e727..ffe412265c18209cbcce8bc442bd6094e0eecf1d 100644
--- a/pkg/schema/field/unknown.go
+++ b/pkg/schema/field/unknown.go
@@ -50,8 +50,7 @@ func (UnknownType) ConvertParameters(p Parameters) (Parameters, error) {
}
func Unknown(typ string, params json.RawMessage, o ...interface{}) *Field {
- var pc ParametersConverter
- pc = unknownType
+ pc := unknownType
_ = pc
return NewField(&UnknownParameters{Typ: typ, Params: params}, o...)
}
diff --git a/pkg/schema/modify/default.go b/pkg/schema/modify/default.go
index 66ce6b89c0619ceb232050fa5ab057e4330fdfcb..637a0ff86021b61a59621a6aea7f63d89a40db64 100644
--- a/pkg/schema/modify/default.go
+++ b/pkg/schema/modify/default.go
@@ -14,7 +14,7 @@ type defaultValue struct {
func (d *defaultValue) Prepare(f *field.Field) error {
var err error
- d.Value, err = field.Decode(nil, f, d.Value)
+ d.Value, err = field.Decode(context.Background(), f, d.Value)
return err
}
diff --git a/pkg/schema/modify/default_test.go b/pkg/schema/modify/default_test.go
index b99630dc65a9249d04bc1b29ac9e9fc902c745cf..6ea9d11047c13434553ae0ee7776a49ab0ffaf44 100644
--- a/pkg/schema/modify/default_test.go
+++ b/pkg/schema/modify/default_test.go
@@ -1,6 +1,7 @@
package modify
import (
+ "context"
"testing"
"time"
@@ -45,9 +46,9 @@ func TestDefault(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := field.Decode(nil, tt.field, tt.data)
+ got, err := field.Decode(context.Background(), tt.field, tt.data)
require.NoError(t, err)
- got, _, err = Modify(nil, tt.field, got)
+ got, _, err = Modify(context.Background(), tt.field, got)
if (err != nil) != tt.wantErr {
t.Errorf("Modify() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/modify/string_test.go b/pkg/schema/modify/string_test.go
index ef90f7f6f4d6a43ff13b3ac10bda68602f09c5f4..2f6451266aa08612718321d1b85d4341f280ee74 100644
--- a/pkg/schema/modify/string_test.go
+++ b/pkg/schema/modify/string_test.go
@@ -1,6 +1,7 @@
package modify
import (
+ "context"
"reflect"
"testing"
@@ -25,7 +26,7 @@ func TestTrimSpace(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, _, err := Modify(nil, tt.field, tt.data)
+ got, _, err := Modify(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Modify() error = %v, wantErr %v", err, tt.wantErr)
return
@@ -65,7 +66,7 @@ func TestModify(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- _, _, err := Modify(nil, tt.field, tt.data)
+ _, _, err := Modify(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.error)
diff --git a/pkg/schema/modify/value_test.go b/pkg/schema/modify/value_test.go
index 9878fc70663005f7650ac567899634a94446e8b9..eb3b9a99f6d4df61f738a993c35b61be2ea865eb 100644
--- a/pkg/schema/modify/value_test.go
+++ b/pkg/schema/modify/value_test.go
@@ -1,6 +1,7 @@
package modify
import (
+ "context"
"reflect"
"testing"
@@ -50,7 +51,7 @@ func TestValue(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, _, err := Modify(nil, tt.field, tt.data)
+ got, _, err := Modify(context.Background(), tt.field, tt.data)
if (err != nil) != tt.wantErr {
t.Errorf("Modify() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/schema.go b/pkg/schema/schema.go
index e45298241602e6855c63019fe5bebcc4e2df27ee..a99f7b53f8a48253ddf620006b10f1ed8cdca97b 100644
--- a/pkg/schema/schema.go
+++ b/pkg/schema/schema.go
@@ -222,7 +222,7 @@ func (s *Schema) Introspect(ctx context.Context, data map[string]interface{}) (m
}
if parent != nil && name != "" {
- field.AddField(parent, name, fld)
+ _ = field.AddField(parent, name, fld)
}
ctx = context.WithValue(ctx, parentFieldCtxKey{}, fld)
diff --git a/pkg/schema/test/object_test.go b/pkg/schema/test/object_test.go
index 8ba60d9d39857f64af77ce14610b698049548093..f17b64511668ad8b4a86c5d91cb908a781384493 100644
--- a/pkg/schema/test/object_test.go
+++ b/pkg/schema/test/object_test.go
@@ -65,7 +65,7 @@ func TestNumberField_JSON(t *testing.T) {
b, err := json.MarshalIndent(fld, "", " ")
require.NoError(t, err)
- //fmt.Println(string(b))
+ // fmt.Println(string(b))
res := field.NewField(nil)
err = json.Unmarshal(b, res)
@@ -187,7 +187,7 @@ func TestSchema_JSON(t *testing.T) {
b, err := json.MarshalIndent(sch, "", " ")
require.NoError(t, err)
- //fmt.Println(string(b))
+ // fmt.Println(string(b))
res := schema.New()
err = json.Unmarshal(b, res)
@@ -703,7 +703,7 @@ func TestSchema_Modify(t *testing.T) {
)
in := map[string]interface{}{"last_name": "Curie", "name": "Marie"}
- _, _, err := modify.Modify(nil, sch, in)
+ _, _, err := modify.Modify(context.Background(), sch, in)
require.NoError(t, err)
}
@@ -724,7 +724,7 @@ func TestSchema_Validate(t *testing.T) {
)
in := map[string]interface{}{"info": map[string]interface{}{"time": time.Now()}, "name": "Name"}
- err := validate.Validate(nil, sch, in)
+ err := validate.Validate(context.Background(), sch, in)
require.NoError(t, err)
}
@@ -768,9 +768,9 @@ func TestSchema_ValidateErrors(t *testing.T) {
)
in := map[string]interface{}{"a": map[string]interface{}{"num2": 20, "num3": 5, "str1": "123456", "str2": "123", "str3": "some"}}
- decoded, err := schema.Decode(nil, sch, in)
+ decoded, err := schema.Decode(context.Background(), sch, in)
require.NoError(t, err)
- err = validate.Validate(nil, sch, decoded)
+ err = validate.Validate(context.Background(), sch, decoded)
require.Error(t, err)
require.Contains(t, err.Error(), "validation error")
var merr *multierror.Error
@@ -784,11 +784,11 @@ func TestSchema_ValidateEmptyObject(t *testing.T) {
"num1", field.Number(field.NumberFormatInt, validate.Required()),
)
- res, err := schema.Decode(nil, sch, nil)
+ res, err := schema.Decode(context.Background(), sch, nil)
require.NoError(t, err)
- res, _, err = modify.Modify(nil, sch, res)
+ res, _, err = modify.Modify(context.Background(), sch, res)
require.NoError(t, err)
- err = validate.Validate(nil, sch, res)
+ err = validate.Validate(context.Background(), sch, res)
require.NoError(t, err, "поля объекта nil не проверяются")
}
{
@@ -796,11 +796,11 @@ func TestSchema_ValidateEmptyObject(t *testing.T) {
"num1", field.Number(field.NumberFormatInt, validate.Required()),
)
- res, err := schema.Decode(nil, sch, map[string]interface{}{})
+ res, err := schema.Decode(context.Background(), sch, map[string]interface{}{})
require.NoError(t, err)
- res, _, err = modify.Modify(nil, sch, res)
+ res, _, err = modify.Modify(context.Background(), sch, res)
require.NoError(t, err)
- err = validate.Validate(nil, sch, res)
+ err = validate.Validate(context.Background(), sch, res)
require.Error(t, err, "поля пустого объекта проверяются")
}
{
@@ -808,11 +808,11 @@ func TestSchema_ValidateEmptyObject(t *testing.T) {
"num1", field.Number(field.NumberFormatInt, validate.Required()),
)
- res, err := schema.Decode(nil, sch, map[string]interface{}{"a": "sss"})
+ res, err := schema.Decode(context.Background(), sch, map[string]interface{}{"a": "sss"})
require.NoError(t, err)
- res, _, err = modify.Modify(nil, sch, res)
+ res, _, err = modify.Modify(context.Background(), sch, res)
require.NoError(t, err)
- err = validate.Validate(nil, sch, res)
+ err = validate.Validate(context.Background(), sch, res)
require.Error(t, err, "поля объекта с некорректными данными проверяются")
}
@@ -821,11 +821,11 @@ func TestSchema_ValidateEmptyObject(t *testing.T) {
"num1", field.Number(field.NumberFormatInt, validate.Required()),
).AddOptions(modify.Default(map[string]interface{}{}))
- res, err := schema.Decode(nil, sch, nil)
+ res, err := schema.Decode(context.Background(), sch, nil)
require.NoError(t, err)
- res, _, err = modify.Modify(nil, sch, res)
+ res, _, err = modify.Modify(context.Background(), sch, res)
require.NoError(t, err)
- err = validate.Validate(nil, sch, res)
+ err = validate.Validate(context.Background(), sch, res)
require.Error(t, err, "поля nil объекта Default данными проверяются")
}
}
@@ -839,9 +839,9 @@ func TestSchema_ModificationErrors(t *testing.T) {
)
in := map[string]interface{}{"a": map[string]interface{}{"num1": 20, "num3": 5, "str1": "123456", "str2": "123", "str3": "some"}}
- decoded, err := schema.Decode(nil, sch, in)
+ decoded, err := schema.Decode(context.Background(), sch, in)
require.NoError(t, err)
- _, _, err = modify.Modify(nil, sch, decoded)
+ _, _, err = modify.Modify(context.Background(), sch, decoded)
require.Error(t, err)
require.Contains(t, err.Error(), "modification error")
var merr *multierror.Error
@@ -868,10 +868,10 @@ func TestSchema_UnknownJSON(t *testing.T) {
assert.Equal(t, "unknown", s1.GetType().Name(), "Схема неизвестного типа должна определяться как unknown")
in := map[string]interface{}{"info": map[string]interface{}{"time": time.Now()}, "name": "Name"}
- out, err := field.Decode(nil, s1, in)
+ out, err := field.Decode(context.Background(), s1, in)
require.NoError(t, err)
assert.Equal(t, in, out, "Данные неизвестного типа не изменяются при декодировании")
- err = validate.Validate(nil, s1, in)
+ err = validate.Validate(context.Background(), s1, in)
require.NoError(t, err, "Данные неизвестного типа не валидируются вглубь")
b, err = json.Marshal(s1)
@@ -1421,9 +1421,9 @@ func TestSchema_Introspect(t *testing.T) {
assert.Nil(t, fld, fmt.Sprintf("поле '%s' должно отсутствовать в схеме", f))
}
- //b, err := json.MarshalIndent(got.Schema, "", " ")
- //require.NoError(t, err)
- //fmt.Printf("---\n%s\n---\n", b)
+ // b, err := json.MarshalIndent(got.Schema, "", " ")
+ // require.NoError(t, err)
+ // fmt.Printf("---\n%s\n---\n", b)
assert.Equal(t, tt.want, gotValue)
})
}
@@ -1526,11 +1526,11 @@ func TestSchema_Load(t *testing.T) {
)
schema.SetDefaultLoader(loader)
- err := sch.Load(nil)
+ err := sch.Load(context.Background())
require.NoError(t, err)
- //b, _ := json.MarshalIndent(sch, "", " ")
- //fmt.Println(string(b))
+ // b, _ := json.MarshalIndent(sch, "", " ")
+ // fmt.Println(string(b))
assert.NotNil(t, sch.GetField("s1"))
assert.NotNil(t, sch.GetField("s2"))
@@ -1579,7 +1579,7 @@ func TestSchema_WithIncludesCircle(t *testing.T) {
schema.SetDefaultLoader(loader)
sch := schema.NewFromField(field.Object().WithIncludes("f1"))
- err := sch.Load(nil)
+ err := sch.Load(context.Background())
require.Error(t, err)
assert.EqualError(t, err, "limit for included fields exceeded")
}
diff --git a/pkg/schema/validate/array_test.go b/pkg/schema/validate/array_test.go
index 57b99445d4681b3994cb9cc5e3c35822a38a4900..ec9e9d818d5b86d7fe9e8647d862e73f44232c65 100644
--- a/pkg/schema/validate/array_test.go
+++ b/pkg/schema/validate/array_test.go
@@ -1,6 +1,7 @@
package validate
import (
+ "context"
"testing"
"git.perx.ru/perxis/perxis-go/pkg/schema/field"
@@ -28,9 +29,9 @@ func TestArray(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := field.Decode(nil, tt.field, tt.data)
+ got, err := field.Decode(context.Background(), tt.field, tt.data)
require.NoError(t, err)
- err = Validate(nil, tt.field, got)
+ err = Validate(context.Background(), tt.field, got)
if (err != nil) != tt.wantErr {
t.Errorf("Validate() error = %v, wantErr %v", err, tt.wantErr)
return
@@ -67,7 +68,7 @@ func TestArrayValidate(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- err := Validate(nil, tt.field, tt.data)
+ err := Validate(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.error)
diff --git a/pkg/schema/validate/enum_test.go b/pkg/schema/validate/enum_test.go
index a473dc015f80e92a2b0845228b02023f3f92b63a..a4c301e190dd951da7f0fb3b3c2a2ed014277028 100644
--- a/pkg/schema/validate/enum_test.go
+++ b/pkg/schema/validate/enum_test.go
@@ -1,6 +1,7 @@
package validate
import (
+ "context"
"testing"
"git.perx.ru/perxis/perxis-go/pkg/schema/field"
@@ -57,9 +58,9 @@ func TestEnum(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := field.Decode(nil, tt.field, tt.data)
+ got, err := field.Decode(context.Background(), tt.field, tt.data)
require.NoError(t, err)
- err = Validate(nil, tt.field, got)
+ err = Validate(context.Background(), tt.field, got)
if (err != nil) != tt.wantErr {
t.Errorf("Validate() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/validate/number_test.go b/pkg/schema/validate/number_test.go
index edbd218cf3b19ecd5b412e5a7e74015a8dfaecb5..08f69401807c2cb6da3f403ee20bcbef51c06114 100644
--- a/pkg/schema/validate/number_test.go
+++ b/pkg/schema/validate/number_test.go
@@ -1,6 +1,7 @@
package validate
import (
+ "context"
"testing"
"git.perx.ru/perxis/perxis-go/pkg/schema/field"
@@ -40,9 +41,9 @@ func TestNumber(t *testing.T) {
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := field.Decode(nil, tt.field, tt.data)
+ got, err := field.Decode(context.Background(), tt.field, tt.data)
require.NoError(t, err)
- err = Validate(nil, tt.field, got)
+ err = Validate(context.Background(), tt.field, got)
if (err != nil) != tt.wantErr {
t.Errorf("Validate() error = %v, wantErr %v", err, tt.wantErr)
return
@@ -86,7 +87,7 @@ func TestNumberValidate(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- err := Validate(nil, tt.field, tt.data)
+ err := Validate(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.error)
diff --git a/pkg/schema/validate/readonly_test.go b/pkg/schema/validate/readonly_test.go
index ee8ca9ba89a16a02375556d365884bb35d378f83..379d906e139cb1191ef11751cc68ccb10766040f 100644
--- a/pkg/schema/validate/readonly_test.go
+++ b/pkg/schema/validate/readonly_test.go
@@ -1,6 +1,7 @@
package validate
import (
+ "context"
"testing"
"git.perx.ru/perxis/perxis-go/pkg/schema/field"
@@ -20,9 +21,9 @@ func TestReadonly(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := field.Decode(nil, tt.field, tt.data)
+ got, err := field.Decode(context.Background(), tt.field, tt.data)
require.NoError(t, err)
- err = Validate(nil, tt.field, got)
+ err = Validate(context.Background(), tt.field, got)
if (err != nil) != tt.wantErr {
t.Errorf("Validate() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/validate/required_test.go b/pkg/schema/validate/required_test.go
index 41a03ab50d6fab906e7f78229b560e4298475dde..b22a3748fa1a6459d33e76b9114b7dc9a6165351 100644
--- a/pkg/schema/validate/required_test.go
+++ b/pkg/schema/validate/required_test.go
@@ -1,6 +1,7 @@
package validate
import (
+ "context"
"testing"
"time"
@@ -21,7 +22,7 @@ func TestRequired(t *testing.T) {
{"Boolean no value", field.Bool(Required()), nil, true},
{"Boolean", field.Bool(Required()), false, false},
{"Location: no value", field.Location(Required()), nil, true},
- //{"Location: empty", field.Location(Required()), map[string]interface{}{}, true}, // не имеет смысла, при Decode вернется ошибка если объект пустой
+ // {"Location: empty", field.Location(Required()), map[string]interface{}{}, true}, // не имеет смысла, при Decode вернется ошибка если объект пустой
{"Location: not empty", field.Location(Required()), &field.GeoObject{Address: "addr"}, false},
{"Number (int) no value", field.Number(field.NumberFormatInt, Required()), nil, true},
{"Number (int) empty", field.Number(field.NumberFormatInt, Required()), 0, false},
@@ -41,9 +42,9 @@ func TestRequired(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := field.Decode(nil, tt.field, tt.data)
+ got, err := field.Decode(context.Background(), tt.field, tt.data)
require.NoError(t, err)
- err = Validate(nil, tt.field, got)
+ err = Validate(context.Background(), tt.field, got)
if (err != nil) != tt.wantErr {
t.Errorf("Validate() error = %v, wantErr %v", err, tt.wantErr)
return
diff --git a/pkg/schema/validate/string_test.go b/pkg/schema/validate/string_test.go
index 9d48cf4d75c5c7bba2763c125bc1b598e78b23ac..0fac9bb7c83d4a49b2b834cd779c74f3be529230 100644
--- a/pkg/schema/validate/string_test.go
+++ b/pkg/schema/validate/string_test.go
@@ -1,6 +1,7 @@
package validate
import (
+ "context"
"testing"
"git.perx.ru/perxis/perxis-go/pkg/schema/field"
@@ -112,9 +113,9 @@ func TestString(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- got, err := field.Decode(nil, tt.field, tt.data)
+ got, err := field.Decode(context.Background(), tt.field, tt.data)
require.NoError(t, err)
- err = Validate(nil, tt.field, got)
+ err = Validate(context.Background(), tt.field, got)
if tt.wantErr {
require.Error(t, err)
}
@@ -151,7 +152,7 @@ func TestStringValidate(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
- err := Validate(nil, tt.field, tt.data)
+ err := Validate(context.Background(), tt.field, tt.data)
if tt.wantErr {
require.Error(t, err)
assert.EqualError(t, err, tt.error)
diff --git a/pkg/schema/walk/walk.go b/pkg/schema/walk/walk.go
index 4757742f82efcaffd5faba47eb076ed727783c75..73bd1f9258d17d33fa4350a18a835e786f1082b5 100644
--- a/pkg/schema/walk/walk.go
+++ b/pkg/schema/walk/walk.go
@@ -93,7 +93,7 @@ func (m *Walker) datawalk(w *WalkContext) (err error) {
path := w.GetPath()
fn := m.DefaultFn
- fieldCfg, _ := m.config.Fields[path]
+ fieldCfg := m.config.Fields[path]
if fieldCfg.Fn != nil {
fn = fieldCfg.Fn
diff --git a/pkg/schemaloader/loader_test.go b/pkg/schemaloader/loader_test.go
index f796fd8f669e31140e4171955c4d7db8723cec26..b7cc32b21a91c2ad6efd86c9918800e56496919e 100644
--- a/pkg/schemaloader/loader_test.go
+++ b/pkg/schemaloader/loader_test.go
@@ -8,7 +8,7 @@ import (
"github.com/stretchr/testify/assert"
)
-//func Test_Load(t *testing.T) {
+// func Test_Load(t *testing.T) {
//
// const (
// spaceID = "SpaceID"
@@ -107,10 +107,10 @@ import (
// require.Nil(t, schemas, "Метод должен вернуть nil")
// collSvs.AssertExpectations(t)
// })
-//}
+// }
func Test_parseRef(t *testing.T) {
- ctx := WithContext(nil, &LoaderContext{SpaceID: "spc", EnvID: "env"})
+ ctx := WithContext(context.Background(), &LoaderContext{SpaceID: "spc", EnvID: "env"})
tests := []struct {
ref string
ctx context.Context
diff --git a/pkg/setup/client.go b/pkg/setup/client.go
index cc103faf1dd4dca2ee1547e88b150819ebb730a9..d465670e4ea063d8583277f7b743df1835501c6b 100644
--- a/pkg/setup/client.go
+++ b/pkg/setup/client.go
@@ -115,7 +115,7 @@ func (s *Setup) InstallClient(ctx context.Context, c ClientConfig) error {
client.SpaceID = s.SpaceID
if s.IsForce() {
- s.content.Clients.Delete(ctx, s.SpaceID, c.client.ID)
+ _ = s.content.Clients.Delete(ctx, s.SpaceID, c.client.ID)
_, err := s.content.Clients.Create(ctx, c.client)
return err
}
diff --git a/pkg/spaces/middleware/caching_middleware.go b/pkg/spaces/middleware/caching_middleware.go
index 03e220e2a86b8dfb563b0ef35085271cea4151c0..46c9ef468b39f15f0d462de695f1da4f38213832 100644
--- a/pkg/spaces/middleware/caching_middleware.go
+++ b/pkg/spaces/middleware/caching_middleware.go
@@ -30,7 +30,7 @@ func (m cachingMiddleware) Create(ctx context.Context, space *service.Space) (sp
sp, err = m.next.Create(ctx, space)
if err == nil {
- m.cache.Remove(orgKey(sp.OrgID))
+ _ = m.cache.Remove(orgKey(sp.OrgID))
}
return sp, err
}
@@ -43,7 +43,7 @@ func (m cachingMiddleware) Get(ctx context.Context, spaceId string) (sp *service
}
sp, err = m.next.Get(ctx, spaceId)
if err == nil {
- m.cache.Set(spaceId, sp)
+ _ = m.cache.Set(spaceId, sp)
}
return sp, err
}
@@ -56,9 +56,9 @@ func (m cachingMiddleware) List(ctx context.Context, orgId string) (spaces []*se
}
spaces, err = m.next.List(ctx, orgId)
if err == nil {
- m.cache.Set(orgKey(orgId), spaces)
+ _ = m.cache.Set(orgKey(orgId), spaces)
for _, s := range spaces {
- m.cache.Set(s.ID, s)
+ _ = m.cache.Set(s.ID, s)
}
}
return spaces, err
@@ -75,9 +75,9 @@ func (m cachingMiddleware) Update(ctx context.Context, space *service.Space) (er
value, e := m.cache.Get(space.ID)
if e == nil {
space := value.(*service.Space)
- m.cache.Remove(orgKey(space.OrgID))
+ _ = m.cache.Remove(orgKey(space.OrgID))
}
- m.cache.Remove(space.ID)
+ _ = m.cache.Remove(space.ID)
}
return err
}
@@ -89,9 +89,9 @@ func (m cachingMiddleware) UpdateConfig(ctx context.Context, spaceId string, con
value, e := m.cache.Get(spaceId)
if e == nil {
space := value.(*service.Space)
- m.cache.Remove(orgKey(space.OrgID))
+ _ = m.cache.Remove(orgKey(space.OrgID))
}
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
}
return err
}
@@ -117,9 +117,9 @@ func (m cachingMiddleware) Delete(ctx context.Context, spaceId string) (err erro
value, e := m.cache.Get(spaceId)
if e == nil {
space := value.(*service.Space)
- m.cache.Remove(orgKey(space.OrgID))
+ _ = m.cache.Remove(orgKey(space.OrgID))
}
- m.cache.Remove(spaceId)
+ _ = m.cache.Remove(spaceId)
}
return err
}
@@ -130,11 +130,11 @@ func (m cachingMiddleware) Transfer(ctx context.Context, spaceID, transferToOrg
value, e := m.cache.Get(spaceID)
if e == nil {
space := value.(*service.Space)
- m.cache.Remove(orgKey(space.OrgID))
- m.cache.Remove(orgKey(space.TransferToOrg))
+ _ = m.cache.Remove(orgKey(space.OrgID))
+ _ = m.cache.Remove(orgKey(space.TransferToOrg))
}
- m.cache.Remove(spaceID)
- m.cache.Remove(transferToOrg)
+ _ = m.cache.Remove(spaceID)
+ _ = m.cache.Remove(transferToOrg)
}
return err
}
@@ -145,10 +145,10 @@ func (m cachingMiddleware) AbortTransfer(ctx context.Context, spaceID string) er
value, e := m.cache.Get(spaceID)
if e == nil {
space := value.(*service.Space)
- m.cache.Remove(orgKey(space.OrgID))
- m.cache.Remove(orgKey(space.TransferToOrg))
+ _ = m.cache.Remove(orgKey(space.OrgID))
+ _ = m.cache.Remove(orgKey(space.TransferToOrg))
}
- m.cache.Remove(spaceID)
+ _ = m.cache.Remove(spaceID)
}
return err
}
@@ -163,11 +163,11 @@ func (m cachingMiddleware) Move(ctx context.Context, spaceID, orgID string) erro
value, e := m.cache.Get(spaceID)
if e == nil {
space := value.(*service.Space)
- m.cache.Remove(orgKey(space.OrgID))
- m.cache.Remove(orgKey(space.TransferToOrg))
+ _ = m.cache.Remove(orgKey(space.OrgID))
+ _ = m.cache.Remove(orgKey(space.TransferToOrg))
}
- m.cache.Remove(spaceID)
- m.cache.Remove(orgID)
+ _ = m.cache.Remove(spaceID)
+ _ = m.cache.Remove(orgID)
}
return err
}
diff --git a/pkg/users/middleware/caching_middleware.go b/pkg/users/middleware/caching_middleware.go
index 8397bfd3a5c2a02c9ff52c42f9d1e23d431aed8e..ee0bf4a0599276737b9f258e7f30995388edc8f3 100644
--- a/pkg/users/middleware/caching_middleware.go
+++ b/pkg/users/middleware/caching_middleware.go
@@ -34,9 +34,9 @@ func (m cachingMiddleware) Get(ctx context.Context, userId string) (user *servic
}
user, err = m.next.Get(ctx, userId)
if err == nil {
- m.cache.Set(user.ID, user)
+ _ = m.cache.Set(user.ID, user)
for _, i := range user.Identities {
- m.cache.Set(i, user)
+ _ = m.cache.Set(i, user)
}
}
return user, err
@@ -52,9 +52,9 @@ func (m cachingMiddleware) Update(ctx context.Context, update *service.User) (er
value, e := m.cache.Get(update.ID)
if err == nil && e == nil {
usr := value.(*service.User)
- m.cache.Remove(usr.ID)
+ _ = m.cache.Remove(usr.ID)
for _, i := range usr.Identities {
- m.cache.Remove(i)
+ _ = m.cache.Remove(i)
}
}
return err
@@ -66,9 +66,9 @@ func (m cachingMiddleware) Delete(ctx context.Context, userId string) (err error
value, e := m.cache.Get(userId)
if err == nil && e == nil {
usr := value.(*service.User)
- m.cache.Remove(usr.ID)
+ _ = m.cache.Remove(usr.ID)
for _, i := range usr.Identities {
- m.cache.Remove(i)
+ _ = m.cache.Remove(i)
}
}
return err
@@ -82,9 +82,9 @@ func (m cachingMiddleware) GetByIdentity(ctx context.Context, identity string) (
}
user, err = m.next.GetByIdentity(ctx, identity)
if err == nil {
- m.cache.Set(user.ID, user)
+ _ = m.cache.Set(user.ID, user)
for _, i := range user.Identities {
- m.cache.Set(i, user)
+ _ = m.cache.Set(i, user)
}
}
return user, err