# Copyright 2019 Apex.AI, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import os
import sys
import unittest

import ament_index_python

import launch
import launch.actions
import launch.substitutions

import launch_testing
import launch_testing.actions
import launch_testing.util

import pytest


@pytest.mark.launch_test
def generate_test_description():
    dut_process = launch.actions.ExecuteProcess(
        cmd=[
            sys.executable,
            os.path.join(
                ament_index_python.get_package_prefix('launch_testing'),
                'lib/launch_testing',
                'terminating_proc.py',
            ),

            # Arguments
            launch.substitutions.LaunchConfiguration('dut_arg')
        ],
    )

    return launch.LaunchDescription([

        # This argument can be passed into the test, and can be discovered by running
        # launch_test --show-args
        launch.actions.DeclareLaunchArgument(
            'dut_arg',
            default_value=['default'],
            description='Passed to the terminating process',
        ),

        dut_process,

        # In tests where all of the procs under tests terminate themselves, it's necessary
        # to add a dummy process not under test to keep the launch alive. launch_test
        # provides a simple launch action that does this:
        launch_testing.util.KeepAliveProc(),

        launch_testing.actions.ReadyToTest()
    ]), {'dut_process': dut_process}


class TestTerminatingProcessStops(unittest.TestCase):

    def test_proc_terminates(self, proc_info, dut_process):
        proc_info.assertWaitForShutdown(process=dut_process, timeout=10)


@launch_testing.post_shutdown_test()
class TestProcessOutput(unittest.TestCase):

    def test_ran_with_arg(self, dut_process):
        self.assertNotIn(
            'default',
            dut_process.process_details['cmd'],
            'Try running: launch_test test_with_args.test.py dut_arg:=arg'
        )

    def test_arg_printed_in_output(self, proc_output, test_args, dut_process):
        launch_testing.asserts.assertInStdout(
            proc_output,
            test_args['dut_arg'],
            dut_process
        )

    def test_default_not_printed(self, proc_output, dut_process):
        with self.assertRaises(AssertionError):
            launch_testing.asserts.assertInStdout(
                proc_output,
                'default',
                dut_process
            )

504b42f37852dbe63165f7ceeb4d0083c29dc351
<mask token>


@launch_testing.post_shutdown_test()
class TestProcessOutput(unittest.TestCase):

    def test_ran_with_arg(self, dut_process):
        self.assertNotIn('default', dut_process.process_details['cmd'],
            'Try running: launch_test test_with_args.test.py dut_arg:=arg')

    def test_arg_printed_in_output(self, proc_output, test_args, dut_process):
        launch_testing.asserts.assertInStdout(proc_output, test_args[
            'dut_arg'], dut_process)

    def test_default_not_printed(self, proc_output, dut_process):
        with self.assertRaises(AssertionError):
            launch_testing.asserts.assertInStdout(proc_output, 'default',
                dut_process)

<mask token>


class TestTerminatingProcessStops(unittest.TestCase):
    <mask token>


@launch_testing.post_shutdown_test()
class TestProcessOutput(unittest.TestCase):

    def test_ran_with_arg(self, dut_process):
        self.assertNotIn('default', dut_process.process_details['cmd'],
            'Try running: launch_test test_with_args.test.py dut_arg:=arg')

    def test_arg_printed_in_output(self, proc_output, test_args, dut_process):
        launch_testing.asserts.assertInStdout(proc_output, test_args[
            'dut_arg'], dut_process)

    def test_default_not_printed(self, proc_output, dut_process):
        with self.assertRaises(AssertionError):
            launch_testing.asserts.assertInStdout(proc_output, 'default',
                dut_process)

<mask token>


class TestTerminatingProcessStops(unittest.TestCase):

    def test_proc_terminates(self, proc_info, dut_process):
        proc_info.assertWaitForShutdown(process=dut_process, timeout=10)


@launch_testing.post_shutdown_test()
class TestProcessOutput(unittest.TestCase):

    def test_ran_with_arg(self, dut_process):
        self.assertNotIn('default', dut_process.process_details['cmd'],
            'Try running: launch_test test_with_args.test.py dut_arg:=arg')

    def test_arg_printed_in_output(self, proc_output, test_args, dut_process):
        launch_testing.asserts.assertInStdout(proc_output, test_args[
            'dut_arg'], dut_process)

    def test_default_not_printed(self, proc_output, dut_process):
        with self.assertRaises(AssertionError):
            launch_testing.asserts.assertInStdout(proc_output, 'default',
                dut_process)

import os
import sys
import unittest
import ament_index_python
import launch
import launch.actions
import launch.substitutions
import launch_testing
import launch_testing.actions
import launch_testing.util
import pytest


@pytest.mark.launch_test
def generate_test_description():
    dut_process = launch.actions.ExecuteProcess(cmd=[sys.executable, os.
        path.join(ament_index_python.get_package_prefix('launch_testing'),
        'lib/launch_testing', 'terminating_proc.py'), launch.substitutions.
        LaunchConfiguration('dut_arg')])
    return launch.LaunchDescription([launch.actions.DeclareLaunchArgument(
        'dut_arg', default_value=['default'], description=
        'Passed to the terminating process'), dut_process, launch_testing.
        util.KeepAliveProc(), launch_testing.actions.ReadyToTest()]), {
        'dut_process': dut_process}


class TestTerminatingProcessStops(unittest.TestCase):

    def test_proc_terminates(self, proc_info, dut_process):
        proc_info.assertWaitForShutdown(process=dut_process, timeout=10)


@launch_testing.post_shutdown_test()
class TestProcessOutput(unittest.TestCase):

    def test_ran_with_arg(self, dut_process):
        self.assertNotIn('default', dut_process.process_details['cmd'],
            'Try running: launch_test test_with_args.test.py dut_arg:=arg')

    def test_arg_printed_in_output(self, proc_output, test_args, dut_process):
        launch_testing.asserts.assertInStdout(proc_output, test_args[
            'dut_arg'], dut_process)

    def test_default_not_printed(self, proc_output, dut_process):
        with self.assertRaises(AssertionError):
            launch_testing.asserts.assertInStdout(proc_output, 'default',
                dut_process)

# Copyright 2019 Apex.AI, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import os
import sys
import unittest

import ament_index_python

import launch
import launch.actions
import launch.substitutions

import launch_testing
import launch_testing.actions
import launch_testing.util

import pytest


@pytest.mark.launch_test
def generate_test_description():
    dut_process = launch.actions.ExecuteProcess(
        cmd=[
            sys.executable,
            os.path.join(
                ament_index_python.get_package_prefix('launch_testing'),
                'lib/launch_testing',
                'terminating_proc.py',
            ),

            # Arguments
            launch.substitutions.LaunchConfiguration('dut_arg')
        ],
    )

    return launch.LaunchDescription([

        # This argument can be passed into the test, and can be discovered by running
        # launch_test --show-args
        launch.actions.DeclareLaunchArgument(
            'dut_arg',
            default_value=['default'],
            description='Passed to the terminating process',
        ),

        dut_process,

        # In tests where all of the procs under tests terminate themselves, it's necessary
        # to add a dummy process not under test to keep the launch alive. launch_test
        # provides a simple launch action that does this:
        launch_testing.util.KeepAliveProc(),

        launch_testing.actions.ReadyToTest()
    ]), {'dut_process': dut_process}


class TestTerminatingProcessStops(unittest.TestCase):

    def test_proc_terminates(self, proc_info, dut_process):
        proc_info.assertWaitForShutdown(process=dut_process, timeout=10)


@launch_testing.post_shutdown_test()
class TestProcessOutput(unittest.TestCase):

    def test_ran_with_arg(self, dut_process):
        self.assertNotIn(
            'default',
            dut_process.process_details['cmd'],
            'Try running: launch_test test_with_args.test.py dut_arg:=arg'
        )

    def test_arg_printed_in_output(self, proc_output, test_args, dut_process):
        launch_testing.asserts.assertInStdout(
            proc_output,
            test_args['dut_arg'],
            dut_process
        )

    def test_default_not_printed(self, proc_output, dut_process):
        with self.assertRaises(AssertionError):
            launch_testing.asserts.assertInStdout(
                proc_output,
                'default',
                dut_process
            )
