unit+integration)

Information

Class:	AsyncResponse.Transports.GooglePubSub.GooglePubSubCorrelationIdExtractor
Assembly:	AsyncResponse.Transports.GooglePubSub
File(s):	/_/src/Transports/AsyncResponse.Transports.GooglePubSub/GooglePubSubCorrelationIdExtractor.cs

Line coverage

100%

Branch coverage

100%

Method coverage

Feature is only available for sponsors

Metrics

Method	Branch coverage	Crap Score	Cyclomatic complexity	Line coverage
Extract(...)	100%	6	6	100%

#	Line	Line coverage
	`1`	`using Google.Cloud.PubSub.V1;`
	`2`
	`3`	`namespace AsyncResponse.Transports.GooglePubSub;`
	`4`
	`5`	`/// <summary>`
	`6`	`/// Extracts the AsyncResponse correlation id from an inbound response message: first from the`
	`7`	`/// configured message attribute, then from the JSON body via the configured paths (walked by the`
	`8`	`/// shared <see cref="CorrelationIdJsonPaths"/>).`
	`9`	`/// </summary>`
	`10`	`internal static class GooglePubSubCorrelationIdExtractor`
	`11`	`{`
	`12`	`/// <summary>Extracts the correlation id from the supplied message.</summary>`
	`13`	`public static string? Extract(`
	`14`	`PubsubMessage message,`
	`15`	`string messageJson,`
	`16`	`GooglePubSubAsyncResponseOptions options)`
	`17`	`{`
30	`18`	`if (!string.IsNullOrWhiteSpace(options.CorrelationIdAttribute)`
30	`19`	`&& message.Attributes.TryGetValue(options.CorrelationIdAttribute, out var attributeValue)`
30	`20`	`&& !string.IsNullOrWhiteSpace(attributeValue))`
	`21`	`{`
4	`22`	`return attributeValue;`
	`23`	`}`
	`24`
26	`25`	`return CorrelationIdJsonPaths.Extract(messageJson, options.CorrelationIdJsonPaths);`
	`26`	`}`
	`27`	`}`