package x2j

import (
	"bytes"
	"fmt"
	"testing"
)

var doc = `<entry><vars><foo>bar</foo><foo2><hello>world</hello></foo2></vars></entry>`


func TestToMap(t *testing.T) {
	fmt.Println("\nToMap - Read doc:",doc)
	rdr := bytes.NewBufferString(doc)
	m,err := ToMap(rdr)
	if err != nil {
		fmt.Println("err:",err.Error())
	}
	fmt.Println(WriteMap(m))
}

func TestToJson(t *testing.T) {
	fmt.Println("\nToJson - Read doc:",doc)
	rdr := bytes.NewBufferString(doc)
	s,err := ToJson(rdr)
	if err != nil {
		fmt.Println("err:",err.Error())
	}
	fmt.Println("json:",s)
}

func TestToJsonIndent(t *testing.T) {
	fmt.Println("\nToJsonIndent - Read doc:",doc)
	rdr := bytes.NewBufferString(doc)
	s,err := ToJsonIndent(rdr)
	if err != nil {
		fmt.Println("err:",err.Error())
	}
	fmt.Println("json:",s)
}

func TestBulkParser(t *testing.T) {
	s := doc + `<this><is>an</err>`+ doc
	fmt.Println("\nBulkParser (with error) - Read doc:",s)
	rdr := bytes.NewBufferString(s)
	err := XmlMsgsFromReader(rdr,phandler,ehandler)
	if err != nil {
		fmt.Println("reader terminated:",err.Error())
	}
}

func phandler(m map[string]interface{}) bool {
	fmt.Println("phandler m:",m)
	return true
}

func ehandler(err error) bool {
	fmt.Println("ehandler err:",err.Error())
	return true
}

func TestBulkParserToJson(t *testing.T) {
	s := doc + `<this><is>an</err>`+ doc
	fmt.Println("\nBulkParser (with error) - Read doc:",s)
	rdr := bytes.NewBufferString(s)
	err := XmlMsgsFromReaderAsJson(rdr,phandlerj,ehandler)
	if err != nil {
		fmt.Println("reader terminated:",err.Error())
	}
}

func phandlerj(s string) bool {
	fmt.Println("phandlerj s:",s)
	return true
}