Skip to content

Commit 14bd489

Browse files
authored
feat: add queries for PGCoord HTMLDebug (#10913)
Adds queries for implementing HTMLDebug on the new PGCoordinator
1 parent 3416f6d commit 14bd489

File tree

7 files changed

+208
-0
lines changed

7 files changed

+208
-0
lines changed

coderd/database/dbauthz/dbauthz.go

+21
Original file line numberDiff line numberDiff line change
@@ -881,6 +881,27 @@ func (q *querier) GetAllTailnetClients(ctx context.Context) ([]database.GetAllTa
881881
return q.db.GetAllTailnetClients(ctx)
882882
}
883883

884+
func (q *querier) GetAllTailnetCoordinators(ctx context.Context) ([]database.TailnetCoordinator, error) {
885+
if err := q.authorizeContext(ctx, rbac.ActionRead, rbac.ResourceTailnetCoordinator); err != nil {
886+
return nil, err
887+
}
888+
return q.db.GetAllTailnetCoordinators(ctx)
889+
}
890+
891+
func (q *querier) GetAllTailnetPeers(ctx context.Context) ([]database.TailnetPeer, error) {
892+
if err := q.authorizeContext(ctx, rbac.ActionRead, rbac.ResourceTailnetCoordinator); err != nil {
893+
return nil, err
894+
}
895+
return q.db.GetAllTailnetPeers(ctx)
896+
}
897+
898+
func (q *querier) GetAllTailnetTunnels(ctx context.Context) ([]database.TailnetTunnel, error) {
899+
if err := q.authorizeContext(ctx, rbac.ActionRead, rbac.ResourceTailnetCoordinator); err != nil {
900+
return nil, err
901+
}
902+
return q.db.GetAllTailnetTunnels(ctx)
903+
}
904+
884905
func (q *querier) GetAppSecurityKey(ctx context.Context) (string, error) {
885906
// No authz checks
886907
return q.db.GetAppSecurityKey(ctx)

coderd/database/dbmem/dbmem.go

+12
Original file line numberDiff line numberDiff line change
@@ -1276,6 +1276,18 @@ func (*FakeQuerier) GetAllTailnetClients(_ context.Context) ([]database.GetAllTa
12761276
return nil, ErrUnimplemented
12771277
}
12781278

1279+
func (*FakeQuerier) GetAllTailnetCoordinators(context.Context) ([]database.TailnetCoordinator, error) {
1280+
return nil, ErrUnimplemented
1281+
}
1282+
1283+
func (*FakeQuerier) GetAllTailnetPeers(context.Context) ([]database.TailnetPeer, error) {
1284+
return nil, ErrUnimplemented
1285+
}
1286+
1287+
func (*FakeQuerier) GetAllTailnetTunnels(context.Context) ([]database.TailnetTunnel, error) {
1288+
return nil, ErrUnimplemented
1289+
}
1290+
12791291
func (q *FakeQuerier) GetAppSecurityKey(_ context.Context) (string, error) {
12801292
q.mutex.RLock()
12811293
defer q.mutex.RUnlock()

coderd/database/dbmetrics/dbmetrics.go

+21
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

coderd/database/dbmock/dbmock.go

+45
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

coderd/database/querier.go

+4
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

coderd/database/queries.sql.go

+94
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

coderd/database/queries/tailnet.sql

+11
Original file line numberDiff line numberDiff line change
@@ -199,3 +199,14 @@ SELECT tailnet_tunnels.src_id as peer_id, tailnet_peers.coordinator_id, tailnet_
199199
FROM tailnet_tunnels
200200
INNER JOIN tailnet_peers ON tailnet_tunnels.src_id = tailnet_peers.id
201201
WHERE tailnet_tunnels.dst_id = $1;
202+
203+
-- For PG Coordinator HTMLDebug
204+
205+
-- name: GetAllTailnetCoordinators :many
206+
SELECT * FROM tailnet_coordinators;
207+
208+
-- name: GetAllTailnetPeers :many
209+
SELECT * FROM tailnet_peers;
210+
211+
-- name: GetAllTailnetTunnels :many
212+
SELECT * FROM tailnet_tunnels;

0 commit comments

Comments
 (0)