Merge remote-tracking branch 'origin/indexing_latency_method'

Author: mr-tron

api/openapi.json

@@ -4416,6 +4416,23 @@
     ],
     "type": "object"
    },
+   "ServiceStatus": {
+    "properties": {
+     "indexing_latency": {
+      "example": 100,
+      "type": "integer"
+     },
+     "rest_online": {
+      "default": true,
+      "type": "boolean"
+     }
+    },
+    "required": [
+     "indexing_latency",
+     "rest_online"
+    ],
+    "type": "object"
+   },
    "SizeLimitsConfig": {
     "properties": {
      "max_acc_state_bits": {
@@ -8940,6 +8957,30 @@
     ]
    }
   },
+  "/v2/status": {
+   "get": {
+    "description": "Reduce indexing latency",
+    "operationId": "reduceIndexingLatency",
+    "responses": {
+     "200": {
+      "content": {
+       "application/json": {
+        "schema": {
+         "$ref": "#/components/schemas/ServiceStatus"
+        }
+       }
+      },
+      "description": "indexing latency"
+     },
+     "default": {
+      "$ref": "#/components/responses/Error"
+     }
+    },
+    "tags": [
+     "Blockchain"
+    ]
+   }
+  },
   "/v2/storage/providers": {
    "get": {
     "description": "Get TON storage providers deployed to the blockchain.",

api/openapi.yml

@@ -11,6 +11,21 @@ servers:
   - url: "https://testnet.tonapi.io"
   - url: "http://localhost:8081"
 paths:
+  /v2/status:
+    get:
+      description: Reduce indexing latency
+      operationId: reduceIndexingLatency
+      tags:
+        - Blockchain
+      responses:
+        '200':
+          description: indexing latency
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/ServiceStatus'
+        'default':
+          $ref: '#/components/responses/Error'
   /v2/blockchain/blocks/{block_id}:
     get:
       description: Get blockchain block data
@@ -2982,7 +2997,18 @@ components:
           $ref: '#/components/schemas/BlockCurrencyCollection'
         minted:
           $ref: '#/components/schemas/BlockCurrencyCollection'
-
+    ServiceStatus:
+      type: object
+      required:
+        - indexing_latency
+        - rest_online
+      properties:
+        rest_online:
+          type: boolean
+          default: true
+        indexing_latency:
+          type: integer
+          example: 100
     BlockchainBlock:
       type: object
       required:

pkg/api/blockchain_handlers.go

@@ -21,6 +21,21 @@ import (
 	"github.com/tonkeeper/tongo/ton"
 )
 
+func (h *Handler) ReduceIndexingLatency(ctx context.Context) (*oas.ServiceStatus, error) {
+	indexingLatency, err := h.storage.ReduceIndexingLatency(ctx)
+	if errors.Is(err, core.ErrEntityNotFound) {
+		return nil, toError(http.StatusInternalServerError, err)
+	}
+	var restOnline = true
+	if err != nil {
+		restOnline = false
+	}
+	return &oas.ServiceStatus{
+		IndexingLatency: int(indexingLatency),
+		RestOnline:      restOnline,
+	}, nil
+}
+
 func (h *Handler) GetBlockchainBlock(ctx context.Context, params oas.GetBlockchainBlockParams) (*oas.BlockchainBlock, error) {
 	blockID, err := ton.ParseBlockID(params.BlockID)
 	if err != nil {

pkg/api/interfaces.go

@@ -41,6 +41,7 @@ type storage interface {
 	GetDnsExpiring(ctx context.Context, id tongo.AccountID, period *int) ([]core.DnsExpiring, error)
 	GetLogs(ctx context.Context, account tongo.AccountID, destination *tlb.MsgAddress, limit int, beforeLT uint64) ([]core.Message, error)
 	GetAccountDiff(ctx context.Context, account tongo.AccountID, startTime int64, endTime int64) (int64, error)
+	ReduceIndexingLatency(ctx context.Context) (int64, error)
 
 	GetTrace(ctx context.Context, hash tongo.Bits256) (*core.Trace, error)
 	SearchTraces(ctx context.Context, a tongo.AccountID, limit int, beforeLT, startTime, endTime *int64, initiator bool) ([]tongo.Bits256, error)

pkg/litestorage/account.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/ed25519"
 	"errors"
+	"time"
 
 	"github.com/tonkeeper/tongo/tlb"
 	tongoWallet "github.com/tonkeeper/tongo/wallet"
@@ -46,3 +47,12 @@ func (s *LiteStorage) SearchAccountsByPubKey(pubKey ed25519.PublicKey) ([]tongo.
 func (s *LiteStorage) GetAccountDiff(ctx context.Context, account tongo.AccountID, startTime int64, endTime int64) (int64, error) {
 	return 0, errors.New("not implemented")
 }
+
+func (s *LiteStorage) ReduceIndexingLatency(ctx context.Context) (int64, error) {
+	blockHeader, err := s.LastMasterchainBlockHeader(ctx)
+	if err != nil {
+		return 0, err
+	}
+	latency := time.Now().Unix() - int64(blockHeader.GenUtime)
+	return latency, nil
+}