118 lines
2.3 KiB
Go
118 lines
2.3 KiB
Go
package witch
|
|
|
|
import (
|
|
"sync"
|
|
|
|
"github.com/vilmibm/hermeticum/server/db"
|
|
lua "github.com/yuin/gopher-lua"
|
|
)
|
|
|
|
/*
|
|
|
|
the purpose of this package is to provide abstractions for sending verbs to game objects.
|
|
|
|
Game objects get pulled from the DB into memory and their scripts become Lua States.
|
|
|
|
*/
|
|
|
|
type scriptContext struct {
|
|
script string
|
|
l *lua.LState
|
|
incoming chan string
|
|
// TODO whatever is needed to support calling a Go API
|
|
}
|
|
|
|
func (sc *scriptContext) NeedsRefresh(obj db.Object) bool {
|
|
return sc.script != obj.Script
|
|
}
|
|
|
|
// TODO using a dummy script for now
|
|
|
|
const dummyScript = `
|
|
has({
|
|
name = "spaghetti",
|
|
description = "a plate of pasta covered in pomodoro sauce"
|
|
})
|
|
|
|
hears(".*eat.*", function(msg)
|
|
does("quivers nervously")
|
|
end)
|
|
`
|
|
|
|
/*
|
|
allows({
|
|
read = "world",
|
|
write = "owner"
|
|
carry = "owner",
|
|
execute = "world",
|
|
})
|
|
|
|
hears(".*eat.*", function(msg)
|
|
does("quivers nervously")
|
|
end)
|
|
`
|
|
*/
|
|
|
|
// TODO figure out channel stuff
|
|
// TODO figure out how to inject WITCH header
|
|
// - do i inject from Go or prepend some Lua code?
|
|
// TODO figure out how the Lua code can affect Go and thus the database
|
|
|
|
func newScriptContext(obj db.Object) (*scriptContext, error) {
|
|
l := lua.NewState()
|
|
|
|
l.SetGlobal("has", l.NewFunction(hasWrapper(obj)))
|
|
l.SetGlobal("_handlers", l.NewTable())
|
|
|
|
//if err := l.DoString(obj.Script); err != nil {
|
|
if err := l.DoString(dummyScript); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &scriptContext{}, nil
|
|
}
|
|
|
|
func (sc *scriptContext) Handle(verb, rest string, sender, target *db.Object) error {
|
|
|
|
// TODO call _handle function from the Lstate
|
|
return nil
|
|
}
|
|
|
|
type Gateway struct {
|
|
// maps game object IDs to script contexts
|
|
m map[int]*scriptContext
|
|
mu sync.RWMutex
|
|
cb func(string, string, *db.Object)
|
|
}
|
|
|
|
func NewGateway(cb func(string, string, *db.Object)) *Gateway {
|
|
return &Gateway{
|
|
m: map[int]*scriptContext{},
|
|
mu: sync.RWMutex{},
|
|
// TODO use cb from scriptContext
|
|
cb: cb,
|
|
}
|
|
}
|
|
|
|
func (g *Gateway) VerbHandler(verb, rest string, sender, target *db.Object) error {
|
|
var sc *scriptContext
|
|
g.mu.RLock()
|
|
sc, ok := g.m[target.ID]
|
|
g.mu.RUnlock()
|
|
|
|
if !ok || sc.NeedsRefresh(*target) {
|
|
sc, err := newScriptContext(*target)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
g.mu.Lock()
|
|
g.m[target.ID] = sc
|
|
g.mu.Unlock()
|
|
}
|
|
|
|
sc.Handle(verb, rest, sender, target)
|
|
|
|
return nil
|
|
}
|