1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
# -*- coding: utf-8 -*-
"""
Each user has a set of images that have been installed.
"""
#external imports
import os
import json
from collections import OrderedDict
#internal imports
from subuserlib.classes.userOwnedObject import UserOwnedObject
from subuserlib.classes.describable import Describable
import subuserlib.classes.docker.dockerDaemon as dockerDaemon
class InstalledImage(UserOwnedObject,Describable):
def __init__(self,user,imageId,imageSourceName,sourceRepoId,imageSourceHash):
self.imageId = imageId
self.imageSourceHash = imageSourceHash
self.imageSourceName = imageSourceName
self.sourceRepoId = sourceRepoId
self.__alreadyCheckedForUpdates = None
UserOwnedObject.__init__(self,user)
@property
def imageSource(self):
return self.user.registry.repositories[self.sourceRepoId][self.imageSourceName]
def isDockerImageThere(self):
"""
Does the Docker daemon have an image with this imageId?
"""
return not (self.user.dockerDaemon.getImageProperties(self.imageId) == None)
def removeCachedRuntimes(self):
"""
Remove cached runtime environments.
"""
pathToImagesRuntimeCacheDir = os.path.join(self.user.config["runtime-cache"],self.imageId)
try:
for permissionsSpecificCacheInfoFileName in os.listdir(pathToImagesRuntimeCacheDir):
permissionsSpecificCacheInfoFilePath = os.path.join(pathToImagesRuntimeCacheDir,permissionsSpecificCacheInfoFileName)
with open(permissionsSpecificCacheInfoFilePath,mode='r') as permissionsSpecificCacheInfoFileHandle:
permissionsSpecificCacheInfo = json.load(permissionsSpecificCacheInfoFileHandle, object_pairs_hook=OrderedDict)
try:
try:
imageId = permissionsSpecificCacheInfo['run-ready-image-id']
self.user.registry.log("Removing runtime cache image %s"%imageId)
self.user.dockerDaemon.removeImage(imageId)
except dockerDaemon.ImageDoesNotExistsException:
pass
os.remove(permissionsSpecificCacheInfoFilePath)
except dockerDaemon.ContainerDependsOnImageException:
pass
except OSError:
pass
def removeDockerImage(self):
"""
Remove the image from the Docker daemon's image store.
"""
try:
self.user.registry.log("Removing image %s"%self.imageId)
self.user.dockerDaemon.removeImage(self.imageId)
except (dockerDaemon.ImageDoesNotExistsException,dockerDaemon.ServerErrorException) as e:
self.user.registry.log("Error removing image: "+self.imageId+"\n"+str(e))
def describe(self):
print("Image Id: "+self.imageId)
try:
print("Image source: "+self.imageSource.getIdentifier())
except KeyError:
print("Image is broken, image source does not exist!")
print("Last update time: "+self.getCreationDateTime())
def serializeToDict(self):
imageAttributes = OrderedDict()
imageAttributes["image-source-hash"] = self.imageSourceHash
imageAttributes["image-source"] = self.imageSourceName
imageAttributes["source-repo"] = self.sourceRepoId
return imageAttributes
def checkForUpdates(self):
"""
Check for updates using the image's built in check-for-updates script. This launches the script as root in a privilageless container. Returns True if the image needs to be updated.
"""
if self.__alreadyCheckedForUpdates:
return False
self.__alreadyCheckedForUpdates = True
self.user.registry.log("Checking for updates to: " + self.imageSource.getIdentifier())
if self.user.dockerDaemon.execute(["run","--rm","--entrypoint","/usr/bin/test",self.imageId,"-e","/subuser/check-for-updates"]) == 0:
returnCode = self.user.dockerDaemon.execute(["run","--rm","--entrypoint","/subuser/check-for-updates",self.imageId])
if returnCode == 0:
return True
return False
def getCreationDateTime(self):
"""
Return the creation date/time of the installed docker image. Or None if the image does not exist.
"""
imageProperties = self.user.dockerDaemon.getImageProperties(self.imageId)
if not imageProperties is None:
return imageProperties["Created"]
else:
return None
def getLineageLayers(self):
"""
Return the list(lineage) of id of Docker image layers which goes from a base image to this image including all of the image's ancestors in order of dependency.
"""
def getLineageRecursive(imageId):
imageProperties = self.user.dockerDaemon.getImageProperties(imageId)
if imageProperties == None:
return []
#sys.exit("Failed to get properties of image "+imageId)
if not imageProperties["Parent"] == "":
return getLineageRecursive(imageProperties["Parent"]) + [imageId]
else:
return [imageId]
return getLineageRecursive(self.imageId)
def getImageLineage(self):
"""
Return the list(lineage) of InstalledImages which goes from a base image to this image including all of the image's ancestors in order of dependency.
"""
lineage = []
dockerImageLayers = self.getLineageLayers()
for dockerImageLayer in dockerImageLayers:
if dockerImageLayer in self.user.installedImages:
lineage.append(self.user.installedImages[dockerImageLayer])
return lineage
|
