Skip to content

Commit 751b22f

Browse files
committed
fixup! add subscriber subsystem
1 parent bdd7ef1 commit 751b22f

File tree

3 files changed

+30
-35
lines changed

3 files changed

+30
-35
lines changed

coderd/database/dbauthz/dbauthz.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -685,6 +685,13 @@ func (q *querier) DeleteAPIKeysByUserID(ctx context.Context, userID uuid.UUID) e
685685
return q.db.DeleteAPIKeysByUserID(ctx, userID)
686686
}
687687

688+
func (q *querier) DeleteAllTailnetClientSubscriptions(ctx context.Context, arg database.DeleteAllTailnetClientSubscriptionsParams) error {
689+
if err := q.authorizeContext(ctx, rbac.ActionDelete, rbac.ResourceTailnetCoordinator); err != nil {
690+
return err
691+
}
692+
return q.db.DeleteAllTailnetClientSubscriptions(ctx, arg)
693+
}
694+
688695
func (q *querier) DeleteApplicationConnectAPIKeysByUserID(ctx context.Context, userID uuid.UUID) error {
689696
// TODO: This is not 100% correct because it omits apikey IDs.
690697
err := q.authorizeContext(ctx, rbac.ActionDelete,
@@ -781,13 +788,6 @@ func (q *querier) DeleteTailnetClientSubscription(ctx context.Context, arg datab
781788
return q.db.DeleteTailnetClientSubscription(ctx, arg)
782789
}
783790

784-
func (q *querier) DeleteAllTailnetClientSubscriptions(ctx context.Context, arg database.DeleteAllTailnetClientSubscriptionsParams) error {
785-
if err := q.authorizeContext(ctx, rbac.ActionDelete, rbac.ResourceTailnetCoordinator); err != nil {
786-
return err
787-
}
788-
return q.db.DeleteAllTailnetClientSubscriptions(ctx, arg)
789-
}
790-
791791
func (q *querier) GetAPIKeyByID(ctx context.Context, id string) (database.APIKey, error) {
792792
return fetch(q.log, q.auth, q.db.GetAPIKeyByID)(ctx, id)
793793
}

coderd/database/dbfake/dbfake.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -844,7 +844,7 @@ func (q *FakeQuerier) DeleteAPIKeysByUserID(_ context.Context, userID uuid.UUID)
844844
return nil
845845
}
846846

847-
func (q *FakeQuerier) DeleteAllTailnetClientSubscriptions(_ context.Context, arg database.DeleteAllTailnetClientSubscriptionsParams) error {
847+
func (*FakeQuerier) DeleteAllTailnetClientSubscriptions(_ context.Context, arg database.DeleteAllTailnetClientSubscriptionsParams) error {
848848
err := validateDatabaseType(arg)
849849
if err != nil {
850850
return err

coderd/database/dump.sql

Lines changed: 22 additions & 27 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)