2022-10-03 12:12:20 +02:00
|
|
|
package contextargs
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"net/http/cookiejar"
|
|
|
|
|
|
2023-07-24 16:50:28 +02:00
|
|
|
mapsutil "github.com/projectdiscovery/utils/maps"
|
2022-10-03 12:12:20 +02:00
|
|
|
)
|
|
|
|
|
|
|
|
|
|
// Context implements a shared context struct to share information across multiple templates within a workflow
|
|
|
|
|
type Context struct {
|
2022-11-09 14:18:56 +01:00
|
|
|
// Meta is the target for the executor
|
|
|
|
|
MetaInput *MetaInput
|
|
|
|
|
|
2022-10-03 12:12:20 +02:00
|
|
|
// CookieJar shared within workflow's http templates
|
|
|
|
|
CookieJar *cookiejar.Jar
|
|
|
|
|
|
|
|
|
|
// Args is a workflow shared key-value store
|
2023-07-24 16:50:28 +02:00
|
|
|
args *mapsutil.SyncLockMap[string, interface{}]
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Create a new contextargs instance
|
|
|
|
|
func New() *Context {
|
2022-11-09 14:18:56 +01:00
|
|
|
return &Context{MetaInput: &MetaInput{}}
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Create a new contextargs instance with input string
|
|
|
|
|
func NewWithInput(input string) *Context {
|
2022-11-09 14:18:56 +01:00
|
|
|
return &Context{MetaInput: &MetaInput{Input: input}}
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (ctx *Context) initialize() {
|
2023-07-24 16:50:28 +02:00
|
|
|
ctx.args = &mapsutil.SyncLockMap[string, interface{}]{Map: mapsutil.Map[string, interface{}]{}}
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Set the specific key-value pair
|
|
|
|
|
func (ctx *Context) Set(key string, value interface{}) {
|
|
|
|
|
if !ctx.isInitialized() {
|
|
|
|
|
ctx.initialize()
|
|
|
|
|
}
|
|
|
|
|
|
2023-07-24 16:50:28 +02:00
|
|
|
_ = ctx.args.Set(key, value)
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (ctx *Context) isInitialized() bool {
|
|
|
|
|
return ctx.args != nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (ctx *Context) hasArgs() bool {
|
|
|
|
|
return ctx.isInitialized() && !ctx.args.IsEmpty()
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Get the value with specific key if exists
|
|
|
|
|
func (ctx *Context) Get(key string) (interface{}, bool) {
|
|
|
|
|
if !ctx.hasArgs() {
|
|
|
|
|
return nil, false
|
|
|
|
|
}
|
|
|
|
|
|
2023-07-24 16:50:28 +02:00
|
|
|
return ctx.args.Get(key)
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
2023-07-24 16:50:28 +02:00
|
|
|
func (ctx *Context) GetAll() *mapsutil.SyncLockMap[string, interface{}] {
|
2022-10-03 12:12:20 +02:00
|
|
|
if !ctx.hasArgs() {
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
2023-07-24 16:50:28 +02:00
|
|
|
return ctx.args.Clone()
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (ctx *Context) ForEach(f func(string, interface{})) {
|
2023-07-24 16:50:28 +02:00
|
|
|
_ = ctx.args.Iterate(func(k string, v interface{}) error {
|
2022-10-03 12:12:20 +02:00
|
|
|
f(k, v)
|
2023-07-24 16:50:28 +02:00
|
|
|
return nil
|
|
|
|
|
})
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Has check if the key exists
|
|
|
|
|
func (ctx *Context) Has(key string) bool {
|
2023-07-24 16:50:28 +02:00
|
|
|
return ctx.hasArgs() && ctx.args.Has(key)
|
2022-10-03 12:12:20 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (ctx *Context) HasArgs() bool {
|
|
|
|
|
return ctx.hasArgs()
|
|
|
|
|
}
|
2022-11-09 14:18:56 +01:00
|
|
|
|
|
|
|
|
func (ctx *Context) Clone() *Context {
|
|
|
|
|
newCtx := &Context{
|
|
|
|
|
MetaInput: ctx.MetaInput.Clone(),
|
|
|
|
|
args: ctx.args,
|
|
|
|
|
CookieJar: ctx.CookieJar,
|
|
|
|
|
}
|
|
|
|
|
return newCtx
|
|
|
|
|
}
|