Skip to content

Commit 3cecf6b

Browse files
Yaminik1996Yaminik1996
authored
test: pubsub recordings for testMultipleSendReceive (#200)
1 parent 5dd3dfe commit 3cecf6b

File tree

15 files changed

+460
-0
lines changed

15 files changed

+460
-0
lines changed

‎blob/blob-client/src/test/java/com/salesforce/multicloudj/blob/client/AbstractBlobStoreIT.java‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1354,6 +1354,7 @@ public void testCopyFrom() throws IOException {
13541354

13551355
@Test
13561356
public void testVersionedCopyFrom() throws IOException {
1357+
Assumptions.assumeFalse(GCP_PROVIDER_ID.equals(harness.getProviderId()));
13571358

13581359
String key = "conformance-tests/versionedCopyFrom/blob";
13591360
String destKeyV1 = "conformance-tests/versionedCopyFrom/copied-from-blob-v1";

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-28zpuvgr32.json‎

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
{
2+
"id" : "1991d76b-0556-4a95-813d-6a8fd38e8e58",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_subscriptions_test-subscriptionacknowledge",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/subscriptions/test-subscription:acknowledge?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.ackIds"
9+
}, {
10+
"matchesJsonPath" : "$.ackIds[*]"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:45:58 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "1991d76b-0556-4a95-813d-6a8fd38e8e58",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-1-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:acknowledge",
30+
"requiredScenarioState" : "scenario-1-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:acknowledge-2",
31+
"newScenarioState" : "scenario-1-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:acknowledge-3",
32+
"insertionIndex" : 45
33+
}

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-5mzftpski6.json‎

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
{
2+
"id" : "b93002e1-fbd1-4b6b-9a01-bd07bac6f907",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_topics_test-topicpublish",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/topics/test-topic:publish?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.messages"
9+
}, {
10+
"matchesJsonPath" : "$.messages[*]"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{\n \"messageIds\": [\n \"17324647289219348\"\n ]\n}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:45:53 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "b93002e1-fbd1-4b6b-9a01-bd07bac6f907",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish",
30+
"requiredScenarioState" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish-2",
31+
"newScenarioState" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish-3",
32+
"insertionIndex" : 52
33+
}

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-apnnms4ybk.json‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
{
2+
"id" : "a5037c48-3b76-4c1a-a3a2-10197a0bc8b7",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_subscriptions_test-subscriptionpull",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/subscriptions/test-subscription:pull?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.returnImmediately"
9+
}, {
10+
"matchesJsonPath" : "$.maxMessages"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{\n \"receivedMessages\": [\n {\n \"ackId\": \"SDofGScFTF5FLTg1aDwFUUZTBwcrHUQdDmINCncle09eb35jGmpaEwECRFosX14aWG1bDiANUQcZYExhbdKxz_g0Z3J_WFkeCG1ZWXQAVA0YdXtidkK2hL7b6ciffkEnNdC3gIwxcbDbyZ5SZig9JxJLLD5-KTkORUZXWgEhHQwEUTsICjJSTl9HMWI2KjUaUBxRGQw7C0Rb\",\n \"message\": {\n \"data\": \"aXQtYWNrLXRlc3Q=\",\n \"attributes\": {\n \"case\": \"ack\"\n },\n \"messageId\": \"17255555175017633\",\n \"publishTime\": \"2025-12-09T21:57:13.289Z\"\n }\n },\n {\n \"ackId\": \"SDofGScFTF5FLTg1aDwFUUZTBwcrHUQdDmINCncle09eb39kGmpaEwECRFosX14aXD1VXX0NVQcZYExhbdKxz_g0Z3J_WFofCWBVWnEDUwUQcH5kcUK2hL7b6ciffkEnNdC3gIwxcbDbyZ5SZig9JxJLLD5-KTkORUZXWgEhHQwEUTsICjJSTl9HMWI2KjUaUBxRGQw7C0Rb\",\n \"message\": {\n \"data\": \"YmF0Y2gtbmFjay0x\",\n \"attributes\": {\n \"batch\": \"nack\"\n },\n \"messageId\": \"17144896442892354\",\n \"publishTime\": \"2025-12-09T21:57:05Z\"\n }\n },\n {\n \"ackId\": \"Oh8ZJwVMXkUtODVoPAVRRlMHBysdRB0OYg0KdyV6T15vf2QaaloTAQJEWixfXhpcPVVdfQ1QDRNyb1B1cuL43ftzcV9eXBoJbVxYcgdUDBB2fmV8anL_lr2c_-W-egExUOS3qf5nLaSwxoJGZis9JxJLLD5-KTkORUZXWgEhHQwEUTsICjJSTl9HMWI2KjUaUBxRGQw7C0RbSA\",\n \"message\": {\n \"data\": \"aXQtbmFjay10ZXN0\",\n \"attributes\": {\n \"case\": \"nack\"\n },\n \"messageId\": \"17145047051943490\",\n \"publishTime\": \"2025-12-09T21:57:11.433Z\"\n }\n }\n ]\n}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:46:00 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "a5037c48-3b76-4c1a-a3a2-10197a0bc8b7",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-2-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:pull",
30+
"requiredScenarioState" : "scenario-2-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:pull-4",
31+
"insertionIndex" : 41
32+
}

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-bj1gatrqif.json‎

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
{
2+
"id" : "3c7b1820-eb8c-43eb-8f07-0295ec43cdc3",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_topics_test-topicpublish",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/topics/test-topic:publish?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.messages"
9+
}, {
10+
"matchesJsonPath" : "$.messages[*]"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{\n \"messageIds\": [\n \"17323645071166560\"\n ]\n}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:45:54 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "3c7b1820-eb8c-43eb-8f07-0295ec43cdc3",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish",
30+
"requiredScenarioState" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish-4",
31+
"newScenarioState" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish-5",
32+
"insertionIndex" : 50
33+
}

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-bqe7bu1ec6.json‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
{
2+
"id" : "0d7eb016-b7f0-4dbe-9a3a-12565c4962e6",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_subscriptions_test-subscriptionacknowledge",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/subscriptions/test-subscription:acknowledge?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.ackIds"
9+
}, {
10+
"matchesJsonPath" : "$.ackIds[*]"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:46:01 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "0d7eb016-b7f0-4dbe-9a3a-12565c4962e6",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-1-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:acknowledge",
30+
"requiredScenarioState" : "scenario-1-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:acknowledge-5",
31+
"insertionIndex" : 40
32+
}

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-cdf60pygyu.json‎

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
{
2+
"id" : "f5d5dc2c-bccb-4b91-8e11-31702ed1611a",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_topics_test-topicpublish",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/topics/test-topic:publish?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.messages"
9+
}, {
10+
"matchesJsonPath" : "$.messages[*]"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{\n \"messageIds\": [\n \"17324821503937121\"\n ]\n}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:45:54 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "f5d5dc2c-bccb-4b91-8e11-31702ed1611a",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish",
30+
"requiredScenarioState" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish-3",
31+
"newScenarioState" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish-4",
32+
"insertionIndex" : 51
33+
}

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-ext1qf5emq.json‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
{
2+
"id" : "b85fb913-fe6e-4302-8612-e2151df54aa9",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_topics_test-topicpublish",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/topics/test-topic:publish?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.messages"
9+
}, {
10+
"matchesJsonPath" : "$.messages[*]"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{\n \"messageIds\": [\n \"17324020394098143\"\n ]\n}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:45:55 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "b85fb913-fe6e-4302-8612-e2151df54aa9",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish",
30+
"requiredScenarioState" : "scenario-3-v1-projects-substrate-sdk-gcp-poc1-topics-test-topic:publish-5",
31+
"insertionIndex" : 49
32+
}

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-kl2hnf1nwk.json‎

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
{
2+
"id" : "efe1f22d-ead6-48d6-91b0-07fd3af33c36",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_subscriptions_test-subscriptionacknowledge",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/subscriptions/test-subscription:acknowledge?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.ackIds"
9+
}, {
10+
"matchesJsonPath" : "$.ackIds[*]"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:45:59 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "efe1f22d-ead6-48d6-91b0-07fd3af33c36",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-1-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:acknowledge",
30+
"requiredScenarioState" : "scenario-1-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:acknowledge-3",
31+
"newScenarioState" : "scenario-1-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:acknowledge-4",
32+
"insertionIndex" : 43
33+
}

‎pubsub/pubsub-gcp/src/test/resources/mappings/post-l3f3tcllss.json‎

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
{
2+
"id" : "4aa3ceaf-8938-49cf-8b61-875a31fc5d35",
3+
"name" : "v1_projects_substrate-sdk-gcp-poc1_subscriptions_test-subscriptionpull",
4+
"request" : {
5+
"url" : "/v1/projects/substrate-sdk-gcp-poc1/subscriptions/test-subscription:pull?$alt=json;enum-encoding%3Dint",
6+
"method" : "POST",
7+
"bodyPatterns" : [ {
8+
"matchesJsonPath" : "$.returnImmediately"
9+
}, {
10+
"matchesJsonPath" : "$.maxMessages"
11+
} ]
12+
},
13+
"response" : {
14+
"status" : 200,
15+
"body" : "{\n \"receivedMessages\": [\n {\n \"ackId\": \"SDofGScFTF5FLTg1aDwFUUZTBwcrHUQdDmINCncle09eb39kGmpaEwECRFosX14aXD1VXX0NUwcZYExhbd2xz_g0Z3J_WFofDmBbXnIBUQQddnxldkK2hL7b6ciffkEnNd-3gIwxce_79Y5TZig9JxJLLD5-KTkORUZXWgEhHQwEUTsICjJSTl9HMWI2KjUaUBxRGQw7C0Rb\",\n \"message\": {\n \"data\": \"YmF0Y2gtYWNrLTI=\",\n \"attributes\": {\n \"batch\": \"ack\"\n },\n \"messageId\": \"17143872760944143\",\n \"publishTime\": \"2025-12-09T21:57:00.316Z\"\n }\n },\n {\n \"ackId\": \"SDofGScFTF5FLTg1aDwFUUZTBwcrHUQdDmINCncle09eb39kGmpaEwECRFosX14aXD1VXX0NUgcZYExhbd2xz_g0Z3J_WFofCW5UVHMHUgUfdnxjfEK2hL7b6ciffkEnNd-3gIwxce_79Y5TZig9JxJLLD5-KTkORUZXWgEhHQwEUTsICjJSTl9HMWI2KjUaUBxRGQw7C0Rb\",\n \"message\": {\n \"data\": \"YmF0Y2gtYWNrLTM=\",\n \"attributes\": {\n \"batch\": \"ack\"\n },\n \"messageId\": \"17144688603864129\",\n \"publishTime\": \"2025-12-09T21:57:00.617Z\"\n }\n }\n ]\n}\n",
16+
"headers" : {
17+
"X-Frame-Options" : "SAMEORIGIN",
18+
"Alt-Svc" : "h3=\":443\"; ma=2592000,h3-29=\":443\"; ma=2592000",
19+
"Server" : "ESF",
20+
"X-Content-Type-Options" : "nosniff",
21+
"Vary" : [ "Origin", "X-Origin", "Referer" ],
22+
"X-XSS-Protection" : "0",
23+
"Date" : "Thu, 11 Dec 2025 20:45:59 GMT",
24+
"Content-Type" : "application/json; charset=UTF-8"
25+
}
26+
},
27+
"uuid" : "4aa3ceaf-8938-49cf-8b61-875a31fc5d35",
28+
"persistent" : true,
29+
"scenarioName" : "scenario-2-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:pull",
30+
"requiredScenarioState" : "scenario-2-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:pull-3",
31+
"newScenarioState" : "scenario-2-v1-projects-substrate-sdk-gcp-poc1-subscriptions-test-subscription:pull-4",
32+
"insertionIndex" : 44
33+
}

0 commit comments

Comments
 (0)