Skip to content

Commit 6473193

Browse files
Use snapshot-v2
1 parent a2344fc commit 6473193

File tree

1 file changed

+5
-10
lines changed

1 file changed

+5
-10
lines changed

src/prevayler_clj_aws/core.clj

Lines changed: 5 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -46,18 +46,13 @@
4646
unmarshal-fn))
4747

4848
(defn- read-snapshot [s3-cli s3-sdk-cli bucket snapshot-path]
49-
(if (snapshot-exists? s3-cli bucket snapshot-path)
50-
(let [v2-path (snapshot-v2-path snapshot-path)
51-
snap1 (read-object s3-sdk-cli bucket snapshot-path unmarshal)]
52-
(if (snapshot-exists? s3-cli bucket v2-path)
53-
(let [snap2 (read-object s3-sdk-cli bucket v2-path unmarshal-from-in)]
54-
(throw (RuntimeException. (str "Snapshot v1" (if (= snap1 snap2) "IS" "IS NOT") "equal to v2"))))
55-
(throw (RuntimeException. (str v2-path "object not found in bucket."))))
56-
snap1)
57-
{:partkey 0}))
49+
(let [v2-path (snapshot-v2-path snapshot-path)]
50+
(if (snapshot-exists? s3-cli bucket v2-path)
51+
(read-object s3-sdk-cli bucket v2-path unmarshal-from-in)
52+
{:partkey 0})))
5853

5954
(defn- save-snapshot! [s3-cli s3-sdk-cli bucket snapshot-path snapshot]
60-
(util/aws-invoke s3-cli {:op :PutObject
55+
#_(util/aws-invoke s3-cli {:op :PutObject
6156
:request {:Bucket bucket
6257
:Key snapshot-path
6358
:Body (marshal snapshot)}})

0 commit comments

Comments
 (0)