blob: 833c066689a832667f66aadc9ff44e3e67a69368 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
(ns weepinbell.migration-test
(:require [weepinbell.migration :as m]
[weepinbell.metadata.jf2-spec]
[fast-edn.core :as edn]
[weepinbell.storage.h2 :as h2]
[weepinbell.utils.digest :refer [digest]]
[next.jdbc :as jdbc]
[next.jdbc.sql :as sql]
[clojure.spec.alpha :as s]
[clojure.test :refer [deftest testing is]]
[clojure.java.io :as io]))
(def test-source-edn (io/resource "webmention-test.edn"))
(def webmention-test-edn
(with-open [rdr (io/reader test-source-edn)]
(->> rdr line-seq (map edn/read-string) doall)))
(deftest test-migration-from-mf-to-jf2
(testing "Convert a Webmention object with microformats to one with jf2"
(let [data (->> webmention-test-edn
(filter #(some? (:microformats %)))
first)
converted (m/mf->jf2 data)]
(is (contains? converted :jf2))
(is (not (contains? converted :microformats)))
(is (s/valid? :weepinbell.metadata.jf2-spec/jf2
(:jf2 converted))))))
(deftest test-migration-from-edn-to-h2
(testing "Migrating EDN file storage to H2 database storage:"
(let [target-h2 "tmp/webmention-test-h2"]
(testing "no error or exception should be thrown"
(is (nil? (try
(m/edn->h2 test-source-edn target-h2)
(catch Throwable _ :fail)))))
(testing "there should be no data loss"
(let [ds (h2/make-datasource target-h2)
result (jdbc/execute! ds ["SELECT count(*) FROM webmention"])
len (get (first result) (keyword "count(*)"))]
(is (= len (count webmention-test-edn)))))
(testing "should recalculate hash/id of webmentions"
(let [ds (h2/make-datasource target-h2)
result (jdbc/execute! ds ["SELECT hash, wm_source, wm_target FROM webmention"])
match? (fn [{:keys [hash wm_source wm_target]}]
(= hash (digest (str wm_source wm_target))))]
(is (every? match? result))))
(io/delete-file (str target-h2 ".mv.db"))))
(testing "Exceptions thrown during migration does not abort program"
(with-redefs [weepinbell.storage.h2/insert-webmention
(fn [& _] (throw (Exception. "Test exception")))]
(let [target-h2 "tmp/webmention-test-exception-h2"]
(is (nil? (try
(m/edn->h2 test-source-edn target-h2)
(catch Exception _ :fail)))))))
(testing "Errors thrown during migration should fail migration"
(with-redefs [weepinbell.storage.h2/insert-webmention
(fn [& _] (throw (Error. "Test error")))]
(let [target-h2 "tmp/webmention-test-exception-h2"]
(is (= :fail (try
(m/edn->h2 test-source-edn target-h2)
(catch Error _ :fail))))))))
(deftest test-edn-jf2ify
(testing "Convert webmenion-test.edn to webmention-test-jf2.edn with jf2 markup"
(let [target-edn "tmp/webmention-test-jf2ified.edn"]
(m/edn-jf2ify test-source-edn target-edn)
(with-open [rdr (io/reader target-edn)]
(let [all (->> rdr line-seq (map edn/read-string))
jf2s (->> all (filter :jf2) (map :jf2))]
(is (every? #(not (:microformats %)) all))
(is (every? #(s/valid? :weepinbell.metadata.jf2-spec/jf2 %) jf2s)))))))
|
