diff --git a/terminusdb_client/tests/test_connectionConfig.py b/terminusdb_client/tests/test_connectionConfig.py index bfdb491a..4025a6ce 100644 --- a/terminusdb_client/tests/test_connectionConfig.py +++ b/terminusdb_client/tests/test_connectionConfig.py @@ -1,3 +1,6 @@ +import secrets +import string + from terminusdb_client.woqlclient.connectionConfig import ConnectionConfig @@ -5,6 +8,12 @@ class TestConnectionConfig: start_server_url = "http://localhost:6363/" start_dbid = "testDB" local_user = "admin" + # Set of random string values that can as replacements for dummy id valuess + # i.e accountid,branchid,refid etc + id_value = "".join( + secrets.choice(string.ascii_uppercase + string.ascii_lowercase) + for _ in range(16) + ) # to be review !!!!! connection_config = ConnectionConfig( start_server_url, @@ -38,3 +47,103 @@ def test_change_server(self): def test_check_basic_auth(self): assert self.connection_config.basic_auth == "admin:mykey" + + def test_set_remote_auth(self): + auth_dict = {type: "jwt", "key": "eyJhbGciOiJIUzI1NiIsInR5c"} + self.connection_config.set_remote_auth(auth_dict) + assert self.connection_config.remote_auth == auth_dict + auth_dict = { + type: "basic", + "user": self.local_user, + "key": "admin_testDB_Password", + } + self.connection_config.update(remote_auth=auth_dict) + assert self.connection_config.remote_auth == auth_dict + + def test_update(self): + self.connection_config.update(db=self.id_value) + self.connection_config.update(account=self.id_value) + self.connection_config.update(repo=self.id_value) + self.connection_config.update(branch=self.id_value) + self.connection_config.update(ref=self.id_value) + self.connection_config.update(repo=self.id_value) + assert self.connection_config.db == self.id_value + assert self.connection_config.account == self.id_value + assert self.connection_config.repo == self.id_value + assert self.connection_config.branch == self.id_value + assert self.connection_config.ref == self.id_value + assert self.connection_config.repo == self.id_value + + def test_clear_cursor(self): + self.connection_config.update(branch=self.id_value) + self.connection_config.update(repo=self.id_value) + self.connection_config.update(account=self.id_value) + self.connection_config.update(db=self.id_value) + self.connection_config.update(ref=self.id_value) + self.connection_config.clear_cursor() + assert self.connection_config.branch != self.id_value + assert self.connection_config.repo != self.id_value + assert self.connection_config.account is False + assert self.connection_config.db is False + assert self.connection_config.ref is False + + def test_user(self): + assert self.connection_config.user() == self.local_user + auth_dict = {type: "jwt", "key": "eyJhbGciOiJIUzI1NiIsInR5c"} + self.connection_config.update(remote=auth_dict) + assert self.connection_config.user() == self.local_user + + def test_set_basic_auth(self): + assert self.connection_config.set_basic_auth() is None + self.connection_config.set_basic_auth(api_key="admin_testDB_Password") + basic_auth = self.connection_config.basic_auth + assert basic_auth == "admin:admin_testDB_Password" + + def test_db_url_fragmen(self): + self.connection_config.update(db=self.id_value) + self.connection_config.update(account=self.id_value) + db_url_fragment = self.connection_config.db_url_fragment() + assert db_url_fragment == f"{self.id_value}/{self.id_value}" + + def test_db_base(self): + self.connection_config.update(db=self.id_value) + self.connection_config.update(account=self.id_value) + db_base = self.connection_config.db_base("push") + assert db_base == f"http://localhost:6363/push/{self.id_value}/{self.id_value}" + + def test_repo_base(self): + self.connection_config.update(db=self.id_value) + self.connection_config.update(account=self.id_value) + self.connection_config.db_base("pull") + default_base = self.connection_config.repo_base("pull") + assert ( + default_base + == f"http://localhost:6363/pull/{self.id_value}/{self.id_value}/local" + ) + + self.connection_config.update(repo=self.id_value) + updated_base = self.connection_config.db_base("pull") + assert ( + updated_base + == f"http://localhost:6363/pull/{self.id_value}/{self.id_value}" + ) + + def test_account(self): + self.connection_config.account = self.id_value + assert self.connection_config.account == self.id_value + + def test_db(self): + self.connection_config.db = self.id_value + assert self.connection_config.db == self.id_value + + def test_repo(self): + self.connection_config.repo = self.id_value + assert self.connection_config.repo == self.id_value + + def branch(self): + self.connection_config.branch = self.id_value + assert self.connection_config.branch == self.id_value + + def ref(self): + self.connection_config.ref = self.id_value + assert self.connection_config.ref == self.id_value diff --git a/terminusdb_client/woqldataframe/woqlDataframe.py b/terminusdb_client/woqldataframe/woqlDataframe.py index 79d74220..5ba4f4a7 100644 --- a/terminusdb_client/woqldataframe/woqlDataframe.py +++ b/terminusdb_client/woqldataframe/woqlDataframe.py @@ -28,7 +28,6 @@ class EmptyException(Exception): If the result table of the query is empty """ - pass def _is_empty(query):