[CON-2362] feat: add paypal write connector

providers/paypal/connector.go

@@ -8,6 +8,7 @@ import (
 	"github.com/amp-labs/connectors/internal/components/operations"
 	"github.com/amp-labs/connectors/internal/components/reader"
 	"github.com/amp-labs/connectors/internal/components/schema"
+	"github.com/amp-labs/connectors/internal/components/writer"
 	"github.com/amp-labs/connectors/internal/staticschema"
 	"github.com/amp-labs/connectors/providers"
 	"github.com/amp-labs/connectors/tools/fileconv"
@@ -35,6 +36,7 @@ type Connector struct {
 	// Supported operations
 	components.SchemaProvider
 	components.Reader
+	components.Writer
 }
 
 func NewConnector(params common.ConnectorParams) (*Connector, error) {
@@ -50,9 +52,14 @@ func constructor(base *components.Connector) (*Connector, error) {
 
 	connector.SchemaProvider = schema.NewOpenAPISchemaProvider(common.ModuleRoot, schemas)
 
+	registry, err := components.NewEndpointRegistry(supportedOperations())
+	if err != nil {
+		return nil, err
+	}
+
 	connector.Reader = reader.NewHTTPReader(
 		connector.HTTPClient().Client,
-		components.NewEmptyEndpointRegistry(),
+		registry,
 		common.ModuleRoot,
 		operations.ReadHandlers{
 			BuildRequest:  connector.buildReadRequest,
@@ -61,5 +68,16 @@ func constructor(base *components.Connector) (*Connector, error) {
 		},
 	)
 
+	connector.Writer = writer.NewHTTPWriter(
+		connector.HTTPClient().Client,
+		registry,
+		common.ModuleRoot,
+		operations.WriteHandlers{
+			BuildRequest:  connector.buildWriteRequest,
+			ParseResponse: connector.parseWriteResponse,
+			ErrorHandler:  common.InterpretError,
+		},
+	)
+
 	return connector, nil
 }

providers/paypal/handlers.go

@@ -1,14 +1,17 @@
 package paypal
 
 import (
+	"bytes"
 	"context"
+	"encoding/json"
 	"net/http"
 	"strconv"
 	"time"
 
 	"github.com/amp-labs/connectors/common"
 	"github.com/amp-labs/connectors/common/urlbuilder"
 	"github.com/amp-labs/connectors/internal/datautils"
+	"github.com/amp-labs/connectors/internal/jsonquery"
 )
 
 type timeFilter struct {
@@ -95,3 +98,93 @@ func (c *Connector) parseReadResponse(
 		params.Fields,
 	)
 }
+
+// objectUpdateMethod maps objects to their HTTP update method. Defaults to PATCH.
+//
+//nolint:gochecknoglobals
+var objectUpdateMethod = datautils.NewDefaultMap(
+	map[string]string{
+		"invoices":     http.MethodPut,
+		"templates":    http.MethodPut,
+		"web-profiles": http.MethodPut,
+	},
+	func(_ string) string {
+		return http.MethodPatch
+	},
+)
+
+// objectWritePath holds write paths for objects that are not in the read schema (write-only).
+//
+//nolint:gochecknoglobals
+var objectWritePath = map[string]string{
+	"orders": "/v2/checkout/orders",
+}
+
+func (c *Connector) buildWriteRequest(ctx context.Context, params common.WriteParams) (*http.Request, error) {
+	method := http.MethodPost
+
+	path, err := schemas.FindURLPath(common.ModuleRoot, params.ObjectName)
+	if err != nil {
+		var ok bool
+
+		path, ok = objectWritePath[params.ObjectName]
+		if !ok {
+			return nil, err
+		}
+	}
+
+	url, err := urlbuilder.New(c.ProviderInfo().BaseURL, path)
+	if err != nil {
+		return nil, err
+	}
+
+	if params.RecordId != "" {
+		url.AddPath(params.RecordId)
+		method = objectUpdateMethod.Get(params.ObjectName)
+	}
+
+	jsonData, err := json.Marshal(params.RecordData)
+	if err != nil {
+		return nil, err
+	}
+
+	req, err := http.NewRequestWithContext(ctx, method, url.String(), bytes.NewReader(jsonData))
+	if err != nil {
+		return nil, err
+	}
+
+	return req, nil
+}
+
+func (c *Connector) parseWriteResponse(
+	ctx context.Context,
+	params common.WriteParams,
+	request *http.Request,
+	response *common.JSONHTTPResponse,
+) (*common.WriteResult, error) {
+	body, ok := response.Body()
+	if !ok {
+		return &common.WriteResult{Success: true}, nil
+	}
+
+	recordID, err := jsonquery.New(body).StringOptional("id")
+	if err != nil {
+		return nil, err
+	}
+
+	resp, err := jsonquery.Convertor.ObjectToMap(body)
+	if err != nil {
+		return nil, err
+	}
+
+	id := ""
+	if recordID != nil {
+		id = *recordID
+	}
+
+	return &common.WriteResult{
+		RecordId: id,
+		Success:  true,
+		Data:     resp,
+	}, nil
+}

providers/paypal/support.go

@@ -0,0 +1,48 @@
+package paypal
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/amp-labs/connectors/common"
+	"github.com/amp-labs/connectors/internal/components"
+)
+
+func supportedOperations() components.EndpointRegistryInput {
+	readObjects := []string{
+		"balances",
+		"disputes",
+		"invoices",
+		"plans",
+		"products",
+		"templates",
+		"transactions",
+		"web-profiles",
+		"webhooks",
+		"webhooks-event-types",
+		"webhooks-events",
+	}
+
+	writeObjects := []string{
+		"invoices",
+		"orders",
+		"plans",
+		"products",
+		"templates",
+		"web-profiles",
+		"webhooks",
+	}
+
+	return components.EndpointRegistryInput{
+		common.ModuleRoot: {
+			{
+				Endpoint: fmt.Sprintf("{%s}", strings.Join(readObjects, ",")),
+				Support:  components.ReadSupport,
+			},
+			{
+				Endpoint: fmt.Sprintf("{%s}", strings.Join(writeObjects, ",")),
+				Support:  components.WriteSupport,
+			},
+		},
+	}
+}