package main

import (
	"context"
	"fmt"
	"log"
	"os"

	attesto "go.attesto.eu/sdk"
)

func main() {
	ctx := context.Background()
	client, err := attesto.NewClient(os.Getenv("ATTESTO_API_KEY"))
	if err != nil {
		log.Fatal(err)
	}
	stream, err := client.CreateStream(ctx, attesto.StreamCreateInput{
		UseCase:  "ai-governance",
		PolicyID: "policy-main",
	})
	if err != nil {
		log.Fatal(err)
	}
	receipt, err := client.LogEvent(ctx, stream.StreamID, attesto.EventInput{
		SourceRef: "example-decision",
		Payload: attesto.M{
			"decision": "approved",
			"reason":   "policy-threshold-met",
		},
	})
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("%s %s\n", receipt.StreamEventID, receipt.EventHash)
}