fix: first spike of integration of GraphQL query

Author: jstrachan

go.mod

@@ -5,6 +5,8 @@ require (
 	github.com/google/go-cmp v0.3.0
 	github.com/h2non/gock v1.0.9
 	github.com/pkg/errors v0.8.1
+	github.com/shurcooL/githubv4 v0.0.0-20190718010115-4ba037080260
+	github.com/shurcooL/graphql v0.0.0-20181231061246-d48a9a75455f // indirect
 	github.com/stretchr/testify v1.3.0
 	golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45
 	k8s.io/apimachinery v0.0.0-20190703205208-4cfb76a8bf76

go.sum

@@ -36,6 +36,10 @@ github.com/pkg/errors v0.8.1 h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I=
 github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/shurcooL/githubv4 v0.0.0-20190718010115-4ba037080260 h1:xKXiRdBUtMVp64NaxACcyX4kvfmHJ9KrLU+JvyB1mdM=
+github.com/shurcooL/githubv4 v0.0.0-20190718010115-4ba037080260/go.mod h1:hAF0iLZy4td2EX+/8Tw+4nodhlMrwN3HupfaXj3zkGo=
+github.com/shurcooL/graphql v0.0.0-20181231061246-d48a9a75455f h1:tygelZueB1EtXkPI6mQ4o9DQ0+FKW41hTbunoXZCTqk=
+github.com/shurcooL/graphql v0.0.0-20181231061246-d48a9a75455f/go.mod h1:AuYgA5Kyo4c7HfUmvRGs/6rGlMMV/6B1bVnB9JxJEEg=
 github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.3.0 h1:TivCn/peBQ7UY8ooIcPgZFpTNSz0Q2U6UrFlUfqbe0Q=

scm/client.go

@@ -75,6 +75,11 @@ type (
 		Size int
 	}
 
+	// GraphQLService the API to performing GraphQL queries
+	GraphQLService interface {
+		Query(ctx context.Context, q interface{}, vars map[string]interface{}) error
+	}
+
 	// Client manages communication with a version control
 	// system API.
 	Client struct {
@@ -97,6 +102,7 @@ type (
 		Reviews       ReviewService
 		Users         UserService
 		Webhooks      WebhookService
+		Query         GraphQLService
 
 		// DumpResponse optionally specifies a function to
 		// dump the the response body for debugging purposes.

scm/driver/github/github.go

@@ -9,13 +9,22 @@ import (
 	"bytes"
 	"context"
 	"encoding/json"
+	"fmt"
+	"net/http"
 	"net/url"
 	"strconv"
 	"strings"
+	"time"
 
 	"github.com/jenkins-x/go-scm/scm"
+	githubql "github.com/shurcooL/githubv4"
 )
 
+// Abort requests that don't return in 5 mins. Longest graphql calls can
+// take up to 2 minutes. This limit should ensure all successful calls return
+// but will prevent an indefinite stall if GitHub never responds.
+const maxRequestTime = 5 * time.Minute
+
 // New returns a new GitHub API client.
 func New(uri string) (*scm.Client, error) {
 	base, err := url.Parse(uri)
@@ -38,9 +47,37 @@ func New(uri string) (*scm.Client, error) {
 	client.Reviews = &reviewService{client}
 	client.Users = &userService{client}
 	client.Webhooks = &webhookService{client}
+
+	graphqlEndpoint := scm.UrlJoin(uri, "/graphql")
+	client.Query = &dynamicGraphQLClient{client, graphqlEndpoint}
+
 	return client.Client, nil
 }
 
+type dynamicGraphQLClient struct {
+	wrapper         *wrapper
+	graphqlEndpoint string
+}
+
+func (d *dynamicGraphQLClient) Query(ctx context.Context, q interface{}, vars map[string]interface{}) error {
+	httpClient := d.wrapper.Client.Client
+	if httpClient != nil {
+
+		transport := httpClient.Transport
+		if transport != nil {
+			query := githubql.NewEnterpriseClient(
+				d.graphqlEndpoint,
+				&http.Client{
+					Timeout:   maxRequestTime,
+					Transport: transport,
+				})
+			return query.Query(ctx, q, vars)
+		}
+	}
+	fmt.Println("WARNING: no http transport configured for GraphQL and GitHub")
+	return nil
+}
+
 // NewDefault returns a new GitHub API client using the
 // default api.github.com address.
 func NewDefault() *scm.Client {