| # Copyright (C) 2009 The Android Open Source Project |
| # |
| # Licensed under the Apache License, Version 2.0 (the "License"); |
| # you may not use this file except in compliance with the License. |
| # You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, software |
| # distributed under the License is distributed on an "AS IS" BASIS, |
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| # See the License for the specific language governing permissions and |
| # limitations under the License. |
| |
| import os |
| import re |
| |
| import common |
| |
| class EdifyGenerator(object): |
| """Class to generate scripts in the 'edify' recovery script language |
| used from donut onwards.""" |
| |
| def __init__(self, version, info): |
| self.script = [] |
| self.mounts = set() |
| self.version = version |
| self.info = info |
| |
| def MakeTemporary(self): |
| """Make a temporary script object whose commands can latter be |
| appended to the parent script with AppendScript(). Used when the |
| caller wants to generate script commands out-of-order.""" |
| x = EdifyGenerator(self.version, self.info) |
| x.mounts = self.mounts |
| return x |
| |
| @staticmethod |
| def _WordWrap(cmd, linelen=80): |
| """'cmd' should be a function call with null characters after each |
| parameter (eg, "somefun(foo,\0bar,\0baz)"). This function wraps cmd |
| to a given line length, replacing nulls with spaces and/or newlines |
| to format it nicely.""" |
| indent = cmd.index("(")+1 |
| out = [] |
| first = True |
| x = re.compile("^(.{,%d})\0" % (linelen-indent,)) |
| while True: |
| if not first: |
| out.append(" " * indent) |
| first = False |
| m = x.search(cmd) |
| if not m: |
| parts = cmd.split("\0", 1) |
| out.append(parts[0]+"\n") |
| if len(parts) == 1: |
| break |
| else: |
| cmd = parts[1] |
| continue |
| out.append(m.group(1)+"\n") |
| cmd = cmd[m.end():] |
| |
| return "".join(out).replace("\0", " ").rstrip("\n") |
| |
| def AppendScript(self, other): |
| """Append the contents of another script (which should be created |
| with temporary=True) to this one.""" |
| self.script.extend(other.script) |
| |
| def AssertSomeFingerprint(self, *fp): |
| """Assert that the current system build fingerprint is one of *fp.""" |
| if not fp: |
| raise ValueError("must specify some fingerprints") |
| cmd = ( |
| ' ||\n '.join([('file_getprop("/system/build.prop", ' |
| '"ro.build.fingerprint") == "%s"') |
| % i for i in fp]) + |
| ' ||\n abort("Package expects build fingerprint of %s; this ' |
| 'device has " + getprop("ro.build.fingerprint") + ".");' |
| ) % (" or ".join(fp),) |
| self.script.append(cmd) |
| |
| def AssertOlderBuild(self, timestamp, timestamp_text): |
| """Assert that the build on the device is older (or the same as) |
| the given timestamp.""" |
| self.script.append( |
| ('(!less_than_int(%s, getprop("ro.build.date.utc"))) || ' |
| 'abort("Can\'t install this package (%s) over newer ' |
| 'build (" + getprop("ro.build.date") + ").");' |
| ) % (timestamp, timestamp_text)) |
| |
| def AssertDevice(self, device): |
| """Assert that the device identifier is the given string.""" |
| cmd = ('getprop("ro.product.device") == "%s" || ' |
| 'abort("This package is for \\"%s\\" devices; ' |
| 'this is a \\"" + getprop("ro.product.device") + "\\".");' |
| ) % (device, device) |
| self.script.append(cmd) |
| |
| def AssertSomeBootloader(self, *bootloaders): |
| """Asert that the bootloader version is one of *bootloaders.""" |
| cmd = ("assert(" + |
| " ||\0".join(['getprop("ro.bootloader") == "%s"' % (b,) |
| for b in bootloaders]) + |
| ");") |
| self.script.append(self._WordWrap(cmd)) |
| |
| def ShowProgress(self, frac, dur): |
| """Update the progress bar, advancing it over 'frac' over the next |
| 'dur' seconds. 'dur' may be zero to advance it via SetProgress |
| commands instead of by time.""" |
| self.script.append("show_progress(%f, %d);" % (frac, int(dur))) |
| |
| def SetProgress(self, frac): |
| """Set the position of the progress bar within the chunk defined |
| by the most recent ShowProgress call. 'frac' should be in |
| [0,1].""" |
| self.script.append("set_progress(%f);" % (frac,)) |
| |
| def PatchCheck(self, filename, *sha1): |
| """Check that the given file (or MTD reference) has one of the |
| given *sha1 hashes, checking the version saved in cache if the |
| file does not match.""" |
| self.script.append( |
| 'apply_patch_check("%s"' % (filename,) + |
| "".join([', "%s"' % (i,) for i in sha1]) + |
| ') || abort("\\"%s\\" has unexpected contents.");' % (filename,)) |
| |
| def FileCheck(self, filename, *sha1): |
| """Check that the given file (or MTD reference) has one of the |
| given *sha1 hashes.""" |
| self.script.append('assert(sha1_check(read_file("%s")' % (filename,) + |
| "".join([', "%s"' % (i,) for i in sha1]) + |
| '));') |
| |
| def CacheFreeSpaceCheck(self, amount): |
| """Check that there's at least 'amount' space that can be made |
| available on /cache.""" |
| self.script.append(('apply_patch_space(%d) || abort("Not enough free space ' |
| 'on /system to apply patches.");') % (amount,)) |
| |
| def Mount(self, mount_point): |
| """Mount the partition with the given mount_point.""" |
| fstab = self.info.get("fstab", None) |
| if fstab: |
| p = fstab[mount_point] |
| self.script.append('mount("%s", "%s", "%s", "%s");' % |
| (p.fs_type, common.PARTITION_TYPES[p.fs_type], |
| p.device, p.mount_point)) |
| self.mounts.add(p.mount_point) |
| |
| def UnpackPackageDir(self, src, dst): |
| """Unpack a given directory from the OTA package into the given |
| destination directory.""" |
| self.script.append('package_extract_dir("%s", "%s");' % (src, dst)) |
| |
| def Comment(self, comment): |
| """Write a comment into the update script.""" |
| self.script.append("") |
| for i in comment.split("\n"): |
| self.script.append("# " + i) |
| self.script.append("") |
| |
| def Print(self, message): |
| """Log a message to the screen (if the logs are visible).""" |
| self.script.append('ui_print("%s");' % (message,)) |
| |
| def FormatPartition(self, partition): |
| """Format the given partition, specified by its mount point (eg, |
| "/system").""" |
| |
| reserve_size = 0 |
| fstab = self.info.get("fstab", None) |
| if fstab: |
| p = fstab[partition] |
| self.script.append('format("%s", "%s", "%s", "%s", "%s");' % |
| (p.fs_type, common.PARTITION_TYPES[p.fs_type], |
| p.device, p.length, p.mount_point)) |
| |
| def DeleteFiles(self, file_list): |
| """Delete all files in file_list.""" |
| if not file_list: return |
| cmd = "delete(" + ",\0".join(['"%s"' % (i,) for i in file_list]) + ");" |
| self.script.append(self._WordWrap(cmd)) |
| |
| def ApplyPatch(self, srcfile, tgtfile, tgtsize, tgtsha1, *patchpairs): |
| """Apply binary patches (in *patchpairs) to the given srcfile to |
| produce tgtfile (which may be "-" to indicate overwriting the |
| source file.""" |
| if len(patchpairs) % 2 != 0 or len(patchpairs) == 0: |
| raise ValueError("bad patches given to ApplyPatch") |
| cmd = ['apply_patch("%s",\0"%s",\0%s,\0%d' |
| % (srcfile, tgtfile, tgtsha1, tgtsize)] |
| for i in range(0, len(patchpairs), 2): |
| cmd.append(',\0%s, package_extract_file("%s")' % patchpairs[i:i+2]) |
| cmd.append(');') |
| cmd = "".join(cmd) |
| self.script.append(self._WordWrap(cmd)) |
| |
| def WriteRawImage(self, mount_point, fn): |
| """Write the given package file into the partition for the given |
| mount point.""" |
| |
| fstab = self.info["fstab"] |
| if fstab: |
| p = fstab[mount_point] |
| partition_type = common.PARTITION_TYPES[p.fs_type] |
| args = {'device': p.device, 'fn': fn} |
| if partition_type == "MTD": |
| self.script.append( |
| 'write_raw_image(package_extract_file("%(fn)s"), "%(device)s");' |
| % args) |
| elif partition_type == "EMMC": |
| self.script.append( |
| 'package_extract_file("%(fn)s", "%(device)s");' % args) |
| else: |
| raise ValueError("don't know how to write \"%s\" partitions" % (p.fs_type,)) |
| |
| def SetPermissions(self, fn, uid, gid, mode): |
| """Set file ownership and permissions.""" |
| self.script.append('set_perm(%d, %d, 0%o, "%s");' % (uid, gid, mode, fn)) |
| |
| def SetPermissionsRecursive(self, fn, uid, gid, dmode, fmode): |
| """Recursively set path ownership and permissions.""" |
| self.script.append('set_perm_recursive(%d, %d, 0%o, 0%o, "%s");' |
| % (uid, gid, dmode, fmode, fn)) |
| |
| def MakeSymlinks(self, symlink_list): |
| """Create symlinks, given a list of (dest, link) pairs.""" |
| by_dest = {} |
| for d, l in symlink_list: |
| by_dest.setdefault(d, []).append(l) |
| |
| for dest, links in sorted(by_dest.iteritems()): |
| cmd = ('symlink("%s", ' % (dest,) + |
| ",\0".join(['"' + i + '"' for i in sorted(links)]) + ");") |
| self.script.append(self._WordWrap(cmd)) |
| |
| def AppendExtra(self, extra): |
| """Append text verbatim to the output script.""" |
| self.script.append(extra) |
| |
| def UnmountAll(self): |
| for p in sorted(self.mounts): |
| self.script.append('unmount("%s");' % (p,)) |
| self.mounts = set() |
| |
| def AddToZip(self, input_zip, output_zip, input_path=None): |
| """Write the accumulated script to the output_zip file. input_zip |
| is used as the source for the 'updater' binary needed to run |
| script. If input_path is not None, it will be used as a local |
| path for the binary instead of input_zip.""" |
| |
| self.UnmountAll() |
| |
| common.ZipWriteStr(output_zip, "META-INF/com/google/android/updater-script", |
| "\n".join(self.script) + "\n") |
| |
| if input_path is None: |
| data = input_zip.read("OTA/bin/updater") |
| else: |
| data = open(os.path.join(input_path, "updater")).read() |
| common.ZipWriteStr(output_zip, "META-INF/com/google/android/update-binary", |
| data, perms=0755) |
