// 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_test

import (
	"context"
	"encoding/json"
	"fmt"

	kivik "github.com/go-kivik/kivik/v4"
)

var db = &kivik.DB{}

// Storing a document is done with Put or CreateDoc, which correspond to
// `PUT /{db}/{doc}` and `POST /{db}` respectively. In most cases, you should
// use Put.
func ExampleDB_CreateDoc() {
	type Animal struct {
		ID       string `json:"_id"`
		Rev      string `json:"_rev,omitempty"`
		Feet     int    `json:"feet"`
		Greeting string `json:"greeting"`
	}

	cow := Animal{Feet: 4, Greeting: "moo"}
	docID, rev, err := db.CreateDoc(context.TODO(), cow)
	if err != nil {
		panic(err)
	}
	cow.ID = docID
	cow.Rev = rev
}

var cow struct {
	Rev      string
	Greeting string
}

// Updating a document is the same as storing one, except that the `_rev`
// parameter must match that stored on the server.
func ExampleDB_Put() {
	cow.Rev = "1-6e609020e0371257432797b4319c5829" // Must be set
	cow.Greeting = "Moo!"
	newRev, err := db.Put(context.TODO(), "cow", cow)
	if err != nil {
		panic(err)
	}
	cow.Rev = newRev
}

// As with updating a document, deletion depends on the proper _rev parameter.
func ExampleDB_Delete() {
	newRev, err := db.Delete(context.TODO(), "cow", "2-9c65296036141e575d32ba9c034dd3ee")
	if err != nil {
		panic(err)
	}
	fmt.Printf("The tombstone document has revision %s\n", newRev)
}

// When fetching a document, the document will be unmarshaled from JSON into
// your structure by the row.ScanDoc method.
func ExampleDB_Get() {
	type Animal struct {
		ID       string `json:"_id"`
		Rev      string `json:"_rev,omitempty"`
		Feet     int    `json:"feet"`
		Greeting string `json:"greeting"`
	}

	var cow Animal
	err := db.Get(context.TODO(), "cow").ScanDoc(&cow)
	if err != nil {
		panic(err)
	}
	fmt.Printf("The cow says '%s'\n", cow.Greeting)
}

// Design documents are treated identically to normal documents by both CouchDB
// and Kivik. The only difference is the document ID.
//
// Store your document normally, formatted with your views (or other functions).
func ExampleDB_Put_updateView() {
	_, err := db.Put(context.TODO(), "_design/foo", map[string]interface{}{
		"_id": "_design/foo",
		"views": map[string]interface{}{
			"foo_view": map[string]interface{}{
				"map": "function(doc) { emit(doc._id) }",
			},
		},
	})
	if err != nil {
		panic(err)
	}
}

func ExampleDB_Query() {
	rs := db.Query(context.TODO(), "_design/foo", "_view/bar", kivik.Params(map[string]interface{}{
		"startkey": `foo`,
		"endkey":   `foo` + kivik.EndKeySuffix,
	}))
	defer rs.Close()
	for rs.Next() {
		var doc interface{}
		if err := rs.ScanDoc(&doc); err != nil {
			panic(err)
		}
		/* do something with doc */
	}
	if rs.Err() != nil {
		panic(rs.Err())
	}
}

func ExampleDB_Query_compoundKey() {
	rs := db.Query(context.TODO(), "_design/foo", "_view/bar", kivik.Params(map[string]interface{}{
		"startkey": []string{"foo", "bar"},
		"endkey":   []string{"foo", "bar" + kivik.EndKeySuffix},
	}))
	defer rs.Close()
	for rs.Next() {
		var doc interface{}
		if err := rs.ScanDoc(&doc); err != nil {
			panic(err)
		}
		/* do something with doc */
	}
	if rs.Err() != nil {
		panic(rs.Err())
	}
}

func ExampleDB_Query_literalJSONKeys() {
	rs := db.Query(context.TODO(), "_design/foo", "_view/bar", kivik.Param(
		"startkey", json.RawMessage(`{"foo":true}`),
	))
	defer rs.Close()
	for rs.Next() {
		var doc interface{}
		if err := rs.ScanDoc(&doc); err != nil {
			panic(err)
		}
		/* do something with doc */
	}
	if rs.Err() != nil {
		panic(rs.Err())
	}
}

func ExampleDB_Query_multiple() {
	rs := db.Query(context.TODO(), "_design/foo", "_view/bar", kivik.Param(
		"queries", []interface{}{
			map[string]interface{}{
				"startkey":     []string{"foo", "bar"},
				"endkey":       []string{"foo", "bar" + kivik.EndKeySuffix},
				"include_docs": true,
			},
			map[string]interface{}{
				"startkey":     []string{"baz", "bar"},
				"endkey":       []string{"baz", "bar" + kivik.EndKeySuffix},
				"include_docs": true,
			},
		}))
	defer rs.Close()
	var rsIndex int
	for rs.NextResultSet() {
		rsIndex++
		for rs.Next() {
			var doc interface{}
			if err := rs.ScanDoc(&doc); err != nil {
				panic(err)
			}
			/* do something with doc */
		}
	}
}

//nolint:revive // allow empty block in example
func ExampleDB_Query_mapReduce() {
	opts := kivik.Param("group", true)
	rows := db.Query(context.TODO(), "_design/foo", "_view/bar", opts)
	if err := rows.Err(); err != nil {
		panic(err)
	}
	for rows.Next() {
		/* ... */
	}
}