@@ -905,6 +905,15 @@ func (*FakeQuerier) AcquireLock(_ context.Context, _ int64) error {
905905return xerrors .New ("AcquireLock must only be called within a transaction" )
906906}
907907
908+ func (q * FakeQuerier )AcquireNotificationMessages (ctx context.Context ,arg database.AcquireNotificationMessagesParams ) ([]database.AcquireNotificationMessagesRow ,error ) {
909+ err := validateDatabaseType (arg )
910+ if err != nil {
911+ return nil ,err
912+ }
913+
914+ panic ("not implemented" )
915+ }
916+
908917func (q * FakeQuerier )AcquireProvisionerJob (_ context.Context ,arg database.AcquireProvisionerJobParams ) (database.ProvisionerJob ,error ) {
909918if err := validateDatabaseType (arg );err != nil {
910919return database.ProvisionerJob {},err
@@ -1167,6 +1176,24 @@ func (q *FakeQuerier) BatchUpdateWorkspaceLastUsedAt(_ context.Context, arg data
11671176return nil
11681177}
11691178
1179+ func (q * FakeQuerier )BulkMarkNotificationMessagesFailed (ctx context.Context ,arg database.BulkMarkNotificationMessagesFailedParams ) (int64 ,error ) {
1180+ err := validateDatabaseType (arg )
1181+ if err != nil {
1182+ return 0 ,err
1183+ }
1184+
1185+ panic ("not implemented" )
1186+ }
1187+
1188+ func (q * FakeQuerier )BulkMarkNotificationMessagesSent (ctx context.Context ,arg database.BulkMarkNotificationMessagesSentParams ) (int64 ,error ) {
1189+ err := validateDatabaseType (arg )
1190+ if err != nil {
1191+ return 0 ,err
1192+ }
1193+
1194+ panic ("not implemented" )
1195+ }
1196+
11701197func (* FakeQuerier )CleanTailnetCoordinators (_ context.Context )error {
11711198return ErrUnimplemented
11721199}
@@ -1502,6 +1529,10 @@ func (q *FakeQuerier) DeleteOAuth2ProviderAppTokensByAppAndUserID(_ context.Cont
15021529return nil
15031530}
15041531
1532+ func (q * FakeQuerier )DeleteOldNotificationMessages (ctx context.Context )error {
1533+ panic ("not implemented" )
1534+ }
1535+
15051536func (q * FakeQuerier )DeleteOldProvisionerDaemons (_ context.Context )error {
15061537q .mutex .Lock ()
15071538defer q .mutex .Unlock ()
@@ -1717,6 +1748,15 @@ func (q *FakeQuerier) DeleteWorkspaceAgentPortSharesByTemplate(_ context.Context
17171748return nil
17181749}
17191750
1751+ func (q * FakeQuerier )EnqueueNotificationMessage (ctx context.Context ,arg database.EnqueueNotificationMessageParams ) (database.NotificationMessage ,error ) {
1752+ err := validateDatabaseType (arg )
1753+ if err != nil {
1754+ return database.NotificationMessage {},err
1755+ }
1756+
1757+ panic ("not implemented" )
1758+ }
1759+
17201760func (q * FakeQuerier )FavoriteWorkspace (_ context.Context ,arg uuid.UUID )error {
17211761err := validateDatabaseType (arg )
17221762if err != nil {
@@ -1736,6 +1776,15 @@ func (q *FakeQuerier) FavoriteWorkspace(_ context.Context, arg uuid.UUID) error
17361776return nil
17371777}
17381778
1779+ func (q * FakeQuerier )FetchNewMessageMetadata (ctx context.Context ,arg database.FetchNewMessageMetadataParams ) (database.FetchNewMessageMetadataRow ,error ) {
1780+ err := validateDatabaseType (arg )
1781+ if err != nil {
1782+ return database.FetchNewMessageMetadataRow {},err
1783+ }
1784+
1785+ panic ("not implemented" )
1786+ }
1787+
17391788func (q * FakeQuerier )GetAPIKeyByID (_ context.Context ,id string ) (database.APIKey ,error ) {
17401789q .mutex .RLock ()
17411790defer q .mutex .RUnlock ()
@@ -6063,6 +6112,15 @@ func (q *FakeQuerier) InsertMissingGroups(_ context.Context, arg database.Insert
60636112return newGroups ,nil
60646113}
60656114
6115+ func (q * FakeQuerier )InsertNotificationTemplate (ctx context.Context ,arg database.InsertNotificationTemplateParams ) (database.NotificationTemplate ,error ) {
6116+ err := validateDatabaseType (arg )
6117+ if err != nil {
6118+ return database.NotificationTemplate {},err
6119+ }
6120+
6121+ panic ("not implemented" )
6122+ }
6123+
60666124func (q * FakeQuerier )InsertOAuth2ProviderApp (_ context.Context ,arg database.InsertOAuth2ProviderAppParams ) (database.OAuth2ProviderApp ,error ) {
60676125err := validateDatabaseType (arg )
60686126if err != nil {