/*
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
Copyright (C) ITsysCOM GmbH

This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License
along with this program.  If not, see <https://www.gnu.org/licenses/>
*/

package registrarc

import (
	"encoding/json"
	"errors"
	"fmt"
	"net"
	"net/http"

	"github.com/cgrates/cgrates/config"
	"github.com/cgrates/cgrates/engine"
	"github.com/cgrates/cgrates/utils"
	"github.com/cgrates/rpcclient"
)

// NewRegisterArgs creates the arguments for register hosts API
func NewRegisterArgs(cfg *config.CGRConfig, tnt string, hostCfgs []*config.RemoteHost) (rargs *RegisterArgs, err error) {
	rargs = &RegisterArgs{
		Tenant: tnt,
		Opts:   make(map[string]any),
		Hosts:  make([]*RegisterHostCfg, len(hostCfgs)),
	}
	for i, hostCfg := range hostCfgs {
		var port string
		if port, err = getConnPort(cfg,
			hostCfg.Transport,
			hostCfg.TLS); err != nil {
			utils.Logger.Warning(fmt.Sprintf("<%s> Unable to get the port because : %s",
				utils.RegistrarC, err))
			return
		}

		if hostCfg.ID == "" {
			hostCfg.ID = cfg.GeneralCfg().NodeID
		}

		rargs.Hosts[i] = &RegisterHostCfg{
			ID:        hostCfg.ID,
			Port:      port,
			Transport: hostCfg.Transport,
			TLS:       hostCfg.TLS,
		}
	}
	return
}

// RegisterArgs the arguments to register the dispacher host
type RegisterArgs struct {
	Tenant string
	Opts   map[string]any
	Hosts  []*RegisterHostCfg
}

// RegisterHostCfg the host config used to register
type RegisterHostCfg struct {
	ID          string
	Port        string
	Transport   string
	TLS         bool
	Synchronous bool
}

// AsDispatcherHosts converts the arguments to DispatcherHosts
func (rargs *RegisterArgs) AsDispatcherHosts(ip string) (dHs []*engine.DispatcherHost) {
	dHs = make([]*engine.DispatcherHost, len(rargs.Hosts))
	for i, hCfg := range rargs.Hosts {
		dHs[i] = hCfg.AsDispatcherHost(rargs.Tenant, ip)
	}
	return
}

// AsDispatcherHost converts the arguments to DispatcherHosts
func (rhc *RegisterHostCfg) AsDispatcherHost(tnt, ip string) *engine.DispatcherHost {
	return &engine.DispatcherHost{
		Tenant: tnt,
		RemoteHost: &config.RemoteHost{
			ID:        rhc.ID,
			Address:   ip + ":" + rhc.Port,
			Transport: rhc.Transport,
			TLS:       rhc.TLS,
		},
	}
}

// NewUnregisterArgs creates the arguments for unregister hosts API
func NewUnregisterArgs(tnt string, hostCfgs []*config.RemoteHost) (uargs *UnregisterArgs) {
	uargs = &UnregisterArgs{
		Tenant: tnt,
		Opts:   make(map[string]any),
		IDs:    make([]string, len(hostCfgs)),
	}
	for i, hostCfg := range hostCfgs {
		uargs.IDs[i] = hostCfg.ID
	}
	return
}

// UnregisterArgs the arguments to unregister the dispacher host
type UnregisterArgs struct {
	Tenant string
	Opts   map[string]any
	IDs    []string
}

// Registrar handdle for httpServer to register the dispatcher hosts
func Registrar(w http.ResponseWriter, r *http.Request) {
	defer r.Body.Close()
	w.Header().Set("Content-Type", "application/json")
	var result any = utils.OK
	var errMessage any
	var err error
	var id *json.RawMessage
	if id, err = register(r); err != nil {
		result, errMessage = nil, err.Error()
	}
	if err := utils.WriteServerResponse(w, id, result, errMessage); err != nil {
		utils.Logger.Warning(fmt.Sprintf("<%s> Failed to write resonse because: %s",
			utils.RegistrarC, err))
	}
}

func register(req *http.Request) (*json.RawMessage, error) {
	id := json.RawMessage("0")
	sReq, err := utils.DecodeServerRequest(req.Body)
	if err != nil {
		utils.Logger.Warning(fmt.Sprintf("<%s> Failed to decode request because: %s",
			utils.RegistrarC, err))
		return &id, err
	}
	var hasErrors bool
	switch sReq.Method {
	default:
		err = errors.New("rpc: can't find service " + sReq.Method)
		utils.Logger.Warning(fmt.Sprintf("<%s> Failed to register hosts because: %s",
			utils.RegistrarC, err))
		return sReq.Id, err
	case utils.RegistrarSv1UnregisterDispatcherHosts:
		var args UnregisterArgs
		params := []any{&args}
		if err = json.Unmarshal(*sReq.Params, &params); err != nil {
			utils.Logger.Warning(fmt.Sprintf("<%s> Failed to decode params because: %s",
				utils.RegistrarC, err))
			return sReq.Id, err
		}
		for _, id := range args.IDs {
			if err = engine.Cache.Remove(utils.CacheDispatcherHosts, utils.ConcatenatedKey(args.Tenant, id), true, utils.NonTransactional); err != nil {
				utils.Logger.Warning(fmt.Sprintf("<%s> Failed to remove DispatcherHost <%s> from cache because: %s",
					utils.RegistrarC, id, err))
				hasErrors = true
				continue
			}
		}

	case utils.RegistrarSv1RegisterDispatcherHosts:
		dH, err := unmarshallRegisterArgs(req, *sReq.Params)
		if err != nil {
			return sReq.Id, err
		}

		for _, dH := range dH {
			if err = engine.Cache.Set(utils.CacheDispatcherHosts, dH.TenantID(), dH, nil,
				true, utils.NonTransactional); err != nil {
				utils.Logger.Warning(fmt.Sprintf("<%s> Failed to set DispatcherHost <%s> in cache because: %s",
					utils.RegistrarC, dH.TenantID(), err))
				hasErrors = true
				continue
			}
		}

	case utils.RegistrarSv1UnregisterRPCHosts:
		var args UnregisterArgs
		params := []any{&args}
		if err = json.Unmarshal(*sReq.Params, &params); err != nil {
			utils.Logger.Warning(fmt.Sprintf("<%s> Failed to decode params because: %s",
				utils.RegistrarC, err))
			return sReq.Id, err
		}
		rpcConns := config.CgrConfig().RPCConns()
		config.CgrConfig().LockSections(config.RPCConnsJsonName)
		for connID := range config.RemoveRPCCons(rpcConns, utils.NewStringSet(args.IDs)) {
			if err = engine.Cache.Remove(utils.CacheRPCConnections, connID,
				true, utils.NonTransactional); err != nil {
				utils.Logger.Warning(fmt.Sprintf("<%s> Failed to remove connection <%s> in cache because: %s",
					utils.RegistrarC, connID, err))
				hasErrors = true
			}
		}
		config.CgrConfig().UnlockSections(config.RPCConnsJsonName)
	case utils.RegistrarSv1RegisterRPCHosts:
		dH, err := unmarshallRegisterArgs(req, *sReq.Params)
		if err != nil {
			return sReq.Id, err
		}
		cfgHosts := make(map[string]*config.RemoteHost)
		for _, dH := range dH {
			cfgHosts[dH.ID] = dH.RemoteHost
		}
		rpcConns := config.CgrConfig().RPCConns()
		config.CgrConfig().LockSections(config.RPCConnsJsonName)
		for connID := range config.UpdateRPCCons(rpcConns, cfgHosts) {
			if err = engine.Cache.Remove(utils.CacheRPCConnections, connID,
				true, utils.NonTransactional); err != nil {
				utils.Logger.Warning(fmt.Sprintf("<%s> Failed to remove connection <%s> in cache because: %s",
					utils.RegistrarC, connID, err))
				hasErrors = true
			}
		}
		config.CgrConfig().UnlockSections(config.RPCConnsJsonName)
	}
	if hasErrors {
		return sReq.Id, utils.ErrPartiallyExecuted
	}
	return sReq.Id, nil
}

func getConnPort(cfg *config.CGRConfig, transport string, tls bool) (port string, err error) {
	var address string
	var extraPath string
	switch transport {
	case utils.MetaJSON:
		if tls {
			address = cfg.ListenCfg().RPCJSONTLSListen
		} else {
			address = cfg.ListenCfg().RPCJSONListen
		}
	case utils.MetaGOB:
		if tls {
			address = cfg.ListenCfg().RPCGOBTLSListen
		} else {
			address = cfg.ListenCfg().RPCGOBListen
		}
	case rpcclient.HTTPjson:
		if tls {
			address = cfg.ListenCfg().HTTPTLSListen
		} else {
			address = cfg.ListenCfg().HTTPListen
		}
		extraPath = cfg.HTTPCfg().HTTPJsonRPCURL
	case rpcclient.BiRPCJSON:
		address = cfg.SessionSCfg().ListenBiJSON
	case rpcclient.BiRPCGOB:
		address = cfg.SessionSCfg().ListenBiGob
	}
	if _, port, err = net.SplitHostPort(address); err != nil {
		return
	}
	port += extraPath
	return
}

func unmarshallRegisterArgs(req *http.Request, reqParams json.RawMessage) (dH []*engine.DispatcherHost, err error) {
	var dHs RegisterArgs
	params := []any{&dHs}
	if err = json.Unmarshal(reqParams, &params); err != nil {
		utils.Logger.Warning(fmt.Sprintf("<%s> Failed to decode params because: %s",
			utils.RegistrarC, err))
		return
	}
	var addr string
	if addr, err = utils.GetRemoteIP(req); err != nil {
		utils.Logger.Warning(fmt.Sprintf("<%s> Failed to obtain the remote IP because: %s",
			utils.RegistrarC, err))
		return
	}

	return dHs.AsDispatcherHosts(addr), nil
}