# Subclass of Archive that can be understood by a C program (see launch.c).

# Copyright (C) 2005, Giovanni Bajo

# Based on previous work under copyright (c) 1999, 2002 McMillan Enterprises, Inc.

#

# This program is free software; you can redistribute it and/or

# modify it under the terms of the GNU General Public License

# as published by the Free Software Foundation; either version 2

# of the License, or (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU General Public License for more details.

#

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA

import archive

import struct

try:

  import zlib

except ImportError:

  zlib = archive.DummyZlib()

import sys

if sys.version[0] == '1':

    import strop

    find = strop.find

    split = strop.split

else:

    def find(s, sub):

        return s.find(sub)

    def split(s, delim, count):

        return s.split(delim, count)

class CTOC:

  """A class encapsulating the table of contents of a CArchive.

     When written to disk, it is easily read from C."""

  ENTRYSTRUCT = '!iiiibc' #(structlen, dpos, dlen, ulen, flag, typcd) followed by name

  def __init__(self):

    self.data = []

  def frombinary(self, s):

    """Decode the binary string into an in memory list.

        S is a binary string."""

    entrylen = struct.calcsize(self.ENTRYSTRUCT)

    p = 0

    while p<len(s):

      (slen, dpos, dlen, ulen, flag, typcd) = struct.unpack(self.ENTRYSTRUCT,

                                                  s[p:p+entrylen])

      nmlen = slen - entrylen

      p = p + entrylen

      (nm,) = struct.unpack(`nmlen`+'s', s[p:p+nmlen])

      p = p + nmlen

      # version 4

      # self.data.append((dpos, dlen, ulen, flag, typcd, nm[:-1]))

      # version 5

      # nm may have up to 15 bytes of padding

      pos = find(nm, '\0')

      if pos < 0:

          self.data.append((dpos, dlen, ulen, flag, typcd, nm))

      else:

          self.data.append((dpos, dlen, ulen, flag, typcd, nm[:pos]))

      #end version 5

  def tobinary(self):

    """Return self as a binary string."""

    import string

    entrylen = struct.calcsize(self.ENTRYSTRUCT)

    rslt = []

    for (dpos, dlen, ulen, flag, typcd, nm) in self.data:

      nmlen = len(nm) + 1	# add 1 for a '\0'

      # version 4

      # rslt.append(struct.pack(self.ENTRYSTRUCT+`nmlen`+'s',

      #   nmlen+entrylen, dpos, dlen, ulen, flag, typcd, nm+'\0'))

      # version 5

      #   align to 16 byte boundary so xplatform C can read

      toclen = nmlen + entrylen

      if toclen % 16 == 0:

          pad = '\0'

      else:

          padlen = 16 - (toclen % 16)

          pad = '\0'*padlen

          nmlen = nmlen + padlen

      rslt.append(struct.pack(self.ENTRYSTRUCT+`nmlen`+'s',

                      nmlen+entrylen, dpos, dlen, ulen, flag, typcd, nm+pad))

      # end version 5

    return string.join(rslt, '')

  def add(self, dpos, dlen, ulen, flag, typcd, nm):

    """Add an entry to the table of contents.

       DPOS is data position.

       DLEN is data length.

       ULEN is the uncompressed data len.

       FLAG says if the data is compressed.

       TYPCD is the "type" of the entry (used by the C code)

       NM is the entry's name."""

    self.data.append((dpos, dlen, ulen, flag, typcd, nm))

  def get(self, ndx):

    """return the toc entry (tuple) at index NDX"""

    return self.data[ndx]

  def __getitem__(self, ndx):

    return self.data[ndx]

  def find(self, name):

    """Return the index of the toc entry with name NAME.

       Return -1 for failure."""

    for i in range(len(self.data)):

      if self.data[i][-1] == name:

        return i

    return -1

class CArchive(archive.Archive):

  """An Archive subclass that an hold arbitrary data.

     Easily handled from C or from Python."""

  MAGIC = 'MEI\014\013\012\013\016'

  HDRLEN = 0

  TOCTMPLT = CTOC

  TRLSTRUCT = '!8siiii'

  TRLLEN = 24

  LEVEL = 9

  def __init__(self, path=None, start=0, len=0):

    """Constructor.

       PATH is path name of file (create an empty CArchive if path is None).

       START is the seekposition within PATH.

       LEN is the length of the CArchive (if 0, then read till EOF). """

    self.len = len

    archive.Archive.__init__(self, path, start)

  def checkmagic(self):

    """Verify that self is a valid CArchive.

        Magic signature is at end of the archive."""

    #magic is at EOF; if we're embedded, we need to figure where that is

    if self.len:

      self.lib.seek(self.start+self.len, 0)

    else:

      self.lib.seek(0, 2)

    filelen = self.lib.tell()

    if self.len:

      self.lib.seek(self.start+self.len-self.TRLLEN, 0)

    else:

      self.lib.seek(-self.TRLLEN, 2)

    (magic, totallen, tocpos, toclen, pyvers) = struct.unpack(self.TRLSTRUCT,

                        self.lib.read(self.TRLLEN))

    if magic != self.MAGIC:

      raise RuntimeError, "%s is not a valid %s archive file" \

        % (self.path, self.__class__.__name__)

    self.pkgstart = filelen - totallen

    if self.len:

      if totallen != self.len or self.pkgstart != self.start:

        raise RuntimeError, "Problem with embedded archive in %s" % self.path

    self.tocpos, self.toclen = tocpos, toclen

  def loadtoc(self):

    """Load the table of contents into memory."""

    self.toc = self.TOCTMPLT()

    self.lib.seek(self.pkgstart+self.tocpos)

    tocstr = self.lib.read(self.toclen)

    self.toc.frombinary(tocstr)

  def extract(self, name):

    """Get the contents of an entry.

       NAME is an entry name.

       Return the tuple (ispkg, contents).

       For non-Python resoures, ispkg is meaningless (and 0).

       Used by the import mechanism."""

    if type(name) == type(''):

      ndx = self.toc.find(name)

      if ndx == -1:

        return None

    else:

      ndx = name

    (dpos, dlen, ulen, flag, typcd, nm) = self.toc.get(ndx)

    self.lib.seek(self.pkgstart+dpos)

    rslt = self.lib.read(dlen)

    if flag == 1:

      rslt = zlib.decompress(rslt)

    if typcd == 'M':

      return (1, rslt)

    return (0, rslt)

  def contents(self):

    """Return the names of the entries"""

    rslt = []

    for (dpos, dlen, ulen, flag, typcd, nm) in self.toc:

      rslt.append(nm)

    return rslt

  def add(self, entry):

    """Add an ENTRY to the CArchive.

       ENTRY must have:

         entry[0] is name (under which it will be saved).

         entry[1] is fullpathname of the file.

         entry[2] is a flag for it's storage format (0==uncompressed,

         1==compressed)

         entry[3] is the entry's type code.

         Version 5:

           If the type code is 'o':

             entry[0] is the runtime option

             eg: v  (meaning verbose imports)

                 u  (menaing unbuffered)

                 W arg (warning option arg)

                 s  (meaning do site.py processing."""

    (nm, pathnm, flag, typcd) = entry[:4]

    # version 5 - allow type 'o' = runtime option

    try:

      if typcd == 'o':

          s = ''

          flag = 0

      elif typcd == 's':

          # If it's a source code file, add \0 terminator as it will be

          # executed as-is by the bootloader.

          s = open(pathnm, 'r').read()

          s = s + '\n\0'

      else:

          s = open(pathnm, 'rb').read()

    except IOError:

      print "Cannot find ('%s', '%s', %s, '%s')" % (nm, pathnm, flag, typcd)

      raise

    ulen = len(s)

    if flag == 1:

      s = zlib.compress(s, self.LEVEL)

    dlen = len(s)

    where = self.lib.tell()

    if typcd == 'm':

      if find(pathnm, '.__init__.py') > -1:

        typcd = 'M'

    self.toc.add(where, dlen, ulen, flag, typcd, nm)

    self.lib.write(s)

  def save_toc(self, tocpos):

    """Save the table of contents to disk."""

    self.tocpos = tocpos

    tocstr = self.toc.tobinary()

    self.toclen = len(tocstr)

    self.lib.write(tocstr)

  def save_trailer(self, tocpos):

    """Save the trailer to disk.

       CArchives can be opened from the end - the trailer points

       back to the start. """

    totallen = tocpos + self.toclen + self.TRLLEN

    if hasattr(sys, "version_info"):

        pyvers = sys.version_info[0]*10 + sys.version_info[1]

    else:

        toks = split(sys.version, '.', 2)

        pyvers = int(toks[0])*10 + int(toks[1])

    trl = struct.pack(self.TRLSTRUCT, self.MAGIC, totallen,

                      tocpos, self.toclen, pyvers)

    self.lib.write(trl)

  def openEmbedded(self, name):

    """Open a CArchive of name NAME embedded within this CArchive."""

    ndx = self.toc.find(name)

    if ndx == -1:

      raise KeyError, "Member '%s' not found in %s" % (name, self.path)

    (dpos, dlen, ulen, flag, typcd, nm) = self.toc.get(ndx)

    if flag:

      raise ValueError, "Cannot open compressed archive %s in place"

    return CArchive(self.path, self.pkgstart+dpos, dlen)