Function TestProcessEvent

pkg/memory/logic/manager_test.go:126–216

(t *testing.T)

}

func TestProcessEvent(t *testing.T) {
	ctx := context.Background()
	store := NewInMemoryStore()

	t.Run("with valid matcher", func(t *testing.T) {
		// 创建测试 Matcher
		matcher := &testMatcher{
			supportedTypes: []string{"user_action"},
			memories: []*LogicMemory{
				{
					Namespace:   "user:789",
					Scope:       ScopeUser,
					Type:        "behavior",
					Key:         "click_pattern",
					Value:       "fast_clicker",
					Description: "User clicks quickly",
					Provenance: &memory.MemoryProvenance{
						SourceType: memory.SourceUserInput,
						Confidence: 0.75,
					},
				},
			},
		}

		manager, err := NewManager(&ManagerConfig{
			Store:    store,
			Matchers: []PatternMatcher{matcher},
		})
		require.NoError(t, err)

		// 处理事件
		event := Event{
			Type:      "user_action",
			Source:    "user:789",
			Data:      map[string]any{"action": "click"},
			Timestamp: time.Now(),
		}

		err = manager.ProcessEvent(ctx, event)
		require.NoError(t, err)

		// 验证 Memory 已创建
		retrieved, err := store.Get(ctx, "user:789", "click_pattern")
		require.NoError(t, err)
		assert.Equal(t, "fast_clicker", retrieved.Value)
		assert.Equal(t, "User clicks quickly", retrieved.Description)
	})

	t.Run("no matchers", func(t *testing.T) {
		manager, err := NewManager(&ManagerConfig{
			Store:    store,
			Matchers: nil, // 没有 Matcher
		})
		require.NoError(t, err)

		event := Event{
			Type:      "unknown",
			Source:    "user:999",