remove support of Synchronize File Shares integration with Docker Desktop

Signed-off-by: Guillaume Lours <[email protected]>

Author: glours

internal/desktop/client.go

@@ -17,10 +17,8 @@
 package desktop
 
 import (
-	"bytes"
 	"context"
 	"encoding/json"
-	"errors"
 	"fmt"
 	"io"
 	"net"
@@ -29,7 +27,6 @@ import (
 
 	"github.com/docker/compose/v2/internal"
 	"github.com/docker/compose/v2/internal/memnet"
-	"github.com/r3labs/sse"
 	"go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
 )
 
@@ -130,212 +127,6 @@ func (c *Client) FeatureFlags(ctx context.Context) (FeatureFlagResponse, error)
 	return ret, nil
 }
 
-type GetFileSharesConfigResponse struct {
-	Active  bool `json:"active"`
-	Compose struct {
-		ManageBindMounts bool `json:"manageBindMounts"`
-	}
-}
-
-func (c *Client) GetFileSharesConfig(ctx context.Context) (*GetFileSharesConfigResponse, error) {
-	req, err := c.newRequest(ctx, http.MethodGet, "/mutagen/file-shares/config", http.NoBody)
-	if err != nil {
-		return nil, err
-	}
-
-	resp, err := c.client.Do(req)
-	if err != nil {
-		return nil, err
-	}
-	defer func() {
-		_ = resp.Body.Close()
-	}()
-
-	if resp.StatusCode != http.StatusOK {
-		return nil, newHTTPStatusCodeError(resp)
-	}
-
-	var ret GetFileSharesConfigResponse
-	if err := json.NewDecoder(resp.Body).Decode(&ret); err != nil {
-		return nil, err
-	}
-	return &ret, nil
-}
-
-type CreateFileShareRequest struct {
-	HostPath string            `json:"hostPath"`
-	Labels   map[string]string `json:"labels,omitempty"`
-}
-
-type CreateFileShareResponse struct {
-	FileShareID string `json:"fileShareID"`
-}
-
-func (c *Client) CreateFileShare(ctx context.Context, r CreateFileShareRequest) (*CreateFileShareResponse, error) {
-	rawBody, err := json.Marshal(r)
-	if err != nil {
-		return nil, fmt.Errorf("failed to marshal request: %w", err)
-	}
-
-	req, err := c.newRequest(ctx, http.MethodPost, "/mutagen/file-shares", bytes.NewReader(rawBody))
-	if err != nil {
-		return nil, err
-	}
-	req.Header.Set("Content-Type", "application/json")
-
-	resp, err := c.client.Do(req)
-	if err != nil {
-		return nil, err
-	}
-	defer func() {
-		_ = resp.Body.Close()
-	}()
-
-	if resp.StatusCode != http.StatusOK {
-		errBody, _ := io.ReadAll(resp.Body)
-		return nil, fmt.Errorf("unexpected status code %d: %s", resp.StatusCode, string(errBody))
-	}
-
-	var ret CreateFileShareResponse
-	if err := json.NewDecoder(resp.Body).Decode(&ret); err != nil {
-		return nil, err
-	}
-	return &ret, nil
-}
-
-type FileShareReceiverState struct {
-	TotalReceivedSize uint64 `json:"totalReceivedSize"`
-}
-
-type FileShareEndpoint struct {
-	Path            string                  `json:"path"`
-	TotalFileSize   uint64                  `json:"totalFileSize,omitempty"`
-	StagingProgress *FileShareReceiverState `json:"stagingProgress"`
-}
-
-type FileShareSession struct {
-	SessionID string            `json:"identifier"`
-	Alpha     FileShareEndpoint `json:"alpha"`
-	Beta      FileShareEndpoint `json:"beta"`
-	Labels    map[string]string `json:"labels"`
-	Status    string            `json:"status"`
-}
-
-func (c *Client) ListFileShares(ctx context.Context) ([]FileShareSession, error) {
-	req, err := c.newRequest(ctx, http.MethodGet, "/mutagen/file-shares", http.NoBody)
-	if err != nil {
-		return nil, err
-	}
-
-	resp, err := c.client.Do(req)
-	if err != nil {
-		return nil, err
-	}
-	defer func() {
-		_ = resp.Body.Close()
-	}()
-
-	if resp.StatusCode != http.StatusOK {
-		return nil, newHTTPStatusCodeError(resp)
-	}
-
-	var ret []FileShareSession
-	if err := json.NewDecoder(resp.Body).Decode(&ret); err != nil {
-		return nil, err
-	}
-	return ret, nil
-}
-
-func (c *Client) DeleteFileShare(ctx context.Context, id string) error {
-	req, err := c.newRequest(ctx, http.MethodDelete, "/mutagen/file-shares/"+id, http.NoBody)
-	if err != nil {
-		return err
-	}
-
-	resp, err := c.client.Do(req)
-	if err != nil {
-		return err
-	}
-	defer func() {
-		_ = resp.Body.Close()
-	}()
-
-	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
-		return newHTTPStatusCodeError(resp)
-	}
-	return nil
-}
-
-type EventMessage[T any] struct {
-	Value T
-	Error error
-}
-
-func newHTTPStatusCodeError(resp *http.Response) error {
-	r := io.LimitReader(resp.Body, 2048)
-	body, err := io.ReadAll(r)
-	if err != nil {
-		return fmt.Errorf("http status code %d", resp.StatusCode)
-	}
-	return fmt.Errorf("http status code %d: %s", resp.StatusCode, string(body))
-}
-
-func (c *Client) StreamFileShares(ctx context.Context) (<-chan EventMessage[[]FileShareSession], error) {
-	req, err := c.newRequest(ctx, http.MethodGet, "/mutagen/file-shares/stream", http.NoBody)
-	if err != nil {
-		return nil, err
-	}
-
-	resp, err := c.client.Do(req)
-	if err != nil {
-		return nil, err
-	}
-
-	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
-		_ = resp.Body.Close()
-		return nil, newHTTPStatusCodeError(resp)
-	}
-
-	events := make(chan EventMessage[[]FileShareSession])
-	go func(ctx context.Context) {
-		defer func() {
-			_ = resp.Body.Close()
-			close(events)
-		}()
-		if err := readEvents(ctx, resp.Body, events); err != nil {
-			select {
-			case <-ctx.Done():
-			case events <- EventMessage[[]FileShareSession]{Error: err}:
-			}
-		}
-	}(ctx)
-	return events, nil
-}
-
-func readEvents[T any](ctx context.Context, r io.Reader, events chan<- EventMessage[T]) error {
-	eventReader := sse.NewEventStreamReader(r)
-	for {
-		msg, err := eventReader.ReadEvent()
-		if errors.Is(err, io.EOF) {
-			return nil
-		} else if err != nil {
-			return fmt.Errorf("reading events: %w", err)
-		}
-		msg = bytes.TrimPrefix(msg, []byte("data: "))
-
-		var event T
-		if err := json.Unmarshal(msg, &event); err != nil {
-			return err
-		}
-		select {
-		case <-ctx.Done():
-			return context.Cause(ctx)
-		case events <- EventMessage[T]{Value: event}:
-			// event was sent to channel, read next
-		}
-	}
-}
-
 func (c *Client) newRequest(ctx context.Context, method, path string, body io.Reader) (*http.Request, error) {
 	req, err := http.NewRequestWithContext(ctx, method, backendURL(path), body)
 	if err != nil {