From aface85b80c8d07fdb0506a266006f7633829fc3 Mon Sep 17 00:00:00 2001 From: wisplite Date: Tue, 7 Apr 2026 10:37:55 -0500 Subject: [PATCH] time to start working on this again --- engine.go | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/engine.go b/engine.go index f21853e..6a6c939 100644 --- a/engine.go +++ b/engine.go @@ -8,14 +8,20 @@ import ( type Engine struct { db *gorm.DB channels map[string]*reactivity.Channel - mutations []func(ctx *MutationCtx) error - queries []func(ctx *QueryCtx) error + mutations map[string]func(ctx *MutationCtx) error + queries map[string]func(ctx *QueryCtx) error } 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) { - e.mutations = append(e.mutations, mutation) +func (e *Engine) RegisterMutation(name string, mutation func(ctx *MutationCtx) error) { + e.mutations[name] = mutation } + +func (e *Engine) RegisterQuery(name string, query func(ctx *QueryCtx) error) { + e.queries[name] = query +} + +