Function TestNoteboxConcurrencyBugDemo

lib/notebox_bug_demo_test.go:14–132

TestNoteboxConcurrencyBugDemo demonstrates the specific bug: Multiple goroutines calling OpenNotebox/Close on the same endpoint:localStorage can cause race conditions due to insufficient concurrency protection

(t *testing.T)

// Multiple goroutines calling OpenNotebox/Close on the same endpoint:localStorage
// can cause race conditions due to insufficient concurrency protection
func TestNoteboxConcurrencyBugDemo(t *testing.T) {
	longRunningTest(t)
	ctx := context.Background()

	// Clean up any leftover noteboxes from previous tests
	_ = Purge(ctx)
	forceCleanupAllNoteboxes() // Force cleanup to ensure test isolation

	// Create temp directory for test
	tmpDir := t.TempDir()

	// Set file storage directory
	FileSetStorageLocation(tmpDir)

	const (
		endpoint      = "bug-demo-endpoint"
		numGoroutines = 20
		numOperations = 50
	)

	// Create a single storage location that all goroutines will share
	testStorage := FileStorageObject("shared_notebox_storage")

	// Create the notebox once
	err := CreateNotebox(ctx, endpoint, testStorage)
	if err != nil {
		t.Fatalf("Failed to create notebox: %v", err)
	}

	// Track errors and panics
	var (
		errors sync.Map
		panics sync.Map
		wg     sync.WaitGroup
	)

	wg.Add(numGoroutines)

	// Launch N goroutines that all try to open/work/close the same notebox
	for i := 0; i < numGoroutines; i++ {
		go func(id int) {
			defer wg.Done()

			for op := 0; op < numOperations; op++ {
				// Catch panics
				func() {
					defer func() {
						if r := recover(); r != nil {
							panics.Store(fmt.Sprintf("goroutine-%d-op-%d", id, op), r)
						}
					}()

					// Open the notebox
					box, err := OpenNotebox(ctx, endpoint, testStorage)
					if err != nil {
						errors.Store(fmt.Sprintf("open-%d-%d", id, op), err)
						return
					}