path: root/lib/_ak_ipfs

#!/bin/bash
source $AK_LIBDIR/_ak_log
AK_IPFS_REPO="$AK_WORKDIR/ipfsrepo"

_ak_ipfs(){
    export IPFS_PATH=$AK_IPFS_REPO; ipfs $*
}

_ak_ipfs_get_peers(){
    _ak_ipfs swarm peers 1> /dev/null 2>&1
    if [ $? == 0 ]
    then
        _ak_ipfs swarm peers > $AK_WORKDIR/peers.ipfs
    fi
}

_ak_ipfs_scanner(){
    peersIPFSfile="$AK_WORKDIR/peers.ipfs"
    ak_peersIPFSfile="$AK_WORKDIR/ipfs.peers.akn"
    if [ ! -f $peersIPFSfile ]
    then
        _ak_ipfs_get_peers
        if [ $? -ne 0 ]
        then
            exit 1
        fi
    fi
    counter=0

    printf '[' > walk.aknet
    cat $peersIPFSfile \
        | cut -d '/' -f 2,3,7 \
        | sort \
        | uniq \
        | while read -r line || [ -n "$line" ]
    do
        protocol="`printf '%s' "$line" | cut -d '/' -f 1`"
        ip="`printf '%s' "$line" | cut -d '/' -f 2`"
        ipfsId="`printf '%s' "$line" | cut -d '/' -f 3`"
        if [ "$protocol" == "ip6" ]
        then
            url="http://[$ip]:8610/v0/node_info"
        else
            url="http://$ip:8610/v0/node_info"
        fi
        node_info="`curl \
            -A 'akd/0.1.0; https://github.com/arching-kaos' \
            --connect-timeout 3 \
            "$url" 2>/dev/null`"
        if [ $? -eq 0 ]
        then
            if [ "$counter" -ne "0" ]
            then
                printf ',' >> walk.aknet
            fi
            printf '{"ipfsPublicKey":"%s","ip":"%s","node_info":%s}' \
                "$ipfsId" "$ip" "$node_info" >> walk.aknet
            counter="`expr $counter + 1`"
        fi
    done
    printf ']' >> walk.aknet

    mv walk.aknet $ak_peersIPFSfile
}

_ak_ipfs_add(){
    # Receives a file
    # Returns a hash
    _ak_ipfs add -Qr "$1"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to add $1"
        exit 1
    fi
}

_ak_ipfs_block_stat(){
    _ak_ipfs block stat "$1"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to retrieve stat of block $1"
        exit 1
    fi
}

_ak_ipfs_cat(){
    _ak_ipfs --timeout=10s cat $1
    if [ "$?" -ne "0" ]
    then
        logit "ERROR" "Failed to cat $1"
        exit 1
    fi

}

_ak_ipfs_files_cp(){
    _ak_ipfs files cp "$1" "$2"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to copy $1 to $2"
        exit 1
    fi
}

_ak_ipfs_files_ls(){
    _ak_ipfs files ls "$1"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to list $1"
        exit 1
    fi
}

_ak_ipfs_files_mkdir(){
    _ak_ipfs files mkdir "$1"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to mkdir $1"
        exit 1
    fi
}

_ak_ipfs_files_mv(){
    _ak_ipfs files mv "$1" "$2"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to move $1 to $2"
        exit 1
    fi
}

_ak_ipfs_files_rm(){
    _ak_ipfs files rm "$1"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to remove $1"
        exit 1
    fi
}

_ak_ipfs_files_stat(){
    _ak_ipfs files stat "$1"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to get file's stats $1"
        exit 1
    fi
}

_ak_ipfs_get(){
    _ak_ipfs --timeout=10s get "$1" > /dev/null 2>&1
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to get $1"
        exit 1
    fi
}

_ak_ipfs_key_gen(){
    _ak_ipfs key gen "$1"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to generate key $1"
        exit 1
    fi
}

_ak_ipfs_key_list(){
    _ak_ipfs key list
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to get key list"
        exit 1
    fi
}

_ak_ipfs_key_list_full(){
    _ak_ipfs key list -l
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to get key list"
        exit 1
    fi
}

_ak_ipfs_name_publish(){
    _ak_ipfs name publish "$1" "$2"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to get $1"
        exit 1
    fi

}

_ak_ipfs_name_resolve(){
    _ak_ipfs name resolve "$1"
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to resolve $1"
        exit 1
    fi

}

_ak_ipfs_swarm_peers(){
    _ak_ipfs swarm peers
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to get list of peers"
        exit 1
    fi
}

_ak_ipfs_starter(){
    _ak_ipfs daemon --routing=dht --migrate
    if [ $? -ne 0 ]
    then
        logit "ERROR" "Failed to start IPFS daemon"
        exit 1
    fi
}

_ak_ipns_resolve(){
    if [ ! -z $1 ]
    then
        rsld=$(_ak_ipfs_name_resolve $1)
        if [ $? -ne 0 ]
        then
            logit "ERROR" "Failed to resolve $1"
            exit 1
        fi
        echo -n $rsld | sed -e 's/\/ipfs\///'
        logit "INFO" "Resolved $1 to $rsld"
    else
        exit 1
    fi
}

_ak_ipfs_check(){
    _ak_ipfs_files_ls /zarchive > /dev/null
    if [ $? != 0 ]
    then
        logit "ERROR" "/zarchive is missing"
    else
        logit "INFO" "/zarchive OK"
    fi

    _ak_ipfs_files_ls /zlatest > /dev/null
    if [ $? != 0 ]
    then
        logit "ERROR" "/zlatest is missing"
    else
        logit "INFO" "/zlatest is OK"
    fi

    _ak_ipfs_key_list | grep zchain > /dev/null
    if [ $? != 0 ]; then
        logit "WARNING" "zchain key is missing"
        _ak_ipfs_key_gen zchain > $ZCHAIN
        if [ $? != 0 ]; then
            logit "ERROR" "zchain fails to create"
        else
            logit "INFO" "zchain created"
        fi
    else
        logit "INFO" "zchain is there"
    fi

    _ak_ipfs_key_list | grep ak-config > /dev/null
    if [ $? != 0 ]; then
        logit "WARNING" "ak-config key is missing"
        _ak_ipfs_key_gen ak-config
        if [ $? != 0 ]; then
            logit "ERROR" "ak-config fails to create"
        else
            logit "INFO" "ak-config created"
        fi
    else
        logit "INFO" "ak-config is there"
    fi
}

_ak_ipfs_init(){
    if [ ! -d $AK_IPFS_REPO ]
    then
        mkdir $AK_IPFS_REPO
        _ak_ipfs init

    fi
}

_ak_ipfs_download(){
    logit "INFO" "Attempting to install IPFS..."
    IPFS_VERSION="$(curl -s https://dist.ipfs.tech/kubo/versions | tail -1)"
    IPFS_TARGET_FILE="kubo_"$IPFS_VERSION"_linux-amd64.tar.gz"

    logit "INFO" "Downloading ipfs $IPFS_VERSION"
    if [ ! -f $AK_ARCHIVESDIR/$IPFS_TARGET_FILE ]
    then
        wget -O $AK_ARCHIVESDIR/$IPFS_TARGET_FILE https://dist.ipfs.tech/kubo/$IPFS_VERSION/$IPFS_TARGET_FILE ;
    else
        logit "INFO" "Already have the latest version"
        exit 0
    fi
}

_ak_ipfs_cid_v0_check () {
    if [ -z $1 ] || [ "$1" != "" ]
    then
        echo $1 | grep -e 'Qm.\{44\}' > /dev/null
        if [ "$?" -ne 0 ]
        then
            logit "ERROR" "$1 is not an IPFS CIDv0 string"
            exit 1
        fi
        logit "INFO" "$1 provided is an IPFS CIDv0 string"
    else
        logit "ERROR" "No argument was provided"
        exit 1
    fi
}

_ak_ipfs_swarm_install() {
    SWARMSHA512SUM="7001e37412758c43d372a969e977ca11511e034c8c1e233a58dc3ce1c6f3c1aa7d2da8cba9944a5eabaa8885742bfe6cc6794224c146b7129da8f633b53b9cfc"

    if [ ! -f $AK_IPFS_REPO/swarm.key ]
    then
        logit "INFO" "Downloading swarm key"
        wget -O $AK_IPFS_REPO/swarm.key https://arching-kaos.net/files/swarm.key
    elif [ -f $AK_IPFS_REPO/swarm.key ] && [ "$(sha512sum $AK_IPFS_REPO/swarm.key | awk '{ print $1 }')" == "$SWARMSHA512SUM" ]
    then
        logit "INFO" "Congrats! You are already in our swarm"
    else
        logit "ERROR" "Found swarm.key but not ours"
        logit "ERROR" "Visit https://arching-kaos.net/files/swarm.key and copy it to your ipfs folder"
    fi
}