popularity

export const productsSchema: TypesenseCollection = {
  name: 'products',
  fields: [
    // ... other fields ...
    { name: 'popularity', type: 'int32', optional: true, sort: true },
    // ... other fields ...
  ],
};

const rules: Record<string, AnalyticsRule> = {
  product_popularity: {
    type: "counter",
    params: {
      source: {
        collections: [searchCollection], // searchCollection = 'products'
        events: [
          {
            type: "click",
            name: "product_click_event",
            weight: 1
          },
          {
            type: "conversion",
            name: "product_purchase_event",
            weight: 5
          }
        ]
      },
      destination: {
        collection: searchCollection,
        counter_field: "popularity"
      }
    }
  }
};

async trackProductClick(productId: string, userId?: string, metadata?: any) {
  return this.trackEvent('click', {
    doc_id: productId,
    user_id: userId,
    metadata,
    timestamp: Date.now()
  });
}

async trackEvent(type: string, eventData: any) {
  try {
    switch (type) {
      case 'click':
      case 'conversion':
        const eventDocument = {
          type: eventData.type,
          name: type === 'click' ? 'product_click_event' : 'product_purchase_event',
          doc_id: eventData.doc_id,
          user_id: eventData.user_id || 'anonymous',
          timestamp: eventData.timestamp || Date.now(),
          metadata: eventData.metadata
        };
        await this.client.collections('events').documents().create(eventDocument);
        break;
    }
  } catch (error) {
    console.error('Failed to track event:', error);
    throw error;
  }
}