mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-09-07 00:55:55 +00:00
48 lines
1,004 B
Go
48 lines
1,004 B
Go
package csrc_test
|
|
|
|
import (
|
|
"os"
|
|
"testing"
|
|
|
|
"github.com/featurebasedb/featurebase/v3/idk/kafka/csrc"
|
|
)
|
|
|
|
func TestPostGet(t *testing.T) {
|
|
if testing.Short() {
|
|
t.Skip()
|
|
}
|
|
|
|
var registryHost string
|
|
registryHost, ok := os.LookupEnv("IDK_TEST_REGISTRY_HOST")
|
|
if !ok {
|
|
registryHost = "schema-registry:8081"
|
|
}
|
|
|
|
client := csrc.NewClient(registryHost, nil, nil)
|
|
|
|
schemaStr := `{"type":"record","name":"a","fields":[{"name":"blah","type":"string"}]}`
|
|
r, err := client.PostSubjects("aname", schemaStr)
|
|
if err != nil {
|
|
t.Fatalf("postsubjects: %v", err)
|
|
}
|
|
|
|
// Docs indicate that schema and subject should be returned by the
|
|
// POST, but they are not.
|
|
//
|
|
// if r.Schema != schemaStr {
|
|
// t.Errorf("wrong schema: %s", r.Schema)
|
|
// }
|
|
|
|
// if r.Subject != "aname" {
|
|
// t.Errorf("wrong name: %v", r.Subject)
|
|
// }
|
|
|
|
sch, err := client.GetSchema(r.ID)
|
|
if err != nil {
|
|
t.Fatalf("getting schema: %v", err)
|
|
}
|
|
|
|
if sch != schemaStr {
|
|
t.Errorf("unexpected schema\n%s\n%s", sch, schemaStr)
|
|
}
|
|
}
|