class
Analyzer::Specification::AsyncApi
- Analyzer::Specification::AsyncApi
- Analyzer::Specification::SpecificationEngine
- Analyzer
- Reference
- Object
Overview
AsyncAPI 2.x / 3.x analyzer.
Maps event-driven channels to endpoints:
- 2.x —
channels.<name>.{publish,subscribe}→ one endpoint per (channel, operation). Operation becomes the method-like field ("PUBLISH" / "SUBSCRIBE"). Message payload schema becomes the body shape. - 3.x —
operations.<id>withaction: send|receivereferencing achannels.<name>entry. Method becomes "SEND" / "RECEIVE". The channel'saddress(or the channel key as fallback) is the path.
The first server's protocol (kafka, mqtt, ws, amqp, nats, http, …)
is surfaced on the endpoint so DAST consumers can route accordingly.
Defined in:
analyzer/analyzers/specification/asyncapi.crConstant Summary
-
OPERATIONS_2X =
{"publish", "subscribe"} -
Operation keys on
channelsentries (2.x).
Class Method Summary
Instance Method Summary
- #analyze
-
#tech : String
Instance-side view of the same declaration.
Instance methods inherited from class Analyzer
analyze
analyze,
base_path : String
base_path,
base_paths : Array(String)
base_paths,
base_relative_path(path : String) : String
base_relative_path,
callees_needed? : Bool
callees_needed?,
content_matches?(content : String, markers : Regex) : Bool
content_matches?,
http_header_name(name : String) : String | Nil
http_header_name,
line_number_for_index(content : String, char_index : Int32) : Int32
line_number_for_index,
logger : NoirLogger
logger,
parallel_analyze(files : Array(String), &block : String -> Nil)
parallel_analyze,
read_file_content(path : String) : String
read_file_content,
result : Array(Endpoint)
result,
tech : String
tech,
unique_params(params : Array(Param)) : Array(Param)
unique_params,
url : String
url,
web_root_path(path : String, markers : Array(String)) : String
web_root_path
Constructor methods inherited from class Analyzer
new(options : Hash(String, YAML::Any))
new
Macros inherited from class Analyzer
analyzer_for(tech)
analyzer_for
Instance methods inherited from module FileHelper
all_files : Array(String)
all_files,
get_files_by_basename(basename : String) : Array(String)
get_files_by_basename,
get_files_by_extension(extension : String) : Array(String)
get_files_by_extension,
get_files_by_extensions(extensions : Array(String)) : Array(String)
get_files_by_extensions,
get_files_by_prefix(prefix : String) : Array(String)
get_files_by_prefix,
get_files_by_prefix_and_extension(prefix : String, extension : String) : Array(String)
get_files_by_prefix_and_extension,
get_files_by_relative_path(relative_path : String, root : String = "") : Array(String)
get_files_by_relative_path,
get_public_dir_files(base_path : String, folder : String) : Array(String)
get_public_dir_files,
get_public_files(base_path : String, anchors : Array(String) = ["shard.yml", "Gemfile"]) : Array(String)
get_public_files,
walked_path(expanded : String) : String
walked_path
Class Method Detail
Instance Method Detail
Instance-side view of the same declaration. The per-file rescues live on
this base class, which has no way to name the analyzer that is running
inside them, so a skipped file could not be attributed to a tech.
Deriving it from analyzer_for keeps the name written exactly once.