wisplite/tether
1
0
Fork 0
mirror of https://github.com/wisplite/tether.git synced 2026-05-01 06:22:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

time to start working on this again

Browse Source
This commit is contained in:
wisplite
2026-04-07 10:37:55 -05:00
parent 1d3e911515
commit aface85b80
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
engine.go
+11 -5
View File
@@ -8,14 +8,20 @@ import (
type Engine struct { type Engine struct {
db *gorm.DB db *gorm.DB
channels map[string]*reactivity.Channel channels map[string]*reactivity.Channel
mutations []func(ctx *MutationCtx) error mutations map[string]func(ctx *MutationCtx) error
queries []func(ctx *QueryCtx) error queries map[string]func(ctx *QueryCtx) error
} }
func NewEngine(db *gorm.DB) *Engine { func NewEngine(db *gorm.DB) *Engine {
return &Engine{db: db, channels: make(map[string]*reactivity.Channel)} return &Engine{db: db, channels: make(map[string]*reactivity.Channel), mutations: make(map[string]func(ctx *MutationCtx) error), queries: make(map[string]func(ctx *QueryCtx) error)}
} }
func (e *Engine) RegisterMutation(mutation func(ctx *MutationCtx) error) { func (e *Engine) RegisterMutation(name string, mutation func(ctx *MutationCtx) error) {
e.mutations = append(e.mutations, mutation) e.mutations[name] = mutation
} }
func (e *Engine) RegisterQuery(name string, query func(ctx *QueryCtx) error) {
e.queries[name] = query
}