@@ -367,6 +367,7 @@ func (api *API) workspaceAgentStartupLogs(rw http.ResponseWriter, r *http.Reques
367
367
// This mostly copies how provisioner job logs are streamed!
368
368
var (
369
369
ctx = r .Context ()
370
+ actor , _ = dbauthz .ActorFromContext (ctx )
370
371
workspaceAgent = httpmw .WorkspaceAgentParam (r )
371
372
workspace = httpmw .WorkspaceParam (r )
372
373
logger = api .Logger .With (slog .F ("workspace_agent_id" , workspaceAgent .ID ))
@@ -475,7 +476,7 @@ func (api *API) workspaceAgentStartupLogs(rw http.ResponseWriter, r *http.Reques
475
476
}
476
477
477
478
if jlMsg .CreatedAfter != 0 {
478
- logs , err := api .Database .GetWorkspaceAgentStartupLogsAfter (ctx , database.GetWorkspaceAgentStartupLogsAfterParams {
479
+ logs , err := api .Database .GetWorkspaceAgentStartupLogsAfter (dbauthz . As ( ctx , actor ) , database.GetWorkspaceAgentStartupLogsAfterParams {
479
480
AgentID : workspaceAgent .ID ,
480
481
CreatedAfter : jlMsg .CreatedAfter ,
481
482
})
@@ -488,7 +489,7 @@ func (api *API) workspaceAgentStartupLogs(rw http.ResponseWriter, r *http.Reques
488
489
489
490
if jlMsg .EndOfLogs {
490
491
endOfLogs .Store (true )
491
- logs , err := api .Database .GetWorkspaceAgentStartupLogsAfter (ctx , database.GetWorkspaceAgentStartupLogsAfterParams {
492
+ logs , err := api .Database .GetWorkspaceAgentStartupLogsAfter (dbauthz . As ( ctx , actor ) , database.GetWorkspaceAgentStartupLogsAfterParams {
492
493
AgentID : workspaceAgent .ID ,
493
494
CreatedAfter : lastSentLogID .Load (),
494
495
})
0 commit comments