Commitd8cd584

committed

review

1 parent4fb878d commitd8cd584Copy full SHA for d8cd584

File tree

-7

lines changed

-7

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -144,7 +144,7 @@ func (a LogsAPI) BatchCreateLogs(ctx context.Context, req agentproto.BatchCrea`
`144`	`144`	`ifworkspaceAgent.LogsLength==0&&a.PublishWorkspaceUpdateFn!=nil {`
`145`	`145`	`// If these are the first logs being appended, we publish a UI update`
`146`	`146`	`// to notify the UI that logs are now available.`
`147`		`-err=a.PublishWorkspaceUpdateFn(ctx,&workspaceAgent,wspubsub.WorkspaceEventKindAgentLogsUpdate)`
	`147`	`+err=a.PublishWorkspaceUpdateFn(ctx,&workspaceAgent,wspubsub.WorkspaceEventKindAgentFirstLogs)`
`148`	`148`	`iferr!=nil {`
`149`	`149`	`returnnil,xerrors.Errorf("publish workspace update: %w",err)`
`150`	`150`	`}`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -252,7 +252,7 @@ func (api API) patchWorkspaceAgentLogs(rw http.ResponseWriter, r http.Request)`
`252`	`252`	`}`
`253`	`253`
`254`	`254`	`api.publishWorkspaceUpdate(ctx,workspace.Workspace.OwnerID, wspubsub.WorkspaceEvent{`
`255`		`-Kind:wspubsub.WorkspaceEventKindAgentLogsUpdate,`
	`255`	`+Kind:wspubsub.WorkspaceEventKindAgentLogsOverflow,`
`256`	`256`	`WorkspaceID:workspace.Workspace.ID,`
`257`	`257`	`AgentID:&workspaceAgent.ID,`
`258`	`258`	`})`
`@@ -284,7 +284,7 @@ func (api API) patchWorkspaceAgentLogs(rw http.ResponseWriter, r http.Request)`
`284`	`284`	`}`
`285`	`285`
`286`	`286`	`api.publishWorkspaceUpdate(ctx,workspace.Workspace.OwnerID, wspubsub.WorkspaceEvent{`
`287`		`-Kind:wspubsub.WorkspaceEventKindAgentLogsUpdate,`
	`287`	`+Kind:wspubsub.WorkspaceEventKindAgentFirstLogs,`
`288`	`288`	`WorkspaceID:workspace.Workspace.ID,`
`289`	`289`	`AgentID:&workspaceAgent.ID,`
`290`	`290`	`})`

Lines changed: 1 addition & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -1724,9 +1724,7 @@ func (api API) watchWorkspace(rw http.ResponseWriter, r http.Request) {`
`1724`	`1724`	`defercancelWorkspaceSubscribe()`
`1725`	`1725`
`1726`	`1726`	`// This is required to show whether the workspace is up-to-date.`
`1727`		`-cancelTemplateSubscribe,err:=api.Pubsub.Subscribe(watchTemplateChannel(workspace.TemplateID),func(ctx context.Context,msg []byte) {`
`1728`		`-sendUpdate(ctx,nil)`
`1729`		`-})`
	`1727`	`+cancelTemplateSubscribe,err:=api.Pubsub.Subscribe(watchTemplateChannel(workspace.TemplateID),sendUpdate)`
`1730`	`1728`	`iferr!=nil {`
`1731`	`1729`	`_=sendEvent(ctx, codersdk.ServerSentEvent{`
`1732`	`1730`	`Type:codersdk.ServerSentEventTypeError,`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -49,8 +49,8 @@ const (`
`49`	`49`	`WorkspaceEventKindAppHealthUpdateWorkspaceEventKind="app_health"`
`50`	`50`
`51`	`51`	`WorkspaceEventKindAgentLifecycleUpdateWorkspaceEventKind="agt_lifecycle_update"`
`52`		`-WorkspaceEventKindAgentLogsUpdateWorkspaceEventKind="agt_logs_update"`
`53`	`52`	`WorkspaceEventKindAgentConnectionUpdateWorkspaceEventKind="agt_connection_update"`
	`53`	`+WorkspaceEventKindAgentFirstLogsWorkspaceEventKind="agt_first_logs"`
`54`	`54`	`WorkspaceEventKindAgentLogsOverflowWorkspaceEventKind="agt_logs_overflow"`
`55`	`55`	`WorkspaceEventKindAgentTimeoutWorkspaceEventKind="agt_timeout"`
`56`	`56`	`)`

Comments

(0)