1 files changed, 131 insertions, 0 deletions
diff --git a/lib/_ak_network_yggdrasil b/lib/_ak_network_yggdrasil
new file mode 100755
index 0000000..5620fae
--- /dev/null
+++ b/lib/_ak_network_yggdrasil
@@ -0,0 +1,131 @@
+#!/usr/bin/env bash
+###
+### arching-kaos-tools
+### Tools to interact and build an Arching Kaos Infochain
+### Copyright (C) 2021 - 2025  kaotisk
+###
+### This program is free software: you can redistribute it and/or modify
+### it under the terms of the GNU General Public License as published by
+### the Free Software Foundation, either version 3 of the License, or
+### (at your option) any later version.
+###
+### This program is distributed in the hope that it will be useful,
+### but WITHOUT ANY WARRANTY; without even the implied warranty of
+### MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+### GNU General Public License for more details.
+###
+### You should have received a copy of the GNU General Public License
+### along with this program.  If not, see <http://www.gnu.org/licenses/>.
+###
+source $AK_LIBDIR/_ak_lib_load
+_ak_lib_load _ak_log
+_ak_lib_load _ak_datetime
+
+function _ak_network_yggdrasil_scan_full(){
+    # This scan is using HIA resources to scan the whole cjdns network for peers
+    #
+    # Ref:
+    #  - https://github.com/ircerr/yia/
+    #  - http://yia.yggdrasil-network.ca/watchlist/yia.iplist
+    #
+    TEMPDIR="$(_ak_make_temp_directory)"
+    cd $TEMPDIR
+    last_seen="$TEMPDIR/ls"
+    pubkeys_ips="$TEMPDIR/pi"
+    online_ips="$TEMPDIR/oi"
+    online_pairs="$TEMPDIR/op"
+    filtered_online_pubkeys_ips="$TEMPDIR/fopi"
+    curl -s \
+        --connect-timeout 5 \
+        "http://yia.yggdrasil-network.ca/crawler/crawler-yia.peers.$(_ak_datetime_human_date_only_yesterday)" > $last_seen
+    if [ $? -ne 0 ]
+    then
+        _ak_log_error "Couldn't fetch active peers from YIA"
+        exit 1
+    fi
+    curl -s \
+        --connect-timeout 5 \
+        "http://yia.yggdrasil-network.ca/crawler/crawler-yia.pubkey" > $pubkeys_ips
+    if [ $? -ne 0 ]
+    then
+        _ak_log_error "Couldn't fetch public key DB from YIA"
+        exit 1
+    fi
+    cat $last_seen | tr ' ' '\n' | sort | uniq | while read key
+    do
+        grep ${key} ${pubkeys_ips} >> ${online_pairs}
+    done
+    counter=0
+    count=0
+    max="$(cat $online_pairs|wc -l)"
+    printf '[' > walk.aknet
+    cat $online_pairs \
+        | sort \
+        | uniq \
+        | while read -r pkey ip || [ -n "$ip" ]
+    do
+        count="$(( $count + 1 ))"
+        _ak_log_debug "Scanning [${count}/${max}] $ip..."
+        node_fs_path="$AK_ZPEERSDIR/ygg/$(echo -n $ip| sed 's/://g')"
+        scan_ts="$(_ak_datetime_unix)"
+        if [ ! -d ${node_fs_path} ]
+        then
+            mkdir -p ${node_fs_path}
+            echo ${scan_ts} > ${node_fs_path}/first_seen
+            echo ${scan_ts} > ${node_fs_path}/last_seen
+        else
+            echo ${scan_ts} > ${node_fs_path}/last_seen
+        fi
+        node_fs_pathname="${node_fs_path}/${scan_ts}_node_info"
+        curl \
+            --connect-timeout 3 \
+            -A 'akd/0.1.0; https://github.com/arching-kaos' \
+            "http://[$ip]:8610/v0/node_info" 2>/dev/null | jq -c -M > ${node_fs_pathname}
+        node_info="$(cat ${node_fs_pathname})"
+        if [ $? -eq 0 ] && [ $(echo -n "$node_info" | wc -c) -gt 0 ]
+        then
+            ni_hash="$(echo -n "${node_info}" | sha512sum | cut -d ' ' -f 1)"
+            if [ ! -f "${node_fs_path}/${ni_hash}" ]
+            then
+                mv ${node_fs_pathname} ${node_fs_path}/${ni_hash}
+                echo "${scan_ts} ${ni_hash}" >> ${node_fs_path}/db
+            fi
+            if [ "$counter" -ne "0" ]
+            then
+                printf ',' >> walk.aknet
+            fi
+            if [ ! -n "$node_info" ]
+            then
+                node_info="null"
+            fi
+            printf '{"yggdrasil":{"public_key":"%s","ip":"%s"},"node_info":%s}' \
+                "$pkey" "$ip" "$node_info" >> walk.aknet
+            counter="`expr $counter + 1`"
+        else
+            rm ${node_fs_pathname}
+        fi
+    done
+    printf ']' >> walk.aknet
+    mv walk.aknet $AK_ZPEERSFILE.yggdrasil
+    rm -rf $TEMPDIR
+}
+
+function _ak_network_yggdrasil_show_peers(){
+    if [ -f $AK_ZPEERSFILE.yggdrasil ]
+    then
+        cat $AK_ZPEERSFILE.yggdrasil | jq
+    else
+        _ak_log_debug "No yggdrasil peers found"
+    fi
+}
+
+function _ak_network_yggdrasil_scan(){
+    if [ ! -z $1 ] && [ -n "$1" ]
+    then
+        _ak_network_yggdrasil_scan_specific $1
+    else
+        _ak_network_yggdrasil_scan_full
+    fi
+}
+
+_ak_log_debug "_ak_network_yggdrasil loaded $(caller)"