mirror of
https://github.com/hanzozt/storage.git
synced 2026-10-30 19:34:03 +00:00
zeekay
c0ca153cc2
Global rebrand of all OpenZiti references to Hanzo ZT: - Go module paths: github.com/openziti/* → github.com/hanzozt/* - Docker images: openziti/* → hanzozt/* - Java packages: org.openziti.* → org.hanzozt.* - Brand: OpenZiti → Hanzo ZT - URLs: openziti.io → hanzozt.dev
64 lines
1.8 KiB
Go
64 lines
1.8 KiB
Go
package boltz
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/hanzozt/foundation/v2/errorz"
|
|
"github.com/pkg/errors"
|
|
"go.etcd.io/bbolt"
|
|
)
|
|
|
|
func NewSystemEntityEnforcementConstraint(store Store) Constraint {
|
|
symbol := store.GetSymbol(FieldIsSystemEntity)
|
|
return &systemEntityConstraint{
|
|
systemFlagSymbol: symbol,
|
|
}
|
|
}
|
|
|
|
type systemEntityConstraint struct {
|
|
systemFlagSymbol EntitySymbol
|
|
}
|
|
|
|
func (self *systemEntityConstraint) Label() string {
|
|
return fmt.Sprintf("system entity constraint %s.%s",
|
|
self.systemFlagSymbol.GetStore().GetEntityType(), self.systemFlagSymbol.GetName())
|
|
}
|
|
|
|
func (self *systemEntityConstraint) checkOperation(operation string, ctx *IndexingContext) error {
|
|
t, val := self.systemFlagSymbol.Eval(ctx.Tx(), ctx.RowId)
|
|
isSystem := FieldToBool(t, val)
|
|
if (isSystem != nil && *isSystem) && !ctx.Ctx.IsSystemContext() {
|
|
err := errors.Errorf("cannot %v system %v in a non-system context (id=%v)",
|
|
operation, self.systemFlagSymbol.GetStore().GetSingularEntityType(), string(ctx.RowId))
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (self *systemEntityConstraint) ProcessBeforeUpdate(ctx *IndexingContext) {
|
|
if !ctx.IsCreate {
|
|
if err := self.checkOperation("update", ctx); err != nil {
|
|
ctx.ErrHolder.SetError(errorz.NewEntityCanNotBeUpdatedFrom(err))
|
|
}
|
|
}
|
|
}
|
|
|
|
func (self *systemEntityConstraint) ProcessAfterUpdate(ctx *IndexingContext) {
|
|
if ctx.IsCreate {
|
|
if err := self.checkOperation("create", ctx); err != nil {
|
|
ctx.ErrHolder.SetError(err)
|
|
}
|
|
}
|
|
}
|
|
|
|
func (self *systemEntityConstraint) ProcessBeforeDelete(ctx *IndexingContext) {
|
|
if err := self.checkOperation("delete", ctx); err != nil {
|
|
ctx.ErrHolder.SetError(errorz.NewEntityCanNotBeDeletedFrom(err))
|
|
}
|
|
}
|
|
|
|
func (self *systemEntityConstraint) Initialize(*bbolt.Tx, errorz.ErrorHolder) {}
|
|
|
|
func (self *systemEntityConstraint) CheckIntegrity(MutateContext, bool, func(err error, fixed bool)) error {
|
|
return nil
|
|
}
|