// Licensed 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 kivik

import (
	"context"
	"errors"
	"fmt"
	"net/http"
	"testing"

	"gitlab.com/flimzy/testy"

	"github.com/go-kivik/kivik/v4/driver"
	internal "github.com/go-kivik/kivik/v4/int/errors"
	"github.com/go-kivik/kivik/v4/int/mock"
)

func TestConfig(t *testing.T) {
	type tst struct {
		client   *Client
		node     string
		expected Config
		status   int
		err      string
	}
	tests := testy.NewTable()
	tests.Add("non-configer", tst{
		client: &Client{driverClient: &mock.Client{}},
		status: http.StatusNotImplemented,
		err:    "kivik: driver does not support Config interface",
	})
	tests.Add("error", tst{
		client: &Client{driverClient: &mock.Configer{
			ConfigFunc: func(context.Context, string) (driver.Config, error) {
				return nil, errors.New("conf error")
			},
		}},
		status: http.StatusInternalServerError,
		err:    "conf error",
	})
	tests.Add("success", tst{
		client: &Client{driverClient: &mock.Configer{
			ConfigFunc: func(_ context.Context, node string) (driver.Config, error) {
				if node != "foo" {
					return nil, fmt.Errorf("Unexpected node: %s", node)
				}
				return driver.Config{
					"foo": driver.ConfigSection{"asd": "rew"},
				}, nil
			},
		}},
		node: "foo",
		expected: Config{
			"foo": ConfigSection{"asd": "rew"},
		},
	})
	tests.Add("closed", tst{
		client: &Client{
			closed: true,
		},
		status: http.StatusServiceUnavailable,
		err:    "kivik: client closed",
	})

	tests.Run(t, func(t *testing.T, test tst) {
		result, err := test.client.Config(context.Background(), test.node)
		if d := internal.StatusErrorDiff(test.err, test.status, err); d != "" {
			t.Error(d)
		}
		if d := testy.DiffInterface(test.expected, result); d != nil {
			t.Error(d)
		}
	})
}

func TestConfigSection(t *testing.T) {
	type tst struct {
		client        *Client
		node, section string
		expected      ConfigSection
		status        int
		err           string
	}
	tests := testy.NewTable()
	tests.Add("non-configer", tst{
		client: &Client{driverClient: &mock.Client{}},
		status: http.StatusNotImplemented,
		err:    "kivik: driver does not support Config interface",
	})
	tests.Add("error", tst{
		client: &Client{driverClient: &mock.Configer{
			ConfigSectionFunc: func(context.Context, string, string) (driver.ConfigSection, error) {
				return nil, errors.New("conf error")
			},
		}},
		status: http.StatusInternalServerError,
		err:    "conf error",
	})
	tests.Add("success", tst{
		client: &Client{driverClient: &mock.Configer{
			ConfigSectionFunc: func(_ context.Context, node, section string) (driver.ConfigSection, error) {
				if node != "foo" {
					return nil, fmt.Errorf("Unexpected node: %s", node)
				}
				if section != "foo" {
					return nil, fmt.Errorf("Unexpected section: %s", section)
				}
				return driver.ConfigSection{"lkj": "ghj"}, nil
			},
		}},
		node:     "foo",
		section:  "foo",
		expected: ConfigSection{"lkj": "ghj"},
	})
	tests.Add("closed", tst{
		client: &Client{
			closed: true,
		},
		status: http.StatusServiceUnavailable,
		err:    "kivik: client closed",
	})

	tests.Run(t, func(t *testing.T, test tst) {
		result, err := test.client.ConfigSection(context.Background(), test.node, test.section)
		if d := internal.StatusErrorDiff(test.err, test.status, err); d != "" {
			t.Error(d)
		}
		if d := testy.DiffInterface(test.expected, result); d != nil {
			t.Error(d)
		}
	})
}

func TestConfigValue(t *testing.T) {
	type tst struct {
		client             *Client
		node, section, key string
		expected           string
		status             int
		err                string
	}
	tests := testy.NewTable()
	tests.Add("non-configer", tst{
		client: &Client{driverClient: &mock.Client{}},
		status: http.StatusNotImplemented,
		err:    "kivik: driver does not support Config interface",
	})
	tests.Add("error", tst{
		client: &Client{driverClient: &mock.Configer{
			ConfigValueFunc: func(context.Context, string, string, string) (string, error) {
				return "", errors.New("conf error")
			},
		}},
		status: http.StatusInternalServerError,
		err:    "conf error",
	})
	tests.Add("success", tst{
		client: &Client{driverClient: &mock.Configer{
			ConfigValueFunc: func(_ context.Context, node, section, key string) (string, error) {
				if node != "foo" {
					return "", fmt.Errorf("Unexpected node: %s", node)
				}
				if section != "foo" {
					return "", fmt.Errorf("Unexpected section: %s", section)
				}
				if key != "asd" {
					return "", fmt.Errorf("Unexpected key: %s", key)
				}
				return "jkl", nil
			},
		}},
		node:     "foo",
		section:  "foo",
		key:      "asd",
		expected: "jkl",
	})
	tests.Add("closed", tst{
		client: &Client{
			closed: true,
		},
		status: http.StatusServiceUnavailable,
		err:    "kivik: client closed",
	})

	tests.Run(t, func(t *testing.T, test tst) {
		result, err := test.client.ConfigValue(context.Background(), test.node, test.section, test.key)
		if d := internal.StatusErrorDiff(test.err, test.status, err); d != "" {
			t.Error(d)
		}
		if d := testy.DiffInterface(test.expected, result); d != nil {
			t.Error(d)
		}
	})
}

func TestSetConfigValue(t *testing.T) {
	type tst struct {
		client                    *Client
		node, section, key, value string
		expected                  string
		status                    int
		err                       string
	}
	tests := testy.NewTable()
	tests.Add("non-configer", tst{
		client: &Client{driverClient: &mock.Client{}},
		status: http.StatusNotImplemented,
		err:    "kivik: driver does not support Config interface",
	})
	tests.Add("error", tst{
		client: &Client{driverClient: &mock.Configer{
			SetConfigValueFunc: func(context.Context, string, string, string, string) (string, error) {
				return "", errors.New("conf error")
			},
		}},
		status: http.StatusInternalServerError,
		err:    "conf error",
	})
	tests.Add("success", tst{
		client: &Client{driverClient: &mock.Configer{
			SetConfigValueFunc: func(_ context.Context, node, section, key, value string) (string, error) {
				if node != "foo" {
					return "", fmt.Errorf("Unexpected node: %s", node)
				}
				if section != "foo" {
					return "", fmt.Errorf("Unexpected section: %s", section)
				}
				if key != "vbn" {
					return "", fmt.Errorf("Unexpected key: %s", key)
				}
				if value != "baz" {
					return "", fmt.Errorf("Unexpected value: %s", value)
				}
				return "old", nil
			},
		}},
		node:     "foo",
		section:  "foo",
		key:      "vbn",
		value:    "baz",
		expected: "old",
	})
	tests.Add("closed", tst{
		client: &Client{
			closed: true,
		},
		status: http.StatusServiceUnavailable,
		err:    "kivik: client closed",
	})

	tests.Run(t, func(t *testing.T, test tst) {
		result, err := test.client.SetConfigValue(context.Background(), test.node, test.section, test.key, test.value)
		if d := internal.StatusErrorDiff(test.err, test.status, err); d != "" {
			t.Error(d)
		}
		if d := testy.DiffInterface(test.expected, result); d != nil {
			t.Error(d)
		}
	})
}

func TestDeleteConfigKey(t *testing.T) {
	type tst struct {
		client             *Client
		node, section, key string
		expected           string
		status             int
		err                string
	}
	tests := testy.NewTable()
	tests.Add("non-configer", tst{
		client: &Client{driverClient: &mock.Client{}},
		status: http.StatusNotImplemented,
		err:    "kivik: driver does not support Config interface",
	})
	tests.Add("error", tst{
		client: &Client{driverClient: &mock.Configer{
			DeleteConfigKeyFunc: func(context.Context, string, string, string) (string, error) {
				return "", errors.New("conf error")
			},
		}},
		status: http.StatusInternalServerError,
		err:    "conf error",
	})
	tests.Add("success", tst{
		client: &Client{driverClient: &mock.Configer{
			DeleteConfigKeyFunc: func(_ context.Context, node, section, key string) (string, error) {
				if node != "foo" {
					return "", fmt.Errorf("Unexpected node: %s", node)
				}
				if section != "foo" {
					return "", fmt.Errorf("Unexpected section: %s", section)
				}
				if key != "baz" {
					return "", fmt.Errorf("Unexpected key: %s", key)
				}
				return "old", nil
			},
		}},
		node:     "foo",
		section:  "foo",
		key:      "baz",
		expected: "old",
	})
	tests.Add("closed", tst{
		client: &Client{
			closed: true,
		},
		status: http.StatusServiceUnavailable,
		err:    "kivik: client closed",
	})

	tests.Run(t, func(t *testing.T, test tst) {
		result, err := test.client.DeleteConfigKey(context.Background(), test.node, test.section, test.key)
		if d := internal.StatusErrorDiff(test.err, test.status, err); d != "" {
			t.Error(d)
		}
		if d := testy.DiffInterface(test.expected, result); d != nil {
			t.Error(d)
		}
	})
}