dawarich/app/services/photos/import_parser.rb

# frozen_string_literal: true

class Photos::ImportParser
  include Imports::Broadcaster

  attr_reader :import, :json, :user_id

  def initialize(import, user_id)
    @import = import
    @json = import.raw_data
    @user_id = user_id
  end

  def call
    json.each.with_index(1) { |point, index| create_point(point, index) }
  end

  def create_point(point, index)
    return 0 if point['latitude'].blank? || point['longitude'].blank? || point['timestamp'].blank?
    return 0 if point_exists?(point, point['timestamp'])

    Point.create(
      lonlat: "POINT(#{point['longitude']} #{point['latitude']})",
      timestamp:  point['timestamp'],
      raw_data:   point,
      import_id:  import.id,
      user_id:
    )

    broadcast_import_progress(import, index)
  end

  def point_exists?(point, timestamp)
    Point.exists?(
      lonlat: "POINT(#{point['longitude']} #{point['latitude']})",
      timestamp:,
      user_id:
    )
  end
end