library.py

from threading import Thread
from time import time, sleep
import urllib.request
from json import loads, dumps

def api(*argv, **kwargs):
    url = "http://127.0.0.1:5001/api/v0/"
    for arg in argv:
        arg = arg.replace(" ", "/")
        if arg[:-1] != "/":
            arg += "/"
        url += arg
    url = url[0:-1]
    if kwargs:
        url+="?"
        for val in kwargs:
            url = url + val + "=" + kwargs[val] + "&"
        url = url[0:-1]
        print(url)
    try:
        with urllib.request.urlopen(url, timeout=300) as response:
            return response.read()
    except:
        return b"""{"ERROR": "CANNOT CONNECT TO IPFS!"}"""

class setup():

    def __init__(self):
        api("files", "mkdir", arg="/GANN", parents="True")
        self.root_hash = ""

    def update_root(self):
        try:
            for entry in loads(api("files", "ls", l="True").decode())["Entries"]:
                if entry["Name"] == "GANN":
                    self.root_hash = entry["Hash"]
        except:
            return """{"ERROR": "CANNOT FIND ROOT DIRECTORY"}"""

    def publish_root(self):
        api("name", "publish", arg=self.root_hash)

    def cron(self):
        while True:
            print("CRON Thread Started!")
            self.update_root()
            self.publish_root()
            sleep(600)