Changeset View
Changeset View
Standalone View
Standalone View
swh/vault/cache.py
Show All 25 Lines | class VaultCache: | ||||
def get(self, bundle_type, swhid: CoreSWHID): | def get(self, bundle_type, swhid: CoreSWHID): | ||||
sid = self._get_internal_id(bundle_type, swhid) | sid = self._get_internal_id(bundle_type, swhid) | ||||
return self.objstorage.get(hashutil.hash_to_bytes(sid)) | return self.objstorage.get(hashutil.hash_to_bytes(sid)) | ||||
def delete(self, bundle_type, swhid: CoreSWHID): | def delete(self, bundle_type, swhid: CoreSWHID): | ||||
sid = self._get_internal_id(bundle_type, swhid) | sid = self._get_internal_id(bundle_type, swhid) | ||||
return self.objstorage.delete(hashutil.hash_to_bytes(sid)) | return self.objstorage.delete(hashutil.hash_to_bytes(sid)) | ||||
def get_stream(self, bundle_type, swhid: CoreSWHID): | |||||
sid = self._get_internal_id(bundle_type, swhid) | |||||
return self.objstorage.get_stream(hashutil.hash_to_bytes(sid)) | |||||
def is_cached(self, bundle_type, swhid: CoreSWHID): | def is_cached(self, bundle_type, swhid: CoreSWHID): | ||||
sid = self._get_internal_id(bundle_type, swhid) | sid = self._get_internal_id(bundle_type, swhid) | ||||
return hashutil.hash_to_bytes(sid) in self.objstorage | return hashutil.hash_to_bytes(sid) in self.objstorage | ||||
def _get_internal_id(self, bundle_type, swhid: CoreSWHID): | def _get_internal_id(self, bundle_type, swhid: CoreSWHID): | ||||
return compute_hash("{}:{}".format(bundle_type, swhid).encode()) | return compute_hash("{}:{}".format(bundle_type, swhid).encode()) |