package main

import (
	"context"
	"fmt"

	dapr "github.com/dapr/go-sdk/client"
)

func main() {
	// just for this demo
	ctx := context.Background()
	data := []byte("ping")

	// create the client
	client, err := dapr.NewClient()
	if err != nil {
		panic(err)
	}
	defer client.Close(ctx)

	// publish a message to the topic messagebus
	err = client.PublishEvent(ctx, "messagebus", data)
	if err != nil {
		panic(err)
	}
	fmt.Println("data published")

	// save state with the key key1
	err = client.SaveState(ctx, "statestore", "key1", data)
	if err != nil {
		panic(err)
	}
	fmt.Println("data saved")

	// get state for key key1
	dataOut, err := client.GetState(ctx, "statestore", "key1")
	if err != nil {
		panic(err)
	}
	fmt.Println(string(dataOut))

	// delete state for key key1
	err = client.DeleteState(ctx, "statestore", "key1")
	if err != nil {
		panic(err)
	}
	fmt.Println("data deleted")

	// invoke a method called MyMethod on another dapr enabled service with id client
	resp, err := client.InvokeService(ctx, "serving", "MyMethod", data)
	if err != nil {
		panic(err)
	}
	fmt.Println(string(resp))

	// invoke output binding named 'example-http-binding'
	// uses https://http2.pro/doc/api to check for HTTP/2
	err = client.InvokeBinding(ctx, "example-http-binding", data)
	if err != nil {
		panic(err)
	}
	fmt.Println("binding invoked")
}