new connection plugin netconf (#20636)

* adds connection plugin for creating modules that use netconf
* adds basic unit test cases for connection plugin

test/units/plugins/connection/test_netconf.py

@@ -0,0 +1,133 @@
+#
+# (c) 2016 Red Hat Inc.
+#
+# This file is part of Ansible
+#
+# Ansible is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# Ansible is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with Ansible.  If not, see <http://www.gnu.org/licenses/>.
+
+# Make coding more python3-ish
+from __future__ import (absolute_import, division, print_function)
+__metaclass__ = type
+
+import sys
+import re
+import json
+
+from io import StringIO
+
+from ansible.compat.tests import unittest
+from ansible.compat.tests.mock import patch, MagicMock, PropertyMock
+
+from ansible.errors import AnsibleConnectionFailure
+from ansible.playbook.play_context import PlayContext
+
+PY3 = sys.version_info[0] == 3
+
+builtin_import = __import__
+
+mock_ncclient = MagicMock(name='ncclient')
+
+def import_mock(name, *args):
+    if name.startswith('ncclient'):
+        return mock_ncclient
+    return builtin_import(name, *args)
+
+if PY3:
+    with patch('builtins.__import__', side_effect=import_mock):
+        from ansible.plugins.connection import netconf
+else:
+    with patch('__builtin__.__import__', side_effect=import_mock):
+        from ansible.plugins.connection import netconf
+
+class TestNetconfConnectionClass(unittest.TestCase):
+
+    def test_netconf_init(self):
+        pc = PlayContext()
+        new_stdin = StringIO()
+
+        conn = netconf.Connection(pc, new_stdin)
+
+        self.assertEqual('default', conn._network_os)
+        self.assertIsNone(conn._manager)
+        self.assertFalse(conn._connected)
+
+    def test_netconf__connect(self):
+        pc = PlayContext()
+        new_stdin = StringIO()
+
+        conn = netconf.Connection(pc, new_stdin)
+
+        mock_manager = MagicMock(name='self._manager.connect')
+        type(mock_manager).session_id = PropertyMock(return_value='123456789')
+        netconf.manager.connect.return_value = mock_manager
+
+        rc, out, err = conn._connect()
+
+        self.assertEqual(0, rc)
+        self.assertEqual('123456789', out)
+        self.assertEqual('', err)
+        self.assertTrue(conn._connected)
+
+    def test_netconf_exec_command(self):
+        pc = PlayContext()
+        new_stdin = StringIO()
+
+        conn = netconf.Connection(pc, new_stdin)
+        conn._connected = True
+
+        mock_manager = MagicMock(name='self._manager')
+
+        mock_reply = MagicMock(name='reply')
+        type(mock_reply).data_xml = PropertyMock(return_value='<test/>')
+
+        mock_manager.rpc.return_value = mock_reply
+
+        conn._manager = mock_manager
+
+        rc, out, err = conn.exec_command('<test/>')
+
+        netconf.to_ele.assert_called_with('<test/>')
+
+        self.assertEqual(0, rc)
+        self.assertEqual('<test/>', out)
+        self.assertEqual('', err)
+
+    def test_netconf_exec_command_invalid_request(self):
+        pc = PlayContext()
+        new_stdin = StringIO()
+
+        conn = netconf.Connection(pc, new_stdin)
+        conn._connected = True
+
+        netconf.to_ele.return_value = None
+
+        rc, out, err = conn.exec_command('test string')
+
+        self.assertEqual(1, rc)
+        self.assertEqual('', out)
+        self.assertEqual('unable to parse request', err)
+
+    def test_fetch_file(self):
+        pc = PlayContext()
+        new_stdin = StringIO()
+        conn = netconf.Connection(pc, new_stdin)
+        self.assertIsNone(conn.fetch_file())
+
+    def test_put_file(self):
+        pc = PlayContext()
+        new_stdin = StringIO()
+        conn = netconf.Connection(pc, new_stdin)
+        self.assertIsNone(conn.put_file())
+
+