fmt and regenerate

Signed-off-by: Steve Coffman <steve@khanacademy.org>
99designs · Jan 13, 2023 · f1648cd · f1648cd
1 parent bc2e26d
commit f1648cd
Show file tree

Hide file tree

Showing 5 changed files with 35 additions and 31 deletions.
diff --git a/_examples/chat/chat_test.go b/_examples/chat/chat_test.go
@@ -2,13 +2,14 @@ package chat
 
 import (
 	"fmt"
+	"runtime"
+	"sync"
+	"testing"
+
 	"github.com/99designs/gqlgen/client"
 	"github.com/99designs/gqlgen/graphql/handler"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
-	"runtime"
-	"sync"
-	"testing"
 )
 
 func TestChatSubscriptions(t *testing.T) {

diff --git a/graphql/handler/apollofederatedtracingv1/generated/apollo_trace.pb.go b/graphql/handler/apollofederatedtracingv1/generated/apollo_trace.pb.go
diff --git a/graphql/handler/transport/websocket_resolver_error.go b/graphql/handler/transport/websocket_resolver_error.go
@@ -20,33 +20,35 @@ type subscriptionError struct {
 
 // AddSubscriptionError is used to let websocket return an error message after subscription resolver returns a channel.
 // for example:
-// func (r *subscriptionResolver) Method(ctx context.Context) (<-chan *model.Message, error) {
-//	ch := make(chan *model.Message)
-//	go func() {
-//      defer func() {
-//			close(ch)
-//      }
-//		// some kind of block processing (e.g.: gRPC client streaming)
-//		stream, err := gRPCClientStreamRequest(ctx)
-//		if err != nil {
-//			   transport.AddSubscriptionError(ctx, err)
-//             return // must return and close channel so websocket can send error back
-//      }
-//		for {
-//			m, err := stream.Recv()
-//			if err == io.EOF {
-//				return
-//			}
+//
+//	func (r *subscriptionResolver) Method(ctx context.Context) (<-chan *model.Message, error) {
+//		ch := make(chan *model.Message)
+//		go func() {
+//	     defer func() {
+//				close(ch)
+//	     }
+//			// some kind of block processing (e.g.: gRPC client streaming)
+//			stream, err := gRPCClientStreamRequest(ctx)
 //			if err != nil {
-//			   transport.AddSubscriptionError(ctx, err)
-//             return // must return and close channel so websocket can send error back
+//				   transport.AddSubscriptionError(ctx, err)
+//	            return // must return and close channel so websocket can send error back
+//	     }
+//			for {
+//				m, err := stream.Recv()
+//				if err == io.EOF {
+//					return
+//				}
+//				if err != nil {
+//				   transport.AddSubscriptionError(ctx, err)
+//	            return // must return and close channel so websocket can send error back
+//				}
+//				ch <- m
 //			}
-//			ch <- m
-//		}
-//	}()
+//		}()
+//
+//		return ch, nil
+//	}
 //
-//	return ch, nil
-//}
 // see https://github.com/99designs/gqlgen/pull/2506 for more details
 func AddSubscriptionError(ctx context.Context, err *gqlerror.Error) {
 	subscriptionErrStruct := getSubscriptionErrorStruct(ctx)

diff --git a/plugin/federation/testdata/entityresolver/generated/errors.go b/plugin/federation/testdata/entityresolver/generated/errors.go
@@ -3,7 +3,6 @@ package generated
 import "errors"
 
 // Errors defined for retained code that we want to stick around between generations.
-//
 var (
 	ErrResolvingHelloWithErrorsByName         = errors.New("error resolving HelloWithErrorsByName")
 	ErrEmptyKeyResolvingHelloWithErrorsByName = errors.New("error (empty key) resolving HelloWithErrorsByName")

diff --git a/plugin/resolvergen/testdata/return_values/return_values_test.go b/plugin/resolvergen/testdata/return_values/return_values_test.go
@@ -1,9 +1,10 @@
 package return_values
 
 import (
-	"github.com/stretchr/testify/require"
 	"reflect"
 	"testing"
+
+	"github.com/stretchr/testify/require"
 )
 
 //go:generate rm -f resolvers.go