Implemented a new ExecuteGraphqlWithContext function (#86)

* Implemented a new `ExecuteGraphqlWithContext` function so that users willing to honor a given context termination can use the Lightspark go-sdk.

* Created a `WithContext` options to `LightsparkClient` that allows receiving a context for proper termination of every called operation.

requester/requester.go

@@ -3,6 +3,7 @@ package requester
 
 import (
 	"bytes"
+	"context"
 	"crypto/rand"
 	"encoding/base64"
 	"encoding/json"
@@ -16,6 +17,7 @@ import (
 	"strconv"
 	"strings"
 	"time"
+
 	"github.com/DataDog/zstd"
 
 	lightspark "github.com/lightsparkdev/go-sdk"
@@ -25,7 +27,7 @@ import (
 // It could be due to a service outage or a network error.
 // The request should be retried if RequestError is returned with server errors (500-599).
 type RequestError struct {
-	Message string
+	Message    string
 	StatusCode int
 }
 
@@ -34,7 +36,7 @@ func (e RequestError) Error() string {
 }
 
 // GraphQLInternalError indicates there's a failure in the Lightspark API.
-// It could be due to a bug on Ligthspark's side. 
+// It could be due to a bug on Ligthspark's side.
 // The request can be retried, because the error might be transient.
 type GraphQLInternalError struct {
 	Message string
@@ -48,11 +50,11 @@ func (e GraphQLInternalError) Error() string {
 // The request should not be retried, because the error is due to the user's input.
 type GraphQLError struct {
 	Message string
-	Type string
+	Type    string
 }
 
 func (e GraphQLError) Error() string {
-	return  e.Type + ": " + e.Message
+	return e.Type + ": " + e.Message
 }
 
 type Requester struct {
@@ -107,6 +109,12 @@ const DEFAULT_BASE_URL = "https://api.lightspark.com/graphql/server/2023-09-13"
 
 func (r *Requester) ExecuteGraphql(query string, variables map[string]interface{},
 	signingKey SigningKey,
+) (map[string]interface{}, error) {
+	return r.ExecuteGraphqlWithContext(context.Background(), query, variables, signingKey)
+}
+
+func (r *Requester) ExecuteGraphqlWithContext(ctx context.Context, query string, variables map[string]interface{},
+	signingKey SigningKey,
 ) (map[string]interface{}, error) {
 	re := regexp.MustCompile(`(?i)\s*(?:query|mutation)\s+(?P<OperationName>\w+)`)
 	matches := re.FindStringSubmatch(query)
@@ -143,7 +151,7 @@ func (r *Requester) ExecuteGraphql(query string, variables map[string]interface{
 		return nil, errors.New("error when encoding payload")
 	}
 
-	body := encodedPayload;
+	body := encodedPayload
 	compressed := false
 	if len(encodedPayload) > 1024 {
 		compressed = true
@@ -163,10 +171,11 @@ func (r *Requester) ExecuteGraphql(query string, variables map[string]interface{
 		return nil, err
 	}
 
-	request, err := http.NewRequest("POST", serverUrl, bytes.NewBuffer(body))
+	request, err := http.NewRequestWithContext(ctx, http.MethodPost, serverUrl, bytes.NewBuffer(body))
 	if err != nil {
 		return nil, err
 	}
+
 	request.SetBasicAuth(r.ApiTokenClientId, r.ApiTokenClientSecret)
 	request.Header.Add("Content-Type", "application/json")
 	if compressed {
@@ -202,7 +211,7 @@ func (r *Requester) ExecuteGraphql(query string, variables map[string]interface{
 	}
 	defer response.Body.Close()
 	if response.StatusCode < 200 || response.StatusCode > 299 {
-		return nil, RequestError { Message: response.Status, StatusCode: response.StatusCode }
+		return nil, RequestError{Message: response.Status, StatusCode: response.StatusCode}
 	}
 
 	data, err := io.ReadAll(response.Body)