Add beneficiaries command to beempy,

* New anyx.io node added to nodelist
* GetWitnesses fixed

Author: holgern

beem/cli.py

@@ -1447,6 +1447,67 @@ def updatememokey(account, key):
     print(tx)
 
 
+@cli.command()
+@click.argument('authorperm', nargs=1)
+@click.argument('beneficiaries', nargs=-1)
+def beneficiaries(authorperm, beneficiaries):
+    """Set beneficaries"""
+    stm = shared_steem_instance()
+    if stm.rpc is not None:
+        stm.rpc.rpcconnect()
+    c = Comment(authorperm, steem_instance=stm)
+    account = c["author"]
+
+    if not account:
+        account = stm.config["default_account"]
+    if not unlock_wallet(stm):
+        return
+    beneficiaries_list = []
+    beneficiaries_accounts = []
+    beneficiaries_sum = 0
+
+    options = {"author": c["author"],
+               "permlink": c["permlink"],
+               "max_accepted_payout": c["max_accepted_payout"],
+               "percent_steem_dollars": c["percent_steem_dollars"],
+               "allow_votes": c["allow_votes"],
+               "allow_curation_rewards": c["allow_curation_rewards"]}
+
+    for w in beneficiaries[0].split(","):
+        account_name = w.strip().split(":")[0]
+        if account_name[0] == "@":
+            account_name = account_name[1:]
+        a = Account(account_name, steem_instance=stm)
+        if a["name"] in beneficiaries_accounts:
+            continue
+        if w.find(":") == -1:
+            percentage = -1
+        else:
+            percentage = w.strip().split(":")[1]
+            if "%" in percentage:
+                percentage = percentage.strip().split("%")[0].strip()
+            percentage = float(percentage)
+            beneficiaries_sum += percentage
+        beneficiaries_list.append({"account": a["name"], "weight": int(percentage * 100)})
+        beneficiaries_accounts.append(a["name"])
+
+    missing = 0
+    for bene in beneficiaries_list:
+        if bene["weight"] < 0:
+            missing += 1
+    index = 0
+    for bene in beneficiaries_list:
+        if bene["weight"] < 0:
+            beneficiaries_list[index]["weight"] = int((int(100 * 100) - int(beneficiaries_sum * 100)) / missing)
+        index += 1
+    beneficiaries_list_sorted = sorted(beneficiaries_list, key=lambda beneficiaries_list: beneficiaries_list["account"])
+    tx = stm.comment_options(options, authorperm, beneficiaries_list_sorted, account=account)
+    if stm.unsigned and stm.nobroadcast and stm.steemconnect is not None:
+        tx = stm.steemconnect.url_from_tx(tx)
+    tx = json.dumps(tx, indent=4)
+    print(tx)
+
+
 @cli.command()
 @click.argument('witness', nargs=1)
 @click.option('--account', '-a', help='Your account')

beem/nodelist.py

@@ -208,6 +208,20 @@ def __init__(self):
                 "owner": "followbtcnews",
                 "score": 10
             },
+            {
+                "url": "wss://anyx.io",
+                "version": "0.20.6",
+                "type": "appbase",
+                "owner": "anyx",
+                "score": 50
+            },
+            {
+                "url": "https://anyx.io",
+                "version": "0.20.6",
+                "type": "appbase",
+                "owner": "anyx",
+                "score": 50
+            },            
             {
                 "url": "https://rpc.curiesteem.com",
                 "version": "0.20.2",

beem/witness.py

@@ -293,14 +293,14 @@ def __init__(self, name_list, batch_limit=100, lazy=False, full=True, steem_inst
             return
         witnesses = []
         name_cnt = 0
-
-        while name_cnt < len(name_list):
-            self.steem.rpc.set_next_node_on_empty_reply(False)
-            if self.steem.rpc.get_use_appbase():
+        if self.steem.rpc.get_use_appbase():
+            while name_cnt < len(name_list):
+                self.steem.rpc.set_next_node_on_empty_reply(False)
                 witnesses += self.steem.rpc.find_witnesses({'owners': name_list[name_cnt:batch_limit + name_cnt]}, api="database")["witnesses"]
-            else:
-                witnesses += self.steem.rpc.get_witness_by_account(name_list[name_cnt:batch_limit + name_cnt])
-            name_cnt += batch_limit
+                name_cnt += batch_limit
+        else:
+            for witness in name_list:
+                witnesses.append(self.steem.rpc.get_witness_by_account(witness))
         self.identifier = ""
         super(GetWitnesses, self).__init__(
             [