Dev 316 (#91)

* 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 list languages to library and CLI

* adding error check in test

* adding client unit test

* change assertion in unit test

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,13 +287,20 @@ 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 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()
 
         if "error" in api_response:
             return json.dumps(api_response)
         return json.dumps(api_response['results'], indent=1)
 
+
     def getconfigfile(self):
         if(os.name == "posix"):
             #if!windows

Algorithmia/__main__.py

@@ -107,12 +107,17 @@ 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 listing languages
+    subparsers.add_parser('languages', help = 'lists supported languages')
+
     #sub parser for builds
     parser_builds = subparsers.add_parser('builds', help = 'builds <user> <algo> gets build logs for algorithm')
     parser_builds.add_argument('user')
     parser_builds.add_argument('algo',help='algorithm name')
 
     #sub parser for help
+
     subparsers.add_parser('help')
     parser.add_argument('--profile', action = 'store', type = str, default = 'default')
 
@@ -185,6 +190,12 @@ def main():
 
     elif args.cmd == 'cat':
         print(CLI().cat(args.path, client))
+        
+    elif args.cmd == 'languages':
+        response = CLI().list_languages(client)
+        print("{:<25} {:<35}".format('Name','Description'))
+        for lang in response:
+            print("{:<25} {:<35}".format(lang['name'],lang['display_name']))
 
     elif args.cmd == 'builds':
         print(CLI().getBuildLogs(args.user, args.algo, client))

Algorithmia/client.py

@@ -114,6 +114,11 @@ def invite_to_org(self,orgname,username):
         response = self.putHelper(url,data={})
         return response
 
+    def get_supported_languages(self):
+        url ="/v1/algorithm-environments/edge/languages"
+        response = self.getHelper(url)
+        return response.json()
+
 
     # Used to send insight data to Algorithm Queue Reader in cluster
     def report_insights(self, insights):

Test/CLI_test.py

@@ -171,6 +171,13 @@ def test_auth_cert(self):
 		self.assertEqual(resultA, address)
 		self.assertEqual(resultC, cacert)
 
+	def test_list_languages(self):
+		result = CLI().list_languages(self.client)
+		if("error" in result):
+			print(result)
+		self.assertTrue(result is not None and "name" in result[0])
+
+
 	def test_rm(self):
 		localfile = "./TestFiles/testRM.txt"
 

Test/client_test.py

@@ -67,6 +67,14 @@ def test_edit_org(self):
         response = self.c.edit_org(orgname,obj)
         self.assertEqual(204,response.status_code)
 
+    def test_get_supported_languages(self):
+        client = Algorithmia.client(api_key=os.environ.get('ALGORITHMIA_API_KEY'))
+        response = client.get_supported_languages()
+        language_found = any('anaconda3' in languages['name'] for languages in response)
+        if("error" in response):
+            print(response)
+        self.assertTrue(response is not None and language_found)
+
     def test_invite_to_org(self):
         response = self.c.invite_to_org("a_myOrg38","a_Mrtest4")
         self.assertEqual(200,response.status_code)