Breaking changes, the gpg field inside config is an object now!

4 files changed, 44 insertions, 20 deletions

diff --git a/lib/_ak_config b/lib/_ak_config
index d8705d8..f8b1460 100755
--- a/lib/_ak_config
+++ b/lib/_ak_config
@@ -31,7 +31,10 @@ function _ak_config_show(){
 {
     "profile":'$profile',
     "genesis":"'$(cat $AK_WORKDIR/config/zgenesis)'",
-    "gpg":"'$GPG_PUB_KEY'",
+    "gpg":{
+        "ipfs":"'$GPG_PUB_KEY'",
+        "fingerprint":"'$(ak gpg --get-key-fingerprint-from-ipfs $GPG_PUB_KEY)'"
+    },
     "zchain":"'$(cat $AK_WORKDIR/config/zchain)'",
     "zlatest":"'$(ak zchain --get-latest)'"
 }'| jq;
@@ -43,8 +46,9 @@ function _ak_config_publish(){
     _ak_ipfs_config_publish $ipfs_hash
     if [ $? != 0 ]
     then
-        echo -e "\033[0;34mError on publishing\033[0;0m\nYour information:\n"
-        cat tmpfile
+        _ak_log_error "Error on publishing"
+        _ak_log_debug "Your information:"
+        cat tmpfile | while read line; do _ak_log_debug "$line"; done
         exit 1
     fi
     rm tmpfile
diff --git a/lib/_ak_network_cjdns b/lib/_ak_network_cjdns
index 51cd7d8..31c587b 100755
--- a/lib/_ak_network_cjdns
+++ b/lib/_ak_network_cjdns
@@ -166,17 +166,6 @@ function _ak_network_cjdns_scan(){
     fi
 }
 
-function _ak_network_yggdrasil_scan(){
-    if [ ! -z $1 ] && [ -n "$1" ]
-    then
-        case $1 in
-            *) _ak_network_yggdrasil_scan_full; exit;;
-        esac
-    else
-        _ak_network_yggdrasil_scan_full
-    fi
-}
-
 function _ak_network_cjdns_show_peers(){
     if [ -f $AK_ZPEERSFILE.hyperboria ]
     then
diff --git a/lib/_ak_network_yggdrasil b/lib/_ak_network_yggdrasil
index 9ec68d2..a551cd6 100755
--- a/lib/_ak_network_yggdrasil
+++ b/lib/_ak_network_yggdrasil
@@ -28,32 +28,54 @@ function _ak_network_yggdrasil_scan_full(){
     #
     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.$(date -u +%Y%m%d)" > $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 DB from YIA"
+        _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 $pubkeys_ips|wc -l)"
+    max="$(cat $online_pairs|wc -l)"
     printf '[' > walk.aknet
-    cat $pubkeys_ips \
+    cat $online_pairs \
         | sort \
         | uniq \
         | while read -r pkey ip || [ -n "$ip" ]
     do
         count="$(( $count + 1 ))"
         _ak_log_debug "Scanning [${count}/${max}] $ip..."
-        node_info="$(curl \
+        node_fs_path="$AK_ZPEERSDIR/ygg/$(echo -n $ip| sed 's/://g')"
+        scan_ts="$(date -u +%s)"
+        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)"
+            "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" ]
@@ -82,3 +104,12 @@ function _ak_network_yggdrasil_show_peers(){
         _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
+}
diff --git a/lib/_ak_node b/lib/_ak_node
index 04aa07b..37d8a00 100755
--- a/lib/_ak_node
+++ b/lib/_ak_node
@@ -28,5 +28,5 @@ function _ak_node_info_ipfs_hash(){
 # Finds ak-config ipns key
 # Returns IPNS key
 function _ak_node_info_ipns_key(){
-    _ak_ipfs_key_list_full | grep ak-config | awk '{print $1}'
+    _ak_ipfs_key_list_full | grep 'ak-config' | awk '{print $1}'
 }