RemoteConnection.pm 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. package Selenium::Remote::RemoteConnection;
  2. #ABSTRACT: Connect to a selenium server
  3. use Moo;
  4. use Try::Tiny;
  5. use LWP::UserAgent;
  6. use HTTP::Headers;
  7. use HTTP::Request;
  8. use Net::Ping;
  9. use Carp qw(croak);
  10. use JSON;
  11. use Data::Dumper;
  12. use Selenium::Remote::ErrorHandler;
  13. has 'remote_server_addr' => (
  14. is => 'rw',
  15. );
  16. has 'port' => (
  17. is => 'rw',
  18. );
  19. has 'debug' => (
  20. is => 'rw',
  21. default => sub { 0 }
  22. );
  23. has 'ua' => (
  24. is => 'lazy',
  25. builder => sub { return LWP::UserAgent->new; }
  26. );
  27. sub BUILD {
  28. my $self = shift;
  29. my $status;
  30. try {
  31. $status = $self->request('GET','status');
  32. }
  33. catch {
  34. croak "Could not connect to SeleniumWebDriver: $_" ;
  35. };
  36. if($status->{cmd_status} ne 'OK') {
  37. # Could be grid, see if we can talk to it
  38. $status = undef;
  39. $status = $self->request('GET', 'grid/api/testsession');
  40. }
  41. unless ($status->{cmd_status} eq 'OK') {
  42. croak "Selenium server did not return proper status";
  43. }
  44. }
  45. # This request method is tailored for Selenium RC server
  46. sub request {
  47. my ($self, $method, $url, $params) = @_;
  48. my $content = '';
  49. my $fullurl = '';
  50. # Construct full url.
  51. if ($url =~ m/^http/g) {
  52. $fullurl = $url;
  53. }
  54. elsif ($url =~ m/grid/g) {
  55. $fullurl =
  56. "http://"
  57. . $self->remote_server_addr . ":"
  58. . $self->port
  59. . "/$url";
  60. }
  61. else {
  62. $fullurl =
  63. "http://"
  64. . $self->remote_server_addr . ":"
  65. . $self->port
  66. . "/wd/hub/$url";
  67. }
  68. if ((defined $params) && $params ne '') {
  69. my $json = JSON->new;
  70. $json->allow_blessed;
  71. $content = $json->allow_nonref->utf8->encode($params);
  72. }
  73. print "REQ: $url, $content\n" if $self->debug;
  74. # HTTP request
  75. my $header =
  76. HTTP::Headers->new(Content_Type => 'application/json; charset=utf-8');
  77. $header->header('Accept' => 'application/json');
  78. my $request = HTTP::Request->new($method, $fullurl, $header, $content);
  79. my $response = $self->ua->request($request);
  80. return $self->_process_response($response);
  81. }
  82. sub _process_response {
  83. my ($self, $response) = @_;
  84. my $data; # server response 'value' that'll be returned to the user
  85. my $json = JSON->new;
  86. if ($response->is_redirect) {
  87. return $self->request('GET', $response->header('location'));
  88. }
  89. else {
  90. my $decoded_json = undef;
  91. print "RES: ".$response->decoded_content."\n\n" if $self->debug;
  92. if (($response->message ne 'No Content') && ($response->content ne '')) {
  93. if ($response->content_type !~ m/json/i) {
  94. $data->{'cmd_return'} = 'Server returned error message '.$response->content.' instead of data';
  95. return $data;
  96. }
  97. $decoded_json = $json->allow_nonref(1)->utf8(1)->decode($response->content);
  98. $data->{'sessionId'} = $decoded_json->{'sessionId'};
  99. }
  100. if ($response->is_error) {
  101. my $error_handler = Selenium::Remote::ErrorHandler->new;
  102. $data->{'cmd_status'} = 'NOTOK';
  103. if (defined $decoded_json) {
  104. $data->{'cmd_return'} = $error_handler->process_error($decoded_json);
  105. }
  106. else {
  107. $data->{'cmd_return'} = 'Server returned error code '.$response->code.' and no data';
  108. }
  109. return $data;
  110. }
  111. elsif ($response->is_success) {
  112. $data->{'cmd_status'} = 'OK';
  113. if (defined $decoded_json) {
  114. $data->{'cmd_return'} = $decoded_json->{'value'};
  115. }
  116. else {
  117. $data->{'cmd_return'} = 'Server returned status code '.$response->code.' but no data';
  118. }
  119. return $data;
  120. }
  121. else {
  122. # No idea what the server is telling me, must be high
  123. $data->{'cmd_status'} = 'NOTOK';
  124. $data->{'cmd_return'} = 'Server returned status code '.$response->code.' which I don\'t understand';
  125. return $data;
  126. }
  127. }
  128. }
  129. 1;
  130. __END__