Add FS api skeleton

parsec/core/api.py

@@ -26,7 +26,27 @@ def init_app(self, app):
         app.register_cmd('get_core_state', self._cmd_GET_CORE_STATE)
         app.register_cmd('logout', self._cmd_LOGOUT)
 
+        # FS api
+        app.register_cmd('file_create', self._fs_proxy_factory('file_create'))
+        app.register_cmd('file_read', self._fs_proxy_factory('file_read'))
+        app.register_cmd('file_write', self._fs_proxy_factory('file_write'))
+        app.register_cmd('stat', self._fs_proxy_factory('stat'))
+        app.register_cmd('folder_create', self._fs_proxy_factory('folder_create'))
+        app.register_cmd('move', self._fs_proxy_factory('move'))
+        app.register_cmd('delete', self._fs_proxy_factory('delete'))
+        app.register_cmd('file_truncate', self._fs_proxy_factory('file_truncate'))
+
+    def _fs_proxy_factory(self, cmd):
+        def proxy_cmd(app, req):
+            if not self.user_id:
+                raise ParsecError('not_logged', 'Must be logged in to use this command')
+            else:
+                return getattr(self.fs, '_cmd_%s' % cmd.upper())(app, req)
+
+        return proxy_cmd
+
     def _cmd_REGISTER(self, app, req):
+        raise NotImplementedError()
         return {'status': 'ok'}
 
     def _cmd_LOGIN(self, app, req):
@@ -45,6 +65,7 @@ def _cmd_LOGIN(self, app, req):
 
 
     def _cmd_GET_AVAILABLE_LOGINS(self, app, req):
+        raise NotImplementedError()
         return {'status': 'ok'}
 
 

parsec/core/fs.py

@@ -4,3 +4,27 @@ def start(self):
 
     def stop(self):
         pass
+
+    def _cmd_FILE_CREATE(self, app, req):
+        return {'status': 'ok'}
+
+    def _cmd_FILE_READ(self, app, req):
+        return {'status': 'ok'}
+
+    def _cmd_FILE_WRITE(self, app, req):
+        return {'status': 'ok'}
+
+    def _cmd_STAT(self, app, req):
+        return {'status': 'ok'}
+
+    def _cmd_FOLDER_CREATE(self, app, req):
+        return {'status': 'ok'}
+
+    def _cmd_MOVE(self, app, req):
+        return {'status': 'ok'}
+
+    def _cmd_DELETE(self, app, req):
+        return {'status': 'ok'}
+
+    def _cmd_FILE_TRUNCATE(self, app, req):
+        return {'status': 'ok'}

tests/core/test_control_api.py

@@ -1,3 +1,4 @@
+import pytest
 import zmq
 import json
 from unittest.mock import Mock
@@ -56,6 +57,24 @@ def test_bad_login(self):
             rep = sock.recv()
             assert rep == {"status": "unknown_user", 'label': 'No user known with id `john`'}
 
+    @pytest.mark.parametrize('cmd', [
+        'logout',
+
+        'file_create',
+        'file_read',
+        'file_write',
+        'stat',
+        'folder_create',
+        'move',
+        'delete',
+        'file_truncate',
+    ])
+    def test_must_be_logged_cmds(self, cmd):
+        with self.core.connected() as sock:
+            sock.send({"cmd": cmd})
+            rep = sock.recv()
+            assert rep == {"status": "not_logged", 'label': 'Must be logged in to use this command'}
+
 
 class TestAlreadyLogged(BaseCoreTest):