Skip to content

Create Subscription error #885

Description

@zaka221

Hello

Problem description:

Im trying create subscription for destination, to make destination ant get destinations I don't have any problem.
array:1 [
"payload" => array:1 [
0 => array:3 [
"resource" => array:4 [
"sqs" => array:1 [
"arn" => "arn:aws:sqs:eu-west-2:00***********************"
]
"eventBridge" => null
"privateSqs" => null
"webhook" => null
]
"destinationId" => "32ddc376-****************************"
"name" => "HippoWarehouse-SQS-Destination"
]
]
] so my destination exist
but when Im trying make sub on that dest, i have problems and errors. And i also have SQS on amazon wich i use to create destination.

Error:

[2025-08-29 08:47:24] local.INFO: Creating subscription with API {"destination_id":"32ddc376*******************","api_configured":"yes"} 
[2025-08-29 08:47:24] local.INFO: Subscription request created {"payload_version":"1.0","destination_id":"32ddc376*****************","processing_directive":null} 
[2025-08-29 08:47:24] local.ERROR: Subscription failed with full details {"error_message":"Bad Request (400) Response: {
  \"errors\": [
    {
      \"code\": \"InvalidInput\",
      \"message\": \"Request has missing or invalid parameters and cannot be parsed.\",
      \"details\": \"Processing Directive eventFilter must not be empty\"
    }
  ]
}","error_file":"/home/kc/Documents/GitHub/HippoWarehouse/vendor/saloonphp/saloon/src/Helpers/RequestExceptionHelper.php","error_line":53,"destination_id":"32ddc377*******************"} 

Code

public function subscribeToOrderChangeNotifications(string $destinationId)
  {
      $notificationsApi = $this->api->notificationsV1();
      try {
          Log::info('Creating subscription with API', [
              'destination_id' => $destinationId,
              'api_configured' => $this->api ? 'yes' : 'no'
          ]);
          $subscriptionRequest = new CreateSubscriptionRequest(
              payloadVersion: '1.0',
              destinationId: $destinationId,
              processingDirective:null
          );
          Log::info('Subscription request created', [
              'payload_version' => $subscriptionRequest->payloadVersion,
              'destination_id' => $subscriptionRequest->destinationId,
              'processing_directive' => $subscriptionRequest->processingDirective
          ]);
          $response = $notificationsApi->createSubscription(
            notificationType: 'ORDER_CHANGE',
            createSubscriptionRequest: $subscriptionRequest);
          return $response->json();

      } catch (\Exception $e) {

          Log::error('Subscription failed with full details', [
              'error_message' => $e->getMessage(),
              'error_file' => $e->getFile(),
              'error_line' => $e->getLine(),
              'destination_id' => $destinationId
          ]);
          throw $e;
      }
  }

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions