test: add amqp 0.4.0 binding test

Co-authored-by: Pavel Bodiachevskii <pavelbodyachevskiy@gmail.com>
asyncapi · Oct 2, 2024 · b0e19f8 · b0e19f8
1 parent 5a4092e
commit b0e19f8
Show file tree

Hide file tree

Showing 5 changed files with 162 additions and 6 deletions.
diff --git a/bindings/amqp/0.4.0/channel.json b/bindings/amqp/0.4.0/channel.json
@@ -23,9 +23,7 @@
  },
  "channel": {
  "type": "object",
- "properties": {
- "$ref": "http://asyncapi.com/definitions/3.0.0/Reference.json"
- }
+ "$ref": "http://asyncapi.com/definitions/3.0.0/Reference.json"
  },
  "exchange": {
  "type": "object",

diff --git a/test/ajv-schemes.js b/test/ajv-schemes.js
@@ -7,6 +7,9 @@ function bindingSchemes(ajv) {
  ajv.addSchema(require('@bindings/amqp/0.3.0/channel.json'));
  ajv.addSchema(require('@bindings/amqp/0.3.0/message.json'));
  ajv.addSchema(require('@bindings/amqp/0.3.0/operation.json'));
+ ajv.addSchema(require('@bindings/amqp/0.4.0/channel.json'));
+ ajv.addSchema(require('@bindings/amqp/0.4.0/message.json'));
+ ajv.addSchema(require('@bindings/amqp/0.4.0/operation.json'));
 
  ajv.addSchema(require('@bindings/anypointmq/0.0.1/channel.json'));
  ajv.addSchema(require('@bindings/anypointmq/0.0.1/message.json'));

diff --git a/test/bindings/amqp/amqp channel binding.test.mjs b/test/bindings/amqp/amqp channel binding.test.mjs
@@ -160,12 +160,100 @@ let data = {
  },
  "ext-number": 1
  }
+ ),
+ "0.4.0": new JsonSchemaTestSuiteData(
+ require(`@bindings/amqp/0.4.0/channel.json`),
+ [
+ {
+ "is": "queue",
+ "queue": {
+ "name": "my-queue-name",
+ "durable": true,
+ "exclusive": true,
+ "autoDelete": false,
+ "vhost": "/"
+ },
+ "bindingVersion": "0.4.0"
+ },
+ {
+ "is": "routingKey",
+ "exchange": {
+ "name": "myExchange",
+ "type": "topic",
+ "durable": true,
+ "autoDelete": false,
+ "vhost": "/"
+ },
+ "bindingVersion": "0.4.0"
+ },
+ {
+ "is": "routingKey",
+ "name": "routingKeyName",
+ "channel": {
+ "$ref": "#/components/channels/queue-update"
+ },
+ "exchange": {
+ "name": "myExchange",
+ "type": "topic",
+ "durable": true,
+ "autoDelete": false,
+ "vhost": "/"
+ },
+ "bindingVersion": "0.4.0"
+ }
+ ],
+ {
+ "is": "queue",
+ "queue": {
+ "name": "my-queue-name",
+ "durable": true,
+ "exclusive": true,
+ "autoDelete": false,
+ "vhost": "/"
+ },
+ "bindingVersion": "0.4.0"
+ },
+ {
+ "bindingVersion": "0.4.0"
+ },
+ {
+ "is": "queue",
+ "queue": {
+ "name": "my-queue-name",
+ "durable": true,
+ "exclusive": true,
+ "autoDelete": false,
+ "vhost": "/"
+ },
+ "x-number": 0,
+ "x-string": "",
+ "x-object": {
+ "property": {}
+ }
+ },
+ {
+ "is": "queue",
+ "queue": {
+ "name": "my-queue-name",
+ "durable": true,
+ "exclusive": true,
+ "autoDelete": false,
+ "vhost": "/"
+ },
+ "x-number": 0,
+ "x-string": "",
+ "x-object": {
+ "property": {}
+ },
+ "ext-number": 1
+ }
  )
 }
 
 describe.each([
  '0.2.0',
- '0.3.0'
+ '0.3.0',
+ '0.4.0',
 ])('AMQP channel binding v%s', (bindingVersion) => {
  new JsonSchemaTestSuite(data[bindingVersion], config).testSuite()
 })
diff --git a/test/bindings/amqp/amqp message binding.test.mjs b/test/bindings/amqp/amqp message binding.test.mjs
@@ -66,12 +66,40 @@ let data = {
  },
  "ext-number": 1
  }
+ ),
+ "0.4.0": new JsonSchemaTestSuiteData(
+ require(`@bindings/amqp/0.4.0/message.json`),
+ [
+ {
+ "contentEncoding": "gzip",
+ "messageType": "user.signup",
+ "bindingVersion": "0.4.0"
+ }
+ ],
+ {},
+ {},
+ {
+ "x-number": 0,
+ "x-string": "",
+ "x-object": {
+ "property": {}
+ }
+ },
+ {
+ "x-number": 0,
+ "x-string": "",
+ "x-object": {
+ "property": {}
+ },
+ "ext-number": 1
+ }
  )
 }
 
 describe.each([
  '0.2.0',
- '0.3.0'
+ '0.3.0',
+ '0.4.0'
 ])('AMQP message binding v%s', (bindingVersion) => {
  new JsonSchemaTestSuite(data[bindingVersion], config).testSuite()
 })
diff --git a/test/bindings/amqp/amqp operation binding.test.mjs b/test/bindings/amqp/amqp operation binding.test.mjs
@@ -88,12 +88,51 @@ let data = {
  },
  "ext-number": 1
  }
+ ),
+ "0.4.0": new JsonSchemaTestSuiteData(
+ require(`@bindings/amqp/0.4.0/operation.json`),
+ [
+ {
+ "expiration": 100000,
+ "userId": "guest",
+ "cc": [
+ "user.logs"
+ ],
+ "priority": 10,
+ "deliveryMode": 2,
+ "mandatory": false,
+ "bcc": [
+ "external.audit"
+ ],
+ "timestamp": true,
+ "ack": false,
+ "bindingVersion": "0.4.0"
+ }
+ ],
+ {},
+ {},
+ {
+ "x-number": 0,
+ "x-string": "",
+ "x-object": {
+ "property": {}
+ }
+ },
+ {
+ "x-number": 0,
+ "x-string": "",
+ "x-object": {
+ "property": {}
+ },
+ "ext-number": 1
+ }
  )
 }
 
 describe.each([
  '0.2.0',
- '0.3.0'
+ '0.3.0',
+ '0.4.0'
 ])('AMQP operation binding v%s', (bindingVersion) => {
  new JsonSchemaTestSuite(data[bindingVersion], config).testSuite()
 })