func interceptMessage()

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
    }