Method WatchGit

codersdk/workspacesdk/agentconn.go:557–595

WatchGit opens a bidirectional WebSocket to the agent's git watch endpoint and returns a stream for sending subscribe/refresh messages and receiving change notifications.

(ctx context.Context, logger slog.Logger, chatID uuid.UUID)

// endpoint and returns a stream for sending subscribe/refresh messages
// and receiving change notifications.
func (c *agentConn) WatchGit(ctx context.Context, logger slog.Logger, chatID uuid.UUID) (*wsjson.Stream[codersdk.WorkspaceAgentGitServerMessage, codersdk.WorkspaceAgentGitClientMessage], error) {
	ctx, span := tracing.StartSpan(ctx)
	defer span.End()

	host := net.JoinHostPort(c.agentAddress().String(), strconv.Itoa(AgentHTTPAPIServerPort))

	dialOpts := &websocket.DialOptions{
		HTTPClient:      c.apiClient(),
		CompressionMode: websocket.CompressionNoContextTakeover,
	}
	c.headersMu.RLock()
	if len(c.extraHeaders) > 0 {
		dialOpts.HTTPHeader = c.extraHeaders.Clone()
	}
	c.headersMu.RUnlock()

	url := fmt.Sprintf("http://%s%s", host, "/api/v0/git/watch")
	if chatID != uuid.Nil {
		url += "?chat_id=" + chatID.String()
	}

	conn, res, err := websocket.Dial(ctx, url, dialOpts)
	if err != nil {
		if res == nil {
			return nil, err
		}
		return nil, codersdk.ReadBodyAsError(res)
	}
	if res != nil && res.Body != nil {
		defer res.Body.Close()
	}

	conn.SetReadLimit(1 << 22) // 4MiB

	return wsjson.NewStream[
		codersdk.WorkspaceAgentGitServerMessage,
		codersdk.WorkspaceAgentGitClientMessage,
	](conn, websocket.MessageText, websocket.MessageText, logger), nil
}

// ConnectDesktopVNC opens a WebSocket to the agent's desktop endpoint and
// returns a net.Conn carrying raw RFB (VNC) binary data.