timestamp ALREADY on NODE ~/.zen/ipfs_swarm/~$CHECKSWARM
This commit is contained in:
parent
311a1868a4
commit
1fa2d18211
|
@ -33,8 +33,8 @@ self_name=$(sbotc query.read '{"query":[{"$filter":{"value":{"author": "'"$self"
|
||||||
ipfsnodeid=$(ipfs id -f='<id>\n')
|
ipfsnodeid=$(ipfs id -f='<id>\n')
|
||||||
|
|
||||||
current_ts=$(date -u +%s%N | cut -b1-13)
|
current_ts=$(date -u +%s%N | cut -b1-13)
|
||||||
[ -s ~/.zen/zenyta.last.ts ] && last_ts=$(cat ~/.zen/zenyta.last.ts) || last_ts=$((current_ts - 24*3600*1000 + 1)) # 24h ago
|
[ -s ~/.zen/zenyta.last.ts ] && last_ts=$(cat ~/.zen/zenyta.last.ts) || last_ts=$((current_ts - 24*3600*1000)) # 24h ago
|
||||||
|
last_ts=$((last_ts + 1))
|
||||||
echo "Hi, i am [$self_name]($self)
|
echo "Hi, i am [$self_name]($self)
|
||||||
last timestamp: $last_ts"
|
last timestamp: $last_ts"
|
||||||
echo '
|
echo '
|
||||||
|
@ -67,7 +67,11 @@ do
|
||||||
# TEST if SWARM already made it.
|
# TEST if SWARM already made it.
|
||||||
$MY_PATH/ipfs_SWARM_refresh.sh
|
$MY_PATH/ipfs_SWARM_refresh.sh
|
||||||
CHECKSWARM=$(grep -Rwl "$timestamp" ~/.zen/ipfs_swarm/.Qm*/TAG/*/_tag.zensource | tail -n 1 | cut -f 6 -d '/')
|
CHECKSWARM=$(grep -Rwl "$timestamp" ~/.zen/ipfs_swarm/.Qm*/TAG/*/_tag.zensource | tail -n 1 | cut -f 6 -d '/')
|
||||||
[[ $CHECKSWARM ]] && echo "$timestamp ALREADY on NODE $CHECKSWARM. CONTINUE" && continue
|
|
||||||
|
[[ $CHECKSWARM ]] \
|
||||||
|
&& echo "$timestamp ALREADY on NODE ~/.zen/ipfs_swarm/~$CHECKSWARM CONTINUE" \
|
||||||
|
&& [[ $timestamp ]] && echo "$((timestamp))" > ~/.zen/zenyta.last.ts \
|
||||||
|
&& continue
|
||||||
|
|
||||||
msg_root=$(printf %s "$msg" | jq -r .value.content.root)
|
msg_root=$(printf %s "$msg" | jq -r .value.content.root)
|
||||||
# echo $msg_root
|
# echo $msg_root
|
||||||
|
|
|
@ -32,8 +32,8 @@ self_name=$(sbotc query.read '{"query":[{"$filter":{"value":{"author": "'"$self"
|
||||||
ipfsnodeid=$(ipfs id -f='<id>\n')
|
ipfsnodeid=$(ipfs id -f='<id>\n')
|
||||||
|
|
||||||
current_ts=$(date -u +%s%N | cut -b1-13)
|
current_ts=$(date -u +%s%N | cut -b1-13)
|
||||||
[ -s ~/.zen/zenytv.last.ts ] && last_ts=$(cat ~/.zen/zenytv.last.ts) || last_ts=$((current_ts - 24*3600*1000 + 1)) # 24h ago
|
[ -s ~/.zen/zenytv.last.ts ] && last_ts=$(cat ~/.zen/zenytv.last.ts) || last_ts=$((current_ts - 24*3600*1000)) # 24h ago
|
||||||
|
last_ts=$((last_ts + 1))
|
||||||
echo "Hi, i am [$self_name]($self)
|
echo "Hi, i am [$self_name]($self)
|
||||||
last timestamp: $last_ts"
|
last timestamp: $last_ts"
|
||||||
echo '
|
echo '
|
||||||
|
@ -65,7 +65,11 @@ do
|
||||||
# TEST if SWARM already made it.
|
# TEST if SWARM already made it.
|
||||||
$MY_PATH/ipfs_SWARM_refresh.sh
|
$MY_PATH/ipfs_SWARM_refresh.sh
|
||||||
CHECKSWARM=$(grep -Rwl "$timestamp" ~/.zen/ipfs_swarm/.Qm*/TAG/*/_tag.zensource | tail -n 1 | cut -f 6 -d '/')
|
CHECKSWARM=$(grep -Rwl "$timestamp" ~/.zen/ipfs_swarm/.Qm*/TAG/*/_tag.zensource | tail -n 1 | cut -f 6 -d '/')
|
||||||
[[ $CHECKSWARM ]] && echo "$timestamp ALREADY on NODE $CHECKSWARM. CONTINUE" && continue
|
|
||||||
|
[[ $CHECKSWARM ]] \
|
||||||
|
&& echo "$timestamp ALREADY on NODE $CHECKSWARM CONTINUE" \
|
||||||
|
&& [[ $timestamp ]] && echo "$((timestamp))" > ~/.zen/zenytv.last.ts \
|
||||||
|
&& continue
|
||||||
|
|
||||||
msg_root=$(printf %s "$msg" | jq -r .value.content.root)
|
msg_root=$(printf %s "$msg" | jq -r .value.content.root)
|
||||||
# echo $msg_root
|
# echo $msg_root
|
||||||
|
@ -85,7 +89,7 @@ do
|
||||||
--no-mtime -o "~/.zen/miam/$timestamp/%(id)s.%(ext)s" $msg_ytdlurl
|
--no-mtime -o "~/.zen/miam/$timestamp/%(id)s.%(ext)s" $msg_ytdlurl
|
||||||
|
|
||||||
# REFERENCE msg_key AND timestamp
|
# REFERENCE msg_key AND timestamp
|
||||||
[[ $timestamp ]] && echo "$((timestamp + 1))" > ~/.zen/zenytv.last.ts
|
[[ $timestamp ]] && echo "$((timestamp))" > ~/.zen/zenytv.last.ts
|
||||||
[[ $msg_key ]] && echo "$msg_key" > ~/.zen/miam/$timestamp/msg_key
|
[[ $msg_key ]] && echo "$msg_key" > ~/.zen/miam/$timestamp/msg_key
|
||||||
|
|
||||||
$MY_PATH/miam_miam.sh "$timestamp"
|
$MY_PATH/miam_miam.sh "$timestamp"
|
||||||
|
|
Loading…
Reference in New Issue