Add message channel reset command

[neo773]

In this PR, we are adding a new command to reset a message channel.

We are also refactoring a bit cursor reset as we had multiple implementations at different places in the code base

[greptile-apps]

Greptile Overview

Greptile Summary

Adds a new CLI command messaging:reset-channel to reset message channel sync state and clear all associated data for full resync. The command supports resetting a single channel or all channels in a workspace.

• Creates comprehensive reset functionality that clears sync cursors, deletes message associations, removes cache entries, and resets sync state
• Properly integrates with existing MessagingMessageCleanerService for deletion operations
• Includes detailed logging throughout the process
• Handles both single-channel and bulk operations

Minor optimization opportunity: the resetMessageChannel method retrieves the message channel repository again even though it's already available from the calling method.

Confidence Score: 4/5

• This PR is safe to merge with minimal risk
• The implementation follows established patterns in the codebase, integrates well with existing services, and handles edge cases appropriately. There's one minor inefficiency with redundant repository retrieval, but this doesn't affect functionality or introduce bugs.
• No files require special attention

Important Files Changed

File Analysis

Filename	Score	Overview
packages/twenty-server/src/modules/messaging/message-cleaner/commands/messaging-reset-channel.command.ts	4/5	New command for resetting message channels - retrieves repository redundantly within resetMessageChannel method
packages/twenty-server/src/modules/messaging/message-cleaner/messaging-message-cleaner.module.ts	5/5	Adds new command to module providers - straightforward registration

Sequence Diagram

sequenceDiagram
    participant CLI as CLI Command
    participant CMD as MessagingResetChannelCommand
    participant ORM as TwentyORMGlobalManager
    participant MCS as MessagingMessageCleanerService
    participant Cache as CacheStorageService
    participant DB as Database Repositories

    CLI->>CMD: run(options)
    CMD->>ORM: getRepositoryForWorkspace(messageChannel)
    ORM-->>CMD: messageChannelRepository
    
    alt Single Channel
        CMD->>DB: findOne(messageChannelId)
        DB-->>CMD: messageChannel
        CMD->>CMD: resetMessageChannel()
    else All Channels
        CMD->>DB: find() all channels
        DB-->>CMD: messageChannels[]
        loop For each channel
            CMD->>CMD: resetMessageChannel()
        end
    end
    
    Note over CMD,DB: resetMessageChannel operations
    CMD->>ORM: getRepositoryForWorkspace(messageChannelMessageAssociation)
    ORM-->>CMD: associationRepository
    CMD->>DB: find associations
    DB-->>CMD: associations[]
    
    alt Has message associations
        CMD->>MCS: deleteMessagesChannelMessageAssociationsAndRelatedOrphans()
        MCS->>DB: delete associations, orphan messages, orphan threads
    end
    
    CMD->>Cache: del(messages-to-import cache key)
    CMD->>ORM: getRepositoryForWorkspace(messageFolder)
    ORM-->>CMD: messageFolderRepository
    CMD->>DB: update(syncCursor = null)
    CMD->>DB: update channel(syncCursor, syncStage, syncStatus, etc.)
    CMD-->>CLI: Success

Loading

[greptile-apps]

_{2 files reviewed, 1 comment}

_{Edit Code Review Agent Settings | Greptile}

[greptile-apps]

style: messageChannelRepository is already retrieved in the run method and could be passed as a parameter to avoid redundant database calls

Suggested change

	const messageChannelRepository =
	await this.twentyORMGlobalManager.getRepositoryForWorkspace<MessageChannelWorkspaceEntity>(
	workspaceId,
	'messageChannel',
	);
	private async resetMessageChannel(
	workspaceId: string,
	messageChannel: MessageChannelWorkspaceEntity,
	messageChannelRepository: Repository<MessageChannelWorkspaceEntity>,
	): Promise<void> {

Prompt To Fix With AI

This is a comment left during a code review.
Path: packages/twenty-server/src/modules/messaging/message-cleaner/commands/messaging-reset-channel.command.ts
Line: 105:109

Comment:
**style:** `messageChannelRepository` is already retrieved in the `run` method and could be passed as a parameter to avoid redundant database calls

```suggestion
  private async resetMessageChannel(
    workspaceId: string,
    messageChannel: MessageChannelWorkspaceEntity,
    messageChannelRepository: Repository<MessageChannelWorkspaceEntity>,
  ): Promise<void> {
```

How can I resolve this? If you propose a fix, please make it concise.

[github-actions]

🚀 Preview Environment Ready!

Your preview environment is available at: http://bore.pub:48106

This environment will automatically shut down when the PR is closed or after 5 hours.

[charlesBochet]

Left comment but approving

[twenty-eng-sync]

Hey @charlesBochet! After you've done the QA of your Pull Request, you can mark it as done here. Thank you!