Skip to content

Commit

Permalink
feat: add all{components} functions
Browse files Browse the repository at this point in the history
  • Loading branch information
@KhudaDad414
KhudaDad414 committed Mar 23, 2024
1 parent 58ae938 commit 02e8c8a
Show file tree
Hide file tree
Showing 5 changed files with 610 additions and 1 deletion.
18 changes: 18 additions & 0 deletions src/models/asyncapi.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,13 @@ import type { OperationsInterface } from './operations';
import type { SchemasInterface } from './schemas';
import type { SecuritySchemesInterface } from './security-schemes';
import type { ServersInterface } from './servers';
import type { ServerVariablesInterface } from './server-variables';
import type { ChannelParametersInterface } from './channel-parameters';
import type { CorrelationIdsInterface } from './correlation-ids';
import type { TagsInterface } from './tags';
import type { OperationTraitsInterface } from './operation-traits';
import type { MessageTraitsInterface } from './message-traits';
import type { BindingsInterface } from './bindings';

import type { v2, v3 } from '../spec-types';

Expand All @@ -31,4 +38,15 @@ export interface AsyncAPIDocumentInterface extends BaseModel<v2.AsyncAPIObject |
allOperations(): OperationsInterface;
allMessages(): MessagesInterface;
allSchemas(): SchemasInterface;
allSecuritySchemes(): SecuritySchemesInterface;
allServerVariables(): ServerVariablesInterface;
allParameters(): ChannelParametersInterface;
allCorrelationIds(): CorrelationIdsInterface;
allTags(): TagsInterface;
allOperationTraits(): OperationTraitsInterface;
allMessageTraits(): MessageTraitsInterface;
allServerBindings(): BindingsInterface;
allChannelBindings(): BindingsInterface;
allOperationBindings(): BindingsInterface;
allMessageBindings(): BindingsInterface;
}
99 changes: 98 additions & 1 deletion src/models/v2/asyncapi.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,9 @@ import { Server } from './server';
import { SecuritySchemes } from './security-schemes';
import { SecurityScheme } from './security-scheme';
import { Schemas } from './schemas';
import { Bindings } from './bindings';

import { extensions } from './mixins';
import { extensions, tags } from './mixins';
import { tilde } from '../../utils';
import { schemasFromDocument } from '../utils';

Expand All @@ -29,10 +30,106 @@ import type { MessageInterface } from '../message';
import type { SchemasInterface } from '../schemas';
import type { SecuritySchemesInterface } from '../security-schemes';
import type { ExtensionsInterface } from '../extensions';
import type { BindingsInterface } from 'models/bindings';
import type { ChannelParametersInterface } from 'models/channel-parameters';
import type { CorrelationIdsInterface } from 'models/correlation-ids';
import type { MessageTraitsInterface } from 'models/message-traits';
import type { OperationTraitsInterface } from 'models/operation-traits';
import type { ServerVariablesInterface } from 'models/server-variables';
import type { TagsInterface } from 'models/tags';

import type { v2 } from '../../spec-types';

export class AsyncAPIDocument extends BaseModel<v2.AsyncAPIObject> implements AsyncAPIDocumentInterface {
allSecuritySchemes(): SecuritySchemesInterface {
return this.securitySchemes();
}
allServerVariables(): ServerVariablesInterface {
const serverVariables: ServerVariablesInterface = this.components().serverVariables();
this.allServers().forEach(server => serverVariables.push(...server.variables()));
return serverVariables;
}
allParameters(): ChannelParametersInterface {
const channelParameters: ChannelParametersInterface = this.components().channelParameters();
this.allChannels().forEach(channel => channelParameters.push(...channel.parameters()));
return channelParameters;
}
allCorrelationIds(): CorrelationIdsInterface {
const correlationIds: CorrelationIdsInterface = this.components().correlationIds();
this.allMessages().forEach(message => {
message.traits().forEach(trait => {
const correlationId = trait.correlationId();
if (!correlationId) {
return;
}
if (!correlationIds.includes(correlationId)) {
correlationIds.push(correlationId);
}
});

const correlationId = message.correlationId();
if (!correlationId) {
return;
}
if (!correlationIds.includes(correlationId)) {
correlationIds.push(correlationId);
}
});
return correlationIds;
}
allTags(): TagsInterface {
const rootTags: TagsInterface = tags(this);
this.allServers().forEach(server => rootTags.push(...server.tags()));
this.allOperations().forEach(channel => rootTags.push(...channel.tags()));
this.allOperationTraits().forEach(trait => rootTags.push(...trait.tags()));
this.allMessages().forEach(message => rootTags.push(...message.tags()));
this.allMessageTraits().forEach(trait => rootTags.push(...trait.tags()));
return rootTags;
}
allOperationTraits(): OperationTraitsInterface {
const operationTraits: OperationTraitsInterface = this.components().operationTraits();
this.allOperations().forEach(operation => operation.traits().forEach(trait => (
!operationTraits.some(t => t.json() === trait.json()) && operationTraits.push(trait)
)));

return operationTraits;
}
allMessageTraits(): MessageTraitsInterface {
const messageTraits: MessageTraitsInterface = this.components().messageTraits();
this.allMessages().forEach(message => message.traits().forEach(trait => (
!messageTraits.some(t => t.json() === trait.json()) && messageTraits.push(trait)
)));

return messageTraits;
}
allServerBindings(): BindingsInterface {
const serverBindings = Object.values(this.components().serverBindings()).flat();
this.allServers().forEach(server => server.bindings().forEach(binding => (
!serverBindings.some(b => b.json() === binding.json()) && serverBindings.push(binding)
)));
return new Bindings(serverBindings);
}
allChannelBindings(): BindingsInterface {
const channelBindings = Object.values(this.components().channelBindings()).flat();
this.allChannels().forEach(channel => channel.bindings().forEach(binding => (
!channelBindings.some(b => b.json() === binding.json()) && channelBindings.push(binding)
)));
return new Bindings(channelBindings);
}
allOperationBindings(): BindingsInterface {
const operationBindings = Object.values(this.components().operationBindings()).flat();
this.allOperations().forEach(operation => operation.bindings().forEach(binding => (
!operationBindings.some(b => b.json() === binding.json()) && operationBindings.push(binding)
)));
return new Bindings(operationBindings);
}
allMessageBindings(): BindingsInterface {
const messageBindings = Object.values(this.components().messageBindings()).flat();
this.allMessages().forEach(message => message.bindings().forEach(binding => (
!messageBindings.some(b => b.json() === binding.json()) && messageBindings.push(binding)
)));
return new Bindings(messageBindings);
}
version(): string {
return this._json.asyncapi;
}
Expand Down
164 changes: 164 additions & 0 deletions src/models/v3/asyncapi.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,8 @@ import { SecuritySchemes } from './security-schemes';
import { SecurityScheme } from './security-scheme';
import { Components } from './components';
import { Schemas } from './schemas';
import { Bindings } from './bindings';
import { Tags } from './tags';

import { extensions } from './mixins';
import { tilde } from '../../utils';
Expand All @@ -30,10 +32,172 @@ import type { SchemasInterface } from '../schemas';
import type { OperationInterface } from '../operation';
import type { ChannelInterface } from '../channel';
import type { ServerInterface } from '../server';
import type { BindingsInterface } from 'models/bindings';
import type { ChannelParametersInterface } from 'models/channel-parameters';
import type { CorrelationIdsInterface } from 'models/correlation-ids';
import type { MessageTraitsInterface } from 'models/message-traits';
import type { OperationTraitsInterface } from 'models/operation-traits';
import type { ServerVariablesInterface } from 'models/server-variables';
import type { TagsInterface } from 'models/tags';
import type { Tag } from './tag';
import type { TagInterface } from 'models/tag';

import type { v3 } from '../../spec-types';

export class AsyncAPIDocument extends BaseModel<v3.AsyncAPIObject> implements AsyncAPIDocumentInterface {
allSecuritySchemes(): SecuritySchemesInterface {
return this.securitySchemes();
}
allServerVariables(): ServerVariablesInterface {
const serverVariables: ServerVariablesInterface = this.components().serverVariables();
this.servers().forEach(server => {
server.variables().forEach(variable => {
if (!serverVariables.has(variable.id())) {
serverVariables.push(variable);
}
});
});

return serverVariables;
}
allParameters(): ChannelParametersInterface {
const parameters: ChannelParametersInterface = this.components().channelParameters();
this.channels().forEach(channel => {
channel.parameters().forEach(parameter => {
if (!parameters.includes(parameter)) {
parameters.push(parameter);
}
});
});
return parameters;
}

allCorrelationIds(): CorrelationIdsInterface {
const correlationIds: CorrelationIdsInterface = this.components().correlationIds();
this.allMessages().forEach(message => {
const correlationId = message.correlationId();
if (correlationId) {
correlationIds.push(correlationId);
}
});

this.allMessageTraits().forEach(trait => {
const correlationId = trait.correlationId();
if (correlationId) {
correlationIds.push(correlationId);
}
});

return correlationIds;
}
allTags(): TagsInterface {
const tags: TagInterface[] = Object.values(this.components().json().tags || {}) || [];
this.info().tags().forEach(tag => {
if (!tags.includes(tag)) {
tags.push(tag);
}
});

this.servers().forEach(server => {
server.tags().forEach(tag => {
if (!tags.includes(tag)) {
tags.push(tag);
}
});
});

this.channels().forEach(channel => {
(channel.json().tags || []).forEach((tag: Tag) => {
if (!tags.includes(tag)) {
tags.push(tag);
}
});
});

this.operations().forEach(operation => {
operation.tags().forEach(tag => {
if (!tags.includes(tag)) {
tags.push(tag);
}
});
});

this.allOperationTraits().forEach(trait => {
trait.tags().forEach(tag => {
if (!tags.includes(tag)) {
tags.push(tag);
}
});
});

this.allMessages().forEach(message => {
message.tags().forEach(tag => {
if (!tags.includes(tag)) {
tags.push(tag);
}
});
});

this.allMessageTraits().forEach(trait => {
trait.tags().forEach(tag => {
if (!tags.includes(tag)) {
tags.push(tag);
}
});
});

return new Tags(tags);
}
allOperationTraits(): OperationTraitsInterface {
const traits: OperationTraitsInterface = this.components().operationTraits();
this.operations().forEach(operation => {
operation.traits().forEach(trait => {
if (!traits.includes(trait)) {
traits.push(trait);
}
});
});
return traits;
}
allMessageTraits(): MessageTraitsInterface {
const messageTraits: MessageTraitsInterface = this.components().messageTraits();
this.allMessages().forEach(message => {
message.traits().forEach(trait => {
if (!messageTraits.includes(trait)) {
messageTraits.push(trait);
}
});
});
return messageTraits;
}
allServerBindings(): BindingsInterface {
const serverBindings = Object.values(this.components().serverBindings()).flat();
this.allServers().forEach(server => server.bindings().forEach(binding => (
!serverBindings.some(b => b.json() === binding.json()) && serverBindings.push(binding)
)));
return new Bindings(serverBindings);
}
allChannelBindings(): BindingsInterface {
const channelBindings = Object.values(this.components().channelBindings()).flat();
this.allChannels().forEach(channel => channel.bindings().forEach(binding => (
!channelBindings.some(b => b.json() === binding.json()) && channelBindings.push(binding)
)));
return new Bindings(channelBindings);
}
allOperationBindings(): BindingsInterface {
const operationBindings = Object.values(this.components().operationBindings()).flat();
this.allOperations().forEach(operation => operation.bindings().forEach(binding => (
!operationBindings.some(b => b.json() === binding.json()) && operationBindings.push(binding)
)));
return new Bindings(operationBindings);
}
allMessageBindings(): BindingsInterface {
const messageBindings = Object.values(this.components().messageBindings()).flat();
this.allMessages().forEach(message => message.bindings().forEach(binding => (
!messageBindings.some(b => b.json() === binding.json()) && messageBindings.push(binding)
)));
return new Bindings(messageBindings);
}
version(): string {
return this._json.asyncapi;
}
Expand Down
Loading

0 comments on commit 02e8c8a

Please sign in to comment.