Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/in_memory.py
| Show All 23 Lines | from typing import ( | ||||
| List, | List, | ||||
| Optional, | Optional, | ||||
| Tuple, | Tuple, | ||||
| TypeVar, | TypeVar, | ||||
| ) | ) | ||||
| import attr | import attr | ||||
| from deprecated import deprecated | |||||
| from swh.core.api.serializers import msgpack_loads, msgpack_dumps | from swh.core.api.serializers import msgpack_loads, msgpack_dumps | ||||
| from swh.model.model import ( | from swh.model.model import ( | ||||
| BaseContent, | BaseContent, | ||||
| Content, | Content, | ||||
| SkippedContent, | SkippedContent, | ||||
| Directory, | Directory, | ||||
| Revision, | Revision, | ||||
| Release, | Release, | ||||
| ▲ Show 20 Lines • Show All 718 Lines • ▼ Show 20 Lines | def origin_add(self, origins: Iterable[Origin]) -> Dict[str, int]: | ||||
| added = 0 | added = 0 | ||||
| for origin in origins: | for origin in origins: | ||||
| if origin.url not in self._origins: | if origin.url not in self._origins: | ||||
| self.origin_add_one(origin) | self.origin_add_one(origin) | ||||
| added += 1 | added += 1 | ||||
| return {"origin:add": added} | return {"origin:add": added} | ||||
| @deprecated("Use origin_add([origin]) instead") | |||||
| def origin_add_one(self, origin: Origin) -> str: | def origin_add_one(self, origin: Origin) -> str: | ||||
| if origin.url not in self._origins: | if origin.url not in self._origins: | ||||
| self.journal_writer.origin_add([origin]) | self.journal_writer.origin_add([origin]) | ||||
| # generate an origin_id because it is needed by origin_get_range. | # generate an origin_id because it is needed by origin_get_range. | ||||
| # TODO: remove this when we remove origin_get_range | # TODO: remove this when we remove origin_get_range | ||||
| origin_id = len(self._origins) + 1 | origin_id = len(self._origins) + 1 | ||||
| self._origins_by_id.append(origin.url) | self._origins_by_id.append(origin.url) | ||||
| assert len(self._origins_by_id) == origin_id | assert len(self._origins_by_id) == origin_id | ||||
| ▲ Show 20 Lines • Show All 426 Lines • Show Last 20 Lines | |||||