mirror of
https://github.com/Freika/dawarich.git
synced 2026-01-12 02:01:39 -05:00
64 lines
1.5 KiB
Ruby
64 lines
1.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Gpx::TrackParser
|
|
attr_reader :import, :json, :user_id
|
|
|
|
def initialize(import, user_id)
|
|
@import = import
|
|
@json = import.raw_data
|
|
@user_id = user_id
|
|
end
|
|
|
|
def call
|
|
tracks = json['gpx']['trk']
|
|
tracks_arr = tracks.is_a?(Array) ? tracks : [tracks]
|
|
|
|
tracks_arr
|
|
.map { parse_track(_1) }
|
|
.flatten
|
|
.reduce { |result, points| result.merge(points) { _2 + _3 } }
|
|
end
|
|
|
|
private
|
|
|
|
def parse_track(track)
|
|
segments = track['trkseg']
|
|
segments_arr = segments.is_a?(Array) ? segments : [segments]
|
|
|
|
segments_arr.map do |segment|
|
|
trackpoints = segment['trkpt']
|
|
|
|
points = trackpoints.reduce(0) { _1 + create_point(_2) }
|
|
doubles = trackpoints.size - points
|
|
processed = points + doubles
|
|
|
|
{ raw_points: trackpoints.size, points:, doubles:, processed: }
|
|
end
|
|
end
|
|
|
|
def create_point(point)
|
|
return 0 if point['lat'].blank? || point['lon'].blank? || point['time'].blank?
|
|
return 0 if point_exists?(point)
|
|
|
|
Point.create(
|
|
latitude: point['lat'].to_d,
|
|
longitude: point['lon'].to_d,
|
|
altitude: point['ele'].to_i,
|
|
timestamp: Time.parse(point['time']).to_i,
|
|
import_id: import.id,
|
|
raw_data: point,
|
|
user_id:
|
|
)
|
|
|
|
1
|
|
end
|
|
|
|
def point_exists?(point)
|
|
Point.exists?(
|
|
latitude: point['lat'].to_d,
|
|
longitude: point['lon'].to_d,
|
|
timestamp: Time.parse(point['time']).to_i,
|
|
user_id:
|
|
)
|
|
end
|
|
end
|