mirror of
https://github.com/alexgo-io/stacks-puppet-node.git
synced 2026-06-16 09:43:45 +08:00
aa405e8961
1) Basic version of opennamed that uses zerorpc for efficient rpc calls
2) Basic version of openname-cli to talk to opennamed
3) Support for talking to a default bitcoind server
109 lines
2.9 KiB
Python
109 lines
2.9 KiB
Python
#!/usr/bin/env python
|
|
# -*- coding: utf-8 -*-
|
|
"""
|
|
Opennamed
|
|
~~~~~
|
|
:copyright: (c) 2014 by Openname.org
|
|
:license: MIT, see LICENSE for more details.
|
|
"""
|
|
|
|
#-----------------------------------
|
|
|
|
import argparse
|
|
import zerorpc
|
|
import daemon
|
|
import sys
|
|
|
|
import config
|
|
|
|
import logging
|
|
log = logging.getLogger()
|
|
log.setLevel(logging.DEBUG if config.DEBUG else logging.INFO)
|
|
console = logging.StreamHandler()
|
|
console.setLevel(logging.DEBUG if config.DEBUG else logging.INFO)
|
|
formatter = logging.Formatter('%(message)s')
|
|
console.setFormatter(formatter)
|
|
log.addHandler(console)
|
|
|
|
from bitcoinrpc.authproxy import AuthServiceProxy
|
|
|
|
config_options = 'https://' + config.BITCOIND_USER + ':' + config.BITCOIND_PASSWD + '@' \
|
|
+ config.BITCOIND_SERVER + ':' + str(config.BITCOIND_PORT)
|
|
|
|
bitcoind = AuthServiceProxy(config_options)
|
|
|
|
#-----------------------------------
|
|
class OpennamedRPC(object):
|
|
|
|
#------------------
|
|
def getinfo(self):
|
|
|
|
info = bitcoind.getinfo()
|
|
|
|
reply = {}
|
|
reply['blocks'] = info['blocks']
|
|
return reply
|
|
|
|
#-----------------------------------
|
|
def run_server():
|
|
|
|
try:
|
|
server = zerorpc.Server(OpennamedRPC())
|
|
server.bind('tcp://' + config.LISTEN_IP + ':' + config.DEFAULT_PORT)
|
|
server.run()
|
|
except Exception as e:
|
|
log.debug(e)
|
|
log.info('Exiting opennamed server')
|
|
|
|
#-----------------------------------
|
|
def run_opennamed():
|
|
|
|
parser = argparse.ArgumentParser(description='Openname Core Daemon version {}'.format(config.VERSION))
|
|
|
|
parser.add_argument('--bitcoind-server', help='the hostname or IP address of the bitcoind RPC server')
|
|
parser.add_argument('--bitcoind-port', type=int, help='the bitcoind RPC port to connect to')
|
|
parser.add_argument('--bitcoind-user', help='the username for bitcoind RPC server')
|
|
parser.add_argument('--bitcoind-passwd', help='the password for bitcoind RPC server')
|
|
|
|
subparsers = parser.add_subparsers(dest='action', help='the action to be taken')
|
|
|
|
parser_server = subparsers.add_parser('start', help='start the opennamed server')
|
|
parser_server.add_argument('--foreground', action='store_true', help='start the opennamed server in foreground')
|
|
parser_server = subparsers.add_parser('stop', help='stop the opennamed server')
|
|
|
|
#print default help message, if no argument is given
|
|
if len(sys.argv)==1:
|
|
parser.print_help()
|
|
sys.exit(1)
|
|
|
|
args = parser.parse_args()
|
|
|
|
if args.action == 'start':
|
|
|
|
if args.foreground:
|
|
log.info('Starting opennamed server in foreground')
|
|
run_server()
|
|
else:
|
|
log.info('Starting opennamed server')
|
|
with daemon.DaemonContext():
|
|
run_server()
|
|
|
|
|
|
elif args.action == 'stop':
|
|
|
|
log.info('Stopping opennamed server')
|
|
#quick hack to kill a background daemon
|
|
import subprocess, signal
|
|
import os
|
|
p = subprocess.Popen(['ps', '-A'], stdout=subprocess.PIPE)
|
|
out, err = p.communicate()
|
|
|
|
for line in out.splitlines():
|
|
if 'opennamed' in line:
|
|
pid = int(line.split(None, 1)[0])
|
|
os.kill(pid, signal.SIGTERM)
|
|
|
|
#-----------------------------------
|
|
if __name__ == '__main__':
|
|
|
|
run_opennamed() |