#NEWLINE# def testAuthentication1( self ) : #NEWLINE# #INDENT# 'Test that flows refuse to processes unauthenticated messages.' #NEWLINE# flow_obj = self . FlowSetup ( 'FlowOrderTest' ) #NEWLINE# message_ids = [ 2 , 1 , 4 , 3 , 5 ] #NEWLINE# self . SendMessages ( message_ids , flow_obj . session_id , authenticated = False ) #NEWLINE# message = self . SendOKStatus ( 6 , flow_obj . session_id ) #NEWLINE# runner = flow_runner . FlowRunner ( flow_obj ) #NEWLINE# notification = rdf_flows . Notification ( timestamp = rdfvalue . RDFDatetime ( ) . Now ( ) ) #NEWLINE# runner . ProcessCompletedRequests ( notification , [ message ] ) #NEWLINE# self . assertEqual ( flow_obj . messages , [ ] )