/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package rest

//
//import (
//	"context"
//	"errors"
//	"fmt"
//	"strings"
//	"testing"
//	"time"
//)
//
//import (
//	"github.com/stretchr/testify/assert"
//)
//
//import (
//	"dubbo.apache.org/dubbo-go/v3/common"
//	"dubbo.apache.org/dubbo-go/v3/common/extension"
//	_ "dubbo.apache.org/dubbo-go/v3/proxy/proxy_factory"
//	"dubbo.apache.org/dubbo-go/v3/config"
//	rest_config "dubbo.apache.org/dubbo-go/v3/protocol/rest/config"
//)
//
//func TestRestProtocolRefer(t *testing.T) {
//	// Refer
//	proto := GetRestProtocol()
//	url, err := common.NewURL(mockRestCommonUrl)
//	assert.NoError(t, err)
//	con := config.ConsumerConfig{
//		ConnectTimeout: "5s",
//		RequestTimeout: "5s",
//	}
//	config.SetConsumerConfig(con)
//	configMap := make(map[string]*rest_config.RestServiceConfig)
//	configMap["com.ikurento.user.UserProvider"] = &rest_config.RestServiceConfig{
//		Client: "resty",
//	}
//	rest_config.SetRestConsumerServiceConfigMap(configMap)
//	invoker := proto.Refer(url)
//
//	// make sure url
//	eq := invoker.GetURL().URLEqual(url)
//	assert.True(t, eq)
//
//	// make sure invokers after 'Destroy'
//	invokersLen := len(proto.(*RestProtocol).Invokers())
//	assert.Equal(t, 1, invokersLen)
//	proto.Destroy()
//	invokersLen = len(proto.(*RestProtocol).Invokers())
//	assert.Equal(t, 0, invokersLen)
//}
//
//func TestRestProtocolExport(t *testing.T) {
//	// Export
//	proto := GetRestProtocol()
//	url, err := common.NewURL(mockRestCommonUrl)
//	assert.NoError(t, err)
//	_, err = common.ServiceMap.Register(url.Service(), url.Protocol, "", "", &UserProvider{})
//	assert.NoError(t, err)
//	con := config.ProviderConfig{}
//	config.SetProviderConfig(con)
//	configMap := make(map[string]*rest_config.RestServiceConfig)
//	methodConfigMap := make(map[string]*rest_config.RestMethodConfig)
//	queryParamsMap := make(map[int]string)
//	queryParamsMap[1] = "age"
//	queryParamsMap[2] = "name"
//	pathParamsMap := make(map[int]string)
//	pathParamsMap[0] = "userid"
//	methodConfigMap["GetUser"] = &rest_config.RestMethodConfig{
//		InterfaceName:  "",
//		MethodName:     "GetUser",
//		Path:           "/GetUser/{userid}",
//		Produces:       "application/json",
//		Consumes:       "application/json",
//		MethodType:     "GET",
//		PathParams:     "",
//		PathParamsMap:  pathParamsMap,
//		QueryParams:    "",
//		QueryParamsMap: queryParamsMap,
//		Body:           -1,
//	}
//	configMap["com.ikurento.user.UserProvider"] = &rest_config.RestServiceConfig{
//		Server:               "go-restful",
//		RestMethodConfigsMap: methodConfigMap,
//	}
//	rest_config.SetRestProviderServiceConfigMap(configMap)
//	proxyFactory := extension.GetProxyFactory("default")
//	exporter := proto.Export(proxyFactory.GetInvoker(url))
//	// make sure url
//	eq := exporter.GetInvoker().GetURL().URLEqual(url)
//	assert.True(t, eq)
//	// make sure exporterMap after 'UnExport'
//	fmt.Println(url.Path)
//	_, ok := proto.(*RestProtocol).ExporterMap().Load(strings.TrimPrefix(url.Path, "/"))
//	assert.True(t, ok)
//	exporter.UnExport()
//	_, ok = proto.(*RestProtocol).ExporterMap().Load(strings.TrimPrefix(url.Path, "/"))
//	assert.False(t, ok)
//
//	// make sure serverMap after 'Destroy'
//	_, ok = proto.(*RestProtocol).serverMap[url.Location]
//	assert.True(t, ok)
//	proto.Destroy()
//	_, ok = proto.(*RestProtocol).serverMap[url.Location]
//	assert.False(t, ok)
//}
//
//type UserProvider struct{}
//
//func (p *UserProvider) Reference() string {
//	return "com.ikurento.user.UserProvider"
//}
//
//func (p *UserProvider) GetUser(ctx context.Context, id int, age int32, name string, contentType string) (*User, error) {
//	return &User{
//		ID:   id,
//		Time: nil,
//		Age:  age,
//		Name: name,
//	}, nil
//}
//
//func (p *UserProvider) GetUserOne(ctx context.Context, user *User) (*User, error) {
//	return user, nil
//}
//
//func (p *UserProvider) GetUserTwo(ctx context.Context, req []interface{}, rsp *User) error {
//	m := req[0].(map[string]interface{})
//	rsp.Name = m["Name"].(string)
//	return nil
//}
//
//func (p *UserProvider) GetUserThree(ctx context.Context, user interface{}) (*User, error) {
//	m := user.(map[string]interface{})
//
//	u := &User{}
//	u.Name = m["Name"].(string)
//	return u, nil
//}
//
//func (p *UserProvider) GetUserFour(ctx context.Context, user []interface{}, id string) (*User, error) {
//	m := user[0].(map[string]interface{})
//
//	u := &User{}
//	u.Name = m["Name"].(string)
//	return u, nil
//}
//
//func (p *UserProvider) GetUserFive(ctx context.Context, user []interface{}) (*User, error) {
//	return nil, errors.New("test error")
//}
//
//type User struct {
//	ID   int
//	Time *time.Time
//	Age  int32
//	Name string
//}