Commite4b6074

committed

implement dbmem and dbauthz

1 parent26c7b81 commite4b6074Copy full SHA for e4b6074

File tree

+24

-0

lines changed

+24

-0

lines changed

Lines changed: 8 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -2660,6 +2660,14 @@ func (q *querier) GetWorkspaceAgentByInstanceID(ctx context.Context, authInstanc`
`2660`	`2660`	`returnagent,nil`
`2661`	`2661`	`}`
`2662`	`2662`
	`2663`	`+func (q*querier)GetWorkspaceAgentDevcontainersByWorkspaceAgentID(ctx context.Context,workspaceAgentID uuid.UUID) ([]database.WorkspaceAgentDevcontainer,error) {`
	`2664`	`+_,err:=q.GetWorkspaceAgentByID(ctx,workspaceAgentID)`
	`2665`	`+iferr!=nil {`
	`2666`	`+returnnil,err`
	`2667`	`+}`
	`2668`	`+returnq.db.GetWorkspaceAgentDevcontainersByWorkspaceAgentID(ctx,workspaceAgentID)`
	`2669`	`+}`
	`2670`	`+`
`2663`	`2671`	`func (q*querier)GetWorkspaceAgentLifecycleStateByID(ctx context.Context,id uuid.UUID) (database.GetWorkspaceAgentLifecycleStateByIDRow,error) {`
`2664`	`2672`	`_,err:=q.GetWorkspaceAgentByID(ctx,id)`
`2665`	`2673`	`iferr!=nil {`

Lines changed: 16 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -6697,6 +6697,22 @@ func (q *FakeQuerier) GetWorkspaceAgentByInstanceID(_ context.Context, instanceI`
`6697`	`6697`	`return database.WorkspaceAgent{},sql.ErrNoRows`
`6698`	`6698`	`}`
`6699`	`6699`
	`6700`	`+func (q*FakeQuerier)GetWorkspaceAgentDevcontainersByWorkspaceAgentID(_ context.Context,workspaceAgentID uuid.UUID) ([]database.WorkspaceAgentDevcontainer,error) {`
	`6701`	`+q.mutex.RLock()`
	`6702`	`+deferq.mutex.RUnlock()`
	`6703`	`+`
	`6704`	`+devcontainers:=make([]database.WorkspaceAgentDevcontainer,0)`
	`6705`	`+for_,devcontainer:=rangeq.workspaceAgentDevcontainers {`
	`6706`	`+ifdevcontainer.WorkspaceAgentID==workspaceAgentID {`
	`6707`	`+devcontainers=append(devcontainers,devcontainer)`
	`6708`	`+}`
	`6709`	`+}`
	`6710`	`+iflen(devcontainers)==0 {`
	`6711`	`+returnnil,sql.ErrNoRows`
	`6712`	`+}`
	`6713`	`+returndevcontainers,nil`
	`6714`	`+}`
	`6715`	`+`
`6700`	`6716`	`func (q*FakeQuerier)GetWorkspaceAgentLifecycleStateByID(ctx context.Context,id uuid.UUID) (database.GetWorkspaceAgentLifecycleStateByIDRow,error) {`
`6701`	`6717`	`q.mutex.RLock()`
`6702`	`6718`	`deferq.mutex.RUnlock()`

Comments

(0)