@peer_required
@api_request
@bytes_required
async def respond_transaction(self, tx: full_node_protocol.RespondTransaction, peer: ws.WSChiaConnection, tx_bytes: bytes=b'', test: bool=False) -> Optional[Message]:
    '\n        Receives a full transaction from peer.\n        If tx is added to mempool, send tx_id to others. (new_transaction)\n        '
    assert (tx_bytes != b'')
    spend_name = std_hash(tx_bytes)
    if (spend_name in self.full_node.full_node_store.pending_tx_request):
        self.full_node.full_node_store.pending_tx_request.pop(spend_name)
    if (spend_name in self.full_node.full_node_store.peers_with_tx):
        self.full_node.full_node_store.peers_with_tx.pop(spend_name)
    if (((self.full_node.transaction_queue.qsize() % 100) == 0) and (not self.full_node.transaction_queue.empty())):
        self.full_node.log.debug(f'respond_transaction Waiters: {self.full_node.transaction_queue.qsize()}')
    if self.full_node.transaction_queue.full():
        self.full_node.dropped_tx.add(spend_name)
        return None
    (await self.full_node.transaction_queue.put((0, TransactionQueueEntry(tx.transaction, tx_bytes, spend_name, peer, test))))
    return None
Receives a full transaction from peer.
If tx is added to mempool, send tx_id to others. (new_transaction)
@peer_required
@api_request
@bytes_required
async def respond_transaction(self, tx: full_node_protocol.RespondTransaction, peer: ws.WSChiaConnection, tx_bytes: bytes=b, test: bool=False) -> Optional[Message]:
    '\n        Receives a full transaction from peer.\n        If tx is added to mempool, send tx_id to others. (new_transaction)\n        '
    assert (tx_bytes != b)
    spend_name = std_hash(tx_bytes)
    if (spend_name in self.full_node.full_node_store.pending_tx_request):
        self.full_node.full_node_store.pending_tx_request.pop(spend_name)
    if (spend_name in self.full_node.full_node_store.peers_with_tx):
        self.full_node.full_node_store.peers_with_tx.pop(spend_name)
    if (((self.full_node.transaction_queue.qsize() % 100) == 0) and (not self.full_node.transaction_queue.empty())):
        self.full_node.log.debug(f'respond_transaction Waiters: {self.full_node.transaction_queue.qsize()}')
    if self.full_node.transaction_queue.full():
        self.full_node.dropped_tx.add(spend_name)
        return None
    (await self.full_node.transaction_queue.put((0, TransactionQueueEntry(tx.transaction, tx_bytes, spend_name, peer, test))))
    return None