Fix the batcher/oidc integration test

Author: mayorova

t/apicast-policy-3scale-batcher.t

@@ -484,11 +484,10 @@ rewrite_by_lua_block {
 --- no_error_log
 [error]
 
-
-
 === TEST 6: caches successful authorizations with app_id only
-This test checks that the policy caches successful authorizations. To do that,
-we define a backend that makes sure that it's called only once.
+This test checks that the policy a) caches successful authorizations and b) reports correctly.
+For a) we define a backend that makes sure that it's called only once.
+For b) we force the batch reporting and check that transactions.xml receive it in the expected format.
 --- http_config
 include $TEST_NGINX_UPSTREAM_CONFIG;
 lua_shared_dict cached_auths 1m;
@@ -512,13 +511,14 @@ init_by_lua_block {
         backend_authentication_type = 'service_token',
         backend_authentication_value = 'token-value',
         proxy = {
-          error_status_auth_missing = 403,
           authentication_method = 'oidc',
           oidc_issuer_endpoint = 'https://example.com/auth/realms/apicast',
           backend = { endpoint = "http://127.0.0.1:$TEST_NGINX_SERVER_PORT" },
           api_backend = "http://127.0.0.1:$TEST_NGINX_SERVER_PORT/api-backend/",
+          error_auth_missing = 'credentials missing!',
+          error_status_auth_missing = 401,
           proxy_rules = {
-            { pattern = '/', http_method = 'GET', metric_system_name = 'hits', delta = 2 }
+            { pattern = '/', http_method = 'GET', metric_system_name = 'hits', delta = 1 }
           },
           policy_chain = {
             { name = 'apicast.policy.3scale_batcher', configuration = {} },
@@ -544,22 +544,54 @@ init_by_lua_block {
       end
     }
   }
+  location /transactions.xml {
+    content_by_lua_block {
+      ngx.say('report OK')
+    }
+  }
+
+  location /force_report_to_backend {
+    content_by_lua_block {
+      local ReportsBatcher = require ('apicast.policy.3scale_batcher.reports_batcher')
+      local reporter = require ('apicast.policy.3scale_batcher.reporter')
+      local http_ng_resty = require('resty.http_ng.backend.resty')
+      local backend_client = require('apicast.backend_client')
+
+      local service_id = 42
+
+      local reports_batcher = ReportsBatcher.new(
+        ngx.shared.batched_reports, 'batched_reports_locks')
+
+      local reports = reports_batcher:get_all(service_id)
+
+      local backend = backend_client:new(
+        {
+          id = service_id,
+          backend_authentication_type = 'service_token',
+          backend_authentication_value = 'token-value',
+          backend = { endpoint = "http://127.0.0.1:$TEST_NGINX_SERVER_PORT" }
+        }, http_ng_resty)
+
+      reporter.report(reports, service_id, backend, reports_batcher)
+      ngx.say('force report OK')
+    }
+  }
   location /api-backend {
      echo 'yay, api backend';
   }
 --- request eval
-[ "GET /test", "GET /test" ]
+[ "GET /test", "GET /test", "GET /force_report_to_backend", "GET /transactions.xml"]
 --- error_code eval
-[ 200, 200 ]
+[ 200, 200 , 200, 200 ]
 --- response_body eval
-["yay, api backend\x{0a}","yay, api backend\x{0a}"]
+["yay, api backend\x{0a}","yay, api backend\x{0a}","force report OK\x{0a}", "report OK\x{0a}"]
 --- more_headers eval
 use Crypt::JWT qw(encode_jwt);
 my $jwt = encode_jwt(payload => {
   aud => 'appid',
   sub => 'someone',
   iss => 'https://example.com/auth/realms/apicast',
   exp => time + 3600 }, key => \$::rsa, alg => 'RS256', extra_headers => { kid => 'somekid' });
-["Authorization: Bearer $jwt", "Authorization: Bearer $jwt"]
+["Authorization: Bearer $jwt", "Authorization: Bearer $jwt", "" , ""]
 --- no_error_log
 [error]