mirror of
https://github.com/planetmint/planetmint.git
synced 2025-11-24 22:45:44 +00:00
103 lines
3.5 KiB
Python
103 lines
3.5 KiB
Python
# Copyright © 2020 Interplanetary Database Association e.V.,
|
|
# Planetmint and IPDB software contributors.
|
|
# SPDX-License-Identifier: (Apache-2.0 AND CC-BY-4.0)
|
|
# Code is Apache-2.0 and docs are CC-BY-4.0
|
|
|
|
"""This module provides the blueprint for some basic API endpoints.
|
|
|
|
For more information please refer to the documentation: http://planetmint.io/http-api
|
|
"""
|
|
import logging
|
|
|
|
from flask import current_app, request, jsonify
|
|
from flask_restful import Resource, reqparse
|
|
from transactions.common.transaction_mode_types import BROADCAST_TX_ASYNC
|
|
from transactions.common.exceptions import (
|
|
SchemaValidationError,
|
|
ValidationError,
|
|
)
|
|
from planetmint.web.views.base import make_error
|
|
from planetmint.web.views import parameters
|
|
from transactions.common.transaction import Transaction
|
|
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class TransactionApi(Resource):
|
|
def get(self, tx_id):
|
|
"""API endpoint to get details about a transaction.
|
|
|
|
Args:
|
|
tx_id (str): the id of the transaction.
|
|
|
|
Return:
|
|
A JSON string containing the data about the transaction.
|
|
"""
|
|
pool = current_app.config["bigchain_pool"]
|
|
|
|
with pool() as planet:
|
|
tx = planet.get_transaction_space_by_id(tx_id)
|
|
|
|
if not tx:
|
|
return make_error(404)
|
|
|
|
return tx.to_dict()
|
|
|
|
|
|
class TransactionListApi(Resource):
|
|
def get(self):
|
|
parser = reqparse.RequestParser()
|
|
parser.add_argument("operation", type=parameters.valid_operation)
|
|
parser.add_argument("asset_ids", type=parameters.valid_txid_list, required=True)
|
|
parser.add_argument("last_tx", type=parameters.valid_bool, required=False)
|
|
args = parser.parse_args()
|
|
with current_app.config["bigchain_pool"]() as planet:
|
|
txs = planet.get_transactions_filtered(**args)
|
|
|
|
return [tx.to_dict() for tx in txs]
|
|
|
|
def post(self):
|
|
"""API endpoint to push transactions to the Federation.
|
|
|
|
Return:
|
|
A ``dict`` containing the data about the transaction.
|
|
"""
|
|
parser = reqparse.RequestParser()
|
|
parser.add_argument("mode", type=parameters.valid_mode, default=BROADCAST_TX_ASYNC)
|
|
args = parser.parse_args()
|
|
mode = str(args["mode"])
|
|
|
|
pool = current_app.config["bigchain_pool"]
|
|
|
|
# `force` will try to format the body of the POST request even if the
|
|
# `content-type` header is not set to `application/json`
|
|
tx = request.get_json(force=True)
|
|
|
|
try:
|
|
tx_obj = Transaction.from_dict(tx, False)
|
|
except SchemaValidationError as e:
|
|
return make_error(
|
|
400,
|
|
message="Invalid transaction schema: {}".format(e.__cause__.message),
|
|
)
|
|
except KeyError as e:
|
|
return make_error(400, "Invalid transaction ({}): {}".format(type(e).__name__, e))
|
|
except ValidationError as e:
|
|
return make_error(400, "Invalid transaction ({}): {}".format(type(e).__name__, e))
|
|
|
|
with pool() as planet:
|
|
try:
|
|
planet.validate_transaction(tx_obj)
|
|
except ValidationError as e:
|
|
return make_error(400, "Invalid transaction ({}): {}".format(type(e).__name__, e))
|
|
else:
|
|
status_code, message = planet.write_transaction(tx_obj, mode)
|
|
|
|
if status_code == 202:
|
|
response = jsonify(tx)
|
|
response.status_code = 202
|
|
return response
|
|
else:
|
|
return make_error(status_code, message)
|