// Copyright (c) 2020 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

/**
*@describe:
*@author wfl19/Kristas
*@date 2021/08/31
 */

package bean_repository

import (
	"fmt"
	"gitee.com/kristas/booting-go/framework/common/util/ccmap"
	"gitee.com/kristas/booting-go/framework/common/util/list"
	"gitee.com/kristas/booting-go/framework/common/util/reflectx"
	. "gitee.com/kristas/booting-go/framework/core/bean"
	"reflect"
)

var (
	singletonObjects     *ccmap.ConcurrentMap
	registeredSingletons list.Set
)

func init() {
	singletonObjects = ccmap.NewConcurrentMap()
	registeredSingletons = list.NewConcurrentSets()
}

func GetSingleton(name string) interface{} {
	if ExistsSingletonBean(name) {
		return singletonObjects.Get(name)
	}
	return nil
}

func ExistsSingletonBean(name string) bool {
	return registeredSingletons.Exists(name)
}

func RegisterSingletonBean(bean interface{}) {
	register(GetName(bean), bean)
}

func RegisterSingletonBeanWithName(name string, bean interface{}) {
	register(name, bean)
}

func register(name string, obj interface{}) {
	if ExistsSingletonBean(name) {
		panic(fmt.Sprintf("duplicate bean: %s", name))
	}
	singletonObjects.Set(name, obj)
	registeredSingletons.Put(name)
}

func GetSingletonByInterface(typ reflect.Type) []reflect.Value {
	var valueSet = make([]reflect.Value, 0)
	singletonObjects.ForEach(func(k string, v interface{}) {
		if reflectx.IsImplement(v, reflect.New(typ).Interface()) {
			valueSet = append(valueSet, reflect.ValueOf(v))
		}
	})
	return valueSet
}