package plugin

import (
	"reflect"
	"sync"
)

type Config map[string]interface{}

type Plugin struct {
	Id           string
	Name         string
	Objects      map[string]interface{}
	ConfigSample string
	JsCode       string
	Init         func(map[string]interface{})
}

type Context struct {
	injects map[string]interface{}
	data    map[string]interface{}
}

func NewContext(injects map[string]interface{}) *Context {
	return &Context{
		injects: injects,
		data:    map[string]interface{}{},
	}
}

func (ctx *Context) SetInject(obj interface{}) {
	ctx.injects[reflect.ValueOf(obj).Type().String()] = obj
}

func (ctx *Context) GetInject(typ string) interface{} {
	return ctx.injects[typ]
}

func (ctx *Context) GetData(k string) interface{} {
	return ctx.data[k]
}

func (ctx *Context) SetData(k string, v interface{}) {
	ctx.data[k] = v
}

var pluginById = map[string]*Plugin{}
var pluginsLock = sync.RWMutex{}

func Register(p Plugin) {
	pluginsLock.Lock()
	defer pluginsLock.Unlock()
	pluginById[p.Id] = &p
}

func Update(plugName, objectName string, value interface{}) {
	pluginsLock.RLock()
	p := pluginById[plugName]
	pluginsLock.RUnlock()

	if p != nil {
		pluginsLock.Lock()
		if p.Objects == nil {
			p.Objects = map[string]interface{}{}
		}
		p.Objects[objectName] = value
		pluginsLock.Unlock()
	}
}

func List() []Plugin {
	pluginsLock.RLock()
	defer pluginsLock.RUnlock()
	out := make([]Plugin, len(pluginById))
	i := 0
	for _, p := range pluginById {
		out[i] = *p
		i++
	}
	return out
}

func Get(id string) *Plugin {
	pluginsLock.RLock()
	defer pluginsLock.RUnlock()
	return pluginById[id]
}