Function TestCounterInt64_TryUpdate_RollbackLogic

data/shared_state_variable_test.go:621–770

(t *testing.T)

}

func TestCounterInt64_TryUpdate_RollbackLogic(t *testing.T) {
	tests := []struct {
		name             string
		setupMocks       func(conn *MockConnector, lock *MockLock)
		initialValue     int64
		updateValue      int64
		ignoreRollbackOf int64
		expectedValue    int64
		eventual         bool
		eventualValue    int64
	}{
		{
			name: "remote lock fails, fallback local, higher update => update",
			setupMocks: func(conn *MockConnector, lock *MockLock) {
				// No Set call is expected because we fail to lock remotely
				conn.On("Lock", mock.Anything, "test", mock.Anything).
					Return(nil, errors.New("lock failed"))
				// Background push publishes best-effort even when the lock cannot be acquired.
				conn.On("PublishCounterInt64", mock.Anything, "test", mock.Anything).Return(nil)
			},
			initialValue:     5,
			updateValue:      10,
			ignoreRollbackOf: 1024,
			expectedValue:    10,
		},
		{
			name: "remote lock fails, fallback local, lower update within rollback range => ignored",
			setupMocks: func(conn *MockConnector, lock *MockLock) {
				// Small rollback within ignoreRollbackOf is silently ignored (no remote work)
			},
			initialValue:     100,
			updateValue:      95,
			ignoreRollbackOf: 10, // gap=5 <= 10, so rollback is ignored
			expectedValue:    100,
		},
		{
			name: "remote lock fails, fallback local, lower update exceeds rollback range => applied",
			setupMocks: func(conn *MockConnector, lock *MockLock) {
				// Large rollback exceeding ignoreRollbackOf is APPLIED
				conn.On("Lock", mock.Anything, "test", mock.Anything).
					Return(nil, errors.New("lock failed"))
				conn.On("PublishCounterInt64", mock.Anything, "test", mock.Anything).Return(nil)
			},
			initialValue:     100,
			updateValue:      50,
			ignoreRollbackOf: 40, // gap=50 > 40, so rollback is APPLIED
			expectedValue:    50,
		},
		{
			name: "remote lock succeeds, remote higher => override local; push reconciled value",
			setupMocks: func(conn *MockConnector, lock *MockLock) {
				conn.On("Lock", mock.Anything, "test", mock.Anything).Return(lock, nil)
				lock.On("Unlock", mock.Anything).Return(nil)
				conn.On("Get", mock.Anything, ConnectorMainIndex, "test", "value", nil).
					Return([]byte(fmt.Sprintf(`{"v":200,"t":%d,"b":"test"}`, time.Now().UnixMilli()+60_000)), nil)
				// Background publish is best-effort.
				conn.On("PublishCounterInt64", mock.Anything, "test", mock.Anything).Return(nil)
			},