lash/custom-engin #20
@ -1,35 +0,0 @@
|
||||
package engine
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"git.defalsify.org/vise.git/engine"
|
||||
"git.defalsify.org/vise.git/resource"
|
||||
"git.defalsify.org/vise.git/logging"
|
||||
)
|
||||
|
||||
var (
|
||||
logg = logging.NewVanilla().WithDomain("sarafu-vise.engine")
|
||||
)
|
||||
|
||||
type SarafuEngine struct {
|
||||
engine.Engine
|
||||
}
|
||||
|
||||
func NewSarafuEngine(cfg engine.Config, rs resource.Resource) *SarafuEngine {
|
||||
return &SarafuEngine{
|
||||
Engine: engine.NewEngine(cfg, rs),
|
||||
}
|
||||
}
|
||||
|
||||
func (se *SarafuEngine) Exec(ctx context.Context, input []byte) (bool, error) {
|
||||
logg.TraceCtxf(ctx, "sarafu engine exec", "input", input)
|
||||
// if len(input) == 0 {
|
||||
// e := se.Engine.(*engine.DefaultEngine)
|
||||
// v, err := e.Reset(ctx, true)
|
||||
// if err != nil {
|
||||
// return v, err
|
||||
// }
|
||||
// }
|
||||
return se.Engine.Exec(ctx, input)
|
||||
}
|
@ -131,9 +131,6 @@ func (ls *LocalHandlerService) GetHandler(accountService remote.AccountService)
|
||||
}
|
||||
|
||||
func (ls *LocalHandlerService) GetEngine(cfg engine.Config, rs resource.Resource, pr *persist.Persister) engine.Engine {
|
||||
//logg.Tracef("creating new engine")
|
||||
//se := sarafu_engine.NewSarafuEngine(cfg, rs)
|
||||
//en := se.Engine.(*engine.DefaultEngine)
|
||||
en := engine.NewEngine(cfg, rs)
|
||||
if ls.first != nil {
|
||||
en = en.WithFirst(ls.first)
|
||||
@ -142,6 +139,5 @@ func (ls *LocalHandlerService) GetEngine(cfg engine.Config, rs resource.Resource
|
||||
if cfg.EngineDebug {
|
||||
en = en.WithDebug(nil)
|
||||
}
|
||||
//return se
|
||||
return en
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user