package main
import (
"bufio"
"bytes"
"log"
"os"
"strings"
"github.com/opentdf/platform/sdk"
)
func main() {
platformEndpoint := "http://localhost:9002"
client, err := sdk.New(
platformEndpoint,
sdk.WithClientCredentials("opentdf", "secret", nil),
)
if err != nil {
log.Fatal(err)
}
str := strings.NewReader("Sensitive data!")
buf := &bytes.Buffer{}
out := bufio.NewWriter(buf)
manifest, err := client.CreateTDF(out, str,
sdk.WithKasInformation(
sdk.KASInfo{
URL: "http://localhost:9002",
},
),
)
if err != nil {
log.Fatal(err)
}
out.Flush()
log.Printf("TDF Manifest: %v", manifest)
tdfReader, err := client.LoadTDF(bytes.NewReader(buf.Bytes()))
if err != nil {
log.Fatal(err)
}
_, err = tdfReader.WriteTo(os.Stdout)
if err != nil {
log.Fatal(err)
}
}