records-changed notification not arriving at registered consumer GCP Pre-shipping instance
Hi,
I am using GCP pre-shipping instance hosted at https://preship.gcp.gnrg-osdu.projects.epam.com. Our application is being registered as subscriber to records-changed
event. Here is the response of request to get subscription
Steps to reproduce this issue
- Register subscriber
- Check subscription
- Add new record to storage service
- Check if subscriber receives notification or not
Register subscriber
Endpoint
https://preship.gcp.gnrg-osdu.projects.epam.com/api/register/v1/subscription
Request Body
{
"name": "Alloy Subscription azuredataalloyscom",
"description": "Alloy Subscription",
"topic": "records-changed",
"pushEndpoint": "https://azure.dataalloys.com/an/notification/consumer",
"secret": {
"secretType": "HMAC",
"value": "<HMAC>"
}
}
Check subscription
Endpoint
https://preship.gcp.gnrg-osdu.projects.epam.com/api/register/v1/subscription/cmVjb3Jkcy1jaGFuZ2VkaHR0cHM6Ly9henVyZS5kYXRhYWxsb3lzLmNvbS9hbi9ub3RpZmljYXRpb24vY29uc3VtZXI=
Response
{
"id": "cmVjb3Jkcy1jaGFuZ2VkaHR0cHM6Ly9henVyZS5kYXRhYWxsb3lzLmNvbS9hbi9ub3RpZmljYXRpb24vY29uc3VtZXI=",
"name": "Alloy Subscription azuredataalloyscom",
"description": "Alloy Subscription",
"topic": "records-changed",
"pushEndpoint": "https://azure.dataalloys.com/an/notification/consumer",
"createdBy": "questlabs@osdu-service-prod.iam.gserviceaccount.com",
"notificationId": "de-7505cdae-05ad-447d-a9ed-f2b99989931a"
}
Add new record to storage service
Endpoint
https://preship.gcp.gnrg-osdu.projects.epam.com/api/storage/v2/records
Request Body
[
{
"data": {
"TypeWell": "Example Type Well 1",
"LicenceNumber": "Example Licence Number 1",
"ResourceLifecycleStatus": "odesprod:reference-data--ResourceLifecycleStatus:LOADING:",
"OperatorPercentInterest": 12.6,
"ResourceCurationStatus": "odesprod:reference-data--ResourceCurationStatus:CREATED:",
"TechnicalAssuranceID": null,
"Source": "Example Data Source",
"Name": "wellWD_autotest1443601",
"ResourceHomeRegionID": "odesprod:reference-data--OSDURegion:AWSEastUSA:",
"TimeZone": "Example Time Zone",
"ResourceHostRegionIDs": [
"odesprod:reference-data--OSDURegion:AWSEastUSA:"
],
"ResourceSecurityClassification": "odesprod:reference-data--ResourceSecurityClassification:RESTRICTED:",
"IssueDateTime": 12345.6,
"BlockID": "odesprod:master-data--GeoPoliticalEntity:SomeUniqueGeoPoliticalEntityID:",
"ExistenceKind": "odesprod:reference-data--ExistenceKind:planned:",
"WellID": "odesprod:master-data--Well:wellWD_autotest1443601:1658282591215",
"LicenceName": "Example Licence Name"
},
"kind": "odesprod:wks:master-data--WellPlanningWell:1.0.0",
"source": "wks",
"acl": {
"viewers": [
"data.default.viewers@odesprod.group"
],
"owners": [
"data.default.viewers@odesprod.group"
]
},
"type": "master-data--WellPlanningWell",
"authority": "odesprod",
"namespace": "odesprod:wks",
"legal": {
"legaltags": [
"odesprod-WellDeliveryDDMS-Legal-Tag"
],
"otherRelevantDataCountries": [
"US"
],
"status": "compliant"
}
}
]
Response
{
"recordCount": 1,
"recordIds": [
"odesprod:master-data--WellPlanningWell:6d3401e411ba413684fb949b75033618"
],
"skippedRecordIds": [],
"recordIdVersions": [
"odesprod:master-data--WellPlanningWell:6d3401e411ba413684fb949b75033618:1689597277419426"
]
}
Check if subscriber receives notification or not
Consumer endpoint of our application is not receiving any notification when we tried to PUT record in storage service.