Jun 12, 2025 · Jun 4, 2025
diff --git a/coderd/inboxnotifications.go b/coderd/inboxnotifications.go
 defer encoder.Close(websocket.StatusNormalClosure)

 // Log the request immediately instead of after it completes.
 loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
 if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
 rl.WriteLog(ctx, http.StatusAccepted)
 }

 for {
 select {
diff --git a/coderd/provisionerjobs.go b/coderd/provisionerjobs.go
 }

 // Log the request immediately instead of after it completes.
 loggermw.RequestLoggerFromContext(f.ctx).WriteLog(f.ctx, http.StatusAccepted)
 if rl := loggermw.RequestLoggerFromContext(f.ctx); rl != nil {
 rl.WriteLog(f.ctx, http.StatusAccepted)
 }

 // no need to wait if the job is done
 if f.complete {
diff --git a/coderd/workspaceagents.go b/coderd/workspaceagents.go
 defer t.Stop()

 // Log the request immediately instead of after it completes.
 loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
 if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
 rl.WriteLog(ctx, http.StatusAccepted)
 }

 go func() {
 defer func() {
 defer encoder.Close(websocket.StatusGoingAway)

 // Log the request immediately instead of after it completes.
 loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
 if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
 rl.WriteLog(ctx, http.StatusAccepted)
 }

 go func(ctx context.Context) {
 // TODO(mafredri): Is this too frequent? Use separate ping disconnect timeout?
 defer sendTicker.Stop()

 // Log the request immediately instead of after it completes.
 loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
 if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
 rl.WriteLog(ctx, http.StatusAccepted)
 }

 // Send initial metadata.
 sendMetadata()
diff --git a/enterprise/coderd/provisionerdaemons.go b/enterprise/coderd/provisionerdaemons.go
 })

 // Log the request immediately instead of after it completes.
 loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
 if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
 rl.WriteLog(ctx, http.StatusAccepted)
 }

 err = server.Serve(ctx, session)
 srvCancel()
Original file line number	Diff line number	Diff line change
Expand Up		@@ -221,7 +221,9 @@ func (api API) watchInboxNotifications(rw http.ResponseWriter, r http.Request)
		defer encoder.Close(websocket.StatusNormalClosure)

		// Log the request immediately instead of after it completes.
		loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
		if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
		rl.WriteLog(ctx, http.StatusAccepted)
		}

		for {
		select {
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -557,7 +557,9 @@ func (f *logFollower) follow() {
		}

		// Log the request immediately instead of after it completes.
		loggermw.RequestLoggerFromContext(f.ctx).WriteLog(f.ctx, http.StatusAccepted)
		if rl := loggermw.RequestLoggerFromContext(f.ctx); rl != nil {
		rl.WriteLog(f.ctx, http.StatusAccepted)
		}

		// no need to wait if the job is done
		if f.complete {
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -578,7 +578,9 @@ func (api API) workspaceAgentLogs(rw http.ResponseWriter, r http.Request) {
		defer t.Stop()

		// Log the request immediately instead of after it completes.
		loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
		if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
		rl.WriteLog(ctx, http.StatusAccepted)
		}

		go func() {
		defer func() {
Expand DownExpand Up		@@ -1047,7 +1049,9 @@ func (api API) derpMapUpdates(rw http.ResponseWriter, r http.Request) {
		defer encoder.Close(websocket.StatusGoingAway)

		// Log the request immediately instead of after it completes.
		loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
		if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
		rl.WriteLog(ctx, http.StatusAccepted)
		}

		go func(ctx context.Context) {
		// TODO(mafredri): Is this too frequent? Use separate ping disconnect timeout?
Expand DownExpand Up		@@ -1501,7 +1505,9 @@ func (api *API) watchWorkspaceAgentMetadata(
		defer sendTicker.Stop()

		// Log the request immediately instead of after it completes.
		loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
		if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
		rl.WriteLog(ctx, http.StatusAccepted)
		}

		// Send initial metadata.
		sendMetadata()
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -384,7 +384,9 @@ func (api API) provisionerDaemonServe(rw http.ResponseWriter, r http.Request)
		})

		// Log the request immediately instead of after it completes.
		loggermw.RequestLoggerFromContext(ctx).WriteLog(ctx, http.StatusAccepted)
		if rl := loggermw.RequestLoggerFromContext(ctx); rl != nil {
		rl.WriteLog(ctx, http.StatusAccepted)
		}

		err = server.Serve(ctx, session)
		srvCancel()
Expand Down