def test_hdfs_creation_local_abs_url(self, check_data_source_unique_name):
     check_data_source_unique_name.return_value = True
     data = {
         "name": "test_data_data_source",
         "url": "/tmp/output",
         "type": "hdfs",
         "description": "correct url schema for absolute path on local hdfs"
     }
     ds.check_data_source_create(data)

 def test_hdfs_creation_local_rel_url(self, check_data_source_unique_name):
     check_data_source_unique_name.return_value = True
     data = {
         "name": "test_data_data_source",
         "url": "mydata/input",
         "type": "hdfs",
         "description": "correct url schema for relative path on local hdfs"
     }
     ds.check_data_source_create(data)

    def test_hdfs_creation_correct_url(self, check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": "hdfs://test_cluster/",
            "type": "hdfs",
            "description": "correct url schema"
        }
        ds.check_data_source_create(data)

 def test_manila_creation_empty_url(self, check_ds_unique_name):
     check_ds_unique_name.return_value = True
     data = {
         "name": "test_data_data_source",
         "url": "",
         "type": "manila",
         "description": ("empty url")
     }
     with testtools.ExpectedException(ex.InvalidDataException):
         ds.check_data_source_create(data)

 def test_manila_creation_no_path(self, check_ds_unique_name):
     check_ds_unique_name.return_value = True
     data = {
         "name": "test_data_data_source",
         "url": "manila://%s" % uuid.uuid4(),
         "type": "manila",
         "description": ("netloc is not a uuid")
     }
     with testtools.ExpectedException(ex.InvalidDataException):
         ds.check_data_source_create(data)

 def test_manila_creation_wrong_schema(self, check_ds_unique_name):
     check_ds_unique_name.return_value = True
     data = {
         "name": "test_data_data_source",
         "url": "man://%s" % uuid.uuid4(),
         "type": "manila",
         "description": ("incorrect url schema for")
     }
     with testtools.ExpectedException(ex.InvalidDataException):
         ds.check_data_source_create(data)

    def test_hdfs_creation_wrong_schema(self, check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": "hdf://test_cluster/",
            "type": "hdfs",
            "description": "incorrect url schema"
        }
        with self.assertRaises(ex.InvalidException):
            ds.check_data_source_create(data)

    def test_maprfs_creation_wrong_schema(self, check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": "maprf://test_cluster/",
            "type": "maprfs",
            "description": "incorrect url schema"
        }
        with testtools.ExpectedException(ex.InvalidException):
            ds.check_data_source_create(data)

    def test_swift_creation_wrong_schema(self, check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": "swif://1234/object",
            "type": "swift",
            "description": "incorrect url schema"
        }
        with testtools.ExpectedException(ex.InvalidDataException):
            ds.check_data_source_create(data)

    def test_swift_creation_missing_credentials(self, check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": SAMPLE_SWIFT_URL,
            "type": "swift",
            "description": "long description",
        }
        with testtools.ExpectedException(ex.InvalidCredentials):
            ds.check_data_source_create(data)

    def test_swift_creation_wrong_schema(self, check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": "swif://1234%s/object" % su.SWIFT_URL_SUFFIX,
            "type": "swift",
            "description": "incorrect url schema"
        }
        with self.assertRaises(ex.InvalidException):
            ds.check_data_source_create(data)

    def test_swift_creation_missing_object(self,
                                           check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": "swift://1234/",
            "type": "swift",
            "description": "incorrect url schema"
        }
        with self.assertRaises(ex.InvalidException):
            ds.check_data_source_create(data)

    def test_swift_creation_missing_credentials(self,
                                                check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": "swift://1234",
            "type": "swift",
            "description": "long description"
        }
        with self.assertRaises(ex.InvalidCredentials):
            ds.check_data_source_create(data)

    def test_swift_creation_missing_credentials(self,
                                                check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": SAMPLE_SWIFT_URL,
            "type": "swift",
            "description": "long description"
        }
        with testtools.ExpectedException(ex.InvalidCredentials):
            ds.check_data_source_create(data)
        # proxy enabled should allow creation without credentials
        self.override_config('use_domain_for_proxy_users', True)
        ds.check_data_source_create(data)

    def test_swift_creation_credentials_missing_password(
            self,
            check_data_source_unique_name):
        check_data_source_unique_name.return_value = True

        data = {
            "name": "test_data_data_source",
            "url": SAMPLE_SWIFT_URL,
            "type": "swift",
            "credentials": {
                "user": "user",
            },
            "description": "long description"
        }
        with self.assertRaises(ex.InvalidCredentials):
            ds.check_data_source_create(data)