Skip to content

Commit 2a86e4d

Browse files
committed
Make implementation classes private
Signed-off-by: Pierre R. Mai <pmai@pmsf.de>
1 parent e45ee9c commit 2a86e4d

File tree

1 file changed

+14
-14
lines changed

1 file changed

+14
-14
lines changed

osi3trace/osi_trace.py

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -63,27 +63,27 @@ def message_types():
6363
def __getattr__(self, name):
6464
"""
6565
This method forwards the getattr call for unsuccessful legacy attribute
66-
name lookups to the reader in case it is an OSITraceSingle instance.
66+
name lookups to the reader in case it is an _OSITraceSingle instance.
6767
"""
68-
if name in self._legacy_ositrace_attributes and isinstance(self.reader, OSITraceSingle):
68+
if name in self._legacy_ositrace_attributes and isinstance(self.reader, _OSITraceSingle):
6969
return getattr(self.reader, name)
7070
raise AttributeError(f"'{type(self).__name__}' object has no attribute '{name}'")
7171

7272
def __setattr__(self, name, value):
7373
"""
7474
This method overwrites the default setter and forwards setattr calls for
7575
legacy attribute names to the reader in case the reader is an
76-
OSITraceSingle instance. Otherwise it uses the default setter.
76+
_OSITraceSingle instance. Otherwise it uses the default setter.
7777
"""
7878
reader = super().__getattribute__("reader") if "reader" in self.__dict__ else None
79-
if name in self._legacy_ositrace_attributes and isinstance(reader, OSITraceSingle):
79+
if name in self._legacy_ositrace_attributes and isinstance(reader, _OSITraceSingle):
8080
setattr(reader, name, value)
8181
else:
8282
super().__setattr__(name, value)
8383

8484
def __dir__(self):
8585
attrs = super().__dir__()
86-
if isinstance(self.reader, OSITraceSingle):
86+
if isinstance(self.reader, _OSITraceSingle):
8787
attrs += list(self._legacy_ositrace_attributes)
8888
return attrs
8989

@@ -107,9 +107,9 @@ def _init_reader(self, path, type_name, cache_messages, topic):
107107
raise FileNotFoundError("File not found")
108108

109109
if path.suffix.lower() == ".mcap":
110-
return OSITraceMulti(path, type_name, topic)
110+
return _OSITraceMulti(path, type_name, topic)
111111
elif path.suffix.lower() in [".osi", ".lzma", ".xz"]:
112-
return OSITraceSingle(path, type_name, cache_messages)
112+
return _OSITraceSingle(path, type_name, cache_messages)
113113
else:
114114
raise ValueError(f"Unsupported file format: '{path.suffix}'")
115115

@@ -142,25 +142,25 @@ def close(self):
142142

143143
@deprecated("This is a legacy interface only supported for single-channel traces, which will be removed in future versions.")
144144
def retrieve_offsets(self, limit=None):
145-
if isinstance(self.reader, OSITraceSingle):
145+
if isinstance(self.reader, _OSITraceSingle):
146146
return self.reader.retrieve_offsets(limit)
147147
raise NotImplementedError("Offsets are only supported for single-channel traces.")
148148

149149
@deprecated("This is a legacy interface only supported for single-channel traces, which will be removed in future versions.")
150150
def retrieve_message(self, index=None, skip=False):
151-
if isinstance(self.reader, OSITraceSingle):
151+
if isinstance(self.reader, _OSITraceSingle):
152152
return self.reader.retrieve_message(index, skip)
153153
raise NotImplementedError("Index-based message retrieval is only supported for single-channel traces.")
154154

155155
@deprecated("This is a legacy interface only supported for single-channel traces, which will be removed in future versions.")
156156
def get_message_by_index(self, index):
157-
if isinstance(self.reader, OSITraceSingle):
157+
if isinstance(self.reader, _OSITraceSingle):
158158
return self.reader.get_message_by_index(index)
159159
raise NotImplementedError("Index-based message retrieval is only supported for single-channel traces.")
160160

161161
@deprecated("This is a legacy interface only supported for single-channel traces, which will be removed in future versions.")
162162
def get_messages_in_index_range(self, begin, end):
163-
if isinstance(self.reader, OSITraceSingle):
163+
if isinstance(self.reader, _OSITraceSingle):
164164
return self.reader.get_messages_in_index_range(begin, end)
165165
raise NotImplementedError("Index-based message retrieval is only supported for single-channel traces.")
166166

@@ -174,7 +174,7 @@ def get_channel_metadata(self):
174174
return self.reader.get_channel_metadata()
175175

176176

177-
class ReaderBase(ABC):
177+
class _ReaderBase(ABC):
178178
"""Common interface for trace readers"""
179179

180180
@abstractmethod
@@ -202,7 +202,7 @@ def get_channel_metadata(self):
202202
pass
203203

204204

205-
class OSITraceSingle(ReaderBase):
205+
class _OSITraceSingle(_ReaderBase):
206206
"""OSI single-channel trace reader"""
207207

208208
def __init__(self, path=None, type_name="SensorView", cache_messages=False):
@@ -353,7 +353,7 @@ def get_channel_metadata(self):
353353
raise NotImplementedError("Getting channel metadata is only supported for multi-channel traces.")
354354

355355

356-
class OSITraceMulti(ReaderBase):
356+
class _OSITraceMulti(_ReaderBase):
357357
"""OSI multi-channel trace reader"""
358358

359359
def __init__(self, path, type_name, topic):

0 commit comments

Comments
 (0)