1 files changed, 94 insertions, 0 deletions
diff --git a/lib/Travel/Status/DE/EFA/Trip.pm b/lib/Travel/Status/DE/EFA/Trip.pm
new file mode 100644
index 0000000..3f5b134
--- /dev/null
+++ b/lib/Travel/Status/DE/EFA/Trip.pm
@@ -0,0 +1,94 @@
+package Travel::Status::DE::EFA::Trip;
+
+use strict;
+use warnings;
+use 5.010;
+
+use DateTime::Format::Strptime;
+
+use parent 'Class::Accessor';
+
+our $VERSION = '2.02';
+
+Travel::Status::DE::EFA::Trip->mk_ro_accessors(
+	qw(operator name line number type id dest_name dest_id));
+
+sub new {
+	my ( $obj, %conf ) = @_;
+
+	my $json = $conf{json}{transportation};
+
+	my $ref = {
+		operator     => $json->{operator}{name},
+		polyline     => $json->{coords},
+		name         => $json->{name},
+		line         => $json->{disassembledName},
+		number       => $json->{properties}{trainNumber},
+		type         => $json->{properties}{trainType},
+		id           => $json->{id},
+		dest_name    => $json->{destination}{name},
+		dest_id      => $json->{destination}{id},
+		route_raw    => $json->{locationSequence},
+		strptime_obj => DateTime::Format::Strptime->new(
+			pattern   => '%Y-%m-%dT%H:%M:%SZ',
+			time_zone => 'UTC'
+		),
+	};
+	return bless( $ref, $obj );
+}
+
+sub polyline {
+	my ($self) = @_;
+
+	return @{ $self->{polyline} // [] };
+}
+
+sub parse_dt {
+	my ( $self, $value ) = @_;
+
+	if ($value) {
+		my $dt = $self->{strptime_obj}->parse_datetime($value);
+		if ($dt) {
+			return $dt->set_time_zone('Europe/Berlin');
+		}
+	}
+	return undef;
+}
+
+sub route {
+	my ($self) = @_;
+
+	if ( $self->{route} ) {
+		return @{ $self->{route} };
+	}
+
+	for my $stop ( @{ $self->{route_raw} // [] } ) {
+		push(
+			@{ $self->{route} },
+			{
+				sched_arr => $self->parse_dt( $stop->{arrivalTimePlanned} ),
+				sched_dep => $self->parse_dt( $stop->{departureTimePlanned} ),
+				rt_arr    => $self->parse_dt( $stop->{arrivalTimeEstimated} ),
+				rt_dep    => $self->parse_dt( $stop->{departureTimeEstimated} ),
+				latlon    => $stop->{coord},
+				name_full => $stop->{name},
+				name      => $stop->{parent}{disassembledName},
+				place     => $stop->{parent}{parent}{name},
+				niveau    => $stop->{niveau},
+				id        => $stop->{id},
+			}
+		);
+	}
+
+	delete $self->{route_raw};
+
+	return @{ $self->{route} // [] };
+}
+
+sub TO_JSON {
+	my ($self) = @_;
+
+	return { %{$self} };
+}
+
+1;