1

#!/usr/bin/env python

     2

# -*- coding: utf-8 -*-

     3

     4

# See COPYING file for copyrights details.

     5

     6

from __future__ import absolute_import

     7

import hashlib

     8

     9

    10

class ConnectorBase(object):

    11

    12

    chuncksize = 1024*1024

    13

    14

    def BlobFromFile(self, filepath, seed):

    15

        s = hashlib.new('md5')

    16

        s.update(seed)

    17

        blobID = self.SeedBlob(seed)

    18

        with open(filepath, "rb") as f:

    19

            while blobID == s.digest():

    20

                chunk = f.read(self.chuncksize)

    21

                if len(chunk) == 0:

    22

                    return blobID

    23

                blobID = self.AppendChunkToBlob(chunk, blobID)

    24

                s.update(chunk)

    25

        raise IOError("Data corrupted during transfer or connection lost")