Implement needed test.

slapos/libnetworkcachetests.py

@@ -282,7 +282,70 @@ class OnlineTest(OnlineMixin, unittest.TestCase):
         str(msg).startswith("Too many entries for a given key %r"% key))
 
   def test_DirectoryNotFound_non_trustable_entry(self):
-    raise NotImplementedError
+    key = """-----BEGIN RSA PRIVATE KEY-----
+MIICXQIBAAKBgQDDrOO87nSiDcXOf+xGc4Iqcdjfwd0RTOxEkO9z8mPZVg2bTPwt
+/GwtPgmIC4po3bJdsCpJH21ZJwfmUpaQWIApj3odDAbRXQHWhNiw9ZPMHTCmf8Zl
+yAJBxy9KI9M/fJ5RA67CJ6UYFbpF7+ZrXdkvG+0hdRX5ub0WyTPxc6kEIwIDAQAB
+AoGBAIgUj1jQGKqum1bt3dps8CQmgqWyA9TJQzK3/N8MveXik5niYypz9qNMFoLX
+S818CFRhdDbgNUKgAz1pSC5gbdfCDHYQTBrIt+LGpNSpdmQwReu3XoWOPZp4VWnO
+uCpAkDVt+88wbxtMbZ5/ExNFs2xTO66Aad1dG12tPWoyAf4pAkEA4tCLPFNxHGPx
+tluZXyWwJfVZEwLLzJ9gPkYtWrq843JuKlai2ziroubVLGSxeovBXvsjxBX95khn
+U6G9Nz5EzwJBANzal8zebFdFfiN1DAyGQ4QYsmz+NsRXDbHqFVepymUId1jAFAp8
+RqNt3Y78XlWOj8z5zMd4kWAR62p6LxJcyG0CQAjCaw4qXszs4zHaucKd7v6YShdc
+3UgKw6nEBg5h9deG3NBPxjxXJPHGnmb3gI8uBIrJgikZfFO/ahYlwev3QKsCQGJ0
+kHekMGg3cqQb6eMrd63L1L8CFSgyJsjJsfoCl1ezDoFiH40NGfCBaeP0XZmGlFSs
+h73k4eoSEwDEt3dYJYECQQCBssN92KuYCOfPkJ+OV1tKdJdAsNwI13kA//A7s7qv
+wHQpWKk/PLmpICMBeIiE0xT+CmCfJVOlQrqDdujganZZ
+-----END RSA PRIVATE KEY-----
+"""
+    key_file = tempfile.NamedTemporaryFile()
+    key_file.write(key)
+    key_file.flush()
+    key_file.seek(0)
+
+    certificate = """-----BEGIN CERTIFICATE-----
+MIICgDCCAekCADANBgkqhkiG9w0BAQsFADCBiDELMAkGA1UEBhMCVUwxETAPBgNV
+BAgTCEJlZSBZYXJkMRgwFgYDVQQKEw9CZWUtS2VlcGVyIEx0ZC4xGDAWBgNVBAsT
+D0hvbmV5IEhhcnZlc3RlcjEVMBMGA1UEAxMMTWF5YSB0aGUgQmVlMRswGQYJKoZI
+hvcNAQkBFgxNYXlhIHRoZSBCZWUwHhcNMTEwODI0MDc1MTU2WhcNMTIwODI0MDc1
+MTU2WjCBiDELMAkGA1UEBhMCVUwxETAPBgNVBAgTCEJlZSBZYXJkMRgwFgYDVQQK
+Ew9CZWUtS2VlcGVyIEx0ZC4xGDAWBgNVBAsTD0hvbmV5IEhhcnZlc3RlcjEVMBMG
+A1UEAxMMTWF5YSB0aGUgQmVlMRswGQYJKoZIhvcNAQkBFgxNYXlhIHRoZSBCZWUw
+gZ8wDQYJKoZIhvcNAQEBBQADgY0AMIGJAoGBAMOs47zudKINxc5/7EZzgipx2N/B
+3RFM7ESQ73PyY9lWDZtM/C38bC0+CYgLimjdsl2wKkkfbVknB+ZSlpBYgCmPeh0M
+BtFdAdaE2LD1k8wdMKZ/xmXIAkHHL0oj0z98nlEDrsInpRgVukXv5mtd2S8b7SF1
+Ffm5vRbJM/FzqQQjAgMBAAEwDQYJKoZIhvcNAQELBQADgYEAaT4yamJJowDKMSD2
+eshUW8pjctg6O3Ncm5XDIKd77sRf7RwPjFh+BR59lfFf9xvOu8WymhtUU7FoPDW3
+MYZmKV7A3nFehN9A+REz+WU3I7fE6vQRh9jKeuxnQLRv0TdP9CEdPcYcs/EQpIDb
+8du+N7wcN1ZO8veWSafBzcqgCwg=
+-----END CERTIFICATE-----
+"""
+
+    certificate_descriptor = tempfile.NamedTemporaryFile()
+    key_file_descritor = tempfile.NamedTemporaryFile()
+    nc = slapos.libnetworkcache.NetworkcacheClient(self.shacache, self.shadir)
+    key = 'somekey' + str(random.random())
+    urlmd5 = str(random.random())
+    file_name='my file'
+    nc.upload(self.test_data, key, urlmd5=urlmd5, file_name=file_name)
+    signed_nc = slapos.libnetworkcache.NetworkcacheClient(
+      self.shacache, self.shadir, signature_certificate_list=[certificate])
+    # when no signature is used, all works ok
+    selected = nc.select(key).read()
+    self.assertEqual(selected, self.test_string)
+    # but when signature is used, networkcache will complain
+    try:
+      signed_nc.select(key)
+    except slapos.libnetworkcache.DirectoryNotFound, msg:
+      self.assertEqual(str(msg), 'Could not find a trustable entry.')
+
+    # of course if proper key will be used to sign the content uploaded
+    # into shacache all will work
+    upload_nc = slapos.libnetworkcache.NetworkcacheClient(self.shacache,
+      self.shadir, signature_private_key_file=key_file.name)
+    upload_nc.upload(self.test_data, key, urlmd5=urlmd5, file_name=file_name)
+    selected = signed_nc.select(key).read()
+    self.assertEqual(selected, self.test_string)
 
 def _run_nc_POST200(tree, host, port):
   server_address = (host, port)