wip

packages/analytics/infrastructure/repositories/InMemoryAnalyticsSnapshotRepository.ts

@@ -0,0 +1,76 @@
+/**
+ * Infrastructure: InMemoryAnalyticsSnapshotRepository
+ * 
+ * In-memory implementation of IAnalyticsSnapshotRepository for development/testing.
+ */
+
+import type { IAnalyticsSnapshotRepository } from '../../domain/repositories/IAnalyticsSnapshotRepository';
+import { AnalyticsSnapshot, type SnapshotPeriod, type SnapshotEntityType } from '../../domain/entities/AnalyticsSnapshot';
+
+export class InMemoryAnalyticsSnapshotRepository implements IAnalyticsSnapshotRepository {
+  private snapshots: Map<string, AnalyticsSnapshot> = new Map();
+
+  async save(snapshot: AnalyticsSnapshot): Promise<void> {
+    this.snapshots.set(snapshot.id, snapshot);
+  }
+
+  async findById(id: string): Promise<AnalyticsSnapshot | null> {
+    return this.snapshots.get(id) ?? null;
+  }
+
+  async findByEntity(entityType: SnapshotEntityType, entityId: string): Promise<AnalyticsSnapshot[]> {
+    return Array.from(this.snapshots.values()).filter(
+      s => s.entityType === entityType && s.entityId === entityId
+    );
+  }
+
+  async findByPeriod(
+    entityType: SnapshotEntityType,
+    entityId: string,
+    period: SnapshotPeriod,
+    startDate: Date,
+    endDate: Date
+  ): Promise<AnalyticsSnapshot | null> {
+    return Array.from(this.snapshots.values()).find(
+      s => s.entityType === entityType &&
+           s.entityId === entityId &&
+           s.period === period &&
+           s.startDate >= startDate &&
+           s.endDate <= endDate
+    ) ?? null;
+  }
+
+  async findLatest(
+    entityType: SnapshotEntityType,
+    entityId: string,
+    period: SnapshotPeriod
+  ): Promise<AnalyticsSnapshot | null> {
+    const matching = Array.from(this.snapshots.values())
+      .filter(s => s.entityType === entityType && s.entityId === entityId && s.period === period)
+      .sort((a, b) => b.endDate.getTime() - a.endDate.getTime());
+    
+    return matching[0] ?? null;
+  }
+
+  async getHistoricalSnapshots(
+    entityType: SnapshotEntityType,
+    entityId: string,
+    period: SnapshotPeriod,
+    limit: number
+  ): Promise<AnalyticsSnapshot[]> {
+    return Array.from(this.snapshots.values())
+      .filter(s => s.entityType === entityType && s.entityId === entityId && s.period === period)
+      .sort((a, b) => b.endDate.getTime() - a.endDate.getTime())
+      .slice(0, limit);
+  }
+
+  // Helper for testing
+  clear(): void {
+    this.snapshots.clear();
+  }
+
+  // Helper for seeding demo data
+  seed(snapshots: AnalyticsSnapshot[]): void {
+    snapshots.forEach(s => this.snapshots.set(s.id, s));
+  }
+}

packages/analytics/infrastructure/repositories/InMemoryEngagementRepository.ts

@@ -0,0 +1,64 @@
+/**
+ * Infrastructure: InMemoryEngagementRepository
+ * 
+ * In-memory implementation of IEngagementRepository for development/testing.
+ */
+
+import type { IEngagementRepository } from '../../domain/repositories/IEngagementRepository';
+import { EngagementEvent, type EngagementAction, type EngagementEntityType } from '../../domain/entities/EngagementEvent';
+
+export class InMemoryEngagementRepository implements IEngagementRepository {
+  private events: Map<string, EngagementEvent> = new Map();
+
+  async save(event: EngagementEvent): Promise<void> {
+    this.events.set(event.id, event);
+  }
+
+  async findById(id: string): Promise<EngagementEvent | null> {
+    return this.events.get(id) ?? null;
+  }
+
+  async findByEntityId(entityType: EngagementEntityType, entityId: string): Promise<EngagementEvent[]> {
+    return Array.from(this.events.values()).filter(
+      e => e.entityType === entityType && e.entityId === entityId
+    );
+  }
+
+  async findByAction(action: EngagementAction): Promise<EngagementEvent[]> {
+    return Array.from(this.events.values()).filter(
+      e => e.action === action
+    );
+  }
+
+  async findByDateRange(startDate: Date, endDate: Date): Promise<EngagementEvent[]> {
+    return Array.from(this.events.values()).filter(
+      e => e.timestamp >= startDate && e.timestamp <= endDate
+    );
+  }
+
+  async countByAction(action: EngagementAction, entityId?: string, since?: Date): Promise<number> {
+    return Array.from(this.events.values()).filter(
+      e => e.action === action &&
+           (!entityId || e.entityId === entityId) &&
+           (!since || e.timestamp >= since)
+    ).length;
+  }
+
+  async getSponsorClicksForEntity(entityId: string, since?: Date): Promise<number> {
+    return Array.from(this.events.values()).filter(
+      e => e.entityId === entityId &&
+           (e.action === 'click_sponsor_logo' || e.action === 'click_sponsor_url') &&
+           (!since || e.timestamp >= since)
+    ).length;
+  }
+
+  // Helper for testing
+  clear(): void {
+    this.events.clear();
+  }
+
+  // Helper for seeding demo data
+  seed(events: EngagementEvent[]): void {
+    events.forEach(e => this.events.set(e.id, e));
+  }
+}

packages/analytics/infrastructure/repositories/InMemoryPageViewRepository.ts

@@ -0,0 +1,70 @@
+/**
+ * Infrastructure: InMemoryPageViewRepository
+ * 
+ * In-memory implementation of IPageViewRepository for development/testing.
+ */
+
+import type { IPageViewRepository } from '../../domain/repositories/IPageViewRepository';
+import { PageView, type EntityType } from '../../domain/entities/PageView';
+
+export class InMemoryPageViewRepository implements IPageViewRepository {
+  private pageViews: Map<string, PageView> = new Map();
+
+  async save(pageView: PageView): Promise<void> {
+    this.pageViews.set(pageView.id, pageView);
+  }
+
+  async findById(id: string): Promise<PageView | null> {
+    return this.pageViews.get(id) ?? null;
+  }
+
+  async findByEntityId(entityType: EntityType, entityId: string): Promise<PageView[]> {
+    return Array.from(this.pageViews.values()).filter(
+      pv => pv.entityType === entityType && pv.entityId === entityId
+    );
+  }
+
+  async findByDateRange(startDate: Date, endDate: Date): Promise<PageView[]> {
+    return Array.from(this.pageViews.values()).filter(
+      pv => pv.timestamp >= startDate && pv.timestamp <= endDate
+    );
+  }
+
+  async findBySession(sessionId: string): Promise<PageView[]> {
+    return Array.from(this.pageViews.values()).filter(
+      pv => pv.sessionId === sessionId
+    );
+  }
+
+  async countByEntityId(entityType: EntityType, entityId: string, since?: Date): Promise<number> {
+    return Array.from(this.pageViews.values()).filter(
+      pv => pv.entityType === entityType && 
+            pv.entityId === entityId &&
+            (!since || pv.timestamp >= since)
+    ).length;
+  }
+
+  async countUniqueVisitors(entityType: EntityType, entityId: string, since?: Date): Promise<number> {
+    const visitors = new Set<string>();
+    Array.from(this.pageViews.values())
+      .filter(
+        pv => pv.entityType === entityType && 
+              pv.entityId === entityId &&
+              (!since || pv.timestamp >= since)
+      )
+      .forEach(pv => {
+        visitors.add(pv.visitorId ?? pv.sessionId);
+      });
+    return visitors.size;
+  }
+
+  // Helper for testing
+  clear(): void {
+    this.pageViews.clear();
+  }
+
+  // Helper for seeding demo data
+  seed(pageViews: PageView[]): void {
+    pageViews.forEach(pv => this.pageViews.set(pv.id, pv));
+  }
+}