[CON-3149] feat(clio): write functionality

providers/clio/connector.go

@@ -65,3 +65,33 @@ func (c *Connector) ListObjectMetadata(
 
 	return nil, common.ErrNotImplemented
 }
+
+func (c *Connector) Delete(
+	ctx context.Context,
+	params connectors.DeleteParams,
+) (*connectors.DeleteResult, error) {
+	if c.Grow != nil {
+		return c.Grow.Delete(ctx, params)
+	}
+
+	if c.Manage != nil {
+		return c.Manage.Delete(ctx, params)
+	}
+
+	return nil, common.ErrNotImplemented
+}
+
+func (c *Connector) Write(
+	ctx context.Context,
+	params connectors.WriteParams,
+) (*connectors.WriteResult, error) {
+	if c.Grow != nil {
+		return c.Grow.Write(ctx, params)
+	}
+
+	if c.Manage != nil {
+		return c.Manage.Write(ctx, params)
+	}
+
+	return nil, common.ErrNotImplemented
+}

providers/clio/internal/grow/adapter.go

@@ -3,15 +3,19 @@ package grow
 import (
 	"github.com/amp-labs/connectors/common"
 	"github.com/amp-labs/connectors/internal/components"
+	"github.com/amp-labs/connectors/internal/components/deleter"
+	"github.com/amp-labs/connectors/internal/components/operations"
 	"github.com/amp-labs/connectors/internal/components/schema"
+	"github.com/amp-labs/connectors/internal/components/writer"
 	"github.com/amp-labs/connectors/providers"
 )
 
-// Adapter exposes metadata operations for the Clio Grow module.
 type Adapter struct {
 	*components.Connector
 	common.RequireAuthenticatedClient
 	components.SchemaProvider
+	components.Writer
+	components.Deleter
 }
 
 func NewAdapter(params common.ConnectorParams) (*Adapter, error) {
@@ -28,5 +32,28 @@ func constructor(base *components.Connector) (*Adapter, error) {
 		Schemas,
 	)
 
+	registry := components.NewEmptyEndpointRegistry()
+	adapter.Writer = writer.NewHTTPWriter(
+		adapter.HTTPClient().Client,
+		registry,
+		adapter.ProviderContext.Module(),
+		operations.WriteHandlers{
+			BuildRequest:  adapter.buildWriteRequest,
+			ParseResponse: adapter.parseWriteResponse,
+			ErrorHandler:  common.InterpretError,
+		},
+	)
+
+	adapter.Deleter = deleter.NewHTTPDeleter(
+		adapter.HTTPClient().Client,
+		registry,
+		adapter.ProviderContext.Module(),
+		operations.DeleteHandlers{
+			BuildRequest:  adapter.buildDeleteRequest,
+			ParseResponse: adapter.parseDeleteResponse,
+			ErrorHandler:  common.InterpretError,
+		},
+	)
+
 	return adapter, nil
 }

providers/clio/internal/grow/delete.go

@@ -0,0 +1,25 @@
+package grow
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/amp-labs/connectors/common"
+	"github.com/amp-labs/connectors/providers/clio/internal/shared"
+)
+
+func (c *Adapter) buildDeleteRequest(ctx context.Context, params common.DeleteParams) (*http.Request, error) {
+	return shared.BuildDeleteRequest(ctx, shared.BuildDeleteParams{
+		BaseURL:     c.ProviderInfo().BaseURL,
+		APIPath:     clioGrowAPIPath,
+		Module:      c.Module(),
+		Params:      params,
+		FindURLPath: Schemas.FindURLPath,
+	})
+}
+
+func (c *Adapter) parseDeleteResponse(_ context.Context, params common.DeleteParams,
+	_ *http.Request, resp *common.JSONHTTPResponse,
+) (*common.DeleteResult, error) {
+	return shared.ParseDeleteResponse(params, resp)
+}

providers/clio/internal/grow/write.go

@@ -0,0 +1,27 @@
+package grow
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/amp-labs/connectors/common"
+	"github.com/amp-labs/connectors/providers/clio/internal/shared"
+)
+
+const clioGrowAPIPath = "grow"
+
+func (c *Adapter) buildWriteRequest(ctx context.Context, params common.WriteParams) (*http.Request, error) {
+	return shared.BuildWriteRequest(ctx, shared.BuildWriteParams{
+		BaseURL:     c.ProviderInfo().BaseURL,
+		APIPath:     clioGrowAPIPath,
+		Module:      c.Module(),
+		Params:      params,
+		FindURLPath: Schemas.FindURLPath,
+	})
+}
+
+func (c *Adapter) parseWriteResponse(_ context.Context, params common.WriteParams,
+	_ *http.Request, resp *common.JSONHTTPResponse,
+) (*common.WriteResult, error) {
+	return shared.ParseWriteResponse(params, resp)
+}

providers/clio/internal/manage/adapter.go

@@ -3,15 +3,19 @@ package manage
 import (
 	"github.com/amp-labs/connectors/common"
 	"github.com/amp-labs/connectors/internal/components"
+	"github.com/amp-labs/connectors/internal/components/deleter"
+	"github.com/amp-labs/connectors/internal/components/operations"
 	"github.com/amp-labs/connectors/internal/components/schema"
+	"github.com/amp-labs/connectors/internal/components/writer"
 	"github.com/amp-labs/connectors/providers"
 )
 
-// Adapter exposes metadata operations for the Clio Manage module.
 type Adapter struct {
 	*components.Connector
 	common.RequireAuthenticatedClient
 	components.SchemaProvider
+	components.Writer
+	components.Deleter
 }
 
 func NewAdapter(params common.ConnectorParams) (*Adapter, error) {
@@ -28,5 +32,28 @@ func constructor(base *components.Connector) (*Adapter, error) {
 		Schemas,
 	)
 
+	registry := components.NewEmptyEndpointRegistry()
+	adapter.Writer = writer.NewHTTPWriter(
+		adapter.HTTPClient().Client,
+		registry,
+		adapter.ProviderContext.Module(),
+		operations.WriteHandlers{
+			BuildRequest:  adapter.buildWriteRequest,
+			ParseResponse: adapter.parseWriteResponse,
+			ErrorHandler:  common.InterpretError,
+		},
+	)
+
+	adapter.Deleter = deleter.NewHTTPDeleter(
+		adapter.HTTPClient().Client,
+		registry,
+		adapter.ProviderContext.Module(),
+		operations.DeleteHandlers{
+			BuildRequest:  adapter.buildDeleteRequest,
+			ParseResponse: adapter.parseDeleteResponse,
+			ErrorHandler:  common.InterpretError,
+		},
+	)
+
 	return adapter, nil
 }

providers/clio/internal/manage/delete.go

@@ -0,0 +1,25 @@
+package manage
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/amp-labs/connectors/common"
+	"github.com/amp-labs/connectors/providers/clio/internal/shared"
+)
+
+func (c *Adapter) buildDeleteRequest(ctx context.Context, params common.DeleteParams) (*http.Request, error) {
+	return shared.BuildDeleteRequest(ctx, shared.BuildDeleteParams{
+		BaseURL:     c.ProviderInfo().BaseURL,
+		APIPath:     clioManageAPIPath,
+		Module:      c.Module(),
+		Params:      params,
+		FindURLPath: Schemas.FindURLPath,
+	})
+}
+
+func (c *Adapter) parseDeleteResponse(_ context.Context, params common.DeleteParams,
+	_ *http.Request, resp *common.JSONHTTPResponse,
+) (*common.DeleteResult, error) {
+	return shared.ParseDeleteResponse(params, resp)
+}

providers/clio/internal/manage/test/write-groups-create.json

@@ -0,0 +1,9 @@
+{
+  "data": {
+    "id": 884001,
+    "name": "Scout Unit Group",
+    "type": "AdhocGroup",
+    "etag": "\"etag-create\"",
+    "updated_at": "2026-05-04T12:00:00Z"
+  }
+}

providers/clio/internal/manage/test/write-groups-update.json

@@ -0,0 +1,9 @@
+{
+  "data": {
+    "id": 884001,
+    "name": "Scout Unit Group Updated",
+    "type": "AdhocGroup",
+    "etag": "\"etag-update\"",
+    "updated_at": "2026-05-04T12:05:00Z"
+  }
+}

providers/clio/internal/manage/write.go

@@ -0,0 +1,27 @@
+package manage
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/amp-labs/connectors/common"
+	"github.com/amp-labs/connectors/providers/clio/internal/shared"
+)
+
+const clioManageAPIPath = "api/v4"
+
+func (c *Adapter) buildWriteRequest(ctx context.Context, params common.WriteParams) (*http.Request, error) {
+	return shared.BuildWriteRequest(ctx, shared.BuildWriteParams{
+		BaseURL:     c.ProviderInfo().BaseURL,
+		APIPath:     clioManageAPIPath,
+		Module:      c.Module(),
+		Params:      params,
+		FindURLPath: Schemas.FindURLPath,
+	})
+}
+
+func (c *Adapter) parseWriteResponse(_ context.Context, params common.WriteParams,
+	_ *http.Request, resp *common.JSONHTTPResponse,
+) (*common.WriteResult, error) {
+	return shared.ParseWriteResponse(params, resp)
+}

providers/clio/internal/manage/write_test.go

@@ -0,0 +1,114 @@
+package manage
+
+import (
+	"net/http"
+	"testing"
+
+	"github.com/amp-labs/connectors"
+	"github.com/amp-labs/connectors/common"
+	"github.com/amp-labs/connectors/providers"
+	"github.com/amp-labs/connectors/test/utils/mockutils"
+	"github.com/amp-labs/connectors/test/utils/mockutils/mockcond"
+	"github.com/amp-labs/connectors/test/utils/mockutils/mockserver"
+	"github.com/amp-labs/connectors/test/utils/testroutines"
+	"github.com/amp-labs/connectors/test/utils/testutils"
+)
+
+func TestWriteGroups(t *testing.T) {
+	t.Parallel()
+
+	responseCreate := testutils.DataFromFile(t, "write-groups-create.json")
+	responseUpdate := testutils.DataFromFile(t, "write-groups-update.json")
+
+	tests := []testroutines.Write{
+		{
+			Name: "Create group successfully",
+			Input: common.WriteParams{
+				ObjectName: "groups",
+				RecordData: map[string]any{
+					"name": "Scout Unit Group",
+					"type": "AdhocGroup",
+				},
+			},
+			Server: mockserver.Conditional{
+				Setup: mockserver.ContentJSON(),
+				If: mockcond.And{
+					mockcond.Method(http.MethodPost),
+					mockcond.Path("/api/v4/groups.json"),
+					mockcond.Body(`{"data":{"name":"Scout Unit Group","type":"AdhocGroup"}}`),
+				},
+				Then: mockserver.Response(http.StatusOK, responseCreate),
+			}.Server(),
+			Comparator: testroutines.ComparatorSubsetWrite,
+			Expected: &common.WriteResult{
+				Success:  true,
+				RecordId: "884001",
+				Data: map[string]any{
+					"id":   float64(884001),
+					"name": "Scout Unit Group",
+					"type": "AdhocGroup",
+				},
+			},
+			ExpectedErrs: nil,
+		},
+		{
+			Name: "Update group successfully",
+			Input: common.WriteParams{
+				ObjectName: "groups",
+				RecordId:   "884001",
+				RecordData: map[string]any{
+					"name": "Scout Unit Group Updated",
+					"type": "AdhocGroup",
+				},
+			},
+			Server: mockserver.Conditional{
+				Setup: mockserver.ContentJSON(),
+				If: mockcond.And{
+					mockcond.Method(http.MethodPatch),
+					mockcond.Path("/api/v4/groups/884001.json"),
+					mockcond.Body(`{"data":{"name":"Scout Unit Group Updated","type":"AdhocGroup"}}`),
+				},
+				Then: mockserver.Response(http.StatusOK, responseUpdate),
+			}.Server(),
+			Comparator: testroutines.ComparatorSubsetWrite,
+			Expected: &common.WriteResult{
+				Success:  true,
+				RecordId: "884001",
+				Data: map[string]any{
+					"id":   float64(884001),
+					"name": "Scout Unit Group Updated",
+					"type": "AdhocGroup",
+				},
+			},
+			ExpectedErrs: nil,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.Name, func(t *testing.T) {
+			t.Parallel()
+
+			tt.Run(t, func() (connectors.WriteConnector, error) {
+				return newWriteTestAdapter(tt.Server.URL)
+			})
+		})
+	}
+}
+
+func newWriteTestAdapter(serverURL string) (*Adapter, error) {
+	adapter, err := NewAdapter(common.ConnectorParams{
+		Module:              providers.ModuleClioManage,
+		AuthenticatedClient: mockutils.NewClient(),
+		Workspace:           "app.clio.com",
+		Metadata: map[string]string{
+			"region": "",
+		},
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	adapter.SetUnitTestMockServerBaseURL(serverURL)
+
+	return adapter, nil
+}