commit c73edab652a2a43c94e6a02534e9ed5e7fed2c85 · bretton.dev/coves

+44 -4

internal/core/comments/comment_service_test.go

···

       5
        
       	"Coves/internal/core/posts"

     

       6
        
       	"Coves/internal/core/users"

     

       7
        
       	"context"

     

       0
        
       
     

       8
        
       	"errors"

     

       9
        
       	"testing"

     

       10
        
       	"time"

     
···

       51
        
       func (m *mockCommentRepo) Delete(ctx context.Context, uri string) error {

     

       52
        
       	delete(m.comments, uri)

     

       53
        
       	return nil

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       54
        
       }

     

       55
        
       

     

       56
        
       func (m *mockCommentRepo) ListByRoot(ctx context.Context, rootURI string, limit, offset int) ([]*Comment, error) {

     
···

       831
        
       	assert.Len(t, result, 0)

     

       832
        
       }

     

       833
        
       

     

       834
       -
       func TestCommentService_buildThreadViews_SkipsDeletedComments(t *testing.T) {

     

       835
        
       	// Setup

     

       836
        
       	commentRepo := newMockCommentRepo()

     

       837
        
       	userRepo := newMockUserRepo()

     
···

       840
        
       

     

       841
        
       	postURI := "at://did:plc:post123/app.bsky.feed.post/test"

     

       842
        
       	deletedAt := time.Now()

     

       0
        
       
     

       843
        
       

     

       844
        
       	// Create a deleted comment

     

       845
        
       	deletedComment := createTestComment("at://did:plc:commenter123/comment/1", "did:plc:commenter123", "commenter.test", postURI, postURI, 0)

     

       846
        
       	deletedComment.DeletedAt = &deletedAt

     

       0
        
       
     

       0
        
       
     

       847
        
       

     

       848
        
       	// Create a normal comment

     

       849
        
       	normalComment := createTestComment("at://did:plc:commenter123/comment/2", "did:plc:commenter123", "commenter.test", postURI, postURI, 0)

     
···

       853
        
       	// Execute

     

       854
        
       	result := service.buildThreadViews(context.Background(), []*Comment{deletedComment, normalComment}, 10, "hot", nil)

     

       855
        
       

     

       856
       -
       	// Verify - should only include non-deleted comment

     

       857
       -
       	assert.Len(t, result, 1)

     

       858
       -
       	assert.Equal(t, normalComment.URI, result[0].Comment.URI)

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       859
        
       }

     

       860
        
       

     

       861
        
       func TestCommentService_buildThreadViews_WithNestedReplies(t *testing.T) {

···

       5
        
       	"Coves/internal/core/posts"

     

       6
        
       	"Coves/internal/core/users"

     

       7
        
       	"context"

     

       8
       +
       	"database/sql"

     

       9
        
       	"errors"

     

       10
        
       	"testing"

     

       11
        
       	"time"

     
···

       52
        
       func (m *mockCommentRepo) Delete(ctx context.Context, uri string) error {

     

       53
        
       	delete(m.comments, uri)

     

       54
        
       	return nil

     

       55
       +
       }

     

       56
       +
       

     

       57
       +
       func (m *mockCommentRepo) SoftDeleteWithReason(ctx context.Context, uri, reason, deletedByDID string) error {

     

       58
       +
       	// Validate deletion reason

     

       59
       +
       	if reason != DeletionReasonAuthor && reason != DeletionReasonModerator {

     

       60
       +
       		return errors.New("invalid deletion reason: " + reason)

     

       61
       +
       	}

     

       62
       +
       	_, err := m.SoftDeleteWithReasonTx(ctx, nil, uri, reason, deletedByDID)

     

       63
       +
       	return err

     

       64
       +
       }

     

       65
       +
       

     

       66
       +
       // SoftDeleteWithReasonTx implements RepositoryTx interface for transactional deletes

     

       67
       +
       func (m *mockCommentRepo) SoftDeleteWithReasonTx(ctx context.Context, tx *sql.Tx, uri, reason, deletedByDID string) (int64, error) {

     

       68
       +
       	if c, ok := m.comments[uri]; ok {

     

       69
       +
       		if c.DeletedAt != nil {

     

       70
       +
       			// Already deleted - idempotent

     

       71
       +
       			return 0, nil

     

       72
       +
       		}

     

       73
       +
       		now := time.Now()

     

       74
       +
       		c.DeletedAt = &now

     

       75
       +
       		c.DeletionReason = &reason

     

       76
       +
       		c.DeletedBy = &deletedByDID

     

       77
       +
       		c.Content = ""

     

       78
       +
       		return 1, nil

     

       79
       +
       	}

     

       80
       +
       	return 0, nil

     

       81
        
       }

     

       82
        
       

     

       83
        
       func (m *mockCommentRepo) ListByRoot(ctx context.Context, rootURI string, limit, offset int) ([]*Comment, error) {

     
···

       858
        
       	assert.Len(t, result, 0)

     

       859
        
       }

     

       860
        
       

     

       861
       +
       func TestCommentService_buildThreadViews_IncludesDeletedCommentsAsPlaceholders(t *testing.T) {

     

       862
        
       	// Setup

     

       863
        
       	commentRepo := newMockCommentRepo()

     

       864
        
       	userRepo := newMockUserRepo()

     
···

       867
        
       

     

       868
        
       	postURI := "at://did:plc:post123/app.bsky.feed.post/test"

     

       869
        
       	deletedAt := time.Now()

     

       870
       +
       	deletionReason := DeletionReasonAuthor

     

       871
        
       

     

       872
        
       	// Create a deleted comment

     

       873
        
       	deletedComment := createTestComment("at://did:plc:commenter123/comment/1", "did:plc:commenter123", "commenter.test", postURI, postURI, 0)

     

       874
        
       	deletedComment.DeletedAt = &deletedAt

     

       875
       +
       	deletedComment.DeletionReason = &deletionReason

     

       876
       +
       	deletedComment.Content = "" // Content is blanked on deletion

     

       877
        
       

     

       878
        
       	// Create a normal comment

     

       879
        
       	normalComment := createTestComment("at://did:plc:commenter123/comment/2", "did:plc:commenter123", "commenter.test", postURI, postURI, 0)

     
···

       883
        
       	// Execute

     

       884
        
       	result := service.buildThreadViews(context.Background(), []*Comment{deletedComment, normalComment}, 10, "hot", nil)

     

       885
        
       

     

       886
       +
       	// Verify - both comments should be included to preserve thread structure

     

       887
       +
       	assert.Len(t, result, 2)

     

       888
       +
       

     

       889
       +
       	// First comment should be the deleted one with placeholder info

     

       890
       +
       	assert.Equal(t, deletedComment.URI, result[0].Comment.URI)

     

       891
       +
       	assert.True(t, result[0].Comment.IsDeleted)

     

       892
       +
       	assert.Equal(t, DeletionReasonAuthor, *result[0].Comment.DeletionReason)

     

       893
       +
       	assert.Empty(t, result[0].Comment.Content)

     

       894
       +
       

     

       895
       +
       	// Second comment should be the normal one

     

       896
       +
       	assert.Equal(t, normalComment.URI, result[1].Comment.URI)

     

       897
       +
       	assert.False(t, result[1].Comment.IsDeleted)

     

       898
       +
       	assert.Nil(t, result[1].Comment.DeletionReason)

     

       899
        
       }

     

       900
        
       

     

       901
        
       func TestCommentService_buildThreadViews_WithNestedReplies(t *testing.T) {