Skip to content

Commit

Permalink
Merge pull request #105 from kabirkhaan/fix-typo-startedAt
Browse files Browse the repository at this point in the history 
Fix StartedAt Typo
  • Loading branch information
@NghiaTranUIT
NghiaTranUIT committed Jun 14, 2022
2 parents 7fda1e8 + 7113973 commit 09fc606
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 13 deletions.
14 changes: 7 additions & 7 deletions README.md
View file
Expand Up @@ -230,7 +230,7 @@ grpc-swift and leverage this to get a complete log of your calls.
statusMessage: nil,
streamingType: type.streamingType,
type: .send,
startetAt: logEntry.started,
startedAt: logEntry.started,
endedAt: Date(),
HPACKHeadersRequest: logEntry.request.metadata,
HPACKHeadersResponse: logEntry.response.metadata)
Expand All @@ -248,7 +248,7 @@ grpc-swift and leverage this to get a complete log of your calls.
statusMessage: nil,
streamingType: type.streamingType,
type: .send,
startetAt: logEntry.started,
startedAt: logEntry.started,
endedAt: Date(),
HPACKHeadersRequest: logEntry.request.metadata,
HPACKHeadersResponse: logEntry.response.metadata)
Expand Down Expand Up @@ -291,7 +291,7 @@ grpc-swift and leverage this to get a complete log of your calls.
statusMessage: nil,
streamingType: type.streamingType,
type: .receive,
startetAt: logEntry.started,
startedAt: logEntry.started,
endedAt: Date(),
HPACKHeadersRequest: logEntry.request.metadata,
HPACKHeadersResponse: logEntry.response.metadata)
Expand All @@ -304,7 +304,7 @@ grpc-swift and leverage this to get a complete log of your calls.
statusMessage: status.message,
streamingType: type.streamingType,
type: .receive,
startetAt: logEntry.started,
startedAt: logEntry.started,
endedAt: Date(),
HPACKHeadersRequest: logEntry.request.metadata,
HPACKHeadersResponse: logEntry.response.metadata)
Expand All @@ -324,7 +324,7 @@ grpc-swift and leverage this to get a complete log of your calls.
success: status.isOk,
statusCode: status.code.rawValue,
statusMessage: status.message,
startetAt: logEntry.started,
startedAt: logEntry.started,
endedAt: Date(),
HPACKHeadersRequest: logEntry.request.metadata,
HPACKHeadersResponse: logEntry.response.metadata)
Expand All @@ -341,7 +341,7 @@ grpc-swift and leverage this to get a complete log of your calls.
success: false,
statusCode: GRPCStatus(code: .unknown, message: "").code.rawValue,
statusMessage: error.localizedDescription,
startetAt: logEntry.started,
startedAt: logEntry.started,
endedAt: Date(),
HPACKHeadersRequest: logEntry.request.metadata,
HPACKHeadersResponse: logEntry.response.metadata)
Expand All @@ -360,7 +360,7 @@ grpc-swift and leverage this to get a complete log of your calls.
success: false,
statusCode: GRPCStatus(code: .cancelled, message: nil).code.rawValue,
statusMessage: "canceled",
startetAt: logEntry.started,
startedAt: logEntry.started,
endedAt: Date(),
HPACKHeadersRequest: logEntry.request.metadata,
HPACKHeadersResponse: logEntry.response.metadata)
Expand Down
12 changes: 6 additions & 6 deletions Sources/Atlantis+Manual.swift
View file
Expand Up @@ -70,7 +70,7 @@ extension Atlantis {
/// - success: success state. Get from `CallResult.success`
/// - statusCode: statusCode state. Get from `CallResult.statusCode`
/// - statusMessage: statusMessage state. Get from `CallResult.statusMessage`
/// - startetAt: when the request started
/// - startedAt: when the request started
/// - endedAt: when the request ended
/// - HPACKHeadersRequest: Transformed request headers from gRPC. Get it from `callOptions?.customMetadata`
/// - HPACKHeadersResponse: Transformed response headers from gRPC. Get it from `CallResult.trailingMetadata` or `CallResult.initialMetadata`
Expand All @@ -80,7 +80,7 @@ extension Atlantis {
success: Bool,
statusCode: Int,
statusMessage: String?,
startetAt: Date?,
startedAt: Date?,
endedAt: Date?,
HPACKHeadersRequest: [Header] = [],
HPACKHeadersResponse: [Header] = []) {
Expand All @@ -98,7 +98,7 @@ extension Atlantis {
request: request,
response: response,
responseBodyData: responseObject,
startAt: startetAt?.timeIntervalSince1970 ?? Date().timeIntervalSince1970,
startAt: startedAt?.timeIntervalSince1970 ?? Date().timeIntervalSince1970,
endAt: endedAt?.timeIntervalSince1970)

// Compose and send the message to Proxyman
Expand All @@ -114,7 +114,7 @@ extension Atlantis {
/// - statusMessage: statusMessage state. Get from `CallResult.statusMessage`
/// - streamingType: Determines the stremaing type. `client`, `server` or `biderectional`. Extract it from the interceptor context
/// - type: The WebSocket Message Type, we are mostly using `send` and `receive` for determine the direction
/// - startetAt: when the request started
/// - startedAt: when the request started
/// - endedAt: when the request ended
/// - HPACKHeadersRequest: Transformed request headers from gRPC. Get it from `callOptions?.customMetadata`
/// - HPACKHeadersResponse: Transformed response headers from gRPC. Get it from `CallResult.trailingMetadata` or `CallResult.initialMetadata`
Expand All @@ -126,7 +126,7 @@ extension Atlantis {
statusMessage: String?,
streamingType: GRPCStreamingType,
type: WebsocketMessagePackage.MessageType,
startetAt: Date?,
startedAt: Date?,
endedAt: Date?,
HPACKHeadersRequest: [Header] = [],
HPACKHeadersResponse: [Header] = []) {
Expand Down Expand Up @@ -161,7 +161,7 @@ extension Atlantis {
response: response,
responseBodyData: responseObject,
packageType: .websocket,
startAt: startetAt?.timeIntervalSince1970 ?? Date().timeIntervalSince1970,
startAt: startedAt?.timeIntervalSince1970 ?? Date().timeIntervalSince1970,
endAt: endedAt?.timeIntervalSince1970)
switch (streamingType, type) {
case (.client, .send),
Expand Down

0 comments on commit 09fc606

Please sign in to comment.