diff --git a/gns3server/handlers/__init__.py b/gns3server/handlers/__init__.py
index 307eece3..5db20453 100644
--- a/gns3server/handlers/__init__.py
+++ b/gns3server/handlers/__init__.py
@@ -27,6 +27,7 @@ from gns3server.handlers.api.virtualbox_handler import VirtualBoxHandler
from gns3server.handlers.api.vpcs_handler import VPCSHandler
from gns3server.handlers.api.config_handler import ConfigHandler
from gns3server.handlers.api.server_handler import ServerHandler
+from gns3server.handlers.api.file_handler import FileHandler
from gns3server.handlers.upload_handler import UploadHandler
from gns3server.handlers.index_handler import IndexHandler
diff --git a/gns3server/handlers/api/dynamips_vm_handler.py b/gns3server/handlers/api/dynamips_vm_handler.py
index 8d96f98b..7e6d7a8e 100644
--- a/gns3server/handlers/api/dynamips_vm_handler.py
+++ b/gns3server/handlers/api/dynamips_vm_handler.py
@@ -25,6 +25,7 @@ from ...schemas.dynamips_vm import VM_CAPTURE_SCHEMA
from ...schemas.dynamips_vm import VM_OBJECT_SCHEMA
from ...schemas.dynamips_vm import VM_NIO_SCHEMA
from ...schemas.dynamips_vm import VM_CONFIGS_SCHEMA
+from ...schemas.dynamips_vm import VMS_LIST_SCHEMA
from ...modules.dynamips import Dynamips
from ...modules.project_manager import ProjectManager
@@ -421,3 +422,17 @@ class DynamipsVMHandler:
idlepc = yield from dynamips_manager.auto_idlepc(vm)
response.set_status(200)
response.json({"idlepc": idlepc})
+
+ @Route.get(
+ r"/dynamips/vms",
+ status_codes={
+ 200: "List of Dynamips VM retrieved",
+ },
+ description="Retrieve the list of Dynamips VMS",
+ output=VMS_LIST_SCHEMA)
+ def list_vms(request, response):
+
+ dynamips_manager = Dynamips.instance()
+ vms = yield from dynamips_manager.list_images()
+ response.set_status(200)
+ response.json(vms)
diff --git a/gns3server/handlers/api/file_handler.py b/gns3server/handlers/api/file_handler.py
new file mode 100644
index 00000000..e705ffc2
--- /dev/null
+++ b/gns3server/handlers/api/file_handler.py
@@ -0,0 +1,60 @@
+#
+# Copyright (C) 2015 GNS3 Technologies Inc.
+#
+# This program 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.
+#
+# This program 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 this program. If not, see .
+
+import asyncio
+import aiohttp
+
+from ...web.route import Route
+from ...schemas.file import FILE_STREAM_SCHEMA
+
+
+class FileHandler:
+
+ @classmethod
+ @Route.get(
+ r"/files/stream",
+ description="Stream a file from the server",
+ status_codes={
+ 200: "File retrieved",
+ 404: "File doesn't exist",
+ 409: "Can't access to file"
+ },
+ input=FILE_STREAM_SCHEMA
+ )
+ def read(request, response):
+ response.enable_chunked_encoding()
+
+ try:
+ with open(request.json.get("location"), "rb") as f:
+ loop = asyncio.get_event_loop()
+ response.content_type = "application/octet-stream"
+ response.set_status(200)
+ # Very important: do not send a content lenght otherwise QT close the connection but curl can consume the Feed
+ response.content_length = None
+
+ response.start(request)
+
+ while True:
+ data = yield from loop.run_in_executor(None, f.read, 16)
+ if len(data) == 0:
+ yield from asyncio.sleep(0.1)
+ else:
+ response.write(data)
+ except FileNotFoundError:
+ raise aiohttp.web.HTTPNotFound()
+ except OSError as e:
+ raise aiohttp.web.HTTPConflict(text=str(e))
+
diff --git a/gns3server/handlers/api/iou_handler.py b/gns3server/handlers/api/iou_handler.py
index 3314e580..0b5935e9 100644
--- a/gns3server/handlers/api/iou_handler.py
+++ b/gns3server/handlers/api/iou_handler.py
@@ -25,6 +25,7 @@ from ...schemas.iou import IOU_OBJECT_SCHEMA
from ...schemas.iou import IOU_NIO_SCHEMA
from ...schemas.iou import IOU_CAPTURE_SCHEMA
from ...schemas.iou import IOU_INITIAL_CONFIG_SCHEMA
+from ...schemas.iou import IOU_LIST_VMS_SCHEMA
from ...modules.iou import IOU
@@ -59,6 +60,8 @@ class IOUHandler:
for name, value in request.json.items():
if hasattr(vm, name) and getattr(vm, name) != value:
setattr(vm, name, value)
+ if "initial_config_content" in request.json:
+ vm.initial_config = request.json.get("initial_config_content")
response.set_status(201)
response.json(vm)
@@ -106,6 +109,8 @@ class IOUHandler:
for name, value in request.json.items():
if hasattr(vm, name) and getattr(vm, name) != value:
setattr(vm, name, value)
+ if "initial_config_content" in request.json:
+ vm.initial_config = request.json.get("initial_config_content")
response.json(vm)
@classmethod
@@ -306,3 +311,18 @@ class IOUHandler:
project_id=request.match_info["project_id"])
response.set_status(200)
response.json({"content": vm.initial_config_content})
+
+ @Route.get(
+ r"/iou/vms",
+ status_codes={
+ 200: "List of IOU VM retrieved",
+ },
+ description="Retrieve the list of IOU VMS",
+ output=IOU_LIST_VMS_SCHEMA)
+ def list_vms(request, response):
+
+ iou_manager = IOU.instance()
+ vms = yield from iou_manager.list_images()
+ response.set_status(200)
+ response.json(vms)
+
diff --git a/gns3server/handlers/api/qemu_handler.py b/gns3server/handlers/api/qemu_handler.py
index 714149d6..16aaa6e1 100644
--- a/gns3server/handlers/api/qemu_handler.py
+++ b/gns3server/handlers/api/qemu_handler.py
@@ -21,6 +21,7 @@ from ...schemas.qemu import QEMU_UPDATE_SCHEMA
from ...schemas.qemu import QEMU_OBJECT_SCHEMA
from ...schemas.qemu import QEMU_NIO_SCHEMA
from ...schemas.qemu import QEMU_BINARY_LIST_SCHEMA
+from ...schemas.qemu import QEMU_LIST_IMAGES_SCHEMA
from ...modules.qemu import Qemu
@@ -286,3 +287,17 @@ class QEMUHandler:
binaries = yield from Qemu.binary_list()
response.json(binaries)
+
+ @Route.get(
+ r"/qemu/vms",
+ status_codes={
+ 200: "List of Qemu images retrieved",
+ },
+ description="Retrieve the list of Qemu images",
+ output=QEMU_LIST_IMAGES_SCHEMA)
+ def list_vms(request, response):
+
+ qemu_manager = Qemu.instance()
+ vms = yield from qemu_manager.list_images()
+ response.set_status(200)
+ response.json(vms)
diff --git a/gns3server/handlers/api/virtualbox_handler.py b/gns3server/handlers/api/virtualbox_handler.py
index 008ac2e6..4065b992 100644
--- a/gns3server/handlers/api/virtualbox_handler.py
+++ b/gns3server/handlers/api/virtualbox_handler.py
@@ -42,7 +42,7 @@ class VirtualBoxHandler:
def show(request, response):
vbox_manager = VirtualBox.instance()
- vms = yield from vbox_manager.get_list()
+ vms = yield from vbox_manager.list_images()
response.json(vms)
@classmethod
diff --git a/gns3server/modules/base_manager.py b/gns3server/modules/base_manager.py
index d6097fce..9c1d7fd8 100644
--- a/gns3server/modules/base_manager.py
+++ b/gns3server/modules/base_manager.py
@@ -403,6 +403,25 @@ class BaseManager:
return os.path.basename(path)
return path
+ @asyncio.coroutine
+ def list_images(self):
+ """
+ Return the list of available images for this VM type
+
+ :returns: Array of hash
+ """
+
+ try:
+ files = os.listdir(self.get_images_directory())
+ except FileNotFoundError:
+ return []
+ files.sort()
+ images = []
+ for filename in files:
+ if filename[0] != ".":
+ images.append({"filename": filename})
+ return images
+
def get_images_directory(self):
"""
Get the image directory on disk
diff --git a/gns3server/modules/virtualbox/__init__.py b/gns3server/modules/virtualbox/__init__.py
index a6440072..acfb2c89 100644
--- a/gns3server/modules/virtualbox/__init__.py
+++ b/gns3server/modules/virtualbox/__init__.py
@@ -117,7 +117,7 @@ class VirtualBox(BaseManager):
return stdout_data.decode("utf-8", errors="ignore").splitlines()
@asyncio.coroutine
- def get_list(self):
+ def list_images(self):
"""
Gets VirtualBox VM list.
"""
diff --git a/gns3server/schemas/dynamips_vm.py b/gns3server/schemas/dynamips_vm.py
index 8888f6a6..f1ccfb7d 100644
--- a/gns3server/schemas/dynamips_vm.py
+++ b/gns3server/schemas/dynamips_vm.py
@@ -888,3 +888,21 @@ VM_CONFIGS_SCHEMA = {
"additionalProperties": False,
"required": ["startup_config_content", "private_config_content"]
}
+
+VMS_LIST_SCHEMA = {
+ "$schema": "http://json-schema.org/draft-04/schema#",
+ "description": "List available Dynamips images",
+ "type": "array",
+ "items": [
+ {
+ "type": "object",
+ "properties": {
+ "filename": {
+ "description": "Image filename",
+ "type": ["string"]
+ },
+ },
+ }
+ ],
+ "additionalProperties": False,
+}
diff --git a/gns3server/schemas/file.py b/gns3server/schemas/file.py
new file mode 100644
index 00000000..38ce7a10
--- /dev/null
+++ b/gns3server/schemas/file.py
@@ -0,0 +1,32 @@
+# -*- coding: utf-8 -*-
+#
+# Copyright (C) 2015 GNS3 Technologies Inc.
+#
+# This program 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.
+#
+# This program 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 this program. If not, see .
+
+
+FILE_STREAM_SCHEMA = {
+ "$schema": "http://json-schema.org/draft-04/schema#",
+ "description": "Request validation retrieval of a file stream",
+ "type": "object",
+ "properties": {
+ "location": {
+ "description": "File path",
+ "type": ["string"],
+ "minLength": 1
+ }
+ },
+ "additionalProperties": False,
+ "required": ["location"]
+}
diff --git a/gns3server/schemas/iou.py b/gns3server/schemas/iou.py
index 011607ba..be32019a 100644
--- a/gns3server/schemas/iou.py
+++ b/gns3server/schemas/iou.py
@@ -319,3 +319,21 @@ IOU_INITIAL_CONFIG_SCHEMA = {
"additionalProperties": False,
"required": ["content"]
}
+
+IOU_LIST_VMS_SCHEMA = {
+ "$schema": "http://json-schema.org/draft-04/schema#",
+ "description": "List available IOU images",
+ "type": "array",
+ "items": [
+ {
+ "type": "object",
+ "properties": {
+ "filename": {
+ "description": "Image filename",
+ "type": ["string"]
+ },
+ },
+ }
+ ],
+ "additionalProperties": False,
+}
diff --git a/gns3server/schemas/qemu.py b/gns3server/schemas/qemu.py
index dfa45a07..c2411932 100644
--- a/gns3server/schemas/qemu.py
+++ b/gns3server/schemas/qemu.py
@@ -397,3 +397,21 @@ QEMU_BINARY_LIST_SCHEMA = {
},
"additionalProperties": False,
}
+
+QEMU_LIST_IMAGES_SCHEMA = {
+ "$schema": "http://json-schema.org/draft-04/schema#",
+ "description": "List available QEMU images",
+ "type": "array",
+ "items": [
+ {
+ "type": "object",
+ "properties": {
+ "filename": {
+ "description": "Image filename",
+ "type": ["string"]
+ },
+ },
+ }
+ ],
+ "additionalProperties": False,
+}
diff --git a/tests/handlers/api/base.py b/tests/handlers/api/base.py
index 6a4fd02e..4b677d17 100644
--- a/tests/handlers/api/base.py
+++ b/tests/handlers/api/base.py
@@ -44,7 +44,7 @@ class Query:
def delete(self, path, **kwargs):
return self._fetch("DELETE", path, **kwargs)
- def _get_url(self, path, version):
+ def get_url(self, path, version):
if version is None:
return "http://{}:{}{}".format(self._host, self._port, path)
return "http://{}:{}/v{}{}".format(self._host, self._port, version, path)
@@ -62,7 +62,7 @@ class Query:
@asyncio.coroutine
def go(future):
- response = yield from aiohttp.request(method, self._get_url(path, api_version), data=body)
+ response = yield from aiohttp.request(method, self.get_url(path, api_version), data=body)
future.set_result(response)
future = asyncio.Future()
asyncio.async(go(future))
diff --git a/tests/handlers/api/test_dynamips.py b/tests/handlers/api/test_dynamips.py
index 3f18c6ad..8b096071 100644
--- a/tests/handlers/api/test_dynamips.py
+++ b/tests/handlers/api/test_dynamips.py
@@ -16,6 +16,10 @@
# along with this program. If not, see .
import pytest
+import os
+import stat
+from unittest.mock import patch
+
from tests.utils import asyncio_patch
@@ -123,3 +127,22 @@ from tests.utils import asyncio_patch
# assert response.status == 200
# assert response.json["name"] == "test"
# assert response.json["console"] == free_console_port
+
+
+@pytest.fixture
+def fake_dynamips(tmpdir):
+ """Create a fake IOU image on disk"""
+
+ path = str(tmpdir / "7200.bin")
+ with open(path, "w+") as f:
+ f.write('1')
+ os.chmod(path, stat.S_IREAD)
+ return path
+
+
+def test_vms(server, tmpdir, fake_dynamips):
+
+ with patch("gns3server.modules.Dynamips.get_images_directory", return_value=str(tmpdir), example=True):
+ response = server.get("/dynamips/vms")
+ assert response.status == 200
+ assert response.json == [{"filename": "7200.bin"}]
diff --git a/tests/handlers/api/test_file.py b/tests/handlers/api/test_file.py
new file mode 100644
index 00000000..0b110b2e
--- /dev/null
+++ b/tests/handlers/api/test_file.py
@@ -0,0 +1,62 @@
+# -*- coding: utf-8 -*-
+#
+# Copyright (C) 2015 GNS3 Technologies Inc.
+#
+# This program 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.
+#
+# This program 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 this program. If not, see .
+
+"""
+This test suite check /files endpoint
+"""
+
+import json
+import asyncio
+import aiohttp
+
+from gns3server.version import __version__
+
+
+def test_stream(server, tmpdir, loop):
+ with open(str(tmpdir / "test"), 'w+') as f:
+ f.write("hello")
+
+ def go(future):
+ query = json.dumps({"location": str(tmpdir / "test")})
+ headers = {'content-type': 'application/json'}
+ response = yield from aiohttp.request("GET", server.get_url("/files/stream", 1), data=query, headers=headers)
+ response.body = yield from response.content.read(5)
+ with open(str(tmpdir / "test"), 'a') as f:
+ f.write("world")
+ response.body += yield from response.content.read(5)
+ response.close()
+ future.set_result(response)
+
+ future = asyncio.Future()
+ asyncio.async(go(future))
+ response = loop.run_until_complete(future)
+ assert response.status == 200
+ assert response.body == b'helloworld'
+
+
+def test_stream_file_not_found(server, tmpdir, loop):
+ def go(future):
+ query = json.dumps({"location": str(tmpdir / "test")})
+ headers = {'content-type': 'application/json'}
+ response = yield from aiohttp.request("GET", server.get_url("/files/stream", 1), data=query, headers=headers)
+ response.close()
+ future.set_result(response)
+
+ future = asyncio.Future()
+ asyncio.async(go(future))
+ response = loop.run_until_complete(future)
+ assert response.status == 404
diff --git a/tests/handlers/api/test_iou.py b/tests/handlers/api/test_iou.py
index bc0f8da9..41d87f43 100644
--- a/tests/handlers/api/test_iou.py
+++ b/tests/handlers/api/test_iou.py
@@ -284,3 +284,11 @@ def test_get_initial_config_with_config_file(server, project, vm):
response = server.get("/projects/{project_id}/iou/vms/{vm_id}/initial_config".format(project_id=vm["project_id"], vm_id=vm["vm_id"]), example=True)
assert response.status == 200
assert response.json["content"] == "TEST"
+
+
+def test_vms(server, vm, tmpdir, fake_iou_bin):
+
+ with patch("gns3server.modules.IOU.get_images_directory", return_value=str(tmpdir), example=True):
+ response = server.get("/iou/vms")
+ assert response.status == 200
+ assert response.json == [{"filename": "iou.bin"}]
diff --git a/tests/handlers/api/test_qemu.py b/tests/handlers/api/test_qemu.py
index b06189f5..fe5b7ddf 100644
--- a/tests/handlers/api/test_qemu.py
+++ b/tests/handlers/api/test_qemu.py
@@ -32,12 +32,32 @@ def fake_qemu_bin():
return bin_path
+@pytest.fixture
+def fake_qemu_vm(tmpdir):
+
+ bin_path = os.path.join(str(tmpdir / "linux.img"))
+ with open(bin_path, "w+") as f:
+ f.write("1")
+ os.chmod(bin_path, stat.S_IRUSR | stat.S_IWUSR | stat.S_IXUSR)
+ return bin_path
+
+
@pytest.fixture
def base_params(tmpdir, fake_qemu_bin):
"""Return standard parameters"""
return {"name": "PC TEST 1", "qemu_path": fake_qemu_bin}
+@pytest.fixture
+def fake_qemu_bin():
+
+ bin_path = os.path.join(os.environ["PATH"], "qemu_x42")
+ with open(bin_path, "w+") as f:
+ f.write("1")
+ os.chmod(bin_path, stat.S_IRUSR | stat.S_IWUSR | stat.S_IXUSR)
+ return bin_path
+
+
@pytest.fixture
def vm(server, project, base_params):
response = server.post("/projects/{project_id}/qemu/vms".format(project_id=project.id), base_params)
@@ -175,3 +195,11 @@ def test_qemu_list_binaries(server, vm):
assert mock.called
assert response.status == 200
assert response.json == ret
+
+
+def test_vms(server, tmpdir, fake_qemu_vm):
+
+ with patch("gns3server.modules.Qemu.get_images_directory", return_value=str(tmpdir), example=True):
+ response = server.get("/qemu/vms")
+ assert response.status == 200
+ assert response.json == [{"filename": "linux.img"}]
diff --git a/tests/modules/iou/test_iou_manager.py b/tests/modules/iou/test_iou_manager.py
index 84b3b7e2..42705940 100644
--- a/tests/modules/iou/test_iou_manager.py
+++ b/tests/modules/iou/test_iou_manager.py
@@ -36,11 +36,7 @@ def iou(port_manager):
return iou
-def test_get_application_id(loop, project, port_manager):
- # Cleanup the IOU object
- IOU._instance = None
- iou = IOU.instance()
- iou.port_manager = port_manager
+def test_get_application_id(loop, project, iou):
vm1_id = str(uuid.uuid4())
vm2_id = str(uuid.uuid4())
vm3_id = str(uuid.uuid4())
@@ -54,11 +50,7 @@ def test_get_application_id(loop, project, port_manager):
assert iou.get_application_id(vm3_id) == 1
-def test_get_application_id_multiple_project(loop, port_manager):
- # Cleanup the IOU object
- IOU._instance = None
- iou = IOU.instance()
- iou.port_manager = port_manager
+def test_get_application_id_multiple_project(loop, iou):
vm1_id = str(uuid.uuid4())
vm2_id = str(uuid.uuid4())
vm3_id = str(uuid.uuid4())
@@ -72,11 +64,7 @@ def test_get_application_id_multiple_project(loop, port_manager):
assert iou.get_application_id(vm3_id) == 3
-def test_get_application_id_no_id_available(loop, project, port_manager):
- # Cleanup the IOU object
- IOU._instance = None
- iou = IOU.instance()
- iou.port_manager = port_manager
+def test_get_application_id_no_id_available(loop, project, iou):
with pytest.raises(IOUError):
for i in range(1, 513):
vm_id = str(uuid.uuid4())
diff --git a/tests/modules/test_manager.py b/tests/modules/test_manager.py
index 19d360e4..792f9af3 100644
--- a/tests/modules/test_manager.py
+++ b/tests/modules/test_manager.py
@@ -25,6 +25,14 @@ from gns3server.modules.vpcs import VPCS
from gns3server.modules.iou import IOU
+@pytest.fixture(scope="function")
+def vpcs(port_manager):
+ VPCS._instance = None
+ vpcs = VPCS.instance()
+ vpcs.port_manager = port_manager
+ return vpcs
+
+
@pytest.fixture(scope="function")
def iou(port_manager):
IOU._instance = None
@@ -33,22 +41,14 @@ def iou(port_manager):
return iou
-def test_create_vm_new_topology(loop, project, port_manager):
-
- VPCS._instance = None
- vpcs = VPCS.instance()
- vpcs.port_manager = port_manager
+def test_create_vm_new_topology(loop, project, vpcs):
vm_id = str(uuid.uuid4())
vm = loop.run_until_complete(vpcs.create_vm("PC 1", project.id, vm_id))
assert vm in project.vms
-def test_create_twice_same_vm_new_topology(loop, project, port_manager):
-
+def test_create_twice_same_vm_new_topology(loop, project, vpcs):
project._vms = set()
- VPCS._instance = None
- vpcs = VPCS.instance()
- vpcs.port_manager = port_manager
vm_id = str(uuid.uuid4())
vm = loop.run_until_complete(vpcs.create_vm("PC 1", project.id, vm_id, console=2222))
assert vm in project.vms
@@ -57,17 +57,13 @@ def test_create_twice_same_vm_new_topology(loop, project, port_manager):
assert len(project.vms) == 1
-def test_create_vm_new_topology_without_uuid(loop, project, port_manager):
-
- VPCS._instance = None
- vpcs = VPCS.instance()
- vpcs.port_manager = port_manager
+def test_create_vm_new_topology_without_uuid(loop, project, vpcs):
vm = loop.run_until_complete(vpcs.create_vm("PC 1", project.id, None))
assert vm in project.vms
assert len(vm.id) == 36
-def test_create_vm_old_topology(loop, project, tmpdir, port_manager):
+def test_create_vm_old_topology(loop, project, tmpdir, vpcs):
with patch("gns3server.modules.project.Project.is_local", return_value=True):
# Create an old topology directory
@@ -79,9 +75,6 @@ def test_create_vm_old_topology(loop, project, tmpdir, port_manager):
with open(os.path.join(vm_dir, "startup.vpc"), "w+") as f:
f.write("1")
- VPCS._instance = None
- vpcs = VPCS.instance()
- vpcs.port_manager = port_manager
vm_id = 1
vm = loop.run_until_complete(vpcs.create_vm("PC 1", project.id, vm_id))
assert len(vm.id) == 36
@@ -121,3 +114,27 @@ def test_get_relative_image_path(iou, tmpdir):
assert iou.get_relative_image_path(path2) == "test2.bin"
assert iou.get_relative_image_path("test2.bin") == "test2.bin"
assert iou.get_relative_image_path("../test1.bin") == path1
+
+
+def test_list_images(loop, iou, tmpdir):
+
+ fake_images = ["a.bin", "b.bin", ".blu.bin"]
+ for image in fake_images:
+ with open(str(tmpdir / image), "w+") as f:
+ f.write("1")
+
+ with patch("gns3server.modules.IOU.get_images_directory", return_value=str(tmpdir)):
+ assert loop.run_until_complete(iou.list_images()) == [
+ {"filename": "a.bin"},
+ {"filename": "b.bin"}
+ ]
+
+
+def test_list_images_empty(loop, iou, tmpdir):
+ with patch("gns3server.modules.IOU.get_images_directory", return_value=str(tmpdir)):
+ assert loop.run_until_complete(iou.list_images()) == []
+
+
+def test_list_images_directory_not_exist(loop, iou):
+ with patch("gns3server.modules.IOU.get_images_directory", return_value="/bla"):
+ assert loop.run_until_complete(iou.list_images()) == []