Dev 320 (#86)

* 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 build logs to CLI

* changing username

* changing username

* changing username to env variable for unittest

* adding get build logs to client

* api location fix

* reorganizing methods

Co-authored-by: robert-close <rclose@algorithmia.io>
Co-authored-by: Kenny Daniel <kenny@algorithmia.com>
Co-authored-by: Kenny Daniel <3903376+kennydaniel@users.noreply.github.com>
Co-authored-by: John Bragg <john.bragg@ruralsource.com>
Co-authored-by: James Sutton <1892175+zeryx@users.noreply.github.com>

Author: 5 people

Algorithmia/CLI.py

@@ -287,6 +287,13 @@ 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 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,6 +107,12 @@ 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 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')
 
@@ -179,6 +185,9 @@ def main():
 
     elif args.cmd == 'cat':
         print(CLI().cat(args.path, client))
+
+    elif args.cmd == 'builds':
+        print(CLI().getBuildLogs(args.user, args.algo, client))
     else:
         parser.parse_args(['-h'])
 

Algorithmia/algorithm.py

@@ -112,6 +112,11 @@ def get_build_logs(self, build_id):
             error_message = json.loads(e.body)
             raise raiseAlgoApiError(error_message)
 
+    def build_logs(self):
+        url = '/v1/algorithms/'+self.username+'/'+self.algoname+'/builds'
+        response = json.loads(self.client.getHelper(url).content.decode('utf-8'))
+        return response
+
 
     def get_scm_status(self):
         try:

Algorithmia/client.py

@@ -114,6 +114,7 @@ def invite_to_org(self,orgname,username):
         response = self.putHelper(url,data={})
         return response
 
+
     # Used to send insight data to Algorithm Queue Reader in cluster
     def report_insights(self, insights):
         return Insights(insights)

Test/CLI_test.py

@@ -5,6 +5,7 @@
 
 import unittest
 import os
+import json
 import Algorithmia
 from Algorithmia.CLI import CLI
 import argparse
@@ -67,6 +68,15 @@ def test_cat(self):
 		result = CLI().cat([file],self.client)
 		self.assertEqual(result, fileContents)
 
+	def test_get_build_logs(self):
+		user=os.environ.get('ALGO_USER_NAME')
+		algo="Echo"
+		
+		result = json.loads(CLI().getBuildLogs(user,algo,self.client))
+		if "error" in result:
+			print(result)
+		self.assertTrue("error" not in result)
+
 
 #local to remote
 	def test_cp_L2R(self):

Test/client_test.py

@@ -38,6 +38,16 @@ def test_get_org(self):
         response = self.c.get_org("a_myOrg84")
         self.assertEqual("a_myOrg84",response['org_name'])
 
+    def test_get_build_logs(self):
+        client = Algorithmia.client(api_key=os.environ.get('ALGORITHMIA_API_KEY'))
+        user = os.environ.get('ALGO_USER_NAME')
+        algo = "Echo"
+        result = client.algo(user+'/'+algo).build_logs()
+        if "error" in result:
+            print(result)
+        self.assertTrue("error" not in result)
+        
+			
 
     def test_edit_org(self):
         orgname="a_myOrg84"