-
Notifications
You must be signed in to change notification settings - Fork 0
/
transferslegacy.go
63 lines (53 loc) · 1.64 KB
/
transferslegacy.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
// Copyright (c) 2020 The Meter.io developers
// Distributed under the GNU Lesser General Public License v3.0 software license, see the accompanying
// file LICENSE or <https://www.gnu.org/licenses/lgpl-3.0.html>
package transferslegacy
import (
"context"
"net/http"
"github.com/saolacoincom/saolacoin/api/utils"
"github.com/saolacoincom/saolacoin/logdb"
"github.com/gorilla/mux"
"github.com/pkg/errors"
)
type TransfersLegacy struct {
db *logdb.LogDB
}
func New(db *logdb.LogDB) *TransfersLegacy {
return &TransfersLegacy{
db,
}
}
//Filter query logs with option
func (t *TransfersLegacy) filter(ctx context.Context, filter *logdb.TransferFilter) ([]*FilteredTransfer, error) {
transfers, err := t.db.FilterTransfers(ctx, filter)
if err != nil {
return nil, err
}
tLogs := make([]*FilteredTransfer, len(transfers))
for i, trans := range transfers {
tLogs[i] = convertTransfer(trans)
}
return tLogs, nil
}
func (t *TransfersLegacy) handleFilterTransferLogs(w http.ResponseWriter, req *http.Request) error {
var filter TransferFilter
if err := utils.ParseJSON(req.Body, &filter); err != nil {
return utils.BadRequest(errors.WithMessage(err, "body"))
}
order := req.URL.Query().Get("order")
if order != string(logdb.DESC) {
filter.Order = logdb.ASC
} else {
filter.Order = logdb.DESC
}
tLogs, err := t.filter(req.Context(), convertTransferFilter(&filter))
if err != nil {
return err
}
return utils.WriteJSON(w, tLogs)
}
func (t *TransfersLegacy) Mount(root *mux.Router, pathPrefix string) {
sub := root.PathPrefix(pathPrefix).Subrouter()
sub.Path("").Methods("POST").HandlerFunc(utils.WrapHandlerFunc(t.handleFilterTransferLogs))
}