fix: solve mismatch into sync matchs

Author: Bulletdev

app/modules/matches/controllers/matches_controller.rb

@@ -139,8 +139,9 @@ def stats
       end
 
       def import
-        player_id = validate_required_param!(:player_id)
-        count = integer_param(:count, default: 20, min: 1, max: 100)
+        player_id    = validate_required_param!(:player_id)
+        count        = integer_param(:count, default: 20, min: 1, max: 100)
+        force_update = params[:force_update].in?([true, 'true', '1'])
 
         player = organization_scoped(Player).find(player_id)
 
@@ -152,17 +153,20 @@ def import
           )
         end
 
-        job_id = ImportPlayerMatchesJob.perform_later(
-          player.id,
-          current_organization.id,
-          count
-        ).job_id
-
-        render_success({
-                         job_id: job_id,
-                         player_id: player.id.to_s,
-                         count: count
-                       }, message: 'Match import queued successfully')
+        result = ImportMatchesService.new(
+          player: player,
+          organization: current_organization,
+          count: count,
+          force_update: force_update
+        ).call
+
+        render_success(result, message: 'Matches import started successfully')
+      rescue RiotApiService::RiotApiError => e
+        render_error(
+          message: "Riot API error: #{e.message}",
+          code: 'RIOT_API_ERROR',
+          status: :service_unavailable
+        )
       end
 
       private

app/modules/matches/services/import_matches_service.rb

@@ -0,0 +1,57 @@
+# frozen_string_literal: true
+
+module Matches
+  # Fetches match IDs from Riot API for a player and enqueues SyncMatchJob
+  # for each new match. Returns counts synchronously so the caller can
+  # respond with meaningful feedback without waiting for individual syncs.
+  class ImportMatchesService
+    def initialize(player:, organization:, count: 20, force_update: false)
+      @player       = player
+      @organization = organization
+      @count        = count
+      @force_update = force_update
+    end
+
+    # @return [Hash] counts: total_matches_found, imported, already_imported, updated
+    def call
+      match_ids = fetch_match_ids
+      tally = { imported: 0, already_imported: 0, updated: 0 }
+
+      match_ids.each { |id| process_match(id, tally) }
+
+      tally.merge(total_matches_found: match_ids.size)
+    end
+
+    private
+
+    def fetch_match_ids
+      RiotApiService.new.get_match_history(
+        puuid: @player.riot_puuid,
+        region: region,
+        count: @count
+      )
+    end
+
+    def process_match(match_id, tally)
+      if Match.exists?(riot_match_id: match_id)
+        handle_existing_match(match_id, tally)
+      else
+        SyncMatchJob.perform_later(match_id, @organization.id, region)
+        tally[:imported] += 1
+      end
+    end
+
+    def handle_existing_match(match_id, tally)
+      if @force_update
+        SyncMatchJob.perform_later(match_id, @organization.id, region, force_update: true)
+        tally[:updated] += 1
+      else
+        tally[:already_imported] += 1
+      end
+    end
+
+    def region
+      @player.region || 'BR'
+    end
+  end
+end