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
94 lines
2.4 KiB
Go
94 lines
2.4 KiB
Go
/*
|
|
Copyright NetFoundry, Inc.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
https://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package boltz
|
|
|
|
import (
|
|
"github.com/hanzozt/storage/ast"
|
|
)
|
|
|
|
type Manager struct {
|
|
Employee
|
|
IsTechLead bool
|
|
}
|
|
|
|
type managerEntityStrategy struct {
|
|
employeeStore *employeeStoreImpl
|
|
}
|
|
|
|
func (self *managerEntityStrategy) NewEntity() *Manager {
|
|
return new(Manager)
|
|
}
|
|
|
|
func (self *managerEntityStrategy) FillEntity(entity *Manager, bucket *TypedBucket) {
|
|
_, err := self.employeeStore.LoadEntity(bucket.Tx(), entity.Id, &entity.Employee)
|
|
bucket.SetError(err)
|
|
entity.IsTechLead = bucket.GetBoolWithDefault("isTechLead", false)
|
|
}
|
|
|
|
func (self *managerEntityStrategy) PersistEntity(entity *Manager, ctx *PersistContext) {
|
|
self.employeeStore.GetEntityStrategy().PersistEntity(&entity.Employee, ctx.GetParentContext())
|
|
ctx.SetBool("isTechLead", entity.IsTechLead)
|
|
}
|
|
|
|
func newManagerStore(parent *employeeStoreImpl) *managerStoreImpl {
|
|
storeDef := StoreDefinition[*Manager]{
|
|
EntityStrategy: &managerEntityStrategy{
|
|
employeeStore: parent,
|
|
},
|
|
EntityNotFoundF: func(id string) error {
|
|
return NewNotFoundError(parent.GetSingularEntityType(), "id", id)
|
|
},
|
|
BasePath: []string{"ext"},
|
|
Parent: parent,
|
|
ParentMapper: func(entity Entity) Entity {
|
|
if mgr, ok := entity.(*Manager); ok {
|
|
return &mgr.Employee
|
|
}
|
|
return entity
|
|
},
|
|
}
|
|
|
|
store := &managerStoreImpl{
|
|
BaseStore: NewBaseStore(storeDef),
|
|
}
|
|
store.InitImpl(store)
|
|
parent.RegisterChildStoreStrategy(&ChildStoreUpdateHandler[*Employee, *Manager]{
|
|
Store: store,
|
|
Mapper: func(ctx MutateContext, parent *Employee) (*Manager, bool) {
|
|
mgr, _, _ := store.FindById(ctx.Tx(), parent.Id)
|
|
if mgr != nil {
|
|
return mgr, true
|
|
}
|
|
return nil, false
|
|
},
|
|
})
|
|
return store
|
|
}
|
|
|
|
type managerStoreImpl struct {
|
|
*BaseStore[*Manager]
|
|
}
|
|
|
|
func (store *managerStoreImpl) initializeLocal() {
|
|
store.GetParentStore().GrantSymbols(store)
|
|
store.AddSymbol("isTechLead", ast.NodeTypeBool)
|
|
}
|
|
|
|
func (store *managerStoreImpl) initializeLinked() {
|
|
// does nothing
|
|
}
|