-
Notifications
You must be signed in to change notification settings - Fork 13
Expand file tree
/
Copy pathnode.py
More file actions
66 lines (54 loc) · 2.22 KB
/
node.py
File metadata and controls
66 lines (54 loc) · 2.22 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
import re
from grapheneapi.api import Api as Original_Api
from peerplaysbase.chains import known_chains
from . import exceptions
class Api(Original_Api):
def post_process_exception(self, e):
msg = exceptions.decodeRPCErrorMsg(e).strip()
if msg == "missing required active authority":
raise exceptions.MissingRequiredActiveAuthority
elif re.match("^no method with name.*", msg):
raise exceptions.NoMethodWithName(msg)
elif msg == "Proposed operation is already pending for approval.":
raise exceptions.OperationInProposalExistsException(msg)
elif msg:
raise exceptions.UnhandledRPCError(msg)
else:
raise e
class PeerPlaysNodeRPC(Api):
def register_apis(self):
self.login("", "", api_id=1)
self.api_id["database"] = self.database(api_id=1)
self.api_id["history"] = self.history(api_id=1)
self.api_id["network_broadcast"] = self.network_broadcast(api_id=1)
def get_account(self, name, **kwargs):
""" Get full account details from account name or id
:param str name: Account name or account id
"""
if len(name.split(".")) == 3:
return self.get_objects([name])[0]
else:
return self.get_account_by_name(name, **kwargs)
def get_asset(self, name, **kwargs):
""" Get full asset from name of id
:param str name: Symbol name or asset id (e.g. 1.3.0)
"""
if len(name.split(".")) == 3:
return self.get_objects([name], **kwargs)[0]
else:
return self.lookup_asset_symbols([name], **kwargs)[0]
def get_object(self, o, **kwargs):
""" Get object with id ``o``
:param str o: Full object id
"""
return self.get_objects([o], **kwargs)[0]
def get_network(self):
""" Identify the connected network. This call returns a
dictionary with keys chain_id, core_symbol and prefix
"""
props = self.get_chain_properties()
chain_id = props["chain_id"]
for k, v in known_chains.items():
if v["chain_id"] == chain_id:
return v
raise Exception("Connecting to unknown network!")