package main

import (
	"fmt"
	"log"

	"github.com/hazelcast/hazelcast-go-client"
	"github.com/relex/aini"
)

func main() {
	var hazelcastHosts []string

	id, err := aini.ParseFile("./hazelcast_stack.toml")
	if err != nil {
		log.Fatalln(err)
	}

	for _, h := range id.Groups["all"].Hosts {
		fmt.Printf("scan ansible host : %s => %s:%d\n", h.Name, h.Vars["ansible_host"], h.Port)
		hazelcastHosts = append(hazelcastHosts, h.Vars["ansible_host"])
	}
	//fmt.Printf("%+v\n", id.Groups["all"].Vars)

	clientConfig := hazelcast.NewConfig()
	fmt.Println("Cluster name: ", clientConfig.GroupConfig().Name())

	clientConfig.NetworkConfig().AddAddress(hazelcastHosts...)
	fmt.Println("Cluster discovery: ", clientConfig.NetworkConfig().Addresses())

	hz, err := hazelcast.NewClientWithConfig(clientConfig)
	if err != nil {
		log.Fatalf("fail to start hazelcast client %+v", err)
	}

	// Shutdown this hazelcast client
	defer hz.Shutdown()

	// Get the Distributed Map from Cluster.
	mp, _ := hz.GetMap("myDistributedMap")
	//Standard Put and Get.
	mp.Put("key", "value")

	v, err := mp.Get("key")
	if err != nil {
		log.Fatalf("error reading key into map myDistributedMap", err)
	} else {
		fmt.Printf("myDistributedMap['key'] = %+v\n", v)
	}

	//Concurrent Map methods, optimistic updating
	mp.PutIfAbsent("somekey", "somevalue")
	mp.ReplaceIfSame("key", "value", "newvalue")

	v, err = mp.Get("key")
	if err != nil {
		log.Fatalf("error reading key into map myDistributedMap", err)
	} else {
		fmt.Printf("myDistributedMap['key'] = %+v\n", v)
	}

}