Page MenuHomeSoftware Heritage
Files F9346097

D693.diff
No OneTemporary
Actions

D693.diff
View Options

diff --git a/swh/journal/publisher.py b/swh/journal/publisher.py
--- a/swh/journal/publisher.py
+++ b/swh/journal/publisher.py
@@ -138,6 +138,7 @@
'revision': self.process_revisions,
'release': self.process_releases,
'snapshot': self.process_snapshots,
+ 'origin': self.process_origins,
}
return {
@@ -175,6 +176,9 @@
metadata = self.storage.release_get((r[b'id'] for r in release_objs))
return [(release['id'], release) for release in metadata]
+ def process_origins(self, origin_objs):
+ return origin_objs
+
def process_snapshots(self, snapshot_objs):
metadata = []
for snap in snapshot_objs:
diff --git a/swh/journal/tests/test_publisher.py b/swh/journal/tests/test_publisher.py
--- a/swh/journal/tests/test_publisher.py
+++ b/swh/journal/tests/test_publisher.py
@@ -67,6 +67,17 @@
},
]
+ORIGINS = [
+ {
+ 'url': 'https://somewhere.org/den/fox',
+ 'type': 'git',
+ },
+ {
+ 'url': 'https://overtherainbow.org/fox/den',
+ 'type': 'svn',
+ }
+]
+
class JournalPublisherTest(SWHJournalPublisher):
def parse_config_file(self):
@@ -85,6 +96,7 @@
self.storage.content_add({'data': b'42', **c} for c in CONTENTS)
self.storage.revision_add(REVISIONS)
self.storage.release_add(RELEASES)
+ self.storage.origin_add(ORIGINS)
def _prepare_journal(self, config):
"""No journal for now
@@ -99,6 +111,7 @@
self.contents = [{b'sha1': c['sha1']} for c in CONTENTS]
self.revisions = [{b'id': c['id']} for c in REVISIONS]
self.releases = [{b'id': c['id']} for c in RELEASES]
+ self.origins = ORIGINS
def test_process_contents(self):
actual_contents = self.publisher.process_contents(self.contents)
@@ -115,11 +128,17 @@
expected_releases = [(c['id'], c) for c in RELEASES]
self.assertEqual(actual_releases, expected_releases)
+ def test_process_origins(self):
+ actual_releases = self.publisher.process_origins(self.origins)
+ expected_releases = self.origins
+ self.assertEqual(actual_releases, expected_releases)
+
def test_process_objects(self):
messages = {
'content': self.contents,
'revision': self.revisions,
'release': self.releases,
+ 'origin': self.origins,
}
actual_objects = self.publisher.process_objects(messages)
@@ -127,11 +146,13 @@
expected_contents = [(c['sha1'], c) for c in CONTENTS]
expected_revisions = [(c['id'], c) for c in REVISIONS]
expected_releases = [(c['id'], c) for c in RELEASES]
+ expected_origins = ORIGINS
expected_objects = {
'content': expected_contents,
'revision': expected_revisions,
'release': expected_releases,
+ 'origin': expected_origins,
}
self.assertEqual(actual_objects, expected_objects)

File Metadata

Mime Type
text/plain
Expires
Thu, Jul 3, 3:43 PM (2 w, 3 h ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3217985

Event Timeline

About · Developer information · Legal