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.

Edited by Rakesh Sharma