diff options
| -rw-r--r-- | lib/Travel/Status/DE/HAFAS/StopFinder.pm | 91 |
1 files changed, 87 insertions, 4 deletions
diff --git a/lib/Travel/Status/DE/HAFAS/StopFinder.pm b/lib/Travel/Status/DE/HAFAS/StopFinder.pm index 0ae3800..9b3d232 100644 --- a/lib/Travel/Status/DE/HAFAS/StopFinder.pm +++ b/lib/Travel/Status/DE/HAFAS/StopFinder.pm @@ -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 |