1 | import stampit from 'stampit';
|
---|
2 | import { createNamespace, visit } from '@swagger-api/apidom-core';
|
---|
3 | import asyncApi2Namespace, { getNodeType, isAsyncApi2Element, keyMap, mediaTypes } from '@swagger-api/apidom-ns-asyncapi-2';
|
---|
4 | import ResolveStrategy from "../ResolveStrategy.mjs";
|
---|
5 | import ReferenceSet from "../../../ReferenceSet.mjs";
|
---|
6 | import Reference from "../../../Reference.mjs";
|
---|
7 | import AsyncApi2ResolveVisitor from "./visitor.mjs"; // @ts-ignore
|
---|
8 | const visitAsync = visit[Symbol.for('nodejs.util.promisify.custom')];
|
---|
9 | const AsyncApi2ResolveStrategy = stampit(ResolveStrategy, {
|
---|
10 | init() {
|
---|
11 | this.name = 'asyncapi-2';
|
---|
12 | },
|
---|
13 | methods: {
|
---|
14 | canResolve(file) {
|
---|
15 | var _file$parseResult;
|
---|
16 | // assert by media type
|
---|
17 | if (file.mediaType !== 'text/plain') {
|
---|
18 | return mediaTypes.includes(file.mediaType);
|
---|
19 | }
|
---|
20 |
|
---|
21 | // assert by inspecting ApiDOM
|
---|
22 | return isAsyncApi2Element((_file$parseResult = file.parseResult) === null || _file$parseResult === void 0 ? void 0 : _file$parseResult.api);
|
---|
23 | },
|
---|
24 | async resolve(file, options) {
|
---|
25 | const namespace = createNamespace(asyncApi2Namespace);
|
---|
26 | const reference = Reference({
|
---|
27 | uri: file.uri,
|
---|
28 | value: file.parseResult
|
---|
29 | });
|
---|
30 | const visitor = AsyncApi2ResolveVisitor({
|
---|
31 | reference,
|
---|
32 | namespace,
|
---|
33 | options
|
---|
34 | });
|
---|
35 | const refSet = ReferenceSet();
|
---|
36 | refSet.add(reference);
|
---|
37 | await visitAsync(refSet.rootRef.value, visitor, {
|
---|
38 | keyMap,
|
---|
39 | nodeTypeGetter: getNodeType
|
---|
40 | });
|
---|
41 | await visitor.crawl();
|
---|
42 | return refSet;
|
---|
43 | }
|
---|
44 | }
|
---|
45 | });
|
---|
46 | export default AsyncApi2ResolveStrategy; |
---|