| 900 | |
| 901 | |
| 902 | class ClusterInformation(): |
| 903 | def __init__(self): |
| 904 | self.host = "localhost" |
| 905 | self.port = 8091 |
| 906 | self.admin_username = "Administrator" |
| 907 | self.admin_password = "password" |
| 908 | self.bucket_name = "default" |
| 909 | self.bucket_password = "" |
| 910 | self.real_server_enabled = False |
| 911 | self.mock_server_enabled = False |
| 912 | self.mock_server = None |
| 913 | # self.mock_path = "" |
| 914 | # self.mock_url = None |
| 915 | # self.mock_server = None |
| 916 | # self.mock_version = None |
| 917 | |
| 918 | @property |
| 919 | def is_mock_server(self): |
| 920 | return self.mock_server_enabled |
| 921 | |
| 922 | @property |
| 923 | def is_real_server(self): |
| 924 | return self.real_server_enabled |
| 925 | |
| 926 | def get_connection_string(self): |
| 927 | if self.mock_server_enabled: |
| 928 | if self.mock_server.mock_type == MockServerType.Legacy: |
| 929 | # What current client uses for mock: |
| 930 | # http://127.0.0.1:49696?ipv6=disabled |
| 931 | return f"http://{self.host}:{self.port}" |
| 932 | |
| 933 | return self.mock_server.connstr |
| 934 | else: |
| 935 | return f"couchbase://{self.host}" |
| 936 | |
| 937 | def get_username_and_pw(self): |
| 938 | return self.admin_username, self.admin_password |
| 939 | |
| 940 | def shutdown(self): |
| 941 | if self.mock_server_enabled and self.mock_server.mock_type == MockServerType.GoCAVES: |
| 942 | self.mock_server.shutdown() |
| 943 | |
| 944 | |
| 945 | def create_mock_server(mock_type, # type: MockServerType |