// Copyright 2022 The etcd Authors
//
// 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 integration

import (
	"testing"

	"github.com/stretchr/testify/require"

	clientv3 "go.etcd.io/etcd/client/v3"
	"go.etcd.io/etcd/client/v3/namespace"
	"go.etcd.io/etcd/tests/v3/framework/integration"
)

// TestKVWithEmptyValue ensures that a get/delete with an empty value, and with WithFromKey/WithPrefix function will return an empty error.
func TestKVWithEmptyValue(t *testing.T) {
	integration.BeforeTest(t)

	clus := integration.NewCluster(t, &integration.ClusterConfig{Size: 1})
	defer clus.Terminate(t)

	client := clus.RandClient()

	_, err := client.Put(t.Context(), "my-namespace/foobar", "data")
	require.NoError(t, err)
	_, err = client.Put(t.Context(), "my-namespace/foobar1", "data")
	require.NoError(t, err)
	_, err = client.Put(t.Context(), "namespace/foobar1", "data")
	require.NoError(t, err)

	// Range over all keys.
	resp, err := client.Get(t.Context(), "", clientv3.WithFromKey())
	require.NoError(t, err)
	for _, kv := range resp.Kvs {
		t.Log(string(kv.Key), "=", string(kv.Value))
	}

	// Range over all keys in a namespace.
	client.KV = namespace.NewKV(client.KV, "my-namespace/")
	resp, err = client.Get(t.Context(), "", clientv3.WithFromKey())
	require.NoError(t, err)
	for _, kv := range resp.Kvs {
		t.Log(string(kv.Key), "=", string(kv.Value))
	}

	// Remove all keys without WithFromKey/WithPrefix func
	_, err = client.Delete(t.Context(), "")
	// fatal error duo to without WithFromKey/WithPrefix func called.
	require.Error(t, err)

	respDel, err := client.Delete(t.Context(), "", clientv3.WithFromKey())
	// fatal error duo to with WithFromKey/WithPrefix func called.
	require.NoError(t, err)
	t.Logf("delete keys:%d", respDel.Deleted)
}