in AWSAppSyncClient/Internal/AuthInterceptor/LambdaAuthInterceptor.swift [20:40]
func interceptMessage(_ message: AppSyncMessage, for endpoint: URL) -> AppSyncMessage {
let host = endpoint.host!
guard case let .success(authToken) = self.retrieveLatestAuthToken() else {
return message
}
guard case .subscribe = message.messageType else {
return message
}
let authHeader = TokenAuthHeader(token: authToken, host: host)
var payload = message.payload ?? AppSyncMessage.Payload()
payload.authHeader = authHeader
let signedMessage = AppSyncMessage(
id: message.id,
payload: payload,
type: message.messageType
)
return signedMessage
}