Method purgeChatsInTx

coderd/database/dbpurge/dbpurge.go:485–523

purgeChatsInTx MUST BE CALLED WITH A TRANSACTION

(ctx context.Context, tx database.Store, start time.Time, chatRetentionDays, chatAutoArchiveDays int32)

// purgeChatsInTx MUST BE CALLED WITH A TRANSACTION
func (i *instance) purgeChatsInTx(ctx context.Context, tx database.Store, start time.Time, chatRetentionDays, chatAutoArchiveDays int32) (purgedChats, purgedChatFiles int64, archivedChats []database.AutoArchiveInactiveChatsRow, err error) {
	// Delete old archived chats first, then orphaned files
	// (cascade clears chat_file_links but not chat_files).
	if chatRetentionDays > 0 {
		deleteChatsBefore := start.Add(-time.Duration(chatRetentionDays) * 24 * time.Hour)
		purgedChats, err = tx.DeleteOldChats(ctx, database.DeleteOldChatsParams{
			BeforeTime: deleteChatsBefore,
			LimitCount: chatsBatchSize,
		})
		if err != nil {
			return 0, 0, nil, xerrors.Errorf("failed to delete old chats: %w", err)
		}

		purgedChatFiles, err = tx.DeleteOldChatFiles(ctx, database.DeleteOldChatFilesParams{
			BeforeTime: deleteChatsBefore,
			LimitCount: chatFilesBatchSize,
		})
		if err != nil {
			return 0, 0, nil, xerrors.Errorf("failed to delete old chat files: %w", err)
		}
	}

	// Auto-archive runs after the delete pass so newly
	// archived chats aren't eligible for deletion this tick.
	// Eligibility uses UTC day boundaries: a chat is archived on the
	// start of the UTC day after its inactivity period has elapsed.
	if chatAutoArchiveDays > 0 {
		today := dbtime.StartOfDay(start)
		archiveCutoff := today.Add(-time.Duration(chatAutoArchiveDays) * 24 * time.Hour)
		archivedChats, err = tx.AutoArchiveInactiveChats(ctx, database.AutoArchiveInactiveChatsParams{
			ArchiveCutoff: archiveCutoff,
			LimitCount:    i.chatAutoArchiveBatchSize,
		})
		if err != nil {
			return 0, 0, nil, xerrors.Errorf("failed to auto-archive inactive chats: %w", err)
		}
	}
	return purgedChats, purgedChatFiles, archivedChats, nil
}

// dispatchChatAutoArchive audits every archived root chat and enqueues one
// notification per owner covering the roots archived in this tick. Children