diff options
| -rwxr-xr-x | bin/ak-network | 8 | ||||
| -rwxr-xr-x | lib/_ak_network | 2 | ||||
| -rwxr-xr-x | lib/_ak_network_incoming | 83 | ||||
| -rwxr-xr-x | lib/_ak_network_utils | 79 |
4 files changed, 168 insertions, 4 deletions
diff --git a/bin/ak-network b/bin/ak-network index f20d750..8877760 100755 --- a/bin/ak-network +++ b/bin/ak-network @@ -22,10 +22,10 @@ ## ## Usage: ## -## -h, --help Prints this help message -## -c, --connect [ipfs|cjdns] Connect to network(s) -## -p, --peers [ipfs|cjdns|stellar|yggdrasil] Outputs peers found -## -s, --scan [ipfs|cjdns|stellar|yggdrasil] Scan network(s) for peers +## -h, --help Prints this help message +## -c, --connect [ipfs|cjdns] Connect to network(s) +## -p, --peers [ipfs|cjdns|stellar|yggdrasil] Outputs peers found +## -s, --scan [ipfs|cjdns|stellar|yggdrasil|incoming] Scan network(s) for peers ## ## Bonus: CJDNS network scanning modes ## diff --git a/lib/_ak_network b/lib/_ak_network index d23d913..636cf5e 100755 --- a/lib/_ak_network +++ b/lib/_ak_network @@ -22,6 +22,7 @@ source $AK_LIBDIR/_ak_network_ipfs source $AK_LIBDIR/_ak_network_cjdns source $AK_LIBDIR/_ak_network_yggdrasil source $AK_LIBDIR/_ak_network_stellar +source $AK_LIBDIR/_ak_network_incoming function _ak_network_scan(){ if [ ! -z $1 ] && [ -n "$1" ] @@ -31,6 +32,7 @@ function _ak_network_scan(){ ipfs) _ak_network_ipfs_scan; exit;; cjdns) shift; _ak_network_cjdns_scan $1; exit;; yggdrasil) shift; _ak_network_yggdrasil_scan $1; exit;; + incoming) shift; _ak_network_incoming_scan; exit;; * ) _ak_log_error "Unknown network $1";exit 1;; esac else diff --git a/lib/_ak_network_incoming b/lib/_ak_network_incoming new file mode 100755 index 0000000..e733a2e --- /dev/null +++ b/lib/_ak_network_incoming @@ -0,0 +1,83 @@ +#!/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_log +source $AK_LIBDIR/_ak_utils +source $AK_LIBDIR/_ak_network_utils +source $AK_LIBDIR/_ak_fm + +export AK_ZPEERSINCOMING=$AK_ZPEERSDIR/incomingRequests + +function _ak_network_incoming_tidy(){ + exit 224 +} + +function _ak_network_incoming_scan(){ + if [ -f "${AK_ZPEERSINCOMING}" ] + then + if [ $(cat ${AK_ZPEERSINCOMING}|wc -l) -gt 0 ] + then + counter=0 + count=0 + _ak_fm_sort_uniq_file ${AK_ZPEERSINCOMING} + max="$(cat ${AK_ZPEERSINCOMING}|wc -l)" + printf '[' > walk.aknet + cat ${AK_ZPEERSINCOMING} \ + | sort \ + | uniq \ + | while read -r uip || [ -n "$uip" ] + do + ip="$(_ak_network_utils_pad_ip $uip)" + count="$(( $count + 1 ))" + _ak_log_debug "Scanning [${count}/${max}] $ip..." + node_fs_path="$AK_ZPEERSDIR/inc/$(echo -n $ip| sed 's/://g')" + scan_ts="$(_ak_datetime_unix)" + if [ ! -d ${node_fs_path} ] + then + mkdir -p ${node_fs_path} + fi + node_fs_pathname="${node_fs_path}/${scan_ts}" + 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 + if [ "$counter" -ne "0" ] + then + printf ',' >> walk.aknet + fi + if [ ! -n "$node_info" ] + then + node_info="null" + fi + printf '{"incoming":{"ip":"%s"},"node_info":%s}' \ + "$ip" "$node_info" >> walk.aknet + counter="`expr $counter + 1`" + fi + done + printf ']' >> walk.aknet + mv walk.aknet $AK_ZPEERSFILE.incoming + rm -rf $TEMPDIR + else + _ak_log_info "No incoming requests found." + fi + fi +} diff --git a/lib/_ak_network_utils b/lib/_ak_network_utils new file mode 100755 index 0000000..bef7936 --- /dev/null +++ b/lib/_ak_network_utils @@ -0,0 +1,79 @@ +#!/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_log +source $AK_LIBDIR/_ak_utils + +## +# Copied from http://y.yggdrasil-network.ca/yia/crawler/crawler-yia.sh made by +# ircerr +# +# Changes: +# - name of function from padip to _ak_network_utils_pad_ip +# +function _ak_network_utils_pad_ip() { #Pad IP - fill in missing zeros + ip=$1 + if [ "$ip" == "" ]; then return; fi + PADIP="" + if [ "`echo \"$ip\"|grep '::'`" != "" ] + then + CC="$((`echo \"$ip\"|sed 's/:://g'|tr ':' '\n'|wc -l`))" #count cols + if [ "$CC" != "8" ] + then + NC=$((7-$CC)) + RS="" + for X in `seq 1 $NC` + do + if [ "$RS" == "" ] + then + RS="0000" + else + RS="$RS:0000" + fi + done + ip="`echo \"$ip\"|sed \"s/\:\:/\:$RS\:/g\"`" + fi + fi + SEGIP="`echo $ip|tr ':' ' '`" + for S in $SEGIP + do + while : + do + if [ "`echo $S|cut -b 4`" == "" ] + then + S="0$S" + continue + fi + if [ "$PADIP" == "" ] + then + PADIP="$S" + else + PADIP="$PADIP:$S" + fi + break + done + done + if [ "$PADIP" != "" ] + then + ip="$PADIP" + fi + echo "$ip" + return +} + |