StopFinder: add new_p constructor (346aa5f8) · Commits · derf / Travel-Status-DE-HAFAS

lib/Travel/Status/DE/HAFAS/StopFinder.pm

+87 −4

Original line number	Diff line number	Diff line
		@@ -14,13 +14,15 @@ use LWP::UserAgent;

		our $VERSION = '4.04';

		# {{{ Constructors

		sub new {
		my ( $obj, %conf ) = @_;

		my $lang = $conf{language} // 'd';
		my $ua = $conf{ua};

		if ( not $ua ) {
		if ( not $ua and not $conf{async} ) {
		my %lwp_options = %{ $conf{lwp_options} // { timeout => 10 } };
		$ua = LWP::UserAgent->new(%lwp_options);
		$ua->env_proxy;
		@@ -46,6 +48,10 @@ sub new {

		bless( $ref, $obj );

		if ( $conf{async} ) {
		return $ref;
		}

		my $url = $conf{url} . "/${lang}n";

		$reply = $ua->post( $url, $ref->{post} );
		@@ -69,6 +75,62 @@ sub new {
		return $ref;
		}

		sub new_p {
		my ( $obj, %conf ) = @_;
		my $promise = $conf{promise}->new;

		if ( not $conf{input} ) {
		return $promise->reject('You need to specify an input value');
		}
		if ( not $conf{url} ) {
		return $promise->reject('You need to specify a URL');
		}

		my $self = $obj->new( %conf, async => 1 );
		$self->{promise} = $conf{promise};

		my $lang = $conf{language} // 'd';
		my $url = $conf{url} . "/${lang}n";
		$conf{user_agent}->post_p( $url, form => $self->{post} )->then(
		sub {
		say "then";
		my ($tx) = @_;
		if ( my $err = $tx->error ) {
		$promise->reject(
		"POST $url returned HTTP $err->{code} $err->{message}");
		return;
		}
		my $content = $tx->res->body;

		say $content;
		$self->{raw_reply} = $content;

		$self->{raw_reply} =~ s{ ^ SLs [.] sls = }{}x;
		$self->{raw_reply} =~ s{ ; SLs [.] showSuggestion [(] [)] ; $ }{}x;

		if ( $self->{developer_mode} ) {
		say $self->{raw_reply};
		}

		$self->{json} = from_json( $self->{raw_reply} );

		$promise->resolve($self);
		return;
		}
		)->catch(
		sub {
		say "catch";
		my ($err) = @_;
		$promise->reject($err);
		return;
		}
		)->wait;

		return $promise;
		}

		# }}}

		sub errstr {
		my ($self) = @_;

		@@ -172,18 +234,39 @@ you can use an empty hashref to override it.

		=back

		=item $status->errstr
		=item my $stopfinder_p = Travel::Status::DE::HAFAS::StopFinder->new_p(I<%opt>)

		Return a promise that resolves into a Travel::Status::DE::HAFAS::StopFinder instance
		($stopfinder) on success and rejects with an error message ($stopfinder->errstr) on
		failure. In addition to the arguments of B<new>, the following mandatory
		arguments must be set.

		=over

		=item B<promise> => I<promises module>

		Promises implementation to use for internal promises as well as B<new_p> return
		value. Recommended: Mojo::Promise(3pm).

		=item B<user_agent> => I<user agent>

		User agent instance to use for asynchronous requests. The object must implement
		a B<post_p> function. Recommended: Mojo::UserAgent(3pm).

		=back

		=item $stopfinder->errstr

		In case of an error in the HTTP request, returns a string describing it. If
		no error occurred, returns undef.

		=item $status->results
		=item $stopfinder->results

		Returns a list of stop candidates. Each list element is a hash reference. The
		hash keys are B<id> (IBNR / UIC station code) and B<name> (stop name). Both can
		be used as input for the Travel::Status::DE::HAFAS(3pm) constructor.

		If no matching results were found or the parser / http request failed, returns
		If no matching results were found or the parser / HTTP request failed, returns
		the empty list.

		=back

Admin message