Skip to content

Commit 82192a7

Browse files
dannykoppingdannykopping
committed
WIP
Signed-off-by: Danny Kopping <danny@coder.com>
1 parent 47f8f5d commit 82192a7

19 files changed

+1180
-6
lines changed

‎coderd/apidoc/docs.go

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎coderd/apidoc/swagger.json

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎coderd/database/dbauthz/dbauthz.go

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -766,10 +766,18 @@ func (q *querier) customRoleEscalationCheck(ctx context.Context, actor rbac.Subj
766766
return nil
767767
}
768768

769+
func (q *querier) InsertNotificationMessage(ctx context.Context, arg database.InsertNotificationMessageParams) (database.NotificationMessage, error) {
770+
panic("not implemented")
771+
}
772+
769773
func (q *querier) AcquireLock(ctx context.Context, id int64) error {
770774
return q.db.AcquireLock(ctx, id)
771775
}
772776

777+
func (q *querier) AcquireNotificationMessages(ctx context.Context, arg database.AcquireNotificationMessagesParams) ([]database.NotificationMessage, error) {
778+
panic("not implemented")
779+
}
780+
773781
// TODO: We need to create a ProvisionerJob resource type
774782
func (q *querier) AcquireProvisionerJob(ctx context.Context, arg database.AcquireProvisionerJobParams) (database.ProvisionerJob, error) {
775783
// if err := q.authorizeContext(ctx, policy.ActionUpdate, rbac.ResourceSystem); err != nil {
@@ -963,6 +971,10 @@ func (q *querier) DeleteOAuth2ProviderAppTokensByAppAndUserID(ctx context.Contex
963971
return q.db.DeleteOAuth2ProviderAppTokensByAppAndUserID(ctx, arg)
964972
}
965973

974+
func (q *querier) DeleteOldNotificationMessages(ctx context.Context) error {
975+
panic("not implemented")
976+
}
977+
966978
func (q *querier) DeleteOldProvisionerDaemons(ctx context.Context) error {
967979
if err := q.authorizeContext(ctx, policy.ActionDelete, rbac.ResourceSystem); err != nil {
968980
return err
@@ -1057,6 +1069,10 @@ func (q *querier) DeleteWorkspaceAgentPortSharesByTemplate(ctx context.Context,
10571069
return q.db.DeleteWorkspaceAgentPortSharesByTemplate(ctx, templateID)
10581070
}
10591071

1072+
func (q *querier) EnqueueNotificationMessage(ctx context.Context, arg database.EnqueueNotificationMessageParams) (database.NotificationMessage, error) {
1073+
panic("not implemented")
1074+
}
1075+
10601076
func (q *querier) FavoriteWorkspace(ctx context.Context, id uuid.UUID) error {
10611077
fetch := func(ctx context.Context, id uuid.UUID) (database.Workspace, error) {
10621078
return q.db.GetWorkspaceByID(ctx, id)
@@ -2418,6 +2434,10 @@ func (q *querier) InsertMissingGroups(ctx context.Context, arg database.InsertMi
24182434
return q.db.InsertMissingGroups(ctx, arg)
24192435
}
24202436

2437+
func (q *querier) InsertNotificationTemplate(ctx context.Context, arg database.InsertNotificationTemplateParams) (database.NotificationTemplate, error) {
2438+
panic("not implemented")
2439+
}
2440+
24212441
func (q *querier) InsertOAuth2ProviderApp(ctx context.Context, arg database.InsertOAuth2ProviderAppParams) (database.OAuth2ProviderApp, error) {
24222442
if err := q.authorizeContext(ctx, policy.ActionCreate, rbac.ResourceOauth2App); err != nil {
24232443
return database.OAuth2ProviderApp{}, err
@@ -2725,6 +2745,18 @@ func (q *querier) ListWorkspaceAgentPortShares(ctx context.Context, workspaceID
27252745
return q.db.ListWorkspaceAgentPortShares(ctx, workspaceID)
27262746
}
27272747

2748+
func (q *querier) MarkNotificationMessageFailed(ctx context.Context, arg database.MarkNotificationMessageFailedParams) (database.NotificationMessage, error) {
2749+
panic("not implemented")
2750+
}
2751+
2752+
func (q *querier) MarkNotificationMessageSent(ctx context.Context, arg database.MarkNotificationMessageSentParams) (database.NotificationMessage, error) {
2753+
panic("not implemented")
2754+
}
2755+
2756+
func (q *querier) MarkNotificationMessagesInhibited(ctx context.Context, arg database.MarkNotificationMessagesInhibitedParams) (database.NotificationMessage, error) {
2757+
panic("not implemented")
2758+
}
2759+
27282760
func (q *querier) ReduceWorkspaceAgentShareLevelToAuthenticatedByTemplate(ctx context.Context, templateID uuid.UUID) error {
27292761
template, err := q.db.GetTemplateByID(ctx, templateID)
27302762
if err != nil {

‎coderd/database/dbmem/dbmem.go

Lines changed: 58 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -904,6 +904,15 @@ func (*FakeQuerier) AcquireLock(_ context.Context, _ int64) error {
904904
return xerrors.New("AcquireLock must only be called within a transaction")
905905
}
906906

907+
func (q *FakeQuerier) AcquireNotificationMessages(ctx context.Context, arg database.AcquireNotificationMessagesParams) ([]database.NotificationMessage, error) {
908+
err := validateDatabaseType(arg)
909+
if err != nil {
910+
return nil, err
911+
}
912+
913+
panic("not implemented")
914+
}
915+
907916
func (q *FakeQuerier) AcquireProvisionerJob(_ context.Context, arg database.AcquireProvisionerJobParams) (database.ProvisionerJob, error) {
908917
if err := validateDatabaseType(arg); err != nil {
909918
return database.ProvisionerJob{}, err
@@ -1496,6 +1505,10 @@ func (q *FakeQuerier) DeleteOAuth2ProviderAppTokensByAppAndUserID(_ context.Cont
14961505
return nil
14971506
}
14981507

1508+
func (q *FakeQuerier) DeleteOldNotificationMessages(ctx context.Context) error {
1509+
panic("not implemented")
1510+
}
1511+
14991512
func (q *FakeQuerier) DeleteOldProvisionerDaemons(_ context.Context) error {
15001513
q.mutex.Lock()
15011514
defer q.mutex.Unlock()
@@ -1711,6 +1724,15 @@ func (q *FakeQuerier) DeleteWorkspaceAgentPortSharesByTemplate(_ context.Context
17111724
return nil
17121725
}
17131726

1727+
func (q *FakeQuerier) EnqueueNotificationMessage(ctx context.Context, arg database.EnqueueNotificationMessageParams) (database.NotificationMessage, error) {
1728+
err := validateDatabaseType(arg)
1729+
if err != nil {
1730+
return database.NotificationMessage{}, err
1731+
}
1732+
1733+
panic("not implemented")
1734+
}
1735+
17141736
func (q *FakeQuerier) FavoriteWorkspace(_ context.Context, arg uuid.UUID) error {
17151737
err := validateDatabaseType(arg)
17161738
if err != nil {
@@ -6055,6 +6077,15 @@ func (q *FakeQuerier) InsertMissingGroups(_ context.Context, arg database.Insert
60556077
return newGroups, nil
60566078
}
60576079

6080+
func (q *FakeQuerier) InsertNotificationTemplate(ctx context.Context, arg database.InsertNotificationTemplateParams) (database.NotificationTemplate, error) {
6081+
err := validateDatabaseType(arg)
6082+
if err != nil {
6083+
return database.NotificationTemplate{}, err
6084+
}
6085+
6086+
panic("not implemented")
6087+
}
6088+
60586089
func (q *FakeQuerier) InsertOAuth2ProviderApp(_ context.Context, arg database.InsertOAuth2ProviderAppParams) (database.OAuth2ProviderApp, error) {
60596090
err := validateDatabaseType(arg)
60606091
if err != nil {
@@ -6953,6 +6984,33 @@ func (q *FakeQuerier) ListWorkspaceAgentPortShares(_ context.Context, workspaceI
69536984
return shares, nil
69546985
}
69556986

6987+
func (q *FakeQuerier) MarkNotificationMessageFailed(ctx context.Context, arg database.MarkNotificationMessageFailedParams) (database.NotificationMessage, error) {
6988+
err := validateDatabaseType(arg)
6989+
if err != nil {
6990+
return database.NotificationMessage{}, err
6991+
}
6992+
6993+
panic("not implemented")
6994+
}
6995+
6996+
func (q *FakeQuerier) MarkNotificationMessageSent(ctx context.Context, arg database.MarkNotificationMessageSentParams) (database.NotificationMessage, error) {
6997+
err := validateDatabaseType(arg)
6998+
if err != nil {
6999+
return database.NotificationMessage{}, err
7000+
}
7001+
7002+
panic("not implemented")
7003+
}
7004+
7005+
func (q *FakeQuerier) MarkNotificationMessagesInhibited(ctx context.Context, arg database.MarkNotificationMessagesInhibitedParams) (database.NotificationMessage, error) {
7006+
err := validateDatabaseType(arg)
7007+
if err != nil {
7008+
return database.NotificationMessage{}, err
7009+
}
7010+
7011+
panic("not implemented")
7012+
}
7013+
69567014
func (q *FakeQuerier) ReduceWorkspaceAgentShareLevelToAuthenticatedByTemplate(_ context.Context, templateID uuid.UUID) error {
69577015
err := validateDatabaseType(templateID)
69587016
if err != nil {

‎coderd/database/dbmetrics/dbmetrics.go

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

‎coderd/database/dump.sql

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

‎coderd/database/foreign_key_constraint.go

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

0 commit comments

Comments
 (0)