mirror of
https://github.com/bigchaindb/bigchaindb.git
synced 2024-10-13 13:34:05 +00:00
abdd23f5a6
* Problem: Source files contain no license info Solution: Add comments with SPDX license info to source files * Python 3 files don't need # -*- coding: utf-8 -*-
48 lines
1.3 KiB
Python
48 lines
1.3 KiB
Python
# Copyright BigchainDB GmbH and BigchainDB contributors
|
|
# SPDX-License-Identifier: (Apache-2.0 AND CC-BY-4.0)
|
|
# Code is Apache-2.0 and docs are CC-BY-4.0
|
|
|
|
# # Double Spend testing
|
|
# This test challenge the system with double spends.
|
|
|
|
import os
|
|
from uuid import uuid4
|
|
from threading import Thread
|
|
import queue
|
|
|
|
import bigchaindb_driver.exceptions
|
|
from bigchaindb_driver import BigchainDB
|
|
from bigchaindb_driver.crypto import generate_keypair
|
|
|
|
|
|
def test_double_create():
|
|
bdb = BigchainDB(os.environ.get('BIGCHAINDB_ENDPOINT'))
|
|
alice = generate_keypair()
|
|
|
|
results = queue.Queue()
|
|
|
|
tx = bdb.transactions.fulfill(
|
|
bdb.transactions.prepare(
|
|
operation='CREATE',
|
|
signers=alice.public_key,
|
|
asset={'data': {'uuid': str(uuid4())}}),
|
|
private_keys=alice.private_key)
|
|
|
|
def send_and_queue(tx):
|
|
try:
|
|
bdb.transactions.send(tx)
|
|
results.put('OK')
|
|
except bigchaindb_driver.exceptions.TransportError as e:
|
|
results.put('FAIL')
|
|
|
|
t1 = Thread(target=send_and_queue, args=(tx, ))
|
|
t2 = Thread(target=send_and_queue, args=(tx, ))
|
|
|
|
t1.start()
|
|
t2.start()
|
|
|
|
results = [results.get(timeout=2), results.get(timeout=2)]
|
|
|
|
assert results.count('OK') == 1
|
|
assert results.count('FAIL') == 1
|