67 lines
1.9 KiB
Python
67 lines
1.9 KiB
Python
#!/usr/bin/env python
|
|
from modulebase import ModuleBase,ModuleHook
|
|
from bitcoinrpc.authproxy import AuthServiceProxy
|
|
|
|
class DogeRPC(ModuleBase):
|
|
def __init__(self, bot, moduleName):
|
|
ModuleBase.__init__(self, bot, moduleName);
|
|
self.hooks=[]
|
|
self.services=["dogerpc"]
|
|
self.loadConfig()
|
|
self.rpc = DogeController(self)
|
|
|
|
def getBal(self, acct):
|
|
" get a balance of an address or an account "
|
|
return self.getAcctBal(acct)
|
|
|
|
def getAcctAddr(self, acct):
|
|
" returns the address for an account. creates if necessary "
|
|
self.rpc.ping()
|
|
addrs = self.rpc.con.getaddressesbyaccount(acct)
|
|
if len(addrs)==0:
|
|
return self.rpc.con.getnewaddress(acct)
|
|
return addrs[0]
|
|
|
|
def getAcctBal(self, acct):
|
|
" returns an account's balance"
|
|
self.rpc.ping()
|
|
return float(self.rpc.con.getbalance(acct))
|
|
|
|
def canMove(self, fromAcct, toAcct, amount):
|
|
" true or false if fromAcct can afford to give toAcct an amount of coins "
|
|
balfrom = self.getAcctBal(fromAcct)
|
|
return balfrom >= amount
|
|
|
|
def move(self, fromAcct, toAcct, amount):
|
|
" move coins from one account to another "
|
|
self.rpc.ping()
|
|
if self.canMove(fromAcct, toAcct, amount):
|
|
return self.rpc.con.move(fromAcct, toAcct, amount)
|
|
return False
|
|
|
|
def send(self, fromAcct, toAddr, amount):
|
|
" send coins to an external addr "
|
|
self.rpc.ping()
|
|
if self.canMove(fromAcct, toAddr, amount):
|
|
return self.rpc.con.sendfrom(fromAcct, toAddr, amount)
|
|
return False
|
|
|
|
class DogeController:
|
|
def __init__(self, master):
|
|
self.config = master.config
|
|
self.log = master.log
|
|
self.con = None
|
|
self.ping()
|
|
|
|
def ping(self):
|
|
try:
|
|
self.con.getinfo()
|
|
except:
|
|
self.connect()
|
|
|
|
def connect(self):
|
|
self.log.debug("DogeRPC: Connecting to dogecoind")
|
|
self.con = AuthServiceProxy("http://%s:%s@%s:%s" % (self.config["username"], self.config["password"], self.config["host"], self.config["port"]))
|
|
self.con.getinfo()
|
|
self.log.debug("DogeRPC: Connected to %s:%s" % (self.config["host"], self.config["port"]))
|