package main

import (
	"context"
	"fmt"
	"os"

	pb "github.com/dapr/go-sdk/dapr"
	"github.com/golang/protobuf/ptypes/any"
	"google.golang.org/grpc"
)

func main() {
	// Get the Dapr port and create a connection
	daprPort := os.Getenv("DAPR_GRPC_PORT")
	daprAddress := fmt.Sprintf("localhost:%s", daprPort)
	conn, err := grpc.Dial(daprAddress, grpc.WithInsecure())
	if err != nil {
		fmt.Println(err)
		return
	}
	defer conn.Close()

	// Create the client
	client := pb.NewDaprClient(conn)

	// Invoke a method called MyMethod on another Dapr enabled service with id client
	resp, err := client.InvokeService(context.Background(), &pb.InvokeServiceEnvelope{
		Id:     "client",
		Data:   &any.Any{Value: []byte("Hello")},
		Method: "MyMethod",
	})
	if err != nil {
		fmt.Println(err)
	} else {
		fmt.Println(string(resp.Data.Value))
	}

	// Publish a message to the topic TopicA
	_, err = client.PublishEvent(context.Background(), &pb.PublishEventEnvelope{
		Topic: "TopicA",
		Data: &any.Any{
			Value: []byte("Hi from Pub Sub"),
		},
	})
	if err != nil {
		fmt.Println(err)
	} else {
		fmt.Println("Published message!")
	}

	// Save state with the key myKey
	_, err = client.SaveState(context.Background(), &pb.SaveStateEnvelope{
		Requests: []*pb.StateRequest{
			&pb.StateRequest{
				Key: "myKey",
				Value: &any.Any{
					Value: []byte("My State"),
				},
			},
		},
	})
	if err != nil {
		fmt.Println(err)
	} else {
		fmt.Println("Saved state!")
	}

	// Get state for key myKey
	r, err := client.GetState(context.Background(), &pb.GetStateEnvelope{
		Key: "myKey",
	})
	if err != nil {
		fmt.Println(err)
	} else {
		fmt.Println("Got state!")
		fmt.Println(string(r.Data.Value))
	}

	// Delete state for key myKey
	_, err = client.DeleteState(context.Background(), &pb.DeleteStateEnvelope{
		Key: "myKey",
	})
	if err != nil {
		fmt.Println(err)
	} else {
		fmt.Println("State deleted")
	}

	// Invoke output binding named storage. Make sure you set up a Dapr binding, otherwise this will fail
	_, err = client.InvokeBinding(context.Background(), &pb.InvokeBindingEnvelope{
		Name: "storage",
		Data: &any.Any{
			Value: []byte("some data"),
		},
	})
	if err != nil {
		fmt.Println(err)
	} else {
		fmt.Println("Binding invoked")
	}
}