1
0

RemoteConnection.pm 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128
  1. package Selenium::Remote::Mock::RemoteConnection;
  2. # ABSTRACT: utility class to mock the responses from Selenium server
  3. use Moo;
  4. use JSON;
  5. use Carp;
  6. use Try::Tiny;
  7. extends 'Selenium::Remote::RemoteConnection';
  8. has 'spec' => (
  9. is => 'ro',
  10. required => 1,
  11. );
  12. has 'mock_cmds' => (
  13. is => 'ro',
  14. );
  15. has 'fake_session_id' => (
  16. is => 'lazy',
  17. builder => sub {
  18. my $id = join '',
  19. map +( 0 .. 9, 'a' .. 'z', 'A' .. 'Z' )[ rand( 10 + 26 * 2 ) ], 1 .. 50;
  20. return $id;
  21. },
  22. );
  23. has 'record' => (
  24. is => 'ro',
  25. default => sub { 0 }
  26. );
  27. has 'session_store' => (
  28. is => 'ro',
  29. default => sub { {} }
  30. );
  31. has 'session_id' => (
  32. is => 'rw',
  33. default => sub { undef },
  34. );
  35. sub BUILD {
  36. my $self = shift;
  37. $self->remote_server_addr('localhost');
  38. $self->port('4444');
  39. }
  40. sub check_status {
  41. return;
  42. }
  43. sub dump_session_store {
  44. my $self = shift;
  45. my ($file,$session_id) = @_;
  46. open (my $fh, '>', $file) or croak "Opening '$file' failed";
  47. my $session_store = $self->session_store;
  48. my $dump = {};
  49. foreach my $path (keys %{$session_store->{$session_id}}) {
  50. $dump->{$path} = $session_store->{$session_id}->{$path};
  51. }
  52. my $json = JSON->new;
  53. $json->allow_blessed;
  54. my $json_session = $json->allow_nonref->utf8->encode($dump);
  55. print $fh $json_session;
  56. close ($fh);
  57. }
  58. sub request {
  59. my $self = shift;
  60. my ($resource, $params) = @_;
  61. my $method = $resource->{method};
  62. my $url = $resource->{url};
  63. my $no_content_success = $resource->{no_content_success} // 0;
  64. my $url_params = $resource->{url_params};
  65. if ( $self->record ) {
  66. my $json = JSON->new;
  67. $json->allow_blessed;
  68. my $response = $self->SUPER::request( $resource, $params, 1 );
  69. if ( ( $response->message ne 'No Content' )
  70. && ( $response->content ne '' ) )
  71. {
  72. if ( $response->content_type =~ m/json/i ) {
  73. my $decoded_json =
  74. $json->allow_nonref(1)->utf8(1)->decode( $response->content );
  75. $self->session_id( $decoded_json->{'sessionId'} )
  76. unless $self->session_id;
  77. }
  78. }
  79. my $content = '';
  80. if (($params) && ($params ne '')) {
  81. $content = $json->allow_nonref->utf8->encode($params);
  82. }
  83. $self->session_store->{$self->session_id}->{"$method $url $content"} = $response if ($self->session_id);
  84. return $self->_process_response($response,$no_content_success);
  85. }
  86. my $mock_cmds = $self->mock_cmds;
  87. my $spec = $self->spec;
  88. my $cmd = $mock_cmds->get_method_name_from_parameters({method => $method,url => $url});
  89. my $ret = {cmd_status => 'OK', cmd_return => 1};
  90. if (defined($spec->{$cmd})) {
  91. my $return_sub = $spec->{$cmd};
  92. if ($no_content_success) {
  93. $ret->{cmd_return} = 1;
  94. }
  95. else {
  96. my $mock_return = $return_sub->($url_params,$params);
  97. if (ref($mock_return) eq 'HASH') {
  98. $ret->{cmd_status} = $mock_return->{status};
  99. $ret->{cmd_return} = $mock_return->{return};
  100. $ret->{cmd_error} = $mock_return->{error} // ''
  101. }
  102. else {
  103. $ret = $mock_return;
  104. }
  105. }
  106. $ret->{session_id} = $self->fake_session_id if (ref($ret) eq 'HASH');
  107. }
  108. else {
  109. $ret->{sessionId} = $self->fake_session_id;
  110. }
  111. return $ret;
  112. }
  113. 1;