1
0

RemoteConnection.pm 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154
  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/hub/status');
  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_status'} = 'NOTOK';
  95. $data->{'cmd_return'} = 'Server returned error message '.$response->content.' instead of data';
  96. return $data;
  97. }
  98. $decoded_json = $json->allow_nonref(1)->utf8(1)->decode($response->content);
  99. $data->{'sessionId'} = $decoded_json->{'sessionId'};
  100. }
  101. if ($response->is_error) {
  102. my $error_handler = Selenium::Remote::ErrorHandler->new;
  103. $data->{'cmd_status'} = 'NOTOK';
  104. if (defined $decoded_json) {
  105. $data->{'cmd_return'} = $error_handler->process_error($decoded_json);
  106. }
  107. else {
  108. $data->{'cmd_return'} = 'Server returned error code '.$response->code.' and no data';
  109. }
  110. return $data;
  111. }
  112. elsif ($response->is_success) {
  113. $data->{'cmd_status'} = 'OK';
  114. if (defined $decoded_json) {
  115. $data->{'cmd_return'} = $decoded_json->{'value'} // 'No Content';
  116. }
  117. else {
  118. $data->{'cmd_return'} = 'Server returned status code '.$response->code.' but no data';
  119. }
  120. return $data;
  121. }
  122. else {
  123. # No idea what the server is telling me, must be high
  124. $data->{'cmd_status'} = 'NOTOK';
  125. $data->{'cmd_return'} = 'Server returned status code '.$response->code.' which I don\'t understand';
  126. return $data;
  127. }
  128. }
  129. }
  130. 1;
  131. __END__