Compare commits

..

No commits in common. "a01fd57150da969df8f07fd1c0a5dac4ceb5e4c1" and "807a8bc5235ec33d582ce84602b2f249bca2e6e1" have entirely different histories.

13 changed files with 180 additions and 123 deletions

89
.github/workflows/stable.yml vendored Normal file
View file

@ -0,0 +1,89 @@
name: stable
on:
push:
tags: '[0-9]+.[0-9]+.[0-9]+*'
jobs:
stable:
name: stable
runs-on: ubuntu-latest
strategy:
matrix:
node-version: [14.x]
steps:
- uses: actions/checkout@v2
- name: Use Node.js ${{ matrix.node-version }}
uses: actions/setup-node@v1
with:
node-version: ${{ matrix.node-version }}
- name: test em
run: |
npm install
npm install -g --save-dev shadow-cljs
shadow-cljs compile test
- name: build em
run: |
shadow-cljs release app
chmod a+x mastodon-bot.js
sha256sum mastodon-bot.js > target/mastodon-bot.js.sha256
sha512sum mastodon-bot.js > target/mastodon-bot.js.sha512
- name: Create Release
id: create_release
uses: actions/create-release@v1
env:
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
with:
tag_name: ${{ github.ref }}
release_name: Release ${{ github.ref }}
draft: false
prerelease: false
- name: Upload mastodon-bot.js
id: upload-mastodon-bot-js
uses: actions/upload-release-asset@v1
env:
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
with:
upload_url: ${{ steps.create_release.outputs.upload_url }}
asset_path: ./mastodon-bot.js
asset_name: mastodon-bot.js
asset_content_type: application/javascript
- name: Upload mastodon-bot.js.sha256
id: upload-mastodon-bot-js-sha256
uses: actions/upload-release-asset@v1
env:
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
with:
upload_url: ${{ steps.create_release.outputs.upload_url }}
asset_path: ./target/mastodon-bot.js.sha256
asset_name: mastodon-bot.js.sha256
asset_content_type: text/plain
- name: Upload mastodon-bot.js.sha512
id: upload-mastodon-bot-js-sha512
uses: actions/upload-release-asset@v1
env:
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
with:
upload_url: ${{ steps.create_release.outputs.upload_url }}
asset_path: ./target/mastodon-bot.js.sha512
asset_name: mastodon-bot.js.sha512
asset_content_type: text/plain
- name: upload to npm
env:
NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}
run: |
mkdir -p target/npm-build/mastodon_bot
cp mastodon-bot.js target/npm-build/mastodon_bot/
cp target/mastodon-bot.js.sha256 target/npm-build/mastodon_bot/
cp target/mastodon-bot.js.sha512 target/npm-build/mastodon_bot/
cp package.json target/npm-build/mastodon_bot/
cp README.md target/npm-build/mastodon_bot/
npm publish ./target/npm-build/mastodon_bot --access public

View file

@ -5,7 +5,6 @@
vi package.json vi package.json
lein release lein release
git push --follow-tags
# bump version - increase version and add -SNAPSHOT # bump version - increase version and add -SNAPSHOT
vi package.json vi package.json

Binary file not shown.

Before

Width:  |  Height:  |  Size: 18 KiB

View file

@ -1,10 +0,0 @@
@startuml
"Mastodon-Bot" -> Config: Call rss-sources
Config --> "Mastodon-Bot": URL list of rss-sources
"Mastodon-Bot" -> "Mastodon-Bot": Call "get-feed" for every rss-source.\nStart asyncronous Promise.
activate "Mastodon-Bot"
"Mastodon-Bot" -> "RSS-Sources": Call URL to parse RSS-Feed
"RSS-Sources" --> "Mastodon-Bot": RSS-Feed
"Mastodon-Bot" -> Mastodon: Post feed by post-rss-to-mastodon
deactivate "Mastodon-Bot"
@enduml

View file

@ -2,18 +2,17 @@
"name": "mastodon-bot", "name": "mastodon-bot",
"description": "Bot to publish twitter, tumblr or rss posts to an mastodon account.", "description": "Bot to publish twitter, tumblr or rss posts to an mastodon account.",
"author": "Dmitri Sotnikov", "author": "Dmitri Sotnikov",
"version": "1.12.1-SNAPSHOT", "version": "1.10.12-SNAPSHOT",
"homepage": "https://github.com/yogthos/mastodon-bot", "homepage": "https://github.com/yogthos/mastodon-bot",
"repository": "https://www.npmjs.com/package/mastodon-bot", "repository": "https://www.npmjs.com/package/mastodon-bot",
"license": "MIT", "license": "MIT",
"dependencies": { "dependencies": {
"deasync": "0.1.20",
"mastodon-api": "1.3.0", "mastodon-api": "1.3.0",
"node-fetch": "2.6.1",
"request": "2.88.0",
"rss-parser": "3.7.1", "rss-parser": "3.7.1",
"tumblr": "0.4.1", "tumblr": "0.4.1",
"twitter": "1.7.1" "twitter": "1.7.1",
"deasync": "0.1.20",
"request": "2.88.0"
}, },
"devDependencies": { "devDependencies": {
"shadow-cljs": "^2.8.37" "shadow-cljs": "^2.8.37"

View file

@ -1,4 +1,4 @@
(defproject dda/mastodon-bot "1.12.1-SNAPSHOT" (defproject dda/mastodon-bot "1.10.12-SNAPSHOT"
:description "Bot to publish twitter, tumblr or rss posts to an mastodon account." :description "Bot to publish twitter, tumblr or rss posts to an mastodon account."
:url "https://github.com/yogthos/mastodon-bot" :url "https://github.com/yogthos/mastodon-bot"
:author "Dmitri Sotnikov" :author "Dmitri Sotnikov"

View file

@ -1,21 +1,15 @@
(ns mastodon-bot.infra (ns mastodon-bot.infra
(:require (:require
[cljs.reader :as edn] [cljs.reader :as edn]
[clojure.string :as string] [clojure.pprint :refer [pprint]]
["fs" :as fs] ["fs" :as fs]))
["deasync" :as deasync]
["node-fetch" :as fetch]))
(defn log-error [item] (defn debug [item]
(js/console.error item) (pprint item)
item) item)
(defn log [item] (defn debug-first [item]
(js/console.log item) (pprint (first item))
item)
(defn log-first [item]
(js/console.log (first item))
item) item)
(defn js->edn [data] (defn js->edn [data]
@ -48,22 +42,3 @@
(defn load-config [config-location] (defn load-config [config-location]
(merge (load-main-config config-location) (load-credentials-config))) (merge (load-main-config config-location) (load-credentials-config)))
(defn resolve-promise [promise result-on-error]
(let [done (atom false)
result (atom nil)]
(-> promise
(.then #(do (reset! result %) (reset! done true)))
(.catch #(do
(log-error %)
(reset! result result-on-error)
(reset! done true))))
(.loopWhile deasync (fn [] (not @done)))
@result))
(defn resolve-url [[uri]]
(let [used-uri (if (string/starts-with? uri "https://") uri (str "https://" uri))
location (-> (fetch used-uri #js {:method "GET" :redirect "manual" :timeout "3000"})
(.then #(.get (.-headers %) "Location"))
(.then #(string/replace % "?mbid=social_twitter" "")))]
(resolve-promise location uri)))

View file

@ -2,15 +2,11 @@
(:require (:require
[orchestra.core :refer-macros [defn-spec]] [orchestra.core :refer-macros [defn-spec]]
[mastodon-bot.rss-domain :as rd] [mastodon-bot.rss-domain :as rd]
[mastodon-bot.infra :as infra]
[clojure.spec.alpha :as s]
["rss-parser" :as rss])) ["rss-parser" :as rss]))
(s/def ::pos-integer (and #(< 0 %) integer?))
(defn-spec rss-client any? (defn-spec rss-client any?
[& {:keys [timeout] []
:or {timeout 3000}} (s/keys :opt-un [::pos-integer])] (rss.))
(rss. #js {:timeout timeout}))
(defn-spec parse-feed any? (defn-spec parse-feed any?
[item ::rd/feed-item] [item ::rd/feed-item]
@ -21,5 +17,8 @@
link)})) link)}))
(defn-spec get-feed map? (defn-spec get-feed map?
[url string?] [url string?
(infra/resolve-promise (.parseURL (rss-client) url) [])) callback fn?]
(print url)
(-> (.parseURL (rss-client) url)
(.then callback)))

View file

@ -10,7 +10,22 @@
[mastodon-bot.rss-api :as ra] [mastodon-bot.rss-api :as ra]
[mastodon-bot.tumblr-domain :as td] [mastodon-bot.tumblr-domain :as td]
[mastodon-bot.tumblr-api :as ta] [mastodon-bot.tumblr-api :as ta]
[mastodon-bot.transform-domain :as trd])) [mastodon-bot.transform-domain :as trd]
["deasync" :as deasync]
["request" :as request]))
(defn resolve-url [[uri]]
(try
(or
(some-> ((deasync request)
#js {:method "GET"
:uri (if (string/starts-with? uri "https://") uri (str "https://" uri))
:followRedirect false})
(.-headers)
(.-location)
(string/replace "?mbid=social_twitter" ""))
uri)
(catch js/Error _ uri)))
(def shortened-url-pattern #"(https?://)?(?:\S+(?::\S*)?@)?(?:(?!(?:10|127)(?:\.\d{1,3}){3})(?!(?:169\.254|192\.168)(?:\.\d{1,3}){2})(?!172\.(?:1[6-9]|2\d|3[0-1])(?:\.\d{1,3}){2})(?:[1-9]\d?|1\d\d|2[01]\d|22[0-3])(?:\.(?:1?\d{1,2}|2[0-4]\d|25[0-5])){2}(?:\.(?:[1-9]\d?|1\d\d|2[0-4]\d|25[0-4]))|(?:(?:[a-z\u00a1-\uffff0-9]-*)*[a-z\u00a1-\uffff0-9]+)(?:\.(?:[a-z\u00a1-\uffff0-9]-*)*[a-z\u00a1-\uffff0-9]+)*(?:\.(?:[a-z\u00a1-\uffff]{2,}))\.?)(?::\d{2,5})?(?:[/?#]\S*)?") (def shortened-url-pattern #"(https?://)?(?:\S+(?::\S*)?@)?(?:(?!(?:10|127)(?:\.\d{1,3}){3})(?!(?:169\.254|192\.168)(?:\.\d{1,3}){2})(?!172\.(?:1[6-9]|2\d|3[0-1])(?:\.\d{1,3}){2})(?:[1-9]\d?|1\d\d|2[01]\d|22[0-3])(?:\.(?:1?\d{1,2}|2[0-4]\d|25[0-5])){2}(?:\.(?:[1-9]\d?|1\d\d|2[0-4]\d|25[0-4]))|(?:(?:[a-z\u00a1-\uffff0-9]-*)*[a-z\u00a1-\uffff0-9]+)(?:\.(?:[a-z\u00a1-\uffff0-9]-*)*[a-z\u00a1-\uffff0-9]+)*(?:\.(?:[a-z\u00a1-\uffff]{2,}))\.?)(?::\d{2,5})?(?:[/?#]\S*)?")
@ -18,7 +33,7 @@
[resolve-urls? ::trd/resolve-urls? [resolve-urls? ::trd/resolve-urls?
input trd/intermediate?] input trd/intermediate?]
(if resolve-urls? (if resolve-urls?
(update input :text #(string/replace % shortened-url-pattern infra/resolve-url)) (update input :text #(string/replace % shortened-url-pattern resolve-url))
input)) input))
(defn-spec content-filter-regexes ::trd/content-filters (defn-spec content-filter-regexes ::trd/content-filters
@ -43,11 +58,13 @@
(update input :text #(reduce-kv string/replace % (:replacements transformation)))) (update input :text #(reduce-kv string/replace % (:replacements transformation))))
(defn-spec post-tweets-to-mastodon any? (defn-spec post-tweets-to-mastodon any?
[tweets any? [mastodon-auth md/mastodon-auth?
mastodon-auth md/mastodon-auth?
transformation ::trd/transformation transformation ::trd/transformation
last-post-time any?] last-post-time any?]
(let [{:keys [source target resolve-urls?]} transformation] (let [{:keys [source target resolve-urls?]} transformation]
(fn [error tweets response]
(if error
(infra/exit-with-error error)
(->> (infra/js->edn tweets) (->> (infra/js->edn tweets)
(map twa/parse-tweet) (map twa/parse-tweet)
(filter #(> (:created-at %) last-post-time)) (filter #(> (:created-at %) last-post-time))
@ -56,20 +73,23 @@
(map #(twa/nitter-url source %)) (map #(twa/nitter-url source %))
(map #(perform-replacements transformation %)) (map #(perform-replacements transformation %))
(map #(ma/intermediate-to-mastodon target %)) (map #(ma/intermediate-to-mastodon target %))
(ma/post-items mastodon-auth target)))) (ma/post-items mastodon-auth target))))))
(defn-spec tweets-to-mastodon any? (defn-spec tweets-to-mastodon any?
[mastodon-auth md/mastodon-auth? [mastodon-auth md/mastodon-auth?
twitter-auth twd/twitter-auth? twitter-auth twd/twitter-auth?
transformation ::trd/transformation transformation ::trd/transformation
last-post-time any?] last-post-time any?]
(let [{:keys [source target resolve-urls?]} transformation (let [{:keys [source target resolve-urls?]} transformation]
accounts (:accounts source)] (doseq [account (:accounts source)]
(infra/log (str "processing tweets for " accounts)) (twa/user-timeline
(doseq [account accounts] twitter-auth
(-> (twa/user-timeline twitter-auth source account) source
(post-tweets-to-mastodon mastodon-auth transformation last-post-time))) account
(infra/log "done."))) (post-tweets-to-mastodon
mastodon-auth
transformation
last-post-time)))))
(defn-spec post-tumblr-to-mastodon any? (defn-spec post-tumblr-to-mastodon any?
[mastodon-auth md/mastodon-auth? [mastodon-auth md/mastodon-auth?
@ -93,9 +113,7 @@
tumblr-auth td/tumblr-auth? tumblr-auth td/tumblr-auth?
transformation ::trd/transformation transformation ::trd/transformation
last-post-time any?] last-post-time any?]
(let [{:keys [source target]} transformation (let [{:keys [accounts limit]} transformation]
{:keys [accounts limit]} source]
(infra/log (str "processing tumblr for " accounts))
(doseq [account accounts] (doseq [account accounts]
(let [client (ta/tumblr-client tumblr-auth account)] (let [client (ta/tumblr-client tumblr-auth account)]
(.posts client (.posts client
@ -107,11 +125,11 @@
))))) )))))
(defn-spec post-rss-to-mastodon any? (defn-spec post-rss-to-mastodon any?
[payload any? [mastodon-auth md/mastodon-auth?
mastodon-auth md/mastodon-auth?
transformation ::trd/transformation transformation ::trd/transformation
last-post-time any?] last-post-time any?]
(let [{:keys [source target resolve-urls?]} transformation] (let [{:keys [source target resolve-urls?]} transformation]
(fn [payload]
(->> (infra/js->edn payload) (->> (infra/js->edn payload)
(:items) (:items)
(map ra/parse-feed) (map ra/parse-feed)
@ -120,17 +138,18 @@
(map #(intermediate-resolve-urls resolve-urls? %)) (map #(intermediate-resolve-urls resolve-urls? %))
(map #(perform-replacements transformation %)) (map #(perform-replacements transformation %))
(map #(ma/intermediate-to-mastodon target %)) (map #(ma/intermediate-to-mastodon target %))
(ma/post-items mastodon-auth target)))) (ma/post-items mastodon-auth target)))))
(defn-spec rss-to-mastodon any? (defn-spec rss-to-mastodon any?
[mastodon-auth md/mastodon-auth? [mastodon-auth md/mastodon-auth?
transformation ::trd/transformation transformation ::trd/transformation
last-post-time any?] last-post-time any?]
(let [{:keys [source target]} transformation (let [{:keys [source target]} transformation]
{:keys [feeds]} source] (doseq [[name url] (:feeds source)]
(infra/log (str "processing rss for " feeds)) (ra/get-feed
(doseq [[name url] feeds] url
(-> (ra/get-feed url) (post-rss-to-mastodon
(post-rss-to-mastodon mastodon-auth transformation last-post-time))) mastodon-auth
(infra/log "done."))) transformation
last-post-time)))))

View file

@ -46,14 +46,14 @@
(defn-spec user-timeline any? (defn-spec user-timeline any?
[twitter-auth td/twitter-auth? [twitter-auth td/twitter-auth?
source td/twitter-source? source td/twitter-source?
account ::td/account] account ::td/account
callback fn?]
(let [{:keys [include-rts? include-replies?]} source] (let [{:keys [include-rts? include-replies?]} source]
(infra/resolve-promise
(.get (twitter-client twitter-auth) (.get (twitter-client twitter-auth)
"statuses/user_timeline" "statuses/user_timeline"
#js {:screen_name account #js {:screen_name account
:tweet_mode "extended" :tweet_mode "extended"
:include_rts (boolean include-rts?) :include_rts (boolean include-rts?)
:exclude_replies (not (boolean include-replies?))}) :exclude_replies (not (boolean include-replies?))}
[]))) callback)))

View file

@ -1,13 +0,0 @@
(ns mastodon-bot.infra-test
(:require
[cljs.test :refer-macros [deftest is testing run-tests]]
[mastodon-bot.infra :as sut]))
;TODO: mbid test
(deftest test-resolve-uri
(is (= "https://www.meissa-gmbh.de"
(sut/resolve-url ["https://www.meissa-gmbh.de"])))
(is (= "https://www.doesnotexist-blablabla.de"
(sut/resolve-url ["https://www.doesnotexist-blablabla.de"])))
(is (= "http://www.google.de/"
(sut/resolve-url ["https://t1p.de/44oo"]))))