Remove Authorizer property from public API

Author: exanubes

authorizer/example_test.go

@@ -22,7 +22,7 @@ func ExampleApiKey() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     "wss://xxxxxxxxxxxxxxxxxxxx.appsync-realtime-api.us-east-1.amazonaws.com",
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)
@@ -44,7 +44,7 @@ func ExampleIAM() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     "wss://xxxxxxxxxxxxxxxxxxxx.appsync-realtime-api.us-east-1.amazonaws.com",
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)
@@ -67,7 +67,7 @@ func ExampleToken() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     "wss://xxxxxxxxxxxxxxxxxxxx.appsync-realtime-api.us-east-1.amazonaws.com",
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)

connect.go

@@ -181,9 +181,7 @@ func Connect(ctx context.Context, options ConnectionOptions) (Client, error) {
 	builder := new_builder()
 
 	builder.
-		WithAuthorizers(Authorizers{
-			Default: options.Authorizer,
-		}).
+		WithAuthorizers(options.Authorizers).
 		WithEndpoint(options.Endpoint).
 		WithSubprotocol(options.Subprotocols...).
 		WithBackpressure(options.Backpressure)

e2e/e2e_test.go

@@ -92,7 +92,7 @@ func TestAppSyncAuthorizers(t *testing.T) {
 			client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 				Endpoint:     ws_endpoint,
 				Subprotocols: []string{appsync.ProtocolEvents},
-				Authorizer:   authz,
+				Authorizers:  appsync.Authorizers{Default: authz},
 			})
 			if err != nil {
 				t.Fatalf("connect: %v", err)
@@ -163,7 +163,7 @@ func TestSuccessfulUnsubscribe(t *testing.T) {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     ws_endpoint,
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers:  appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		t.Fatalf("connect: %v", err)
@@ -217,7 +217,7 @@ func TestInvalidApiKeyCannotConnect(t *testing.T) {
 	_, err = appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     ws_endpoint,
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers:  appsync.Authorizers{Default: authz},
 	})
 
 	if err == nil {

example_test.go

@@ -25,7 +25,7 @@ func ExampleConnect() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     "wss://xxxxxxxxxxxxxxxxxxxx.appsync-realtime-api.us-east-1.amazonaws.com",
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)
@@ -47,7 +47,7 @@ func ExampleClient_Subscribe() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     "wss://xxxxxxxxxxxxxxxxxxxx.appsync-realtime-api.us-east-1.amazonaws.com",
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)
@@ -91,7 +91,7 @@ func ExampleClient_Publish() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     "wss://xxxxxxxxxxxxxxxxxxxx.appsync-realtime-api.us-east-1.amazonaws.com",
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)

examples/api-key/main.go

@@ -41,7 +41,7 @@ func main() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     wsEndpoint,
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)

examples/custom-authorizer/main.go

@@ -87,7 +87,7 @@ func main() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     wsEndpoint,
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)

examples/iam/main.go

@@ -41,7 +41,7 @@ func main() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     wsEndpoint,
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)

examples/token/main.go

@@ -41,7 +41,7 @@ func main() {
 	client, err := appsync.Connect(ctx, appsync.ConnectionOptions{
 		Endpoint:     wsEndpoint,
 		Subprotocols: []string{appsync.ProtocolEvents},
-		Authorizer:   authz,
+		Authorizers: appsync.Authorizers{Default: authz},
 	})
 	if err != nil {
 		log.Fatal(err)

ports.go

@@ -10,8 +10,6 @@ import (
 type ConnectionOptions struct {
 	Endpoint     string
 	Subprotocols []string
-	// @deprecated
-	Authorizer   authorizer.Authorizer
 	Authorizers  Authorizers
 	Backpressure Backpressure
 }