From b72f823de556838e097cc22da3bdb05638427c59 Mon Sep 17 00:00:00 2001 From: Vladimir Gorej Date: Mon, 31 Oct 2022 15:00:07 +0100 Subject: [PATCH] feat(ns-asyncapi-2): add latest bindings versions in elements layer Refs #2080 --- .../bindings/kafka/KafkaChannelBinding.ts | 40 ++++++++++++++++++- .../bindings/kafka/KafkaMessageBinding.ts | 24 +++++++++++ .../bindings/kafka/KafkaServerBinding.ts | 26 +++++++++++- .../bindings/nats/NatsOperationBinding.ts | 18 ++++++++- 4 files changed, 105 insertions(+), 3 deletions(-) diff --git a/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaChannelBinding.ts b/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaChannelBinding.ts index 92919e56af..49ac0b7b8b 100644 --- a/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaChannelBinding.ts +++ b/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaChannelBinding.ts @@ -1,4 +1,10 @@ -import { ObjectElement, Attributes, Meta } from '@swagger-api/apidom-core'; +import { + StringElement, + NumberElement, + ObjectElement, + Attributes, + Meta, +} from '@swagger-api/apidom-core'; class KafkaChannelBinding extends ObjectElement { constructor(content?: Record, meta?: Meta, attributes?: Attributes) { @@ -6,6 +12,38 @@ class KafkaChannelBinding extends ObjectElement { this.element = 'kafkaChannelBinding'; this.classes.push('channel-binding'); } + + get topic(): StringElement | undefined { + return this.get('topic'); + } + + set topic(topic: StringElement | undefined) { + this.set('topic', topic); + } + + get partitions(): NumberElement | undefined { + return this.get('partitions'); + } + + set partitions(partitions: NumberElement | undefined) { + this.set('partitions', partitions); + } + + get replicas(): NumberElement | undefined { + return this.get('replicas'); + } + + set replicas(replicas: NumberElement | undefined) { + this.set('replicas', replicas); + } + + get bindingVersion(): StringElement | undefined { + return this.get('bindingVersion'); + } + + set bindingVersion(bindingVersion: StringElement | undefined) { + this.set('bindingVersion', bindingVersion); + } } export default KafkaChannelBinding; diff --git a/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaMessageBinding.ts b/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaMessageBinding.ts index 9812574a40..9728c2d0ba 100644 --- a/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaMessageBinding.ts +++ b/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaMessageBinding.ts @@ -18,6 +18,30 @@ class KafkaMessageBinding extends ObjectElement { this.set('key', key); } + get schemaIdLocation(): StringElement | undefined { + return this.get('schemaIdLocation'); + } + + set schemaIdLocation(schemaIdLocation: StringElement | undefined) { + this.set('schemaIdLocation', schemaIdLocation); + } + + get schemaIdPayloadEncoding(): StringElement | undefined { + return this.get('schemaIdPayloadEncoding'); + } + + set schemaIdPayloadEncoding(schemaIdPayloadEncoding: StringElement | undefined) { + this.set('schemaIdPayloadEncoding', schemaIdPayloadEncoding); + } + + get schemaLookupStrategy(): StringElement | undefined { + return this.get('schemaLookupStrategy'); + } + + set schemaLookupStrategy(schemaLookupStrategy: StringElement | undefined) { + this.set('schemaLookupStrategy', schemaLookupStrategy); + } + get bindingVersion(): StringElement | undefined { return this.get('bindingVersion'); } diff --git a/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaServerBinding.ts b/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaServerBinding.ts index 2180c2c4f8..015116c22f 100644 --- a/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaServerBinding.ts +++ b/packages/apidom-ns-asyncapi-2/src/elements/bindings/kafka/KafkaServerBinding.ts @@ -1,4 +1,4 @@ -import { ObjectElement, Attributes, Meta } from '@swagger-api/apidom-core'; +import { StringElement, ObjectElement, Attributes, Meta } from '@swagger-api/apidom-core'; class KafkaServerBinding extends ObjectElement { constructor(content?: Record, meta?: Meta, attributes?: Attributes) { @@ -6,6 +6,30 @@ class KafkaServerBinding extends ObjectElement { this.element = 'kafkaServerBinding'; this.classes.push('server-binding'); } + + get schemaRegistryUrl(): StringElement | undefined { + return this.get('schemaRegistryUrl'); + } + + set schemaRegistryUrl(schemaRegistryUrl: StringElement | undefined) { + this.set('schemaRegistryUrl', schemaRegistryUrl); + } + + get schemaRegistryVendor(): StringElement | undefined { + return this.get('schemaRegistryVendor'); + } + + set schemaRegistryVendor(schemaRegistryVendor: StringElement | undefined) { + this.set('schemaRegistryVendor', schemaRegistryVendor); + } + + get bindingVersion(): StringElement | undefined { + return this.get('bindingVersion'); + } + + set bindingVersion(bindingVersion: StringElement | undefined) { + this.set('bindingVersion', bindingVersion); + } } export default KafkaServerBinding; diff --git a/packages/apidom-ns-asyncapi-2/src/elements/bindings/nats/NatsOperationBinding.ts b/packages/apidom-ns-asyncapi-2/src/elements/bindings/nats/NatsOperationBinding.ts index f25b83f025..a23de4f5a3 100644 --- a/packages/apidom-ns-asyncapi-2/src/elements/bindings/nats/NatsOperationBinding.ts +++ b/packages/apidom-ns-asyncapi-2/src/elements/bindings/nats/NatsOperationBinding.ts @@ -1,4 +1,4 @@ -import { ObjectElement, Attributes, Meta } from '@swagger-api/apidom-core'; +import { StringElement, ObjectElement, Attributes, Meta } from '@swagger-api/apidom-core'; class NatsOperationBinding extends ObjectElement { constructor(content?: Record, meta?: Meta, attributes?: Attributes) { @@ -6,6 +6,22 @@ class NatsOperationBinding extends ObjectElement { this.element = 'natsOperationBinding'; this.classes.push('operation-binding'); } + + get queue(): StringElement | undefined { + return this.get('queue'); + } + + set queue(queue: StringElement | undefined) { + this.set('queue', queue); + } + + get bindingVersion(): StringElement | undefined { + return this.get('bindingVersion'); + } + + set bindingVersion(bindingVersion: StringElement | undefined) { + this.set('bindingVersion', bindingVersion); + } } export default NatsOperationBinding;