3
0

Remove unused CustomRowScanner & RowScanners features from store

This commit is contained in:
Denis Arh
2022-02-12 09:00:13 +01:00
parent 2d90fe4e9e
commit 1949782ccd
43 changed files with 476 additions and 672 deletions
+4 -5
View File
@@ -11,16 +11,15 @@ package request
import (
"encoding/json"
"fmt"
"io"
"mime/multipart"
"net/http"
"strings"
"github.com/cortezaproject/corteza-server/pkg/label"
"github.com/cortezaproject/corteza-server/pkg/locale"
"github.com/cortezaproject/corteza-server/pkg/payload"
"github.com/go-chi/chi/v5"
sqlxTypes "github.com/jmoiron/sqlx/types"
"io"
"mime/multipart"
"net/http"
"strings"
)
// dummy vars to prevent
+4 -13
View File
@@ -556,20 +556,11 @@ func (s Store) execDelete{{ export $.Types.Plural }}(ctx context.Context, cnd sq
func (s Store) internal{{ export $.Types.Singular }}RowScanner({{ template "extraArgsDefFirst" . }}row rowScanner) (res *{{ $.Types.GoType }}, err error) {
res = &{{ $.Types.GoType }}{}
if _, has := s.config.RowScanners[{{ printf "%q" (unexport $.Types.Singular) }}]; has {
scanner := s.config.RowScanners[{{ printf "%q" (unexport $.Types.Singular) }}].(func({{ template "extraArgsDefFirst" . }}_ rowScanner, _ *{{ $.Types.GoType }}) error)
err = scanner({{ template "extraArgsCallFirst" . }}row, res)
} else {
{{- if .RDBMS.CustomRowScanner }}
err = s.scan{{ $.Types.Singular }}Row({{ template "extraArgsCallFirst" . }}row, res)
{{- else }}
err = row.Scan(
{{- range $.RDBMS.Columns }}
&res.{{ .Field }},
{{- end }}
)
err = row.Scan(
{{- range $.RDBMS.Columns }}
&res.{{ .Field }},
{{- end }}
}
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
-2
View File
@@ -82,7 +82,6 @@ type (
Alias string `yaml:"alias,omitempty"`
Table string `yaml:"table,omitempty"`
CustomRowScanner bool `yaml:"customRowScanner"`
CustomFilterConverter bool `yaml:"customFilterConverter"`
CustomSortConverter bool `yaml:"customSortConverter"`
CustomCursorCollector bool `yaml:"customCursorCollector"`
@@ -221,7 +220,6 @@ func procStore(mm ...string) ([]*storeDef, error) {
Source: m,
RDBMS: storeTypeRdbmsDef{
CustomRowScanner: false,
CustomFilterConverter: false,
CustomEncoder: false,
},
+14 -6
View File
@@ -135,12 +135,20 @@ func (s Store) execCreateActionlogs(ctx context.Context, payload store.Payload)
func (s Store) internalActionlogRowScanner(row rowScanner) (res *actionlog.Action, err error) {
res = &actionlog.Action{}
if _, has := s.config.RowScanners["actionlog"]; has {
scanner := s.config.RowScanners["actionlog"].(func(_ rowScanner, _ *actionlog.Action) error)
err = scanner(row, res)
} else {
err = s.scanActionlogRow(row, res)
}
err = row.Scan(
&res.ID,
&res.Timestamp,
&res.RequestOrigin,
&res.RequestID,
&res.ActorIPAddr,
&res.ActorID,
&res.Resource,
&res.Action,
&res.Error,
&res.Severity,
&res.Description,
&res.Meta,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+15 -20
View File
@@ -404,26 +404,21 @@ func (s Store) execDeleteApigwFilters(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalApigwFilterRowScanner(row rowScanner) (res *types.ApigwFilter, err error) {
res = &types.ApigwFilter{}
if _, has := s.config.RowScanners["apigwFilter"]; has {
scanner := s.config.RowScanners["apigwFilter"].(func(_ rowScanner, _ *types.ApigwFilter) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Route,
&res.Weight,
&res.Kind,
&res.Ref,
&res.Enabled,
&res.Params,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Route,
&res.Weight,
&res.Kind,
&res.Ref,
&res.Enabled,
&res.Params,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+14 -19
View File
@@ -404,25 +404,20 @@ func (s Store) execDeleteApigwRoutes(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalApigwRouteRowScanner(row rowScanner) (res *types.ApigwRoute, err error) {
res = &types.ApigwRoute{}
if _, has := s.config.RowScanners["apigwRoute"]; has {
scanner := s.config.RowScanners["apigwRoute"].(func(_ rowScanner, _ *types.ApigwRoute) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Endpoint,
&res.Method,
&res.Enabled,
&res.Group,
&res.Meta,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Endpoint,
&res.Method,
&res.Enabled,
&res.Group,
&res.Meta,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+11 -16
View File
@@ -432,22 +432,17 @@ func (s Store) execDeleteApplications(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalApplicationRowScanner(row rowScanner) (res *types.Application, err error) {
res = &types.Application{}
if _, has := s.config.RowScanners["application"]; has {
scanner := s.config.RowScanners["application"].(func(_ rowScanner, _ *types.Application) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Name,
&res.OwnerID,
&res.Enabled,
&res.Weight,
&res.Unify,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Name,
&res.OwnerID,
&res.Enabled,
&res.Weight,
&res.Unify,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+12 -17
View File
@@ -246,23 +246,18 @@ func (s Store) execDeleteAttachments(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalAttachmentRowScanner(row rowScanner) (res *types.Attachment, err error) {
res = &types.Attachment{}
if _, has := s.config.RowScanners["attachment"]; has {
scanner := s.config.RowScanners["attachment"].(func(_ rowScanner, _ *types.Attachment) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.OwnerID,
&res.Kind,
&res.Url,
&res.PreviewUrl,
&res.Name,
&res.Meta,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.OwnerID,
&res.Kind,
&res.Url,
&res.PreviewUrl,
&res.Name,
&res.Meta,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+21 -26
View File
@@ -443,32 +443,27 @@ func (s Store) execDeleteAuthClients(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalAuthClientRowScanner(row rowScanner) (res *types.AuthClient, err error) {
res = &types.AuthClient{}
if _, has := s.config.RowScanners["authClient"]; has {
scanner := s.config.RowScanners["authClient"].(func(_ rowScanner, _ *types.AuthClient) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Handle,
&res.Meta,
&res.Secret,
&res.Scope,
&res.ValidGrant,
&res.RedirectURI,
&res.Trusted,
&res.Enabled,
&res.ValidFrom,
&res.ExpiresAt,
&res.Security,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Handle,
&res.Meta,
&res.Secret,
&res.Scope,
&res.ValidGrant,
&res.RedirectURI,
&res.Trusted,
&res.Enabled,
&res.ValidFrom,
&res.ExpiresAt,
&res.Security,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+5 -10
View File
@@ -237,16 +237,11 @@ func (s Store) execDeleteAuthConfirmedClients(ctx context.Context, cnd squirrel.
func (s Store) internalAuthConfirmedClientRowScanner(row rowScanner) (res *types.AuthConfirmedClient, err error) {
res = &types.AuthConfirmedClient{}
if _, has := s.config.RowScanners["authConfirmedClient"]; has {
scanner := s.config.RowScanners["authConfirmedClient"].(func(_ rowScanner, _ *types.AuthConfirmedClient) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.UserID,
&res.ClientID,
&res.ConfirmedAt,
)
}
err = row.Scan(
&res.UserID,
&res.ClientID,
&res.ConfirmedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+13 -18
View File
@@ -190,24 +190,19 @@ func (s Store) execDeleteAuthOa2tokens(ctx context.Context, cnd squirrel.Sqlizer
func (s Store) internalAuthOa2tokenRowScanner(row rowScanner) (res *types.AuthOa2token, err error) {
res = &types.AuthOa2token{}
if _, has := s.config.RowScanners["authOa2token"]; has {
scanner := s.config.RowScanners["authOa2token"].(func(_ rowScanner, _ *types.AuthOa2token) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Code,
&res.Access,
&res.Refresh,
&res.ExpiresAt,
&res.CreatedAt,
&res.Data,
&res.ClientID,
&res.UserID,
&res.RemoteAddr,
&res.UserAgent,
)
}
err = row.Scan(
&res.ID,
&res.Code,
&res.Access,
&res.Refresh,
&res.ExpiresAt,
&res.CreatedAt,
&res.Data,
&res.ClientID,
&res.UserID,
&res.RemoteAddr,
&res.UserAgent,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+9 -14
View File
@@ -234,20 +234,15 @@ func (s Store) execDeleteAuthSessions(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalAuthSessionRowScanner(row rowScanner) (res *types.AuthSession, err error) {
res = &types.AuthSession{}
if _, has := s.config.RowScanners["authSession"]; has {
scanner := s.config.RowScanners["authSession"].(func(_ rowScanner, _ *types.AuthSession) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Data,
&res.UserID,
&res.RemoteAddr,
&res.UserAgent,
&res.CreatedAt,
&res.ExpiresAt,
)
}
err = row.Scan(
&res.ID,
&res.Data,
&res.UserID,
&res.RemoteAddr,
&res.UserAgent,
&res.CreatedAt,
&res.ExpiresAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+16 -21
View File
@@ -432,27 +432,22 @@ func (s Store) execDeleteAutomationSessions(ctx context.Context, cnd squirrel.Sq
func (s Store) internalAutomationSessionRowScanner(row rowScanner) (res *types.Session, err error) {
res = &types.Session{}
if _, has := s.config.RowScanners["automationSession"]; has {
scanner := s.config.RowScanners["automationSession"].(func(_ rowScanner, _ *types.Session) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.WorkflowID,
&res.EventType,
&res.ResourceType,
&res.Status,
&res.Input,
&res.Output,
&res.Stacktrace,
&res.CreatedBy,
&res.CreatedAt,
&res.PurgeAt,
&res.CompletedAt,
&res.SuspendedAt,
&res.Error,
)
}
err = row.Scan(
&res.ID,
&res.WorkflowID,
&res.EventType,
&res.ResourceType,
&res.Status,
&res.Input,
&res.Output,
&res.Stacktrace,
&res.CreatedBy,
&res.CreatedAt,
&res.PurgeAt,
&res.CompletedAt,
&res.SuspendedAt,
&res.Error,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+18 -23
View File
@@ -432,29 +432,24 @@ func (s Store) execDeleteAutomationTriggers(ctx context.Context, cnd squirrel.Sq
func (s Store) internalAutomationTriggerRowScanner(row rowScanner) (res *types.Trigger, err error) {
res = &types.Trigger{}
if _, has := s.config.RowScanners["automationTrigger"]; has {
scanner := s.config.RowScanners["automationTrigger"].(func(_ rowScanner, _ *types.Trigger) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.WorkflowID,
&res.StepID,
&res.Enabled,
&res.ResourceType,
&res.EventType,
&res.Meta,
&res.Constraints,
&res.Input,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.WorkflowID,
&res.StepID,
&res.Enabled,
&res.ResourceType,
&res.EventType,
&res.Meta,
&res.Constraints,
&res.Input,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+20 -25
View File
@@ -443,31 +443,26 @@ func (s Store) execDeleteAutomationWorkflows(ctx context.Context, cnd squirrel.S
func (s Store) internalAutomationWorkflowRowScanner(row rowScanner) (res *types.Workflow, err error) {
res = &types.Workflow{}
if _, has := s.config.RowScanners["automationWorkflow"]; has {
scanner := s.config.RowScanners["automationWorkflow"].(func(_ rowScanner, _ *types.Workflow) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Handle,
&res.Meta,
&res.Enabled,
&res.Trace,
&res.KeepSessions,
&res.Scope,
&res.Steps,
&res.Paths,
&res.Issues,
&res.RunAs,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Handle,
&res.Meta,
&res.Enabled,
&res.Trace,
&res.KeepSessions,
&res.Scope,
&res.Steps,
&res.Paths,
&res.Issues,
&res.RunAs,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+13 -18
View File
@@ -246,24 +246,19 @@ func (s Store) execDeleteComposeAttachments(ctx context.Context, cnd squirrel.Sq
func (s Store) internalComposeAttachmentRowScanner(row rowScanner) (res *types.Attachment, err error) {
res = &types.Attachment{}
if _, has := s.config.RowScanners["composeAttachment"]; has {
scanner := s.config.RowScanners["composeAttachment"].(func(_ rowScanner, _ *types.Attachment) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.NamespaceID,
&res.Kind,
&res.Url,
&res.PreviewUrl,
&res.Name,
&res.Meta,
&res.OwnerID,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.NamespaceID,
&res.Kind,
&res.Url,
&res.PreviewUrl,
&res.Name,
&res.Meta,
&res.OwnerID,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+10 -15
View File
@@ -442,21 +442,16 @@ func (s Store) execDeleteComposeCharts(ctx context.Context, cnd squirrel.Sqlizer
func (s Store) internalComposeChartRowScanner(row rowScanner) (res *types.Chart, err error) {
res = &types.Chart{}
if _, has := s.config.RowScanners["composeChart"]; has {
scanner := s.config.RowScanners["composeChart"].(func(_ rowScanner, _ *types.Chart) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Handle,
&res.Name,
&res.Config,
&res.NamespaceID,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Handle,
&res.Name,
&res.Config,
&res.NamespaceID,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+18 -23
View File
@@ -237,29 +237,24 @@ func (s Store) execDeleteComposeModuleFields(ctx context.Context, cnd squirrel.S
func (s Store) internalComposeModuleFieldRowScanner(row rowScanner) (res *types.ModuleField, err error) {
res = &types.ModuleField{}
if _, has := s.config.RowScanners["composeModuleField"]; has {
scanner := s.config.RowScanners["composeModuleField"].(func(_ rowScanner, _ *types.ModuleField) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Name,
&res.ModuleID,
&res.Place,
&res.Kind,
&res.Label,
&res.Options,
&res.Private,
&res.Required,
&res.Visible,
&res.Multi,
&res.DefaultValue,
&res.Expressions,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Name,
&res.ModuleID,
&res.Place,
&res.Kind,
&res.Label,
&res.Options,
&res.Private,
&res.Required,
&res.Visible,
&res.Multi,
&res.DefaultValue,
&res.Expressions,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+10 -15
View File
@@ -452,21 +452,16 @@ func (s Store) execDeleteComposeModules(ctx context.Context, cnd squirrel.Sqlize
func (s Store) internalComposeModuleRowScanner(row rowScanner) (res *types.Module, err error) {
res = &types.Module{}
if _, has := s.config.RowScanners["composeModule"]; has {
scanner := s.config.RowScanners["composeModule"].(func(_ rowScanner, _ *types.Module) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Handle,
&res.Name,
&res.Meta,
&res.NamespaceID,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Handle,
&res.Name,
&res.Meta,
&res.NamespaceID,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+10 -15
View File
@@ -441,21 +441,16 @@ func (s Store) execDeleteComposeNamespaces(ctx context.Context, cnd squirrel.Sql
func (s Store) internalComposeNamespaceRowScanner(row rowScanner) (res *types.Namespace, err error) {
res = &types.Namespace{}
if _, has := s.config.RowScanners["composeNamespace"]; has {
scanner := s.config.RowScanners["composeNamespace"].(func(_ rowScanner, _ *types.Namespace) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Name,
&res.Slug,
&res.Enabled,
&res.Meta,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Name,
&res.Slug,
&res.Enabled,
&res.Meta,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+16 -21
View File
@@ -452,27 +452,22 @@ func (s Store) execDeleteComposePages(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalComposePageRowScanner(row rowScanner) (res *types.Page, err error) {
res = &types.Page{}
if _, has := s.config.RowScanners["composePage"]; has {
scanner := s.config.RowScanners["composePage"].(func(_ rowScanner, _ *types.Page) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.SelfID,
&res.NamespaceID,
&res.ModuleID,
&res.Handle,
&res.Title,
&res.Description,
&res.Config,
&res.Blocks,
&res.Visible,
&res.Weight,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.SelfID,
&res.NamespaceID,
&res.ModuleID,
&res.Handle,
&res.Title,
&res.Description,
&res.Config,
&res.Blocks,
&res.Visible,
&res.Weight,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+8 -13
View File
@@ -231,19 +231,14 @@ func (s Store) execDeleteComposeRecordValues(ctx context.Context, cnd squirrel.S
func (s Store) internalComposeRecordValueRowScanner(_mod *types.Module, row rowScanner) (res *types.RecordValue, err error) {
res = &types.RecordValue{}
if _, has := s.config.RowScanners["composeRecordValue"]; has {
scanner := s.config.RowScanners["composeRecordValue"].(func(_mod *types.Module, _ rowScanner, _ *types.RecordValue) error)
err = scanner(_mod, row, res)
} else {
err = row.Scan(
&res.RecordID,
&res.Name,
&res.Place,
&res.Value,
&res.Ref,
&res.DeletedAt,
)
}
err = row.Scan(
&res.RecordID,
&res.Name,
&res.Place,
&res.Value,
&res.Ref,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+12 -17
View File
@@ -370,23 +370,18 @@ func (s Store) execDeleteComposeRecords(ctx context.Context, cnd squirrel.Sqlize
func (s Store) internalComposeRecordRowScanner(_mod *types.Module, row rowScanner) (res *types.Record, err error) {
res = &types.Record{}
if _, has := s.config.RowScanners["composeRecord"]; has {
scanner := s.config.RowScanners["composeRecord"].(func(_mod *types.Module, _ rowScanner, _ *types.Record) error)
err = scanner(_mod, row, res)
} else {
err = row.Scan(
&res.ID,
&res.ModuleID,
&res.NamespaceID,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.ModuleID,
&res.NamespaceID,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+13 -18
View File
@@ -236,24 +236,19 @@ func (s Store) execDeleteCredentials(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalCredentialsRowScanner(row rowScanner) (res *types.Credentials, err error) {
res = &types.Credentials{}
if _, has := s.config.RowScanners["credentials"]; has {
scanner := s.config.RowScanners["credentials"].(func(_ rowScanner, _ *types.Credentials) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.OwnerID,
&res.Kind,
&res.Label,
&res.Credentials,
&res.Meta,
&res.LastUsedAt,
&res.ExpiresAt,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.OwnerID,
&res.Kind,
&res.Label,
&res.Credentials,
&res.Meta,
&res.LastUsedAt,
&res.ExpiresAt,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+15 -20
View File
@@ -432,26 +432,21 @@ func (s Store) execDeleteFederationExposedModules(ctx context.Context, cnd squir
func (s Store) internalFederationExposedModuleRowScanner(row rowScanner) (res *types.ExposedModule, err error) {
res = &types.ExposedModule{}
if _, has := s.config.RowScanners["federationExposedModule"]; has {
scanner := s.config.RowScanners["federationExposedModule"].(func(_ rowScanner, _ *types.ExposedModule) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Handle,
&res.Name,
&res.NodeID,
&res.ComposeModuleID,
&res.ComposeNamespaceID,
&res.Fields,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Handle,
&res.Name,
&res.NodeID,
&res.ComposeModuleID,
&res.ComposeNamespaceID,
&res.Fields,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+6 -11
View File
@@ -459,17 +459,12 @@ func (s Store) execDeleteFederationModuleMappings(ctx context.Context, cnd squir
func (s Store) internalFederationModuleMappingRowScanner(row rowScanner) (res *types.ModuleMapping, err error) {
res = &types.ModuleMapping{}
if _, has := s.config.RowScanners["federationModuleMapping"]; has {
scanner := s.config.RowScanners["federationModuleMapping"].(func(_ rowScanner, _ *types.ModuleMapping) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.FederationModuleID,
&res.ComposeModuleID,
&res.ComposeNamespaceID,
&res.FieldMapping,
)
}
err = row.Scan(
&res.FederationModuleID,
&res.ComposeModuleID,
&res.ComposeNamespaceID,
&res.FieldMapping,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+16 -21
View File
@@ -261,27 +261,22 @@ func (s Store) execDeleteFederationNodes(ctx context.Context, cnd squirrel.Sqliz
func (s Store) internalFederationNodeRowScanner(row rowScanner) (res *types.Node, err error) {
res = &types.Node{}
if _, has := s.config.RowScanners["federationNode"]; has {
scanner := s.config.RowScanners["federationNode"].(func(_ rowScanner, _ *types.Node) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Name,
&res.SharedNodeID,
&res.BaseURL,
&res.Status,
&res.Contact,
&res.PairToken,
&res.AuthToken,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Name,
&res.SharedNodeID,
&res.BaseURL,
&res.Status,
&res.Contact,
&res.PairToken,
&res.AuthToken,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+7 -12
View File
@@ -444,18 +444,13 @@ func (s Store) execDeleteFederationNodesSyncs(ctx context.Context, cnd squirrel.
func (s Store) internalFederationNodesSyncRowScanner(row rowScanner) (res *types.NodeSync, err error) {
res = &types.NodeSync{}
if _, has := s.config.RowScanners["federationNodesSync"]; has {
scanner := s.config.RowScanners["federationNodesSync"].(func(_ rowScanner, _ *types.NodeSync) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.NodeID,
&res.ModuleID,
&res.SyncType,
&res.SyncStatus,
&res.TimeOfAction,
)
}
err = row.Scan(
&res.NodeID,
&res.ModuleID,
&res.SyncType,
&res.SyncStatus,
&res.TimeOfAction,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+14 -19
View File
@@ -432,25 +432,20 @@ func (s Store) execDeleteFederationSharedModules(ctx context.Context, cnd squirr
func (s Store) internalFederationSharedModuleRowScanner(row rowScanner) (res *types.SharedModule, err error) {
res = &types.SharedModule{}
if _, has := s.config.RowScanners["federationSharedModule"]; has {
scanner := s.config.RowScanners["federationSharedModule"].(func(_ rowScanner, _ *types.SharedModule) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.NodeID,
&res.Handle,
&res.Name,
&res.ExternalFederationModuleID,
&res.Fields,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.NodeID,
&res.Handle,
&res.Name,
&res.ExternalFederationModuleID,
&res.Fields,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+7 -12
View File
@@ -269,18 +269,13 @@ func (s Store) execDeleteFlags(ctx context.Context, cnd squirrel.Sqlizer) error
func (s Store) internalFlagRowScanner(row rowScanner) (res *types.Flag, err error) {
res = &types.Flag{}
if _, has := s.config.RowScanners["flag"]; has {
scanner := s.config.RowScanners["flag"].(func(_ rowScanner, _ *types.Flag) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.Kind,
&res.ResourceID,
&res.OwnedBy,
&res.Name,
&res.Active,
)
}
err = row.Scan(
&res.Kind,
&res.ResourceID,
&res.OwnedBy,
&res.Name,
&res.Active,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+6 -11
View File
@@ -240,17 +240,12 @@ func (s Store) execDeleteLabels(ctx context.Context, cnd squirrel.Sqlizer) error
func (s Store) internalLabelRowScanner(row rowScanner) (res *types.Label, err error) {
res = &types.Label{}
if _, has := s.config.RowScanners["label"]; has {
scanner := s.config.RowScanners["label"].(func(_ rowScanner, _ *types.Label) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.Kind,
&res.ResourceID,
&res.Name,
&res.Value,
)
}
err = row.Scan(
&res.Kind,
&res.ResourceID,
&res.Name,
&res.Value,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+12 -17
View File
@@ -422,23 +422,18 @@ func (s Store) execDeleteQueues(ctx context.Context, cnd squirrel.Sqlizer) error
func (s Store) internalQueueRowScanner(row rowScanner) (res *types.Queue, err error) {
res = &types.Queue{}
if _, has := s.config.RowScanners["queue"]; has {
scanner := s.config.RowScanners["queue"].(func(_ rowScanner, _ *types.Queue) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Consumer,
&res.Queue,
&res.Meta,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Consumer,
&res.Queue,
&res.Meta,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+7 -12
View File
@@ -380,18 +380,13 @@ func (s Store) execDeleteQueueMessages(ctx context.Context, cnd squirrel.Sqlizer
func (s Store) internalQueueMessageRowScanner(row rowScanner) (res *types.QueueMessage, err error) {
res = &types.QueueMessage{}
if _, has := s.config.RowScanners["queueMessage"]; has {
scanner := s.config.RowScanners["queueMessage"].(func(_ rowScanner, _ *types.QueueMessage) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Queue,
&res.Payload,
&res.Processed,
&res.Created,
)
}
err = row.Scan(
&res.ID,
&res.Queue,
&res.Payload,
&res.Processed,
&res.Created,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+6 -11
View File
@@ -228,17 +228,12 @@ func (s Store) execDeleteRbacRules(ctx context.Context, cnd squirrel.Sqlizer) er
func (s Store) internalRbacRuleRowScanner(row rowScanner) (res *rbac.Rule, err error) {
res = &rbac.Rule{}
if _, has := s.config.RowScanners["rbacRule"]; has {
scanner := s.config.RowScanners["rbacRule"].(func(_ rowScanner, _ *rbac.Rule) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.RoleID,
&res.Resource,
&res.Operation,
&res.Access,
)
}
err = row.Scan(
&res.RoleID,
&res.Resource,
&res.Operation,
&res.Access,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
-3
View File
@@ -87,9 +87,6 @@ type (
ErrorHandler store.ErrorHandler
// Implementations can override internal RDBMS row scanners
RowScanners map[string]interface{}
// Different store backend implementation might handle upsert differently...
UpsertBuilder func(*Config, string, store.Payload, ...string) (squirrel.InsertBuilder, error)
+15 -20
View File
@@ -432,26 +432,21 @@ func (s Store) execDeleteReminders(ctx context.Context, cnd squirrel.Sqlizer) er
func (s Store) internalReminderRowScanner(row rowScanner) (res *types.Reminder, err error) {
res = &types.Reminder{}
if _, has := s.config.RowScanners["reminder"]; has {
scanner := s.config.RowScanners["reminder"].(func(_ rowScanner, _ *types.Reminder) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Resource,
&res.Payload,
&res.SnoozeCount,
&res.AssignedTo,
&res.AssignedBy,
&res.AssignedAt,
&res.DismissedBy,
&res.DismissedAt,
&res.RemindAt,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Resource,
&res.Payload,
&res.SnoozeCount,
&res.AssignedTo,
&res.AssignedBy,
&res.AssignedAt,
&res.DismissedBy,
&res.DismissedAt,
&res.RemindAt,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+16 -20
View File
@@ -11,6 +11,7 @@ package rdbms
import (
"context"
"database/sql"
"github.com/Masterminds/squirrel"
"github.com/cortezaproject/corteza-server/pkg/errors"
"github.com/cortezaproject/corteza-server/pkg/filter"
@@ -443,26 +444,21 @@ func (s Store) execDeleteReports(ctx context.Context, cnd squirrel.Sqlizer) erro
func (s Store) internalReportRowScanner(row rowScanner) (res *types.Report, err error) {
res = &types.Report{}
if _, has := s.config.RowScanners["report"]; has {
scanner := s.config.RowScanners["report"].(func(_ rowScanner, _ *types.Report) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Handle,
&res.Meta,
&res.Scenarios,
&res.Sources,
&res.Blocks,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Handle,
&res.Meta,
&res.Scenarios,
&res.Sources,
&res.Blocks,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+14 -19
View File
@@ -421,25 +421,20 @@ func (s Store) execDeleteResourceTranslations(ctx context.Context, cnd squirrel.
func (s Store) internalResourceTranslationRowScanner(row rowScanner) (res *types.ResourceTranslation, err error) {
res = &types.ResourceTranslation{}
if _, has := s.config.RowScanners["resourceTranslation"]; has {
scanner := s.config.RowScanners["resourceTranslation"].(func(_ rowScanner, _ *types.ResourceTranslation) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Lang,
&res.Resource,
&res.K,
&res.Message,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Lang,
&res.Resource,
&res.K,
&res.Message,
&res.OwnedBy,
&res.CreatedBy,
&res.UpdatedBy,
&res.DeletedBy,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+4 -9
View File
@@ -229,15 +229,10 @@ func (s Store) execDeleteRoleMembers(ctx context.Context, cnd squirrel.Sqlizer)
func (s Store) internalRoleMemberRowScanner(row rowScanner) (res *types.RoleMember, err error) {
res = &types.RoleMember{}
if _, has := s.config.RowScanners["roleMember"]; has {
scanner := s.config.RowScanners["roleMember"].(func(_ rowScanner, _ *types.RoleMember) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.UserID,
&res.RoleID,
)
}
err = row.Scan(
&res.UserID,
&res.RoleID,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+10 -15
View File
@@ -456,21 +456,16 @@ func (s Store) execDeleteRoles(ctx context.Context, cnd squirrel.Sqlizer) error
func (s Store) internalRoleRowScanner(row rowScanner) (res *types.Role, err error) {
res = &types.Role{}
if _, has := s.config.RowScanners["role"]; has {
scanner := s.config.RowScanners["role"].(func(_ rowScanner, _ *types.Role) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Name,
&res.Handle,
&res.Meta,
&res.CreatedAt,
&res.UpdatedAt,
&res.ArchivedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Name,
&res.Handle,
&res.Meta,
&res.CreatedAt,
&res.UpdatedAt,
&res.ArchivedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+7 -12
View File
@@ -247,18 +247,13 @@ func (s Store) execDeleteSettings(ctx context.Context, cnd squirrel.Sqlizer) err
func (s Store) internalSettingRowScanner(row rowScanner) (res *types.SettingValue, err error) {
res = &types.SettingValue{}
if _, has := s.config.RowScanners["setting"]; has {
scanner := s.config.RowScanners["setting"].(func(_ rowScanner, _ *types.SettingValue) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.Name,
&res.OwnedBy,
&res.Value,
&res.UpdatedBy,
&res.UpdatedAt,
)
}
err = row.Scan(
&res.Name,
&res.OwnedBy,
&res.Value,
&res.UpdatedBy,
&res.UpdatedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+14 -19
View File
@@ -443,25 +443,20 @@ func (s Store) execDeleteTemplates(ctx context.Context, cnd squirrel.Sqlizer) er
func (s Store) internalTemplateRowScanner(row rowScanner) (res *types.Template, err error) {
res = &types.Template{}
if _, has := s.config.RowScanners["template"]; has {
scanner := s.config.RowScanners["template"].(func(_ rowScanner, _ *types.Template) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Handle,
&res.Language,
&res.Type,
&res.Partial,
&res.Meta,
&res.Template,
&res.OwnerID,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
&res.LastUsedAt,
)
}
err = row.Scan(
&res.ID,
&res.Handle,
&res.Language,
&res.Type,
&res.Partial,
&res.Meta,
&res.Template,
&res.OwnerID,
&res.CreatedAt,
&res.UpdatedAt,
&res.DeletedAt,
&res.LastUsedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)
+14 -19
View File
@@ -465,25 +465,20 @@ func (s Store) execDeleteUsers(ctx context.Context, cnd squirrel.Sqlizer) error
func (s Store) internalUserRowScanner(row rowScanner) (res *types.User, err error) {
res = &types.User{}
if _, has := s.config.RowScanners["user"]; has {
scanner := s.config.RowScanners["user"].(func(_ rowScanner, _ *types.User) error)
err = scanner(row, res)
} else {
err = row.Scan(
&res.ID,
&res.Email,
&res.EmailConfirmed,
&res.Username,
&res.Name,
&res.Handle,
&res.Meta,
&res.Kind,
&res.CreatedAt,
&res.UpdatedAt,
&res.SuspendedAt,
&res.DeletedAt,
)
}
err = row.Scan(
&res.ID,
&res.Email,
&res.EmailConfirmed,
&res.Username,
&res.Name,
&res.Handle,
&res.Meta,
&res.Kind,
&res.CreatedAt,
&res.UpdatedAt,
&res.SuspendedAt,
&res.DeletedAt,
)
if err == sql.ErrNoRows {
return nil, store.ErrNotFound.Stack(1)