anotherhadi/spilltea
1
Fork 0
mirror of https://github.com/anotherhadi/spilltea.git synced 2026-07-06 20:42:33 +02:00
Code Issues Packages Projects Releases Wiki Activity

change logs fmt

Browse Source 
Signed-off-by: Hadi <hadi@example.com>
This commit is contained in:
Hadi
2026-05-29 11:54:26 +02:00
parent 098400ba77
commit 677223c9b0
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/plugins/lua.go
+4 -4
View File
@@ -46,7 +46,7 @@ func newLuaState(mgr *Manager, p *Plugin) *lua.LState {
func registerUtilities(L *lua.LState, mgr *Manager, p *Plugin) { func registerUtilities(L *lua.LState, mgr *Manager, p *Plugin) {
L.SetGlobal("log", L.NewFunction(func(L *lua.LState) int { L.SetGlobal("log", L.NewFunction(func(L *lua.LState) int {
msg := L.CheckString(1) msg := L.CheckString(1)
log.Printf("[plugin:%s] %s", p.Name, msg) log.Printf("plugin %s: %s", p.Name, msg)
return 0 return 0
})) }))
@@ -85,7 +85,7 @@ func registerUtilities(L *lua.LState, mgr *Manager, p *Plugin) {
CreatedAt: time.Now(), CreatedAt: time.Now(),
}) })
if err != nil { if err != nil {
log.Printf("[plugin:%s] create_finding error: %v", p.Name, err) log.Printf("plugin %s: create_finding error: %v", p.Name, err)
return 0 return 0
} }
_ = inserted _ = inserted
@@ -337,7 +337,7 @@ func luaTableString(t *lua.LTable, key string) string {
return "" return ""
} }
func pushRequest(L *lua.LState, f *goproxy.Flow) *lua.LTable { func pushRequest(L *lua.LState, p *Plugin, f *goproxy.Flow) *lua.LTable {
t := L.NewTable() t := L.NewTable()
r := f.Request r := f.Request
L.SetField(t, "method", lua.LString(r.Method)) L.SetField(t, "method", lua.LString(r.Method))
@@ -377,7 +377,7 @@ func pushRequest(L *lua.LState, f *goproxy.Flow) *lua.LTable {
L.SetField(t, "set_url", L.NewFunction(func(L *lua.LState) int { L.SetField(t, "set_url", L.NewFunction(func(L *lua.LState) int {
parsed, err := url.Parse(L.CheckString(2)) parsed, err := url.Parse(L.CheckString(2))
if err != nil { if err != nil {
log.Printf("[plugin] set_url: %v", err) log.Printf("plugin %s: set_url: %v", p.Name, err)
return 0 return 0
} }
r.URL = parsed r.URL = parsed
internal/plugins/manager.go
+4 -4
View File
@@ -395,25 +395,25 @@ func (m *Manager) runAsyncForPlugins(hookName string, argsFor func(*Plugin) []lu
func (m *Manager) RunSyncOnRequest(f *goproxy.Flow) intercept.Decision { func (m *Manager) RunSyncOnRequest(f *goproxy.Flow) intercept.Decision {
return m.runSyncDecisionForPlugins("on_request", func(p *Plugin) []lua.LValue { return m.runSyncDecisionForPlugins("on_request", func(p *Plugin) []lua.LValue {
return []lua.LValue{pushRequest(p.L, f)} return []lua.LValue{pushRequest(p.L, p, f)}
}) })
} }
func (m *Manager) RunAsyncOnRequest(f *goproxy.Flow) { func (m *Manager) RunAsyncOnRequest(f *goproxy.Flow) {
m.runAsyncForPlugins("on_request", func(p *Plugin) []lua.LValue { m.runAsyncForPlugins("on_request", func(p *Plugin) []lua.LValue {
return []lua.LValue{pushRequest(p.L, f)} return []lua.LValue{pushRequest(p.L, p, f)}
}) })
} }
func (m *Manager) RunSyncOnResponse(f *goproxy.Flow) intercept.Decision { func (m *Manager) RunSyncOnResponse(f *goproxy.Flow) intercept.Decision {
return m.runSyncDecisionForPlugins("on_response", func(p *Plugin) []lua.LValue { return m.runSyncDecisionForPlugins("on_response", func(p *Plugin) []lua.LValue {
return []lua.LValue{pushRequest(p.L, f), pushResponse(p.L, f)} return []lua.LValue{pushRequest(p.L, p, f), pushResponse(p.L, f)}
}) })
} }
func (m *Manager) RunAsyncOnResponse(f *goproxy.Flow) { func (m *Manager) RunAsyncOnResponse(f *goproxy.Flow) {
m.runAsyncForPlugins("on_response", func(p *Plugin) []lua.LValue { m.runAsyncForPlugins("on_response", func(p *Plugin) []lua.LValue {
return []lua.LValue{pushRequest(p.L, f), pushResponse(p.L, f)} return []lua.LValue{pushRequest(p.L, p, f), pushResponse(p.L, f)}
}) })
} }