Created /kaspad/submitTransactionRequest (#16)

* initial submit of transactions

* typo

* tested with real data

* default values

* removed gas and payload in example

* changed endpoint and group

* added prefix "Submit" to models

* added error code 400

endpoints/kaspad_requests/submit_transaction_request.py

@@ -0,0 +1,118 @@
+# encoding: utf-8
+
+from typing import List
+
+from pydantic import BaseModel
+from starlette.responses import JSONResponse
+
+from server import app, kaspad_client
+
+
+class SubmitTxOutpoint(BaseModel):
+    transactionId: str
+    index: int
+
+
+class SubmitTxInput(BaseModel):
+    previousOutpoint: SubmitTxOutpoint
+    signatureScript: str
+    sequence: int
+    sigOpCount: int
+
+
+class SubmitTxScriptPublicKey(BaseModel):
+    version: int
+    scriptPublicKey: str
+
+
+class SubmitTxOutput(BaseModel):
+    amount: int
+    scriptPublicKey: SubmitTxScriptPublicKey
+    # verboseData: TxOutputVerboseData | None
+
+
+class SubmitTxModel(BaseModel):
+    version: int
+    inputs: List[SubmitTxInput]
+    outputs: List[SubmitTxOutput]
+    lockTime: int | None = 0
+    subnetworkId: str | None
+
+
+class SubmitTransactionRequest(BaseModel):
+    transaction: SubmitTxModel
+    allowOrphan: bool = True
+
+
+class SubmitTransactionResponse(BaseModel):
+    transactionId: str | None
+    error: str | None
+
+
+@app.post("/transactions",
+          tags=["Kaspa transactions"],
+          response_model_exclude_unset=True,
+          responses={200: {"model": SubmitTransactionResponse},
+                       400: {"model": SubmitTransactionResponse}})
+async def submit_a_new_transaction(body: SubmitTransactionRequest):
+    """
+    Forwards the body directly to kaspad with the command submitTransactionRequest
+    """
+    tx_resp = await kaspad_client.request("submitTransactionRequest",
+                                          params=body.dict())
+
+    tx_resp = tx_resp["submitTransactionResponse"]
+
+    # if error in response
+    if "error" in tx_resp:
+        return JSONResponse(status_code=400,
+                            content={"error": tx_resp["error"].get("message", "")})
+
+    # if transactionId is in response
+    elif "transactionId" in tx_resp:
+        return {
+            "transactionId": tx_resp["transactionId"]
+        }
+
+    # something else went wrong
+    else:
+        return JSONResponse(status_code=400,
+                            content={"error": str(tx_resp)})
+
+
+"""
+{
+  "transaction": {
+    "version": 0,
+    "inputs": [
+      {
+        "previousOutpoint": {
+          "transactionId": "fa99f98b8e9b0758100d181eccb35a4c053b8265eccb5a89aadd794e087d9820",
+          "index": 1
+        },
+        "signatureScript": "4187173244180496d67a94dc78f3d3651bc645139b636a9c79a4f1d36fdcc718e88e9880eeb0eb208d0c110f31a306556457bc37e1044aeb3fdd303bd1a8c1b84601",
+        "sequence": 0,
+        "sigOpCount": 1
+      }
+    ],
+    "outputs": [
+      {
+        "amount": 100000,
+        "scriptPublicKey": {
+          "scriptPublicKey": "20167f5647a0e88ed3ac7834b5de4a5f0e56a438bcb6c97186a2c935303290ef6fac",
+          "version": 0
+        }
+      },
+      {
+        "amount": 183448,
+        "scriptPublicKey": {
+          "scriptPublicKey": "2010352c822bf3c67637c84ea09ff90edc11fa509475ae1884cf5b971e53afd472ac",
+          "version": 0
+        }
+      }
+    ],
+    "lockTime": 0,
+    "subnetworkId": "0000000000000000000000000000000000000000"
+  }
+}
+"""

main.py

@@ -17,6 +17,7 @@
 from endpoints.get_marketcap import get_marketcap
 from endpoints.get_transactions import get_transaction
 from endpoints.get_virtual_chain_blue_score import get_virtual_selected_parent_blue_score
+from endpoints.kaspad_requests.submit_transaction_request import submit_a_new_transaction
 from server import app, kaspad_client
 from sockets import blocks
 from sockets.blockdag import periodical_blockdag
@@ -27,7 +28,8 @@
     f"Loaded: {get_balance}, {get_utxos}, {get_blocks}, {get_blockdag}, {get_circulating_supply}, "
     f"{get_kaspad_info}, {get_network}, {get_marketcap}, {get_hashrate}, {get_blockreward}, {sockets.join_room}"
     f"{periodic_coin_supply} {periodical_blockdag} {get_halving} {health_state} {get_transaction}"
-    f"{get_virtual_selected_parent_blue_score} {periodical_blue_score} {get_transactions_for_address}")
+    f"{get_virtual_selected_parent_blue_score} {periodical_blue_score} {get_transactions_for_address}"
+    f"{submit_a_new_transaction}")
 
 BLOCKS_TASK = None  # type: Task