mirror of
https://github.com/alexgo-io/stacks-puppet-node.git
synced 2026-04-21 01:46:59 +08:00
test stale files and directories
This commit is contained in:
Jude Nelson
@@ -0,0 +1,472 @@
|
||||
#!/usr/bin/env python
|
||||
# -*- coding: utf-8 -*-
|
||||
"""
|
||||
Blockstack
|
||||
~~~~~
|
||||
copyright: (c) 2014-2015 by Halfmoon Labs, Inc.
|
||||
copyright: (c) 2016 by Blockstack.org
|
||||
|
||||
This file is part of Blockstack
|
||||
|
||||
Blockstack is free software: you can redistribute it and/or modify
|
||||
it under the terms of the GNU General Public License as published by
|
||||
the Free Software Foundation, either version 3 of the License, or
|
||||
(at your option) any later version.
|
||||
|
||||
Blockstack is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU General Public License for more details.
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with Blockstack. If not, see <http://www.gnu.org/licenses/>.
|
||||
"""
|
||||
import os
|
||||
import testlib
|
||||
import pybitcoin
|
||||
import urllib2
|
||||
import json
|
||||
import blockstack_client
|
||||
import blockstack_profiles
|
||||
import blockstack_gpg
|
||||
import sys
|
||||
import errno
|
||||
import keylib
|
||||
import time
|
||||
import shutil
|
||||
|
||||
wallets = [
|
||||
testlib.Wallet( "5JesPiN68qt44Hc2nT8qmyZ1JDwHebfoh9KQ52Lazb1m1LaKNj9", 100000000000 ),
|
||||
testlib.Wallet( "5KHqsiU9qa77frZb6hQy9ocV7Sus9RWJcQGYYBJJBb2Efj1o77e", 100000000000 ),
|
||||
testlib.Wallet( "5Kg5kJbQHvk1B64rJniEmgbD83FpZpbw2RjdAZEzTefs9ihN3Bz", 100000000000 ),
|
||||
testlib.Wallet( "5JuVsoS9NauksSkqEjbUZxWwgGDQbMwPsEfoRBSpLpgDX1RtLX7", 100000000000 ),
|
||||
testlib.Wallet( "5KEpiSRr1BrT8vRD7LKGCEmudokTh1iMHbiThMQpLdwBwhDJB1T", 100000000000 ),
|
||||
testlib.Wallet( "5K5hDuynZ6EQrZ4efrchCwy6DLhdsEzuJtTDAf3hqdsCKbxfoeD", 100000000000 ),
|
||||
testlib.Wallet( "5J39aXEeHh9LwfQ4Gy5Vieo7sbqiUMBXkPH7SaMHixJhSSBpAqz", 100000000000 ),
|
||||
testlib.Wallet( "5K9LmMQskQ9jP1p7dyieLDAeB6vsAj4GK8dmGNJAXS1qHDqnWhP", 100000000000 ),
|
||||
testlib.Wallet( "5KcNen67ERBuvz2f649t9F2o1ddTjC5pVUEqcMtbxNgHqgxG2gZ", 100000000000 )
|
||||
]
|
||||
|
||||
consensus = "17ac43c1d8549c3181b200f1bf97eb7d"
|
||||
wallet_keys = None
|
||||
error = False
|
||||
index_file_data = "<html><head></head><body>foo.test hello world</body></html>"
|
||||
|
||||
def scenario( wallets, **kw ):
|
||||
|
||||
global wallet_keys, error, index_file_data, resource_data
|
||||
|
||||
test_proxy = testlib.TestAPIProxy()
|
||||
blockstack_client.set_default_proxy( test_proxy )
|
||||
wallet_keys = blockstack_client.make_wallet_keys( owner_privkey=wallets[3].privkey, data_privkey=wallets[4].privkey, payment_privkey=wallets[5].privkey )
|
||||
testlib.blockstack_client_set_wallet( "0123456789abcdef", wallet_keys['payment_privkey'], wallet_keys['owner_privkey'], wallet_keys['data_privkey'] )
|
||||
|
||||
testlib.blockstack_namespace_preorder( "test", wallets[1].addr, wallets[0].privkey )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
testlib.blockstack_namespace_reveal( "test", wallets[1].addr, 52595, 250, 4, [6,5,4,3,2,1,0,0,0,0,0,0,0,0,0,0], 10, 10, wallets[0].privkey )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
testlib.blockstack_namespace_ready( "test", wallets[1].privkey )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
testlib.blockstack_name_preorder( "foo.test", wallets[2].privkey, wallets[3].addr )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
testlib.blockstack_name_register( "foo.test", wallets[2].privkey, wallets[3].addr )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
# migrate profiles
|
||||
res = testlib.migrate_profile( "foo.test", proxy=test_proxy, wallet_keys=wallet_keys )
|
||||
if 'error' in res:
|
||||
res['test'] = 'Failed to initialize foo.test profile'
|
||||
print json.dumps(res, indent=4, sort_keys=True)
|
||||
error = True
|
||||
return
|
||||
|
||||
# tell serialization-checker that value_hash can be ignored here
|
||||
print "BLOCKSTACK_SERIALIZATION_CHECK_IGNORE value_hash"
|
||||
sys.stdout.flush()
|
||||
|
||||
testlib.next_block( **kw )
|
||||
|
||||
# sign in and make a token
|
||||
datastore_pk = keylib.ECPrivateKey(wallets[-1].privkey).to_hex()
|
||||
res = testlib.blockstack_cli_app_signin(datastore_pk, 'foo-app.com', ['store_read', 'store_write', 'store_admin'])
|
||||
if 'error' in res:
|
||||
print json.dumps(res, indent=4, sort_keys=True)
|
||||
error = True
|
||||
return
|
||||
|
||||
# export to environment
|
||||
os.environ['BLOCKSTACK_API_SESSION'] = res['token']
|
||||
|
||||
datastore_id_res = testlib.blockstack_cli_datastore_get_id( datastore_pk )
|
||||
datastore_id = datastore_id_res['datastore_id']
|
||||
|
||||
# use random data for file
|
||||
file_data = None
|
||||
with open('/dev/urandom', 'r') as f:
|
||||
file_data = f.read(16384)
|
||||
|
||||
# make datastore
|
||||
res = testlib.blockstack_cli_create_datastore( datastore_pk, ['disk'] )
|
||||
if 'error' in res:
|
||||
print "failed to create datastore: {}".format(res['error'])
|
||||
return False
|
||||
|
||||
# make directories
|
||||
for dpath in ['/dir1', '/dir2', '/dir1/dir3', '/dir1/dir3/dir4']:
|
||||
print 'mkdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_mkdir( datastore_pk, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to mkdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
# stat directories
|
||||
for dpath in ['/dir1', '/dir2', '/dir1/dir3', '/dir1/dir3/dir4']:
|
||||
print 'stat {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to stat {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
if res['inode']['type'] != blockstack_client.schemas.MUTABLE_DATUM_DIR_TYPE:
|
||||
print 'not a directory: {}, {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
# list directories
|
||||
for dpath, expected in [('/', ['dir1', 'dir2']), ('/dir1', ['dir3']), ('/dir1/dir3', ['dir4']), ('/dir1/dir3/dir4', [])]:
|
||||
print 'listdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) != len(expected):
|
||||
print 'invalid directory: expected:\n{}\ngot:\n{}\n'.format(expected, res['idata'])
|
||||
return False
|
||||
|
||||
for child in expected:
|
||||
if not res['idata'].has_key(child):
|
||||
print 'invalid directory: missing {} in {}'.format(child, res['idata'])
|
||||
return False
|
||||
|
||||
# back up disk storage, to test stale data
|
||||
backup_dir = '/tmp/blockstack-disk-backup.{}'.format(time.time())
|
||||
if os.path.exists(backup_dir):
|
||||
shutil.rmtree(backup_dir)
|
||||
|
||||
shutil.copytree('/tmp/blockstack-disk', backup_dir)
|
||||
|
||||
# put files
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'putfile {}'.format(dpath)
|
||||
data = '{} hello {}'.format(file_data, dpath)
|
||||
res = testlib.blockstack_cli_datastore_putfile( datastore_pk, dpath, data )
|
||||
if 'error' in res:
|
||||
print 'failed to putfile {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
# stat files
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'stat {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to stat {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
if res['inode']['type'] != blockstack_client.schemas.MUTABLE_DATUM_FILE_TYPE:
|
||||
print 'not a file: {}, {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
# list directories again
|
||||
for dpath, expected in [('/', ['dir1', 'dir2', 'file1', 'file2']), ('/dir1', ['dir3', 'file3']), ('/dir1/dir3', ['dir4', 'file4']), ('/dir1/dir3/dir4', ['file5'])]:
|
||||
print 'listdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) != len(expected):
|
||||
print 'invalid directory: expected:\n{}\ngot:\n{}\n'.format(expected, res['idata'])
|
||||
return False
|
||||
|
||||
for child in expected:
|
||||
if not res['idata'].has_key(child):
|
||||
print 'invalid directory: missing {} in {}'.format(child, res['idata'])
|
||||
return False
|
||||
|
||||
# get files
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to getfile {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['file']
|
||||
if res['idata'] != '{} hello {}'.format(file_data, dpath):
|
||||
print 'failed to read {}'.format(dpath)
|
||||
return False
|
||||
|
||||
# put files again!
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'putfile {}'.format(dpath)
|
||||
data = '{} hello 2 {}'.format(file_data, dpath)
|
||||
res = testlib.blockstack_cli_datastore_putfile( datastore_pk, dpath, data )
|
||||
if 'error' in res:
|
||||
print 'failed to putfile {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir)
|
||||
return False
|
||||
|
||||
# get files again!
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to getfile {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir)
|
||||
return False
|
||||
|
||||
res = res['file']
|
||||
if res['idata'] != '{} hello 2 {}'.format(file_data, dpath):
|
||||
print 'failed to read {}'.format(dpath)
|
||||
shutil.rmtree(backup_dir)
|
||||
return False
|
||||
|
||||
# restore stale data; verify that file-reads fail
|
||||
backup_dir_2 = backup_dir + '.2'
|
||||
shutil.copytree('/tmp/blockstack-disk', backup_dir_2)
|
||||
shutil.rmtree('/tmp/blockstack-disk')
|
||||
shutil.copytree(backup_dir, '/tmp/blockstack-disk')
|
||||
|
||||
# stat files (should all fail with ESTALE)
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'stat {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to stat {}: {}'.format(dpath, res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ESTALE:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# get files (expect failure with ESTALE)
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to getfile {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ESTALE:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# get files with force (expect failure with ENOENT, since dirs don't have them)
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile force=1 {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath, force=True )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to get {}: {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ENOENT:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
return False
|
||||
|
||||
# stat directories (with force)
|
||||
for dpath in ['/dir1/dir3/dir4', '/dir1/dir3', '/dir2', '/dir1']:
|
||||
print 'stat {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath, force=True )
|
||||
if 'error' in res:
|
||||
print 'failed to stat {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
if res['inode']['type'] != blockstack_client.schemas.MUTABLE_DATUM_DIR_TYPE:
|
||||
print 'not a file: {}, {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
# list directories (expect failure due to stale directories)
|
||||
for dpath, expected in [('/', ['dir1', 'dir2', 'file1', 'file2']), ('/dir1', ['dir3', 'file3']), ('/dir1/dir3', ['dir4', 'file4']), ('/dir1/dir3/dir4', ['file5'])]:
|
||||
print 'listdir {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to listdir {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ESTALE:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# list directories (with force) Expect no files
|
||||
for dpath, expected in [('/', ['file1', 'file2']), ('/dir1', ['file3']), ('/dir1/dir3', ['file4']), ('/dir1/dir3/dir4', [])]:
|
||||
print 'listdir force=1 {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath, force=True )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) != len(expected):
|
||||
print 'invalid directory: expected:\n{}\ngot:\n{}\n'.format(expected, res['idata'])
|
||||
return False
|
||||
|
||||
for child in expected:
|
||||
if res['idata'].has_key(child):
|
||||
print 'invalid directory: accidentally got fresh file data for {} in {}'.format(child, res['idata'])
|
||||
return False
|
||||
|
||||
# remove files, with force (should still fail, but with ENOENT)
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'deletefile {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_deletefile( datastore_pk, dpath, force=True )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to listdir {}: {}'.format(dpath, res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ENOENT:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# remove directories (should all fail with ESTALE)
|
||||
for dpath in ['/dir1/dir3/dir4', '/dir1/dir3', '/dir2', '/dir1']:
|
||||
print 'rmdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_rmdir( datastore_pk, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to rmdir {}: {}'.format(dpath, res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ESTALE:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# remove directories with force (should succeed)
|
||||
for dpath in ['/dir1/dir3/dir4', '/dir1/dir3', '/dir2', '/dir1']:
|
||||
print 'rmdir force=1 {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_rmdir( datastore_pk, dpath, force=True )
|
||||
if 'error' in res:
|
||||
print 'failed to remove {}: {}'.format(dpath, res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# stat directories (should all fail with ENOENT)
|
||||
for dpath in ['/dir1/dir3/dir4', '/dir1/dir3', '/dir2', '/dir1']:
|
||||
print 'stat {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to stat {}: {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ENOENT:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
return False
|
||||
|
||||
# list directories (should all fail with ENOENT now)
|
||||
for dpath, expected in [('/dir1', ['dir3']), ('/dir1/dir3', ['dir4']), ('/dir1/dir3/dir4', [])]:
|
||||
print 'listdir {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to list {}: {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ENOENT:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
return False
|
||||
|
||||
# root should be empty
|
||||
print 'listdir {}'.format('/')
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, '/' )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir /: {}'.format(res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) > 0:
|
||||
print 'root still has children: {}'.format(res['idata'].keys())
|
||||
return False
|
||||
|
||||
# delete datastore
|
||||
print 'delete datastore'
|
||||
res = testlib.blockstack_cli_delete_datastore( datastore_pk )
|
||||
if 'error' in res:
|
||||
print 'failed to delete foo-app.com datastore'
|
||||
print json.dumps(res)
|
||||
return False
|
||||
|
||||
# no more data in disk driver
|
||||
names = os.listdir("/tmp/blockstack-disk/mutable")
|
||||
if names != ['foo.test']:
|
||||
print 'improper cleanup'
|
||||
return False
|
||||
|
||||
testlib.next_block( **kw )
|
||||
|
||||
|
||||
def check( state_engine ):
|
||||
|
||||
global wallet_keys, error
|
||||
|
||||
if error:
|
||||
print "Key operation failed."
|
||||
return False
|
||||
|
||||
# not revealed, but ready
|
||||
ns = state_engine.get_namespace_reveal( "test" )
|
||||
if ns is not None:
|
||||
print "namespace not ready"
|
||||
return False
|
||||
|
||||
ns = state_engine.get_namespace( "test" )
|
||||
if ns is None:
|
||||
print "no namespace"
|
||||
return False
|
||||
|
||||
if ns['namespace_id'] != 'test':
|
||||
print "wrong namespace"
|
||||
return False
|
||||
|
||||
names = ['foo.test']
|
||||
wallet_keys_list = [wallet_keys]
|
||||
test_proxy = testlib.TestAPIProxy()
|
||||
|
||||
for i in xrange(0, len(names)):
|
||||
name = names[i]
|
||||
wallet_payer = 3 * (i+1) - 1
|
||||
wallet_owner = 3 * (i+1)
|
||||
wallet_data_pubkey = 3 * (i+1) + 1
|
||||
wallet_keys = wallet_keys_list[i]
|
||||
|
||||
# not preordered
|
||||
preorder = state_engine.get_name_preorder( name, pybitcoin.make_pay_to_address_script(wallets[wallet_payer].addr), wallets[wallet_owner].addr )
|
||||
if preorder is not None:
|
||||
print "still have preorder"
|
||||
return False
|
||||
|
||||
# registered
|
||||
name_rec = state_engine.get_name( name )
|
||||
if name_rec is None:
|
||||
print "name does not exist"
|
||||
return False
|
||||
|
||||
# owned
|
||||
if name_rec['address'] != wallets[wallet_owner].addr or name_rec['sender'] != pybitcoin.make_pay_to_address_script(wallets[wallet_owner].addr):
|
||||
print "name has wrong owner"
|
||||
return False
|
||||
|
||||
# try to authenticate
|
||||
|
||||
return True
|
||||
@@ -0,0 +1,512 @@
|
||||
#!/usr/bin/env python
|
||||
# -*- coding: utf-8 -*-
|
||||
"""
|
||||
Blockstack
|
||||
~~~~~
|
||||
copyright: (c) 2014-2015 by Halfmoon Labs, Inc.
|
||||
copyright: (c) 2016 by Blockstack.org
|
||||
|
||||
This file is part of Blockstack
|
||||
|
||||
Blockstack is free software: you can redistribute it and/or modify
|
||||
it under the terms of the GNU General Public License as published by
|
||||
the Free Software Foundation, either version 3 of the License, or
|
||||
(at your option) any later version.
|
||||
|
||||
Blockstack is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU General Public License for more details.
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with Blockstack. If not, see <http://www.gnu.org/licenses/>.
|
||||
"""
|
||||
import os
|
||||
import testlib
|
||||
import pybitcoin
|
||||
import urllib2
|
||||
import json
|
||||
import blockstack_client
|
||||
import blockstack_profiles
|
||||
import blockstack_gpg
|
||||
import sys
|
||||
import errno
|
||||
import keylib
|
||||
import time
|
||||
import shutil
|
||||
|
||||
wallets = [
|
||||
testlib.Wallet( "5JesPiN68qt44Hc2nT8qmyZ1JDwHebfoh9KQ52Lazb1m1LaKNj9", 100000000000 ),
|
||||
testlib.Wallet( "5KHqsiU9qa77frZb6hQy9ocV7Sus9RWJcQGYYBJJBb2Efj1o77e", 100000000000 ),
|
||||
testlib.Wallet( "5Kg5kJbQHvk1B64rJniEmgbD83FpZpbw2RjdAZEzTefs9ihN3Bz", 100000000000 ),
|
||||
testlib.Wallet( "5JuVsoS9NauksSkqEjbUZxWwgGDQbMwPsEfoRBSpLpgDX1RtLX7", 100000000000 ),
|
||||
testlib.Wallet( "5KEpiSRr1BrT8vRD7LKGCEmudokTh1iMHbiThMQpLdwBwhDJB1T", 100000000000 ),
|
||||
testlib.Wallet( "5K5hDuynZ6EQrZ4efrchCwy6DLhdsEzuJtTDAf3hqdsCKbxfoeD", 100000000000 ),
|
||||
testlib.Wallet( "5J39aXEeHh9LwfQ4Gy5Vieo7sbqiUMBXkPH7SaMHixJhSSBpAqz", 100000000000 ),
|
||||
testlib.Wallet( "5K9LmMQskQ9jP1p7dyieLDAeB6vsAj4GK8dmGNJAXS1qHDqnWhP", 100000000000 ),
|
||||
testlib.Wallet( "5KcNen67ERBuvz2f649t9F2o1ddTjC5pVUEqcMtbxNgHqgxG2gZ", 100000000000 )
|
||||
]
|
||||
|
||||
consensus = "17ac43c1d8549c3181b200f1bf97eb7d"
|
||||
wallet_keys = None
|
||||
error = False
|
||||
index_file_data = "<html><head></head><body>foo.test hello world</body></html>"
|
||||
|
||||
def scenario( wallets, **kw ):
|
||||
|
||||
global wallet_keys, error, index_file_data, resource_data
|
||||
|
||||
test_proxy = testlib.TestAPIProxy()
|
||||
blockstack_client.set_default_proxy( test_proxy )
|
||||
wallet_keys = blockstack_client.make_wallet_keys( owner_privkey=wallets[3].privkey, data_privkey=wallets[4].privkey, payment_privkey=wallets[5].privkey )
|
||||
testlib.blockstack_client_set_wallet( "0123456789abcdef", wallet_keys['payment_privkey'], wallet_keys['owner_privkey'], wallet_keys['data_privkey'] )
|
||||
|
||||
testlib.blockstack_namespace_preorder( "test", wallets[1].addr, wallets[0].privkey )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
testlib.blockstack_namespace_reveal( "test", wallets[1].addr, 52595, 250, 4, [6,5,4,3,2,1,0,0,0,0,0,0,0,0,0,0], 10, 10, wallets[0].privkey )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
testlib.blockstack_namespace_ready( "test", wallets[1].privkey )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
testlib.blockstack_name_preorder( "foo.test", wallets[2].privkey, wallets[3].addr )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
testlib.blockstack_name_register( "foo.test", wallets[2].privkey, wallets[3].addr )
|
||||
testlib.next_block( **kw )
|
||||
|
||||
# migrate profiles
|
||||
res = testlib.migrate_profile( "foo.test", proxy=test_proxy, wallet_keys=wallet_keys )
|
||||
if 'error' in res:
|
||||
res['test'] = 'Failed to initialize foo.test profile'
|
||||
print json.dumps(res, indent=4, sort_keys=True)
|
||||
error = True
|
||||
return
|
||||
|
||||
# tell serialization-checker that value_hash can be ignored here
|
||||
print "BLOCKSTACK_SERIALIZATION_CHECK_IGNORE value_hash"
|
||||
sys.stdout.flush()
|
||||
|
||||
testlib.next_block( **kw )
|
||||
|
||||
# sign in and make a token
|
||||
datastore_pk = keylib.ECPrivateKey(wallets[-1].privkey).to_hex()
|
||||
res = testlib.blockstack_cli_app_signin(datastore_pk, 'foo-app.com', ['store_read', 'store_write', 'store_admin'])
|
||||
if 'error' in res:
|
||||
print json.dumps(res, indent=4, sort_keys=True)
|
||||
error = True
|
||||
return
|
||||
|
||||
# export to environment
|
||||
os.environ['BLOCKSTACK_API_SESSION'] = res['token']
|
||||
|
||||
datastore_id_res = testlib.blockstack_cli_datastore_get_id( datastore_pk )
|
||||
datastore_id = datastore_id_res['datastore_id']
|
||||
|
||||
# use random data for file
|
||||
file_data = None
|
||||
with open('/dev/urandom', 'r') as f:
|
||||
file_data = f.read(16384)
|
||||
|
||||
# make datastore
|
||||
res = testlib.blockstack_cli_create_datastore( datastore_pk, ['disk'] )
|
||||
if 'error' in res:
|
||||
print "failed to create datastore: {}".format(res['error'])
|
||||
return False
|
||||
|
||||
# make directories
|
||||
for dpath in ['/dir1', '/dir2', '/dir1/dir3', '/dir1/dir3/dir4']:
|
||||
print 'mkdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_mkdir( datastore_pk, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to mkdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
# stat directories
|
||||
for dpath in ['/dir1', '/dir2', '/dir1/dir3', '/dir1/dir3/dir4']:
|
||||
print 'stat {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to stat {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
if res['inode']['type'] != blockstack_client.schemas.MUTABLE_DATUM_DIR_TYPE:
|
||||
print 'not a directory: {}, {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
# list directories
|
||||
for dpath, expected in [('/', ['dir1', 'dir2']), ('/dir1', ['dir3']), ('/dir1/dir3', ['dir4']), ('/dir1/dir3/dir4', [])]:
|
||||
print 'listdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) != len(expected):
|
||||
print 'invalid directory: expected:\n{}\ngot:\n{}\n'.format(expected, res['idata'])
|
||||
return False
|
||||
|
||||
for child in expected:
|
||||
if not res['idata'].has_key(child):
|
||||
print 'invalid directory: missing {} in {}'.format(child, res['idata'])
|
||||
return False
|
||||
|
||||
# put files
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'putfile {}'.format(dpath)
|
||||
data = '{} hello {}'.format(file_data, dpath)
|
||||
res = testlib.blockstack_cli_datastore_putfile( datastore_pk, dpath, data )
|
||||
if 'error' in res:
|
||||
print 'failed to putfile {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
# stat files
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'stat {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to stat {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
if res['inode']['type'] != blockstack_client.schemas.MUTABLE_DATUM_FILE_TYPE:
|
||||
print 'not a file: {}, {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
# list directories again
|
||||
for dpath, expected in [('/', ['dir1', 'dir2', 'file1', 'file2']), ('/dir1', ['dir3', 'file3']), ('/dir1/dir3', ['dir4', 'file4']), ('/dir1/dir3/dir4', ['file5'])]:
|
||||
print 'listdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) != len(expected):
|
||||
print 'invalid directory: expected:\n{}\ngot:\n{}\n'.format(expected, res['idata'])
|
||||
return False
|
||||
|
||||
for child in expected:
|
||||
if not res['idata'].has_key(child):
|
||||
print 'invalid directory: missing {} in {}'.format(child, res['idata'])
|
||||
return False
|
||||
|
||||
# get files
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to getfile {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['file']
|
||||
if res['idata'] != '{} hello {}'.format(file_data, dpath):
|
||||
print 'failed to read {}'.format(dpath)
|
||||
return False
|
||||
|
||||
# back up disk storage, to test stale data
|
||||
backup_dir = '/tmp/blockstack-disk-backup.{}'.format(time.time())
|
||||
if os.path.exists(backup_dir):
|
||||
shutil.rmtree(backup_dir)
|
||||
|
||||
shutil.copytree('/tmp/blockstack-disk', backup_dir)
|
||||
|
||||
# put files again!
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'putfile {}'.format(dpath)
|
||||
data = '{} hello 2 {}'.format(file_data, dpath)
|
||||
res = testlib.blockstack_cli_datastore_putfile( datastore_pk, dpath, data )
|
||||
if 'error' in res:
|
||||
print 'failed to putfile {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir)
|
||||
return False
|
||||
|
||||
# get files again!
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to getfile {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir)
|
||||
return False
|
||||
|
||||
res = res['file']
|
||||
if res['idata'] != '{} hello 2 {}'.format(file_data, dpath):
|
||||
print 'failed to read {}'.format(dpath)
|
||||
shutil.rmtree(backup_dir)
|
||||
return False
|
||||
|
||||
# restore stale data; verify that file-reads fail
|
||||
backup_dir_2 = backup_dir + '.2'
|
||||
shutil.copytree('/tmp/blockstack-disk', backup_dir_2)
|
||||
shutil.rmtree('/tmp/blockstack-disk')
|
||||
shutil.copytree(backup_dir, '/tmp/blockstack-disk')
|
||||
|
||||
# stat files (should all fail)
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'stat {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to stat {}: {}'.format(dpath, res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ESTALE:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# get files (expect failure)
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to getfile {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ESTALE:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# get files with force
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile force=1 {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath, force=True )
|
||||
if 'error' in res:
|
||||
print 'failed to getfile {} force=1: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# expect the stale data
|
||||
res = res['file']
|
||||
if res['idata'] != '{} hello {}'.format(file_data, dpath):
|
||||
print 'failed to read {}'.format(dpath)
|
||||
shutil.rmtree(backup_dir)
|
||||
return False
|
||||
|
||||
# stat directories (with force)
|
||||
for dpath in ['/dir1/dir3/dir4', '/dir1/dir3', '/dir2', '/dir1']:
|
||||
print 'stat {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath, force=True )
|
||||
if 'error' in res:
|
||||
print 'failed to stat {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
if res['inode']['type'] != blockstack_client.schemas.MUTABLE_DATUM_DIR_TYPE:
|
||||
print 'not a file: {}, {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
# list directories (expect failure due to stale directories)
|
||||
for dpath, expected in [('/', ['dir1', 'dir2', 'file1', 'file2']), ('/dir1', ['dir3', 'file3']), ('/dir1/dir3', ['dir4', 'file4']), ('/dir1/dir3/dir4', ['file5'])]:
|
||||
print 'listdir force=1 {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to listdir {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ESTALE:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# list directories (with force)
|
||||
for dpath, expected in [('/', ['dir1', 'dir2', 'file1', 'file2']), ('/dir1', ['dir3', 'file3']), ('/dir1/dir3', ['dir4', 'file4']), ('/dir1/dir3/dir4', ['file5'])]:
|
||||
print 'listdir force=1 {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath, force=True )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) != len(expected):
|
||||
print 'invalid directory: expected:\n{}\ngot:\n{}\n'.format(expected, res['idata'])
|
||||
return False
|
||||
|
||||
for child in expected:
|
||||
if not res['idata'].has_key(child):
|
||||
print 'invalid directory: missing {} in {}'.format(child, res['idata'])
|
||||
return False
|
||||
|
||||
# remove files (should fail, unless we give 'force=1')
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'deletefile {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_deletefile( datastore_pk, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to deletefile {}: {}'.format(dpath, res['error'])
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ESTALE:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# remove files, with force
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'deletefile {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_deletefile( datastore_pk, dpath, force=True )
|
||||
if 'errno' in res:
|
||||
print 'failed to deletefile {}: {}'.format(dpath, res)
|
||||
shutil.rmtree(backup_dir_2)
|
||||
return False
|
||||
|
||||
# stat files in affected (should all fail with ENOENT, since we updated the directories)
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'stat {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to stat {}: {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ENOENT:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
return False
|
||||
|
||||
# get files in affected directoies (should all fail with ENOENT since we updated the directories)
|
||||
for dpath in ['/file1', '/file2', '/dir1/file3', '/dir1/dir3/file4', '/dir1/dir3/dir4/file5']:
|
||||
print 'getfile {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_getfile( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to get {}: {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ENOENT:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
return False
|
||||
|
||||
# list directories (should all succeed since we updated the directories)
|
||||
for dpath, expected in [('/', ['dir1', 'dir2']), ('/dir1', ['dir3']), ('/dir1/dir3', ['dir4']), ('/dir1/dir3/dir4', [])]:
|
||||
print 'listdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) != len(expected):
|
||||
print 'invalid directory: expected:\n{}\ngot:\n{}\n'.format(expected, res['idata'])
|
||||
return False
|
||||
|
||||
for child in expected:
|
||||
if not res['idata'].has_key(child):
|
||||
print 'invalid directory: missing {} in {}'.format(child, res['idata'])
|
||||
return False
|
||||
|
||||
# remove directories (should all succeed since we updated directories)
|
||||
for dpath in ['/dir1/dir3/dir4', '/dir1/dir3', '/dir2', '/dir1']:
|
||||
print 'rmdir {}'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_rmdir( datastore_pk, dpath )
|
||||
if 'error' in res:
|
||||
print 'failed to rmdir {}: {}'.format(dpath, res['error'])
|
||||
return False
|
||||
|
||||
# stat directories (should all fail with ENOENT)
|
||||
for dpath in ['/dir1/dir3/dir4', '/dir1/dir3', '/dir2', '/dir1']:
|
||||
print 'stat {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_stat( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to stat {}: {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ENOENT:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
return False
|
||||
|
||||
# list directories (should all fail with ENOENT now)
|
||||
for dpath, expected in [('/dir1', ['dir3']), ('/dir1/dir3', ['dir4']), ('/dir1/dir3/dir4', [])]:
|
||||
print 'listdir {} (expect failure)'.format(dpath)
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, dpath )
|
||||
if 'error' not in res or 'errno' not in res:
|
||||
print 'accidentally succeeded to list {}: {}'.format(dpath, res)
|
||||
return False
|
||||
|
||||
if res['errno'] != errno.ENOENT:
|
||||
print 'wrong errno: {}'.format(res)
|
||||
return False
|
||||
|
||||
# root should be empty
|
||||
print 'listdir {}'.format('/')
|
||||
res = testlib.blockstack_cli_datastore_listdir( datastore_id, '/' )
|
||||
if 'error' in res:
|
||||
print 'failed to listdir /: {}'.format(res['error'])
|
||||
return False
|
||||
|
||||
res = res['dir']
|
||||
if len(res['idata'].keys()) > 0:
|
||||
print 'root still has children: {}'.format(res['idata'].keys())
|
||||
return False
|
||||
|
||||
# delete datastore
|
||||
print 'delete datastore'
|
||||
res = testlib.blockstack_cli_delete_datastore( datastore_pk )
|
||||
if 'error' in res:
|
||||
print 'failed to delete foo-app.com datastore'
|
||||
print json.dumps(res)
|
||||
return False
|
||||
|
||||
# no more data in disk driver
|
||||
names = os.listdir("/tmp/blockstack-disk/mutable")
|
||||
if names != ['foo.test']:
|
||||
print 'improper cleanup'
|
||||
return False
|
||||
|
||||
testlib.next_block( **kw )
|
||||
|
||||
|
||||
def check( state_engine ):
|
||||
|
||||
global wallet_keys, error
|
||||
|
||||
if error:
|
||||
print "Key operation failed."
|
||||
return False
|
||||
|
||||
# not revealed, but ready
|
||||
ns = state_engine.get_namespace_reveal( "test" )
|
||||
if ns is not None:
|
||||
print "namespace not ready"
|
||||
return False
|
||||
|
||||
ns = state_engine.get_namespace( "test" )
|
||||
if ns is None:
|
||||
print "no namespace"
|
||||
return False
|
||||
|
||||
if ns['namespace_id'] != 'test':
|
||||
print "wrong namespace"
|
||||
return False
|
||||
|
||||
names = ['foo.test']
|
||||
wallet_keys_list = [wallet_keys]
|
||||
test_proxy = testlib.TestAPIProxy()
|
||||
|
||||
for i in xrange(0, len(names)):
|
||||
name = names[i]
|
||||
wallet_payer = 3 * (i+1) - 1
|
||||
wallet_owner = 3 * (i+1)
|
||||
wallet_data_pubkey = 3 * (i+1) + 1
|
||||
wallet_keys = wallet_keys_list[i]
|
||||
|
||||
# not preordered
|
||||
preorder = state_engine.get_name_preorder( name, pybitcoin.make_pay_to_address_script(wallets[wallet_payer].addr), wallets[wallet_owner].addr )
|
||||
if preorder is not None:
|
||||
print "still have preorder"
|
||||
return False
|
||||
|
||||
# registered
|
||||
name_rec = state_engine.get_name( name )
|
||||
if name_rec is None:
|
||||
print "name does not exist"
|
||||
return False
|
||||
|
||||
# owned
|
||||
if name_rec['address'] != wallets[wallet_owner].addr or name_rec['sender'] != pybitcoin.make_pay_to_address_script(wallets[wallet_owner].addr):
|
||||
print "name has wrong owner"
|
||||
return False
|
||||
|
||||
# try to authenticate
|
||||
|
||||
return True
|
||||
@@ -1639,7 +1639,7 @@ def blockstack_cli_datastore_mkdir(datastore_privkey, path, config_path=None, in
|
||||
return cli_datastore_mkdir( args, config_path=config_path, interactive=interactive )
|
||||
|
||||
|
||||
def blockstack_cli_datastore_rmdir( datastore_privkey, path, config_path=None, interactive=False ):
|
||||
def blockstack_cli_datastore_rmdir( datastore_privkey, path, config_path=None, force=False, interactive=False ):
|
||||
"""
|
||||
rmdir
|
||||
"""
|
||||
@@ -1652,6 +1652,7 @@ def blockstack_cli_datastore_rmdir( datastore_privkey, path, config_path=None, i
|
||||
|
||||
args.path = path
|
||||
args.privkey = datastore_privkey
|
||||
args.force = '1' if force else '0'
|
||||
|
||||
return cli_datastore_rmdir( args, config_path=config_path, interactive=interactive )
|
||||
|
||||
@@ -1673,7 +1674,7 @@ def blockstack_cli_datastore_rmtree( datastore_privkey, path, config_path=None,
|
||||
return cli_datastore_rmtree( args, config_path=config_path, interactive=interactive )
|
||||
|
||||
|
||||
def blockstack_cli_datastore_listdir(datastore_id, path, config_path=None, interactive=False ):
|
||||
def blockstack_cli_datastore_listdir(datastore_id, path, config_path=None, force=False, interactive=False ):
|
||||
"""
|
||||
listdir
|
||||
"""
|
||||
@@ -1686,11 +1687,12 @@ def blockstack_cli_datastore_listdir(datastore_id, path, config_path=None, inter
|
||||
|
||||
args.datastore_id = datastore_id
|
||||
args.path = path
|
||||
args.force = '1' if force else '0'
|
||||
|
||||
return cli_datastore_listdir( args, config_path=config_path, interactive=interactive )
|
||||
|
||||
|
||||
def blockstack_cli_datastore_stat( datastore_id, path, config_path=None, interactive=False ):
|
||||
def blockstack_cli_datastore_stat( datastore_id, path, config_path=None, force=False, interactive=False ):
|
||||
"""
|
||||
stat
|
||||
"""
|
||||
@@ -1703,11 +1705,12 @@ def blockstack_cli_datastore_stat( datastore_id, path, config_path=None, interac
|
||||
|
||||
args.datastore_id = datastore_id
|
||||
args.path = path
|
||||
args.force = '1' if force else '0'
|
||||
|
||||
return cli_datastore_stat( args, config_path=config_path, interactive=interactive )
|
||||
|
||||
|
||||
def blockstack_cli_datastore_getfile( datastore_id, path, config_path=None, interactive=False ):
|
||||
def blockstack_cli_datastore_getfile( datastore_id, path, config_path=None, force=False, interactive=False ):
|
||||
"""
|
||||
getfile
|
||||
"""
|
||||
@@ -1720,11 +1723,12 @@ def blockstack_cli_datastore_getfile( datastore_id, path, config_path=None, inte
|
||||
|
||||
args.datastore_id = datastore_id
|
||||
args.path = path
|
||||
args.force = '1' if force else '0'
|
||||
|
||||
return cli_datastore_getfile( args, config_path=config_path, interactive=interactive )
|
||||
|
||||
|
||||
def blockstack_cli_datastore_putfile( datastore_privkey, path, data, data_path=None, interactive=False, proxy=None, config_path=None):
|
||||
def blockstack_cli_datastore_putfile( datastore_privkey, path, data, data_path=None, interactive=False, force=False, proxy=None, config_path=None):
|
||||
"""
|
||||
putfile
|
||||
"""
|
||||
@@ -1737,12 +1741,13 @@ def blockstack_cli_datastore_putfile( datastore_privkey, path, data, data_path=N
|
||||
args.privkey = datastore_privkey
|
||||
args.path = path
|
||||
args.data = data
|
||||
args.data_path = data_path
|
||||
args.data_path = data_path
|
||||
args.force = '1' if force else '0'
|
||||
|
||||
return cli_datastore_putfile( args, config_path=config_path, interactive=interactive )
|
||||
|
||||
|
||||
def blockstack_cli_datastore_deletefile( datastore_privkey, path, interactive=False, proxy=None, config_path=None):
|
||||
def blockstack_cli_datastore_deletefile( datastore_privkey, path, interactive=False, force=False, proxy=None, config_path=None):
|
||||
"""
|
||||
deletefile
|
||||
"""
|
||||
@@ -1754,6 +1759,7 @@ def blockstack_cli_datastore_deletefile( datastore_privkey, path, interactive=Fa
|
||||
|
||||
args.privkey = datastore_privkey
|
||||
args.path = path
|
||||
args.force = '1' if force else '0'
|
||||
|
||||
return cli_datastore_deletefile( args, config_path=config_path, interactive=interactive )
|
||||
|
||||
|
||||
Reference in New Issue
Block a user