add DownloadBlockchainBlockBoc handler

api/openapi.json

@@ -6691,7 +6691,7 @@
   },
   "/v2/accounts/{account_id}/events/emulate": {
    "post": {
-    "description": "Emulate sending message to blockchain",
+    "description": "Emulate sending message to retrieve account-specific events",
     "operationId": "emulateMessageToAccountEvent",
     "parameters": [
      {
@@ -7683,6 +7683,44 @@
     ]
    }
   },
+  "/v2/blockchain/blocks/{block_id}/boc": {
+   "get": {
+    "description": "Download blockchain block BOC",
+    "operationId": "downloadBlockchainBlockBoc",
+    "parameters": [
+     {
+      "$ref": "#/components/parameters/blockchainBlockIDParameter"
+     }
+    ],
+    "responses": {
+     "200": {
+      "content": {
+       "application/octet-stream": {
+        "schema": {
+         "format": "binary",
+         "type": "string"
+        }
+       }
+      },
+      "description": "Block BOC file",
+      "headers": {
+       "Content-Disposition": {
+        "schema": {
+         "example": "attachment; filename=\"block.boc\"",
+         "type": "string"
+        }
+       }
+      }
+     },
+     "default": {
+      "$ref": "#/components/responses/Error"
+     }
+    },
+    "tags": [
+     "Blockchain"
+    ]
+   }
+  },
   "/v2/blockchain/blocks/{block_id}/transactions": {
    "get": {
     "description": "Get transactions from block",
@@ -8181,7 +8219,7 @@
   },
   "/v2/events/emulate": {
    "post": {
-    "description": "Emulate sending message to blockchain",
+    "description": "Emulate sending message to retrieve general blockchain events",
     "operationId": "emulateMessageToEvent",
     "parameters": [
      {
@@ -10720,7 +10758,7 @@
   },
   "/v2/traces/emulate": {
    "post": {
-    "description": "Emulate sending message to blockchain",
+    "description": "Emulate sending message to retrieve with a detailed execution trace",
     "operationId": "emulateMessageToTrace",
     "parameters": [
      {
@@ -10823,7 +10861,7 @@
   },
   "/v2/wallet/emulate": {
    "post": {
-    "description": "Emulate sending message to blockchain",
+    "description": "Emulate sending message to retrieve the resulting wallet state",
     "operationId": "emulateMessageToWallet",
     "parameters": [
      {

api/openapi.yml

@@ -168,6 +168,29 @@ paths:
                 $ref: '#/components/schemas/BlockchainBlock'
         'default':
           $ref: '#/components/responses/Error'
+  /v2/blockchain/blocks/{block_id}/boc:
+    get:
+      description: Download blockchain block BOC
+      operationId: downloadBlockchainBlockBoc
+      tags:
+        - Blockchain
+      parameters:
+        - $ref: '#/components/parameters/blockchainBlockIDParameter'
+      responses:
+        '200':
+          description: Block BOC file
+          content:
+            application/octet-stream:
+              schema:
+                type: string
+                format: binary
+          headers:
+            Content-Disposition:
+              schema:
+                type: string
+                example: 'attachment; filename="block.boc"'
+        'default':
+          $ref: '#/components/responses/Error'
   /v2/blockchain/masterchain/{masterchain_seqno}/shards:
     get:
       description: Get blockchain block shards

pkg/api/blockchain_handlers.go

@@ -1,6 +1,7 @@
 package api
 
 import (
+	"bytes"
 	"context"
 	"encoding/json"
 	"errors"
@@ -72,6 +73,25 @@ func (h *Handler) GetBlockchainBlock(ctx context.Context, params oas.GetBlockcha
 	return &res, nil
 }
 
+func (h *Handler) DownloadBlockchainBlockBoc(ctx context.Context, params oas.DownloadBlockchainBlockBocParams) (*oas.DownloadBlockchainBlockBocOKHeaders, error) {
+	blockID, err := ton.ParseBlockID(params.BlockID)
+	if err != nil {
+		return nil, toError(http.StatusBadRequest, err)
+	}
+
+	bocBytes, err := h.storage.GetBlockchainBlock(ctx, blockID)
+	if err != nil {
+		return nil, toError(http.StatusInternalServerError, err)
+	}
+
+	return &oas.DownloadBlockchainBlockBocOKHeaders{
+		ContentDisposition: oas.NewOptString(fmt.Sprintf(`attachment; filename="block_%s.boc"`, params.BlockID)),
+		Response: oas.DownloadBlockchainBlockBocOK{
+			Data: bytes.NewReader(bocBytes),
+		},
+	}, nil
+}
+
 func (h *Handler) GetBlockchainMasterchainShards(ctx context.Context, params oas.GetBlockchainMasterchainShardsParams) (r *oas.BlockchainBlockShards, _ error) {
 	shards, err := h.storage.GetBlockShards(ctx, ton.BlockID{Shard: 0x8000000000000000, Seqno: uint32(params.MasterchainSeqno), Workchain: -1})
 	if errors.Is(err, core.ErrEntityNotFound) {

pkg/api/interfaces.go

@@ -37,6 +37,7 @@ type storage interface {
 	GetReducedBlocks(ctx context.Context, from, to int64) ([]core.ReducedBlock, error)
 	GetBlockShards(ctx context.Context, id tongo.BlockID) ([]ton.BlockID, error)
 	LastMasterchainBlockHeader(ctx context.Context) (*core.BlockHeader, error)
+	GetBlockchainBlock(ctx context.Context, blockID ton.BlockID) ([]byte, error)
 	GetTransaction(ctx context.Context, hash tongo.Bits256) (*core.Transaction, error)
 	SearchTransactionByMessageHash(ctx context.Context, hash tongo.Bits256) (*tongo.Bits256, error)
 	// GetBlockTransactions returns low-level information about transactions in a particular block.

pkg/litestorage/litestorage.go

@@ -574,3 +574,15 @@ func (s *LiteStorage) SaveTraceWithState(ctx context.Context, msgHash string, tr
 func (s *LiteStorage) GetTraceWithState(ctx context.Context, msgHash string) (*core.Trace, int, []abi.MethodInvocation, error) {
 	return nil, 0, nil, fmt.Errorf("not implemented")
 }
+
+func (s *LiteStorage) GetBlockchainBlock(ctx context.Context, id ton.BlockID) ([]byte, error) {
+	idExt, _, err := s.client.LookupBlock(ctx, id, 1, nil, nil)
+	if err != nil {
+		return nil, err
+	}
+	block, err := s.client.GetBlockRaw(ctx, idExt)
+	if err != nil {
+		return nil, err
+	}
+	return block.Data, nil
+}