feat: add traits field to channel object asyncapi/spec#1220 (#1193)

Co-authored-by: Ivan Garcia Sainz-Aja <ivangsa@gmail.com>
Co-authored-by: Moderator <60972989+AayushSaini101@users.noreply.github.com>
Co-authored-by: Prince Rajpoot <prince.rajpoot.20@gmail.com>

Author: 3 people

packages/parser/src/custom-operations/apply-traits.ts

@@ -49,14 +49,17 @@ function applyTraitsToObjectV2(value: Record<string, unknown>) {
 }
 
 const v3TraitPaths = [
+  // channels
+  '$.channels.*',
+  '$.components.channels.*',
   // operations
   '$.operations.*',
   '$.operations.*.channel.messages.*',
   '$.operations.*.messages.*',
   '$.components.operations.*',
   '$.components.operations.*.channel.messages.*',
   '$.components.operations.*.messages.*',
-  // Channels
+  // messages inside channels
   '$.channels.*.messages.*',
   '$.components.channels.*.messages.*',
   // messages

packages/parser/src/models/channel-trait.ts

@@ -0,0 +1,10 @@
+import type { BaseModel } from './base';
+import type { ChannelParametersInterface } from './channel-parameters';
+import type { CoreMixinInterface } from './mixins';
+import type { ServersInterface } from './servers';
+
+export interface ChannelTraitInterface extends BaseModel, CoreMixinInterface {
+  id(): string;
+  servers(): ServersInterface;
+  parameters(): ChannelParametersInterface;
+}

packages/parser/src/models/channel-traits.ts

@@ -0,0 +1,4 @@
+import type { Collection } from './collection';
+import type { ChannelTraitInterface } from './channel-trait';
+
+export type ChannelTraitsInterface = Collection<ChannelTraitInterface>;

packages/parser/src/models/channel.ts

@@ -1,5 +1,6 @@
 import type { BaseModel } from './base';
 import type { ChannelParametersInterface } from './channel-parameters';
+import type { ChannelTraitsInterface } from './channel-traits';
 import type { MessagesInterface } from './messages';
 import type { BindingsMixinInterface, DescriptionMixinInterface, ExtensionsMixinInterface } from './mixins';
 import type { OperationsInterface } from './operations';
@@ -12,4 +13,5 @@ export interface ChannelInterface extends BaseModel, BindingsMixinInterface, Des
   operations(): OperationsInterface;
   messages(): MessagesInterface;
   parameters(): ChannelParametersInterface;
+  traits(): ChannelTraitsInterface;
 }

packages/parser/src/models/components.ts

@@ -6,6 +6,7 @@ import type { ChannelsInterface } from './channels';
 import type { MessagesInterface } from './messages';
 import type { SchemasInterface } from './schemas';
 import type { ChannelParametersInterface } from './channel-parameters';
+import type { ChannelTraitsInterface } from './channel-traits';
 import type { ServerVariablesInterface } from './server-variables';
 import type { OperationTraitsInterface } from './operation-traits';
 import type { MessageTraitsInterface } from './message-traits';
@@ -21,6 +22,7 @@ export interface ComponentsInterface extends BaseModel, ExtensionsMixinInterface
   channelParameters(): ChannelParametersInterface;
   serverVariables(): ServerVariablesInterface;
   operations(): OperationsInterface;
+  channelTraits(): ChannelTraitsInterface;
   operationTraits(): OperationTraitsInterface;
   messageTraits(): MessageTraitsInterface;
   correlationIds(): CorrelationIdsInterface;

packages/parser/src/models/index.ts

@@ -9,6 +9,8 @@ export * from './channel-parameter';
 export * from './channel-parameters';
 export * from './channel';
 export * from './channels';
+export * from './channel-trait';
+export * from './channel-traits';
 export * from './collection';
 export * from './components';
 export * from './contact';

packages/parser/src/models/v2/channel-traits.ts

@@ -0,0 +1,10 @@
+import { Collection } from '../collection';
+
+import type { ChannelTraitsInterface } from '../channel-traits';
+import type { ChannelTraitInterface } from '../channel-trait';
+
+export class ChannelTraits extends Collection<ChannelTraitInterface> implements ChannelTraitsInterface {
+  override get(id: string): ChannelTraitInterface | undefined {
+    return this.collections.find(trait => trait.id() === id);
+  }
+}

packages/parser/src/models/v2/channel.ts

@@ -1,4 +1,5 @@
 import { BaseModel } from '../base';
+import { ChannelTraits } from './channel-traits';
 import { ChannelParameters } from './channel-parameters';
 import { ChannelParameter } from './channel-parameter';
 import { Messages } from './messages';
@@ -12,6 +13,7 @@ import { bindings, hasDescription, description, extensions } from './mixins';
 import type { BindingsInterface } from '../bindings';
 import type { ChannelInterface } from '../channel';
 import type { ChannelParametersInterface } from '../channel-parameters';
+import type { ChannelTraitsInterface } from '../channel-traits';
 import type { ExtensionsInterface } from '../extensions';
 import type { MessagesInterface } from '../messages';
 import type { MessageInterface } from '../message';
@@ -81,6 +83,10 @@ export class Channel extends BaseModel<v2.ChannelObject, { id: string, address:
     );
   }
 
+  traits(): ChannelTraitsInterface {
+    return new ChannelTraits([]);
+  }
+
   bindings(): BindingsInterface {
     return bindings(this); 
   }

packages/parser/src/models/v2/components.ts

@@ -1,5 +1,6 @@
 import { BaseModel } from '../base';
 import { Collection } from '../collection';
+import { ChannelTraits } from './channel-traits';
 
 import { Bindings } from './bindings';
 import { Binding } from './binding';
@@ -37,6 +38,7 @@ import type { ChannelsInterface } from '../channels';
 import type { MessagesInterface } from '../messages';
 import type { SchemasInterface } from '../schemas';
 import type { ChannelParametersInterface } from '../channel-parameters';
+import type { ChannelTraitsInterface } from '../channel-traits';
 import type { ServerVariablesInterface } from '../server-variables';
 import type { OperationTraitsInterface } from '../operation-traits';
 import type { SecuritySchemesInterface } from '../security-schemes';
@@ -75,6 +77,10 @@ export class Components extends BaseModel<v2.ComponentsObject> implements Compon
     return this.createCollection('parameters', ChannelParameters, ChannelParameter);
   }
 
+  channelTraits(): ChannelTraitsInterface {
+    return new ChannelTraits([]);
+  }
+
   serverVariables(): ServerVariablesInterface {
     return this.createCollection('serverVariables', ServerVariables, ServerVariable);
   }

packages/parser/src/models/v2/index.ts

@@ -5,6 +5,7 @@ export { ChannelParameter as ChannelParameterV2 } from './channel-parameter';
 export { ChannelParameters as ChannelParametersV2 } from './channel-parameters';
 export { Channel as ChannelV2 } from './channel';
 export { Channels as ChannelsV2 } from './channels';
+export { ChannelTraits as ChannelTraitsV2 } from './channel-traits';
 export { Components as ComponentsV2 } from './components';
 export { Contact as ContactV2 } from './contact';
 export { CorrelationId as CorrelationIdV2 } from './correlation-id';
@@ -34,4 +35,4 @@ export { ServerVariables as ServerVariablesV2 } from './server-variables';
 export { Server as ServerV2 } from './server';
 export { Servers as ServersV2 } from './servers';
 export { Tag as TagV2 } from './tag';
-export { Tags as TagsV2 } from './tags';
+export { Tags as TagsV2 } from './tags';