import time, socket, operator, thread, ast, sys,re
import psycopg2, binascii
-import bitcoin
+import bitcoinrpc
from Abe.abe import hash_to_address, decode_check_address
from Abe.DataStore import DataStore as Datastore_class
def send_tx(tx):
- import bitcoin
- conn = bitcoin.connect_to_local()
+ import bitcoinrpc
+ conn = bitcoinrpc.connect_to_local()
try:
v = conn.importtransaction(tx)
except:
def memorypool_update(store):
- conn = bitcoin.connect_to_local()
+ conn = bitcoinrpc.connect_to_local()
try:
v = conn.getmemorypool()
except:
conf = DataStore.CONFIG_DEFAULTS
args, argv = readconf.parse_argv( [], conf)
args.dbtype= config.get('database','type')
- args.connect_args = {'database' : config.get('database','database') }
+ if args.dbtype == 'sqlite3':
+ args.connect_args = { 'database' : config.get('database','database') }
+ elif args.dbtype == 'MySQLdb':
+ args.connect_args = { 'db' : config.get('database','database'), 'user' : config.get('database','user'), 'passwd' : config.get('database','pass') }
+ elif args.dbtype == 'psycopg2':
+ args.connect_args = { 'database' : config.get('database','database') }
store = MyStore(args)
thread.start_new_thread(listen_thread, (store,))