Add import route

app/controllers/internal_controller.rb

@@ -82,4 +82,54 @@ def show_registration
     registration = Registration.find(attendee_id)
     render json: registration
   end
+
+  def import_registrations
+    competition_id = params.require(:competition_id)
+    to_create = params[:create] || []
+    to_update = params[:update] || []
+    to_delete = params[:delete] || []
+    if to_create.any?
+      RegistrationHistory.import(to_create.map do |r|
+        {
+          attendee_id: r['attendee_id'],
+          entries: [History.new({
+                                  'changed_attributes' => {
+                                    event_ids: r['event_ids'],
+                                    status: r['competing_status'],
+                                  },
+                                  'actor_type' => r['actor_type'],
+                                  'actor_id' => r['actor_id'],
+                                  'action' => 'Import',
+                                  'timestamp' => Time.zone.now,
+                                })],
+        }
+      end)
+      Registration.import(to_create.map do |r|
+        {
+          attendee_id: r['attendee_id'],
+          competition_id: competition_id,
+          user_id: r['user_id'],
+          competing_status: r['competing_status'],
+          lanes: [
+            LaneFactory.competing_lane(
+              event_ids: r['event_ids'],
+              registration_status: r['competing_status'],
+            ),
+          ],
+        }
+      end)
+    end
+    to_update.each do |r|
+      registration = Registration.find(r['attendee_id'])
+      registration.update(r['attendee_id'], competing_status: r['competing_status'], lanes: [LaneFactory.competing_lane(event_ids: r['event_ids'], registration_status: r['competing_status'])])
+      registration.history.add_entry({ event_ids: r['event_ids'], status: r['competing_status'] }, r['actor_type'], r['actor_id'], 'import')
+    end
+    to_delete.each do |r|
+      Registration.update(r['attendee_id'], competing_status: 'cancelled', lanes: [LaneFactory.competing_lane(event_ids: r['event_ids'], registration_status: 'cancelled')])
+      registration.history.add_entry({ event_ids: r['event_ids'], status: 'cancelled' }, r['actor_type'], r['actor_id'], 'import')
+    end
+    render json: { errors: [] }
+  rescue StandardError => e
+    render json: { errors: [e.to_s] }, status: :unprocessable_entity
+  end
 end

config/routes.rb

@@ -11,6 +11,7 @@
   get '/healthcheck', to: 'healthcheck#index'
   post '/api/internal/v1/update_payment', to: 'internal#update_payment_status'
   get '/api/internal/v1/:competition_id/registrations', to: 'internal#list_registrations'
+  post '/api/internal/v1/:competition_id/registrations/import', to: 'internal#import_registrations'
   get '/api/internal/v1/:attendee_id', to: 'internal#show_registration'
   get '/api/internal/v1/users/:user_id/registrations', to: 'internal#registrations_for_user'
   get '/api/v1/register', to: 'registration#show'