/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar
0.12.3 by Aaron Bentley
Add pack serialization
1
from bzrlib import pack
0.12.1 by Aaron Bentley
Initial bencode-based encoding
2
from bzrlib.util import bencode
3
4
5
def serialize(tt):
6
    new_name = dict((k, v.encode('utf-8')) for k, v in tt._new_name.items())
0.12.7 by Aaron Bentley
Get executability under test.
7
    new_executability = dict((k, int(v)) for k, v in
8
                             tt._new_executability.items())
0.12.1 by Aaron Bentley
Initial bencode-based encoding
9
    attribs = {
10
        '_id_number': tt._id_number,
11
        '_new_name': new_name,
0.12.2 by Aaron Bentley
Handle parents
12
        '_new_parent': tt._new_parent,
0.12.7 by Aaron Bentley
Get executability under test.
13
        '_new_executability': new_executability,
0.12.1 by Aaron Bentley
Initial bencode-based encoding
14
        '_new_id': tt._new_id,
15
        }
0.12.3 by Aaron Bentley
Add pack serialization
16
    serializer = pack.ContainerSerialiser()
17
    yield serializer.begin()
18
    yield serializer.bytes_record(bencode.bencode(attribs), (('attribs',),))
0.12.4 by Aaron Bentley
Start deserializing files
19
    for trans_id, kind in tt._new_contents.items():
20
        if kind == 'file':
0.12.5 by Aaron Bentley
Test file content
21
            cur_file = open(tt._limbo_name(trans_id), 'rb')
22
            try:
23
                content = cur_file.read()
24
            finally:
25
                cur_file.close()
0.12.6 by Aaron Bentley
Support serializing/deserializing directories
26
        if kind == 'directory':
27
            content = ''
0.12.4 by Aaron Bentley
Start deserializing files
28
        yield serializer.bytes_record(content, ((trans_id, kind),))
0.12.3 by Aaron Bentley
Add pack serialization
29
    yield serializer.end()
30
0.12.1 by Aaron Bentley
Initial bencode-based encoding
31
32
def deserialize(tt, input):
0.12.3 by Aaron Bentley
Add pack serialization
33
    parser = pack.ContainerPushParser()
34
    for bytes in input:
35
        parser.accept_bytes(bytes)
36
    iterator = iter(parser.read_pending_records())
37
    names, content = iterator.next()
38
    attribs = bencode.bdecode(content)
0.12.1 by Aaron Bentley
Initial bencode-based encoding
39
    tt._id_number = attribs['_id_number']
40
    tt._new_name = dict((k, v.decode('utf-8'))
41
                        for k, v in attribs['_new_name'].items())
0.12.2 by Aaron Bentley
Handle parents
42
    tt._new_parent = attribs['_new_parent']
0.12.7 by Aaron Bentley
Get executability under test.
43
    tt._new_executability = dict((k, bool(v)) for k, v in
44
        attribs['_new_executability'].items())
0.12.1 by Aaron Bentley
Initial bencode-based encoding
45
    tt._new_id = attribs['_new_id']
46
    tt._r_new_id = dict((v, k) for k, v in tt._new_id.items())
0.12.4 by Aaron Bentley
Start deserializing files
47
    for ((trans_id, kind),), content in iterator:
48
        if kind == 'file':
49
            tt.create_file(content, trans_id)
0.12.6 by Aaron Bentley
Support serializing/deserializing directories
50
        if kind == 'directory':
51
            tt.create_directory(trans_id)