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
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
# Loom, a plugin for bzr to assist in developing focused patches.
# Copyright (C) 2006 Canonical Limited.
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License version 2 as published
# by the Free Software Foundation.
#
# 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 St, Fifth Floor, Boston, MA 02110-1301 USA
#
"""Routines for reading and writing Looms in streams."""
from __future__ import absolute_import
import breezy.osutils
# The current format marker for serialised loom state.
# This belongs in a format object at some point.
_CURRENT_LOOM_FORMAT_STRING = b"Loom current 1"
# the current loom format :
# first line is the format signature
# second line is the list of parents
# third line and beyond are the current threads.
# each thread line has one field for current status
# one field for each parent
# one field for the current revision id
# and then the rest of the line for the thread name.
class LoomWriter(object):
"""LoomWriter objects are used to serialise looms."""
def write_threads(self, threads, stream):
"""Write threads to stream with a format header."""
thread_content = b'Loom meta 1\n'
for thread, rev_id in threads:
thread_content += b'%s %s\n' % (rev_id, thread.encode('utf-8'))
thread_content = thread_content
stream.write(thread_content)
return breezy.osutils.sha_strings([thread_content])
class LoomStateWriter(object):
"""LoomStateWriter objects are used to write out LoomState objects."""
def __init__(self, state):
"""Initialise a LoomStateWriter with a state object.
:param state: The LoomState object to be written out.
"""
self._state = state
def write(self, stream):
"""Write the state object to stream."""
lines = [_CURRENT_LOOM_FORMAT_STRING + b'\n']
lines.append(b' '.join(self._state.get_parents()) + b'\n')
# Note that we could possibly optimise our unicode handling here.
for thread, rev_id, parents in self._state.get_threads():
assert len(parents) == len(self._state.get_parents())
# leading space for conflict status
line = b" "
for parent in parents:
if parent is not None:
line += b"%s " % parent
else:
line += b" "
line += b": "
lines.append(b'%s%s %s\n' % (line, rev_id, thread.encode('utf-8')))
stream.write(b''.join(lines))
class LoomStateReader(object):
"""LoomStateReaders are used to pull LoomState objects into memory."""
def __init__(self, stream):
"""Initialise a LoomStateReader with a serialised loom-state stream.
:param stream: The stream that contains a loom-state object. This
should allow relative seeking.
"""
self._stream = stream
self._content = None
def _read(self):
"""Read the entire stream into memory.
This is just a first approximation - eventually partial reads
are desirable.
"""
if self._content is None:
# Names are unicode,revids are utf8 - it's arguable whether decode
# all and encode revids, or vice verca is better.
self._content = self._stream.read().split(b'\n')
# this is where detection of different formats should go.
# we probably want either a factory for readers, or a strategy
# for the reader that is looked up on this format string.
# either way, its in the future.
assert self._content[0] == _CURRENT_LOOM_FORMAT_STRING, \
"%r != %r" % (self._content[0], _CURRENT_LOOM_FORMAT_STRING)
def read_parents(self):
"""Read the parents field from the stream.
:return: a list of parent revision ids.
"""
self._read()
return self._content[1].split()
def read_thread_details(self):
"""Read the details for the threads.
:return: a list of thread details. Each thread detail is a 3-tuple
containing the thread name, the current thread revision, and a
list of parent thread revisions, in the same order and length
as the list returned by read_parents. In the parent thread
revision list, None means 'no present in the parent', and
'null:' means 'present but had no commits'.
"""
result = []
parent_count = len(self.read_parents())
# skip the format and parent lines, and the trailing \n line.
for line in self._content[2:-1]:
conflict_status, line = line.split(b' ', 1)
parents = []
parent = b""
while True:
parent, line = line.split(b' ', 1)
if parent == b':':
break
elif parent == b'':
parents.append(None)
else:
parents.append(parent)
rev_id, name = line.split(b' ', 1)
result.append((name.decode('utf-8'), rev_id, parents))
return result
|