Dev 314 (#93)

* INSIGHTS-12 Initial structure of insight functionality

* INSIGHTS-12 Added todo statements

* INSIGHTS-12 Moved Insights out of client

* INSIGHTS-12 Adjusted insight methods to reside in the client class. Removed the ability to collect insights before sending, now the every time the user invokes the collectInsights method, it will also send. This prevents any State issues with the algorithm.

* INSIGHTS-12 Added a todo. Tests fail for unknown reasons at this time

* INSIGHTS-12 Fixed method call. Added a todo to get url from config if necessary.

* INSIGHTS-12 Fixed method call.

* INSIGHTS-12 added json serialization. might not be needed

* INSIGHTS-12 commented test temporarily

* INSIGHTS-12 comment updates and json .encode change

* INSIGHTS-12 comment update

* INSIGHTS-12 changed method signatures to match documentation https://insights1.enthalpy.click/developers/clients/python#publishing-algorithmia-insights

* INSIGHTS-12 Added system property for queue reader url

* INSIGHTS-12 Fixed URL to not be https

* INSIGHTS-12 minor version update

* INSIGHTS-12 revert change

* INSIGHTS-12 removed todo

* INSIGHTS-12 uncommented test. May start failing again in the pipeline.

* INSIGHTS-12 commented test.

* INSIGHTS-12 changed version. Removed unused import.

* INSIGHTS-12 changed url to include /v1/

* Allow listing of non-data:// files on cli

* Allow catting non-data:// files on cli

* Fix tests

* adding get environment method to CLI and client

* CICD fixes

Co-authored-by: robert-close <[email protected]>
Co-authored-by: Kenny Daniel <[email protected]>
Co-authored-by: Kenny Daniel <[email protected]>
Co-authored-by: John Bragg <[email protected]>

Author: 4 people

Algorithmia/CLI.py

@@ -287,11 +287,17 @@ def cp(self, src, dest, client):
                 else:
                     print("at least one of the operands must be a path to a remote data source data://")
 
+    def get_environment_by_language(self,language,client):
+        response = client.get_environment(language)
+        if "error" in response:
+            return json.dumps(response)
+        return json.dumps(response['environments'],indent=1)
+
 
     def list_languages(self, client):
         response = client.get_supported_languages()
         return response
-        
+
 
     def getBuildLogs(self, user, algo, client):
         api_response = client.algo(user+'/'+algo).build_logs()

Algorithmia/__main__.py

@@ -107,6 +107,9 @@ def main():
     parser_cat.add_argument('path', nargs = '*', help = 'file(s) to concatenate and print')
     parser_cat.add_argument('--profile', action = 'store', type = str, default = 'default')
 
+    #sub parser for getting environment by language name
+    parser_env = subparsers.add_parser('environment', help = 'environment <language> gets environment info by language')
+    parser_env.add_argument('language', help='supported language name')
 
     #sub parser for listing languages
     subparsers.add_parser('languages', help = 'lists supported languages')
@@ -197,8 +200,13 @@ def main():
         for lang in response:
             print("{:<25} {:<35}".format(lang['name'],lang['display_name']))
 
+    elif args.cmd == 'environment':
+        response = CLI().get_environment_by_language(args.language,client)
+        print(response)
+
     elif args.cmd == 'builds':
         print(CLI().getBuildLogs(args.user, args.algo, client))
+
     else:
         parser.parse_args(['-h'])
 

Algorithmia/client.py

@@ -114,6 +114,11 @@ def invite_to_org(self,orgname,username):
         response = self.putHelper(url,data={})
         return response
 
+    def get_environment(self,language):
+        url = "/v1/algorithm-environments/edge/languages/"+language+"/environments"
+        response = self.getHelper(url)
+        return response.json()
+
     def get_supported_languages(self):
         url ="/v1/algorithm-environments/edge/languages"
         response = self.getHelper(url)

Test/CLI_test.py

@@ -170,6 +170,13 @@ def test_auth_cert(self):
 		self.assertEqual(resultK, key)
 		self.assertEqual(resultA, address)
 		self.assertEqual(resultC, cacert)
+	
+	def test_get_environment(self):
+		result = CLI().get_environment_by_language("python2",self.client)
+		print(result)
+		if("error" in result):
+			print(result)
+		self.assertTrue(result is not None and "display_name" in result)
 
 	def test_list_languages(self):
 		result = CLI().list_languages(self.client)

Test/client_test.py

@@ -38,6 +38,14 @@ def test_get_org(self):
         response = self.c.get_org("a_myOrg84")
         self.assertEqual("a_myOrg84",response['org_name'])
 
+    def test_get_environment(self):
+        client =Algorithmia.client(api_key=os.environ.get('ALGORITHMIA_API_KEY'))
+        response = client.get_environment("python2")
+        print(response)
+        if("error" in response):
+            print(response)
+        self.assertTrue(response is not None and "environments" in response)
+
     def test_get_build_logs(self):
         client = Algorithmia.client(api_key=os.environ.get('ALGORITHMIA_API_KEY'))
         user = os.environ.get('ALGO_USER_NAME')
@@ -46,8 +54,7 @@ def test_get_build_logs(self):
         if "error" in result:
             print(result)
         self.assertTrue("error" not in result)
-        
-			
+
 
     def test_edit_org(self):
         orgname="a_myOrg84"