-
Notifications
You must be signed in to change notification settings - Fork 128
/
apirouter.go
89 lines (74 loc) · 2.89 KB
/
apirouter.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
// Copyright (c) 2018, The Decred developers
// Copyright (c) 2017, The dcrdata developers
// See LICENSE for details.
//
// This is tested against Insight API Implementation v5.3.04beta
// Package insight handles the insight api
package insight
import (
m "github.com/decred/dcrdata/middleware"
"github.com/didip/tollbooth"
"github.com/didip/tollbooth_chi"
"github.com/go-chi/chi"
"github.com/go-chi/chi/middleware"
)
// ApiMux contains the struct mux
type ApiMux struct {
*chi.Mux
}
// APIVersion is an integer value, incremented for breaking changes
const APIVersion = 0
// NewInsightApiRouter returns a new HTTP path router, ApiMux, for the Insight
// API.
func NewInsightApiRouter(app *insightApiContext, userRealIP bool) ApiMux {
// Create a limiter struct.
limiter := tollbooth.NewLimiter(1, nil)
// chi router
mux := chi.NewRouter()
mux.Use(tollbooth_chi.LimitHandler(limiter))
if userRealIP {
mux.Use(middleware.RealIP)
}
mux.Use(middleware.Logger)
mux.Use(middleware.Recoverer)
mux.Use(middleware.StripSlashes)
mux.Use(middleware.DefaultCompress)
// Block endpoints
mux.With(app.BlockDateLimitQueryCtx).Get("/blocks", app.getBlockSummaryByTime)
mux.With(app.BlockIndexOrHashPathCtx).Get("/block/{idxorhash}", app.getBlockSummary)
mux.With(app.BlockIndexOrHashPathCtx).Get("/block-index/{idxorhash}", app.getBlockHash)
mux.With(app.BlockIndexOrHashPathCtx).Get("/rawblock/{idxorhash}", app.getRawBlock)
// Transaction endpoints
mux.With(middleware.AllowContentType("application/json"),
app.ValidatePostCtx, app.PostBroadcastTxCtx).Post("/tx/send", app.broadcastTransactionRaw)
mux.With(m.TransactionHashCtx).Get("/tx/{txid}", app.getTransaction)
mux.With(m.TransactionHashCtx).Get("/rawtx/{txid}", app.getTransactionHex)
mux.With(m.TransactionsCtx).Get("/txs", app.getTransactions)
// Status and Utility
mux.With(app.StatusInfoCtx).Get("/status", app.getStatusInfo)
mux.With(app.NbBlocksCtx).Get("/utils/estimatefee", app.getEstimateFee)
mux.Get("/peer", app.GetPeerStatus)
// Addresses endpoints
mux.Route("/addrs", func(rd chi.Router) {
rd.Route("/{address}", func(ra chi.Router) {
ra.Use(m.AddressPathCtx, app.FromToPaginationCtx)
ra.Get("/txs", app.getAddressesTxn)
ra.Get("/utxo", app.getAddressesTxnOutput)
})
// POST methods
rd.With(middleware.AllowContentType("application/json"),
app.ValidatePostCtx, app.PostAddrsTxsCtx).Post("/txs", app.getAddressesTxn)
rd.With(middleware.AllowContentType("application/json"),
app.ValidatePostCtx, app.PostAddrsUtxoCtx).Post("/utxo", app.getAddressesTxnOutput)
})
// Address endpoints
mux.Route("/addr/{address}", func(rd chi.Router) {
rd.Use(m.AddressPathCtx)
rd.With(app.FromToPaginationCtx, app.NoTxListCtx).Get("/", app.getAddressInfo)
rd.Get("/utxo", app.getAddressesTxnOutput)
rd.Route("/{command}", func(ra chi.Router) {
ra.With(app.AddressCommandCtx).Get("/", app.getAddressInfo)
})
})
return ApiMux{mux}
}