memory.*SchemaWriter.WriteSchema - Code Metrics - Inspection of "refactor: rename files for consistency and improve..." - Permify/permify - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#2516)

by Tolga

created 2025-10-07 11:06 UTC

memory.*SchemaWriter.WriteSchema A

↳ Parent: internal/storage/memory/schema_writer.go

Complexity

Conditions

Size

Total Lines	22
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
eloc	16
nop	2
dl	0
loc	22
rs	9.6
c	0
b	0
f	0

package memory

import (
	"context"
	"errors"
	"sync"

	"github.com/Permify/permify/internal/storage"
	"github.com/Permify/permify/internal/storage/memory/constants"
	db "github.com/Permify/permify/pkg/database/memory"
	base "github.com/Permify/permify/pkg/pb/base/v1"
)

var (
	headVersion map[string]string
	mu          sync.Mutex
)

func init() {
	headVersion = make(map[string]string)
}

// SchemaWriter - Structure for Schema Writer
type SchemaWriter struct {
	database *db.Memory
}

// NewSchemaWriter creates a new SchemaWriter
func NewSchemaWriter(database *db.Memory) *SchemaWriter {
	return &SchemaWriter{
		database: database,
	}
}

// WriteSchema - Write Schema to repository
func (w *SchemaWriter) WriteSchema(_ context.Context, definitions []storage.SchemaDefinition) error {
	var err error
	txn := w.database.DB.Txn(true)
	defer txn.Abort()

	var tenantID string
	var version string

	for _, definition := range definitions {
		if err = txn.Insert(constants.SchemaDefinitionsTable, definition); err != nil {
			return errors.New(base.ErrorCode_ERROR_CODE_EXECUTION.String())
		}
		tenantID = definition.TenantID
		version = definition.Version
	}
	txn.Commit()

	mu.Lock()
	headVersion[tenantID] = version
	mu.Unlock()

	return nil
}


1			package memory
2
3			import (
4			"context"
5			"errors"
6			"sync"
7
8			"github.com/Permify/permify/internal/storage"
9			"github.com/Permify/permify/internal/storage/memory/constants"
10			db "github.com/Permify/permify/pkg/database/memory"
11			base "github.com/Permify/permify/pkg/pb/base/v1"
12			)
13
14			var (
15			headVersion map[string]string
16			mu sync.Mutex
17			)
18
19			func init() {
20			headVersion = make(map[string]string)
21			}
22
23			// SchemaWriter - Structure for Schema Writer
24			type SchemaWriter struct {
25			database *db.Memory
26			}
27
28			// NewSchemaWriter creates a new SchemaWriter
29			func NewSchemaWriter(database db.Memory) SchemaWriter {
30			return &SchemaWriter{
31			database: database,
32			}
33			}
34
35			// WriteSchema - Write Schema to repository
36			func (w *SchemaWriter) WriteSchema(_ context.Context, definitions []storage.SchemaDefinition) error {
37			var err error
38			txn := w.database.DB.Txn(true)
39			defer txn.Abort()
40
41			var tenantID string
42			var version string
43
44			for _, definition := range definitions {
45			if err = txn.Insert(constants.SchemaDefinitionsTable, definition); err != nil {
46			return errors.New(base.ErrorCode_ERROR_CODE_EXECUTION.String())
47			}
48			tenantID = definition.TenantID
49			version = definition.Version
50			}
51			txn.Commit()
52
53			mu.Lock()
54			headVersion[tenantID] = version
55			mu.Unlock()
56
57			return nil
58			}
59

Permify / permify

Pull Request — master (#2516)

memory.*SchemaWriter.WriteSchema A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like