WIP - refactor events to use a generic build entity for some of the hybrid events

app/serializers/analytics_generic_entity.rb

@@ -23,7 +23,7 @@ class AnalyticsGenericEntity < Grape::Entity
   private
 
   def url_to(route, id = nil)
-    public_send("#{route}_url", options[:project].namespace, options[:project], id)
+    public_send("#{route}_url", request.project.namespace, request.project, id)
   end
 
   def interval_in_words(diff)

lib/gitlab/cycle_analytics/events.rb

 module Gitlab
   module CycleAnalytics
     class Events
-      include ActionView::Helpers::DateHelper
-
       def initialize(project:, options:)
         @project = project
         @fetcher = EventsFetcher.new(project: project, options: options)
@@ -51,20 +49,16 @@ def production_events
 
       private
 
-      def parse_event(event, entity: :issue)
-        event['url'] = Gitlab::LightUrlBuilder.build(entity: entity, project: @project, id: event['iid'].to_s)
-        event['total_time'] = distance_of_time_in_words(event['total_time'].to_f)
-        event['created_at'] = interval_in_words(event['created_at'])
-        event['author_profile_url'] = Gitlab::LightUrlBuilder.build(entity: :user, id: event['author_username'])
-        event['author_avatar_url'] = Gitlab::LightUrlBuilder.build(entity: :user_avatar, id: event['author_id'])
+      def parse_event(event)
+        event['author'] = User.find(event.remove('author_id'))
 
-        event.except!('author_id', 'author_username')
+        AnalyticsGenericSerializer.new(project: @project).represent(event).as_json
       end
 
       def parse_build_event(event)
         build = ::Ci::Build.find(event['id'])
 
-        AnalyticsBuildSerializer.new(project: @project).represent(build).as_json
+        AnalyticsBuildSerializer.new.represent(build).as_json
       end
 
       def first_time_reference_commit(commits, event)

lib/gitlab/cycle_analytics/events_fetcher.rb

@@ -15,24 +15,14 @@ def fetch(stage:)
         end
       end
 
-      def issue_custom_query(base_query)
-        base_query.join(user_table).on(issue_table[:author_id].eq(user_table[:id]))
-      end
-
       def plan_custom_query(base_query)
         base_query.join(mr_diff_table).on(mr_diff_table[:merge_request_id].eq(mr_table[:id]))
       end
 
-      def review_custom_query(base_query)
-        base_query.join(user_table).on(mr_table[:author_id].eq(user_table[:id]))
-      end
-
       def test_custom_query(base_query)
         base_query.join(build_table).on(mr_metrics_table[:ci_commit_id].eq(build_table[:commit_id]))
       end
 
-      alias_method :code_custom_query, :issue_custom_query
-      alias_method :production_custom_query, :issue_custom_query
       alias_method :staging_custom_query, :test_custom_query
     end
   end

lib/gitlab/cycle_analytics/query_config.rb

@@ -24,9 +24,7 @@ def issue
                         issue_table[:iid],
                         issue_table[:id],
                         issue_table[:created_at],
-                        user_table[:name].as('author_name'),
-                        user_table[:username].as('author_username'),
-                        user_table[:id].as('author_id')]
+                        issue_table[:author_id]]
         }
       end
 
@@ -48,9 +46,7 @@ def code
                         mr_table[:id],
                         mr_table[:created_at],
                         mr_table[:state],
-                        user_table[:name].as('author_name'),
-                        user_table[:username].as('author_username'),
-                        user_table[:id].as('author_id')],
+                        mr_table[:author_id]],
           order: mr_table[:created_at]
         }
       end
@@ -73,9 +69,7 @@ def review
                         mr_table[:id],
                         mr_table[:created_at].as('opened_at'),
                         mr_table[:state],
-                        user_table[:name].as('author_name'),
-                        user_table[:username].as('author_username'),
-                        user_table[:id].as('author_id')]
+                        mr_table[:author_id]]
         }
       end
 
@@ -96,9 +90,7 @@ def production
                         issue_table[:iid],
                         issue_table[:id],
                         issue_table[:created_at],
-                        user_table[:name].as('author_name'),
-                        user_table[:username].as('author_username'),
-                        user_table[:id].as('author_id')]
+                        issue_table[:author_id]]
         }
       end
     end

spec/serializers/analytics_build_entity_spec.rb

@@ -5,14 +5,14 @@
     described_class.new(build, request: double)
   end
 
-  context 'when build is a regular job' do
+  context 'build with an author' do
     let(:user) { create(:user) }
     let(:build) { create(:ci_build, author: user) }
 
     subject { entity.as_json }
 
-    it 'contains URLs' do
-      expect(subject).to include(:url, :branch_url, :commit_url)
+    it 'contains the URL' do
+      expect(subject).to include(:url)
     end
 
     it 'contains the author' do

spec/serializers/analytics_build_serializer_spec.rb

@@ -3,12 +3,10 @@
 describe AnalyticsBuildSerializer do
   let(:serializer) do
     described_class
-      .new(project: project)
-      .represent(resource)
+      .new.represent(resource)
   end
 
   let(:json) { serializer.as_json }
-  let(:project) { create(:project) }
   let(:resource) { create(:ci_build) }
 
   context 'when there is a single object provided' do
@@ -18,7 +16,7 @@
 
     it 'contains important elements of analyticsBuild' do
       expect(json)
-        .to include(:name, :branch, :short_sha, :date, :total_time, :url, :branch_url, :commit_url, :author)
+        .to include(:name, :branch, :short_sha, :date, :total_time, :url, :author)
     end
   end
 end

spec/serializers/analytics_generic_serializer_spec.rb

 require 'spec_helper'
 
-describe AnalyticsBuildSerializer do
+describe AnalyticsGenericSerializer do
   let(:serializer) do
     described_class
       .new(project: project)
       .represent(resource)
   end
 
+  let(:user) { create(:user) }
   let(:json) { serializer.as_json }
   let(:project) { create(:project) }
-  let(:resource) { create(:ci_build) }
+  let(:resource) {
+    {
+      total_time: "172802.724419",
+      title: "Eos voluptatem inventore in sed.",
+      iid: "1",
+      id: "1",
+      created_at: "2016-11-12 15:04:02.948604",
+      author: user,
+      entity: :merge_request
+    }
+  }
 
   context 'when there is a single object provided' do
     it 'it generates payload for single object' do
@@ -17,8 +28,7 @@
     end
 
     it 'contains important elements of analyticsBuild' do
-      expect(json)
-        .to include(:name, :branch, :short_sha, :date, :total_time, :url, :branch_url, :commit_url, :author)
+      expect(json).to include(:title, :iid, :date, :total_time, :url, :author)
     end
   end
 end