Fixes for activities endpoints.

app/controllers/activities_controller.rb

@@ -145,8 +145,9 @@ def show
 
   protected
     def set_activity
-      response = Activity.find_by_id(params[:id])
-      @activity = response.results.first
+      response = Activity.find_by_request_uuid!(params[:id])
+      @activity = response
+
       fail ActiveRecord::RecordNotFound if @activity.blank?
     end
 end

app/serializers/activity_serializer.rb

@@ -14,55 +14,33 @@ class ActivitySerializer
              :version
 
   attribute :changes do |object, params|
-    changes = object._source.changes
-    pub = changes.publisher
-    pub_obj = changes.publisher_obj
-
-    ret = changes
+    # Object is of different class if it comes from /activities/:uid
+    if object.is_a? Activity
+      changes = object.audited_changes
+      action = object.action
+    else
+      changes = object._source.changes
+      action = object._source.action
+    end
 
-    if object._source.action == "update"
-      if pub || pub_obj
-        if params[:publisher] == "true"
-          if !pub_obj
-            changes.publisher =
-              [
-                { "name": pub[0] },
-                { "name": pub[1] },
-              ]
-          else
-            changes.publisher = changes.publisher_obj
-          end
-        else
-          if !pub
-            changes.publisher = [ pub_obj[0].name, pub_obj[1].name ]
-          end
-        end
+    pub = changes&.dig("publisher")
+    pub_obj = changes&.dig("publisher_obj")
 
-        ret = changes
+    if params&.dig(:publisher) == "true"
+      if pub_obj
+        changes[:publisher] = pub_obj
+      else
+        changes[:publisher] = action == "update" ? [{ "name": pub[0] }, { "name": pub[1] }] : { "name": pub }
       end
-    elsif object._source.action == "create"
-      if pub || pub_obj
-        if params[:publisher] == "true"
-          if !pub_obj
-            changes.publisher = { "name": pub }
-          else
-            changes.publisher = changes.publisher_obj
-          end
-        else
-          if !pub
-            changes.publisher = pub_obj.name
-          end
-        end
-
-        ret = changes
+    else
+      if pub_obj
+        changes[:publisher] = action == "update" ? [pub_obj[0]["name"], pub_obj[1]["name"]] : pub_obj["name"]
       end
     end
 
-    if pub_obj
-      changes.delete("publisher_obj")
-    end
+    changes.delete("publisher_obj") if pub_obj
 
-    ret
+    changes
   end
 
   attribute "prov:wasDerivedFrom", &:was_derived_from

config/routes.rb

@@ -178,7 +178,7 @@
 
   resources :heartbeat, only: %i[index]
 
-  resources :activities, only: %i[index show]
+  resources :activities, only: %i[index show], constraints: { id: /.+/ }
 
   resources :clients, constraints: { id: /.+/ } do
     resources :prefixes, constraints: { id: /.+/ }

lib/tasks/activity.rake

@@ -36,6 +36,11 @@ namespace :activity do
     puts Activity.monitor_reindex
   end
 
+  desc "Create alias for activities"
+  task create_alias: :environment do
+    puts Activity.create_alias(index: ENV["INDEX"], alias: ENV["ALIAS"])
+  end
+
   desc "Import all activities"
   task import: :environment do
     from_id = (ENV["FROM_ID"] || 1).to_i

lib/tasks/elasticsearch.rake

@@ -32,6 +32,7 @@ namespace :elasticsearch do
     Rake::Task["event:create_alias"].invoke
 
     Rake::Task["activity:create_index"].invoke
+    Rake::Task["activity:create_alias"].invoke
 
     Rake::Task["contact:create_index"].invoke
     Rake::Task["contact:create_alias"].invoke