SSPROD-2210: Added import_image and anchore_account to SDC CLI (#100)

Author: yathi-sysdig

.travis.yml

@@ -5,7 +5,7 @@ python:
 - '2.7'
 install:
   - sudo apt-get install linux-headers-$(uname -r) dkms gcc-multilib g++-multilib
-  - pip install pyyaml requests
+  - pip install pyyaml requests requests_toolbelt
 script:
 - bash test/start_agent.sh
 - bash test/test_monitor_apis.sh

examples/get_anchore_users_account.py

@@ -0,0 +1,40 @@
+#!/usr/bin/env python
+#
+# Get a specific anchore user account
+#
+
+import os
+import sys
+sys.path.insert(0, os.path.join(os.path.dirname(os.path.realpath(sys.argv[0])), '..'))
+from sdcclient import SdScanningClient
+
+
+def usage():
+    print('usage: %s <sysdig-token>' % sys.argv[0])
+    print('You can find your token at https://secure.sysdig.com/#/settings/user')
+    sys.exit(1)
+
+
+#
+# Parse arguments
+#
+if len(sys.argv) != 2:
+    usage()
+
+sdc_token = sys.argv[1]
+
+#
+# Instantiate the SDC client
+#
+sdclient = SdScanningClient(sdc_token, 'https://secure.sysdig.com')
+
+ok, res = sdclient.get_anchore_users_account()
+
+#
+# Return the result
+#
+if ok:
+    print("Anchore User Info %s" % res)
+else:
+    print(res)
+    sys.exit(1)

requirements.txt

@@ -1,2 +1,3 @@
 requests
 pyaml
+requests_toolbelt

sdcclient/_scanning.py

@@ -3,6 +3,7 @@
 import json
 import re
 import requests
+from requests_toolbelt.multipart.encoder import MultipartEncoder
 import time
 
 try:
@@ -54,23 +55,6 @@ def add_image(self, image, force=False, dockerfile=None, annotations={}, autosub
 
         return [True, res.json()]
 
-    def import_image(self, image_data):
-        '''**Description**
-            Import an image from the scanner export
-
-        **Arguments**
-            - image_data: A JSON with the image information.
-
-        **Success Return Value**
-            A JSON object representing the image that was imported.
-        '''
-        url = self.url + "/api/scanning/v1/anchore/imageimport"
-        res = requests.post(url, data=json.dumps(image_data), headers=self.hdrs, verify=self.ssl_verify)
-        if not self._checkResponse(res):
-            return [False, self.lasterr]
-
-        return [True, res.json()]
-
     def get_image(self, image, show_history=False):
         '''**Description**
             Find the image with the tag <image> and return its json description
@@ -323,6 +307,49 @@ def get_pdf_report(self, image, tag=None, date=None):
 
         return [True, res.content]
 
+    def import_image(self, infile):
+        '''**Description**
+            Import an image archive
+
+        **Arguments**
+           - infile: An image archive file
+
+        **Success Return Value**
+            A JSON object representing the image that was imported.
+        '''
+        try:
+            m = MultipartEncoder(
+                fields={'archive_file': (infile, open(infile, 'rb'), 'text/plain')}
+            )
+            url = self.url+"/api/scanning/v1/import/images"
+
+            headers = {'Authorization': 'Bearer ' + self.token, 'Content-Type': m.content_type}
+            res = requests.post(url, data=m, headers=headers)
+            if not self._checkResponse(res):
+                return [False, self.lasterr]
+
+            return [True, res.json()]
+
+        except Exception as err:
+            print(err)
+
+    def get_anchore_users_account(self):
+        '''**Description**
+            Get the anchore user account.
+
+        **Arguments**
+            - None
+
+        **Success Return Value**
+            A JSON object containing user account information.
+        '''
+        url = self.url + "/api/scanning/v1/anchore/account"
+        res = requests.get(url, headers=self.hdrs, verify=self.ssl_verify)
+        if not self._checkResponse(res):
+            return [False, self.lasterr]
+
+        return [True, res.json()]
+
     def add_registry(self, registry, registry_user, registry_pass, insecure=False, registry_type="docker_v2", validate=True):
         '''**Description**
             Add image registry

setup.py

@@ -8,5 +8,5 @@
       author_email='[email protected]',
       license='MIT',
       packages=['sdcclient'],
-      install_requires=['requests', 'pyaml'],
+      install_requires=['requests', 'pyaml', 'requests_toolbelt'],
       zip_safe=False)