spacecruft
/
blockbook
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add sentToSelf to BalanceHistory

subscribeMempool
Martin Boehm 2020-05-19 12:06:47 +02:00
parent b957ed66ab
commit dd2dc6b2ee
6 changed files with 139 additions and 84 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
api/types.go
View File

@ -301,12 +301,13 @@ func (a Utxos) Less(i, j int) bool {
// BalanceHistory contains info about one point in time of balance history // BalanceHistory contains info about one point in time of balance history
type BalanceHistory struct { type BalanceHistory struct {
Time uint32 `json:"time"` Time uint32 `json:"time"`
Txs uint32 `json:"txs"` Txs uint32 `json:"txs"`
ReceivedSat *Amount `json:"received"` ReceivedSat *Amount `json:"received"`
SentSat *Amount `json:"sent"` SentSat *Amount `json:"sent"`
FiatRates map[string]float64 `json:"rates,omitempty"` SentToSelfSat *Amount `json:"sentToSelf"`
Txid string `json:"txid,omitempty"` FiatRates map[string]float64 `json:"rates,omitempty"`
Txid string `json:"txid,omitempty"`
} }
// BalanceHistories is array of BalanceHistory // BalanceHistories is array of BalanceHistory
@ -328,8 +329,9 @@ func (a BalanceHistories) SortAndAggregate(groupByTime uint32) BalanceHistories
bhs := make(BalanceHistories, 0) bhs := make(BalanceHistories, 0)
if len(a) > 0 { if len(a) > 0 {
bha := BalanceHistory{ bha := BalanceHistory{
SentSat: &Amount{}, ReceivedSat: &Amount{},
ReceivedSat: &Amount{}, SentSat: &Amount{},
SentToSelfSat: &Amount{},
} }
sort.Sort(a) sort.Sort(a)
for i := range a { for i := range a {
@ -342,17 +344,19 @@ func (a BalanceHistories) SortAndAggregate(groupByTime uint32) BalanceHistories
bhs = append(bhs, bha) bhs = append(bhs, bha)
} }
bha = BalanceHistory{ bha = BalanceHistory{
Time: time, Time: time,
SentSat: &Amount{}, ReceivedSat: &Amount{},
ReceivedSat: &Amount{}, SentSat: &Amount{},
SentToSelfSat: &Amount{},
} }
} }
if bha.Txid != bh.Txid { if bha.Txid != bh.Txid {
bha.Txs += bh.Txs bha.Txs += bh.Txs
bha.Txid = bh.Txid bha.Txid = bh.Txid
} }
(*big.Int)(bha.SentSat).Add((*big.Int)(bha.SentSat), (*big.Int)(bh.SentSat))
(*big.Int)(bha.ReceivedSat).Add((*big.Int)(bha.ReceivedSat), (*big.Int)(bh.ReceivedSat)) (*big.Int)(bha.ReceivedSat).Add((*big.Int)(bha.ReceivedSat), (*big.Int)(bh.ReceivedSat))
(*big.Int)(bha.SentSat).Add((*big.Int)(bha.SentSat), (*big.Int)(bh.SentSat))
(*big.Int)(bha.SentToSelfSat).Add((*big.Int)(bha.SentToSelfSat), (*big.Int)(bh.SentToSelfSat))
} }
if bha.Txs > 0 { if bha.Txs > 0 {
bha.Txid = "" bha.Txid = ""

113
api/types_test.go
View File

@ -67,20 +67,22 @@ func TestBalanceHistories_SortAndAggregate(t *testing.T) {
name: "one", name: "one",
a: []BalanceHistory{ a: []BalanceHistory{
{ {
ReceivedSat: (*Amount)(big.NewInt(1)), ReceivedSat: (*Amount)(big.NewInt(1)),
SentSat: (*Amount)(big.NewInt(2)), SentSat: (*Amount)(big.NewInt(2)),
Time: 1521514812, SentToSelfSat: (*Amount)(big.NewInt(1)),
Txid: "00b2c06055e5e90e9c82bd4181fde310104391a7fa4f289b1704e5d90caa3840", Time: 1521514812,
Txs: 1, Txid: "00b2c06055e5e90e9c82bd4181fde310104391a7fa4f289b1704e5d90caa3840",
Txs: 1,
}, },
}, },
groupByTime: 3600, groupByTime: 3600,
want: []BalanceHistory{ want: []BalanceHistory{
{ {
ReceivedSat: (*Amount)(big.NewInt(1)), ReceivedSat: (*Amount)(big.NewInt(1)),
SentSat: (*Amount)(big.NewInt(2)), SentSat: (*Amount)(big.NewInt(2)),
Time: 1521514800, SentToSelfSat: (*Amount)(big.NewInt(1)),
Txs: 1, Time: 1521514800,
Txs: 1,
}, },
}, },
}, },
@ -88,67 +90,76 @@ func TestBalanceHistories_SortAndAggregate(t *testing.T) {
name: "aggregate", name: "aggregate",
a: []BalanceHistory{ a: []BalanceHistory{
{ {
ReceivedSat: (*Amount)(big.NewInt(1)), ReceivedSat: (*Amount)(big.NewInt(1)),
SentSat: (*Amount)(big.NewInt(2)), SentSat: (*Amount)(big.NewInt(2)),
Time: 1521504812, SentToSelfSat: (*Amount)(big.NewInt(0)),
Txid: "0011223344556677889900112233445566778899001122334455667788990011", Time: 1521504812,
Txs: 1, Txid: "0011223344556677889900112233445566778899001122334455667788990011",
Txs: 1,
}, },
{ {
ReceivedSat: (*Amount)(big.NewInt(3)), ReceivedSat: (*Amount)(big.NewInt(3)),
SentSat: (*Amount)(big.NewInt(4)), SentSat: (*Amount)(big.NewInt(4)),
Time: 1521504812, SentToSelfSat: (*Amount)(big.NewInt(2)),
Txid: "00b2c06055e5e90e9c82bd4181fde310104391a7fa4f289b1704e5d90caa3840", Time: 1521504812,
Txs: 1, Txid: "00b2c06055e5e90e9c82bd4181fde310104391a7fa4f289b1704e5d90caa3840",
Txs: 1,
}, },
{ {
ReceivedSat: (*Amount)(big.NewInt(5)), ReceivedSat: (*Amount)(big.NewInt(5)),
SentSat: (*Amount)(big.NewInt(6)), SentSat: (*Amount)(big.NewInt(6)),
Time: 1521514812, SentToSelfSat: (*Amount)(big.NewInt(3)),
Txid: "00b2c06055e5e90e9c82bd4181fde310104391a7fa4f289b1704e5d90caa3840", Time: 1521514812,
Txs: 1, Txid: "00b2c06055e5e90e9c82bd4181fde310104391a7fa4f289b1704e5d90caa3840",
Txs: 1,
}, },
{ {
ReceivedSat: (*Amount)(big.NewInt(7)), ReceivedSat: (*Amount)(big.NewInt(7)),
SentSat: (*Amount)(big.NewInt(8)), SentSat: (*Amount)(big.NewInt(8)),
Time: 1521504812, SentToSelfSat: (*Amount)(big.NewInt(3)),
Txid: "00b2c06055e5e90e9c82bd4181fde310104391a7fa4f289b1704e5d90caa3840", Time: 1521504812,
Txs: 1, Txid: "00b2c06055e5e90e9c82bd4181fde310104391a7fa4f289b1704e5d90caa3840",
Txs: 1,
}, },
{ {
ReceivedSat: (*Amount)(big.NewInt(9)), ReceivedSat: (*Amount)(big.NewInt(9)),
SentSat: (*Amount)(big.NewInt(10)), SentSat: (*Amount)(big.NewInt(10)),
Time: 1521534812, SentToSelfSat: (*Amount)(big.NewInt(5)),
Txid: "0011223344556677889900112233445566778899001122334455667788990011", Time: 1521534812,
Txs: 1, Txid: "0011223344556677889900112233445566778899001122334455667788990011",
Txs: 1,
}, },
{ {
ReceivedSat: (*Amount)(big.NewInt(11)), ReceivedSat: (*Amount)(big.NewInt(11)),
SentSat: (*Amount)(big.NewInt(12)), SentSat: (*Amount)(big.NewInt(12)),
Time: 1521534812, SentToSelfSat: (*Amount)(big.NewInt(6)),
Txid: "1122334455667788990011223344556677889900112233445566778899001100", Time: 1521534812,
Txs: 1, Txid: "1122334455667788990011223344556677889900112233445566778899001100",
Txs: 1,
}, },
}, },
groupByTime: 3600, groupByTime: 3600,
want: []BalanceHistory{ want: []BalanceHistory{
{ {
ReceivedSat: (*Amount)(big.NewInt(11)), ReceivedSat: (*Amount)(big.NewInt(11)),
SentSat: (*Amount)(big.NewInt(14)), SentSat: (*Amount)(big.NewInt(14)),
Time: 1521504000, SentToSelfSat: (*Amount)(big.NewInt(5)),
Txs: 2, Time: 1521504000,
Txs: 2,
}, },
{ {
ReceivedSat: (*Amount)(big.NewInt(5)), ReceivedSat: (*Amount)(big.NewInt(5)),
SentSat: (*Amount)(big.NewInt(6)), SentSat: (*Amount)(big.NewInt(6)),
Time: 1521514800, SentToSelfSat: (*Amount)(big.NewInt(3)),
Txs: 1, Time: 1521514800,
Txs: 1,
}, },
{ {
ReceivedSat: (*Amount)(big.NewInt(20)), ReceivedSat: (*Amount)(big.NewInt(20)),
SentSat: (*Amount)(big.NewInt(22)), SentSat: (*Amount)(big.NewInt(22)),
Time: 1521532800, SentToSelfSat: (*Amount)(big.NewInt(11)),
Txs: 2, Time: 1521532800,
Txs: 2,
}, },
}, },
}, },

41
api/worker.go
View File

@ -821,7 +821,7 @@ func (w *Worker) balanceHistoryHeightsFromTo(fromTimestamp, toTimestamp int64) (
return fromUnix, fromHeight, toUnix, toHeight return fromUnix, fromHeight, toUnix, toHeight
} }
func (w *Worker) balanceHistoryForTxid(addrDesc bchain.AddressDescriptor, txid string, fromUnix, toUnix uint32) (*BalanceHistory, error) { func (w *Worker) balanceHistoryForTxid(addrDesc bchain.AddressDescriptor, txid string, fromUnix, toUnix uint32, selfAddrDesc map[string]struct{}) (*BalanceHistory, error) {
var time uint32 var time uint32
var err error var err error
var ta *db.TxAddresses var ta *db.TxAddresses
@ -854,17 +854,30 @@ func (w *Worker) balanceHistoryForTxid(addrDesc bchain.AddressDescriptor, txid s
return nil, nil return nil, nil
} }
bh := BalanceHistory{ bh := BalanceHistory{
Time: time, Time: time,
Txs: 1, Txs: 1,
SentSat: &Amount{}, ReceivedSat: &Amount{},
ReceivedSat: &Amount{}, SentSat: &Amount{},
Txid: txid, SentToSelfSat: &Amount{},
Txid: txid,
} }
countSentToSelf := false
if w.chainType == bchain.ChainBitcoinType { if w.chainType == bchain.ChainBitcoinType {
// detect if this input is the first of selfAddrDesc
// to not to count sentToSelf multiple times if counting multiple xpub addresses
ownInputIndex := -1
for i := range ta.Inputs { for i := range ta.Inputs {
tai := &ta.Inputs[i] tai := &ta.Inputs[i]
if _, found := selfAddrDesc[string(tai.AddrDesc)]; found {
if ownInputIndex < 0 {
ownInputIndex = i
}
}
if bytes.Equal(addrDesc, tai.AddrDesc) { if bytes.Equal(addrDesc, tai.AddrDesc) {
(*big.Int)(bh.SentSat).Add((*big.Int)(bh.SentSat), &tai.ValueSat) (*big.Int)(bh.SentSat).Add((*big.Int)(bh.SentSat), &tai.ValueSat)
if ownInputIndex == i {
countSentToSelf = true
}
} }
} }
for i := range ta.Outputs { for i := range ta.Outputs {
@ -872,6 +885,11 @@ func (w *Worker) balanceHistoryForTxid(addrDesc bchain.AddressDescriptor, txid s
if bytes.Equal(addrDesc, tao.AddrDesc) { if bytes.Equal(addrDesc, tao.AddrDesc) {
(*big.Int)(bh.ReceivedSat).Add((*big.Int)(bh.ReceivedSat), &tao.ValueSat) (*big.Int)(bh.ReceivedSat).Add((*big.Int)(bh.ReceivedSat), &tao.ValueSat)
} }
if countSentToSelf {
if _, found := selfAddrDesc[string(tao.AddrDesc)]; found {
(*big.Int)(bh.SentToSelfSat).Add((*big.Int)(bh.SentToSelfSat), &tao.ValueSat)
}
}
} }
} else if w.chainType == bchain.ChainEthereumType { } else if w.chainType == bchain.ChainEthereumType {
var value big.Int var value big.Int
@ -889,6 +907,9 @@ func (w *Worker) balanceHistoryForTxid(addrDesc bchain.AddressDescriptor, txid s
if bytes.Equal(addrDesc, txAddrDesc) { if bytes.Equal(addrDesc, txAddrDesc) {
(*big.Int)(bh.ReceivedSat).Add((*big.Int)(bh.ReceivedSat), &value) (*big.Int)(bh.ReceivedSat).Add((*big.Int)(bh.ReceivedSat), &value)
} }
if _, found := selfAddrDesc[string(txAddrDesc)]; found {
countSentToSelf = true
}
} }
} }
} }
@ -903,6 +924,11 @@ func (w *Worker) balanceHistoryForTxid(addrDesc bchain.AddressDescriptor, txid s
// add sent amount only for OK transactions, however fees always // add sent amount only for OK transactions, however fees always
if ethTxData.Status == 1 { if ethTxData.Status == 1 {
(*big.Int)(bh.SentSat).Add((*big.Int)(bh.SentSat), &value) (*big.Int)(bh.SentSat).Add((*big.Int)(bh.SentSat), &value)
if countSentToSelf {
if _, found := selfAddrDesc[string(txAddrDesc)]; found {
(*big.Int)(bh.SentToSelfSat).Add((*big.Int)(bh.SentToSelfSat), &value)
}
}
} }
var feesSat big.Int var feesSat big.Int
// mempool txs do not have fees yet // mempool txs do not have fees yet
@ -963,8 +989,9 @@ func (w *Worker) GetBalanceHistory(address string, fromTimestamp, toTimestamp in
if err != nil { if err != nil {
return nil, err return nil, err
} }
selfAddrDesc := map[string]struct{}{string(addrDesc): {}}
for txi := len(txs) - 1; txi >= 0; txi-- { for txi := len(txs) - 1; txi >= 0; txi-- {
bh, err := w.balanceHistoryForTxid(addrDesc, txs[txi], fromUnix, toUnix) bh, err := w.balanceHistoryForTxid(addrDesc, txs[txi], fromUnix, toUnix, selfAddrDesc)
if err != nil { if err != nil {
return nil, err return nil, err
} }

8
api/xpub.go
View File

@ -606,12 +606,18 @@ func (w *Worker) GetXpubBalanceHistory(xpub string, fromTimestamp, toTimestamp i
if err != nil { if err != nil {
return nil, err return nil, err
} }
selfAddrDesc := make(map[string]struct{})
for _, da := range [][]xpubAddress{data.addresses, data.changeAddresses} {
for i := range da {
selfAddrDesc[string(da[i].addrDesc)] = struct{}{}
}
}
for _, da := range [][]xpubAddress{data.addresses, data.changeAddresses} { for _, da := range [][]xpubAddress{data.addresses, data.changeAddresses} {
for i := range da { for i := range da {
ad := &da[i] ad := &da[i]
txids := ad.txids txids := ad.txids
for txi := len(txids) - 1; txi >= 0; txi-- { for txi := len(txids) - 1; txi >= 0; txi-- {
bh, err := w.balanceHistoryForTxid(ad.addrDesc, txids[txi].txid, fromUnix, toUnix) bh, err := w.balanceHistoryForTxid(ad.addrDesc, txids[txi].txid, fromUnix, toUnix, selfAddrDesc)
if err != nil { if err != nil {
return nil, err return nil, err
} }

7
docs/api.md
View File

@ -674,6 +674,7 @@ Example response (fiatcurrency not specified):
"txs": 5, "txs": 5,
"received": "5000000", "received": "5000000",
"sent": "0", "sent": "0",
"sentToSelf":"100000",
"rates": { "rates": {
"usd": 7855.9, "usd": 7855.9,
"eur": 6838.13, "eur": 6838.13,
@ -685,6 +686,7 @@ Example response (fiatcurrency not specified):
"txs": 1, "txs": 1,
"received": "0", "received": "0",
"sent": "5000000", "sent": "5000000",
"sentToSelf":"0",
"rates": { "rates": {
"usd": 8283.11, "usd": 8283.11,
"eur": 7464.45, "eur": 7464.45,
@ -703,6 +705,7 @@ Example response (fiatcurrency=usd):
"txs": 5, "txs": 5,
"received": "5000000", "received": "5000000",
"sent": "0", "sent": "0",
"sentToSelf":"0",
"rates": { "rates": {
"usd": 7855.9 "usd": 7855.9
} }
@ -712,6 +715,7 @@ Example response (fiatcurrency=usd):
"txs": 1, "txs": 1,
"received": "0", "received": "0",
"sent": "5000000", "sent": "5000000",
"sentToSelf":"0",
"rates": { "rates": {
"usd": 8283.11 "usd": 8283.11
} }
@ -728,6 +732,7 @@ Example response (fiatcurrency=usd&groupBy=172800):
"txs": 6, "txs": 6,
"received": "5000000", "received": "5000000",
"sent": "5000000", "sent": "5000000",
"sentToSelf":"0",
"rates": { "rates": {
"usd": 7734.45 "usd": 7734.45
} }
@ -735,6 +740,8 @@ Example response (fiatcurrency=usd&groupBy=172800):
] ]
``` ```
The value of `sentToSelf` is the amount sent from the same address to the same address or within addresses of xpub.
### Websocket API ### Websocket API
Websocket interface is provided at `/websocket/`. The interface can be explored using Blockbook Websocket Test Page found at `/test-websocket.html`. Websocket interface is provided at `/websocket/`. The interface can be explored using Blockbook Websocket Test Page found at `/test-websocket.html`.

26
server/public_test.go
View File

@ -776,7 +776,7 @@ func httpTestsBitcoinType(t *testing.T, ts *httptest.Server) {
status: http.StatusOK, status: http.StatusOK,
contentType: "application/json; charset=utf-8", contentType: "application/json; charset=utf-8",
body: []string{ body: []string{
`[{"time":1521514800,"txs":1,"received":"24690","sent":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"0","sent":"12345","rates":{"eur":1303,"usd":2003}}]`, `[{"time":1521514800,"txs":1,"received":"24690","sent":"0","sentToSelf":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"0","sent":"12345","sentToSelf":"0","rates":{"eur":1303,"usd":2003}}]`,
}, },
}, },
{ {
@ -785,7 +785,7 @@ func httpTestsBitcoinType(t *testing.T, ts *httptest.Server) {
status: http.StatusOK, status: http.StatusOK,
contentType: "application/json; charset=utf-8", contentType: "application/json; charset=utf-8",
body: []string{ body: []string{
`[{"time":1521514800,"txs":1,"received":"9876","sent":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"9000","sent":"9876","rates":{"eur":1303,"usd":2003}}]`, `[{"time":1521514800,"txs":1,"received":"9876","sent":"0","sentToSelf":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"9000","sent":"9876","sentToSelf":"9000","rates":{"eur":1303,"usd":2003}}]`,
}, },
}, },
{ {
@ -794,7 +794,7 @@ func httpTestsBitcoinType(t *testing.T, ts *httptest.Server) {
status: http.StatusOK, status: http.StatusOK,
contentType: "application/json; charset=utf-8", contentType: "application/json; charset=utf-8",
body: []string{ body: []string{
`[{"time":1521514800,"txs":1,"received":"9876","sent":"0","rates":{"eur":1301}},{"time":1521594000,"txs":1,"received":"9000","sent":"9876","rates":{"eur":1303}}]`, `[{"time":1521514800,"txs":1,"received":"9876","sent":"0","sentToSelf":"0","rates":{"eur":1301}},{"time":1521594000,"txs":1,"received":"9000","sent":"9876","sentToSelf":"9000","rates":{"eur":1303}}]`,
}, },
}, },
{ {
@ -803,7 +803,7 @@ func httpTestsBitcoinType(t *testing.T, ts *httptest.Server) {
status: http.StatusOK, status: http.StatusOK,
contentType: "application/json; charset=utf-8", contentType: "application/json; charset=utf-8",
body: []string{ body: []string{
`[{"time":1521514800,"txs":1,"received":"24690","sent":"0","rates":{"eur":1301,"usd":2001}}]`, `[{"time":1521514800,"txs":1,"received":"24690","sent":"0","sentToSelf":"0","rates":{"eur":1301,"usd":2001}}]`,
}, },
}, },
{ {
@ -812,7 +812,7 @@ func httpTestsBitcoinType(t *testing.T, ts *httptest.Server) {
status: http.StatusOK, status: http.StatusOK,
contentType: "application/json; charset=utf-8", contentType: "application/json; charset=utf-8",
body: []string{ body: []string{
`[{"time":1521514800,"txs":1,"received":"1","sent":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"118641975500","sent":"1","rates":{"eur":1303,"usd":2003}}]`, `[{"time":1521514800,"txs":1,"received":"1","sent":"0","sentToSelf":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"118641975500","sent":"1","sentToSelf":"118641975500","rates":{"eur":1303,"usd":2003}}]`,
}, },
}, },
{ {
@ -821,7 +821,7 @@ func httpTestsBitcoinType(t *testing.T, ts *httptest.Server) {
status: http.StatusOK, status: http.StatusOK,
contentType: "application/json; charset=utf-8", contentType: "application/json; charset=utf-8",
body: []string{ body: []string{
`[{"time":1521514800,"txs":1,"received":"1","sent":"0","rates":{"eur":1301,"usd":2001}}]`, `[{"time":1521514800,"txs":1,"received":"1","sent":"0","sentToSelf":"0","rates":{"eur":1301,"usd":2001}}]`,
}, },
}, },
{ {
@ -830,7 +830,7 @@ func httpTestsBitcoinType(t *testing.T, ts *httptest.Server) {
status: http.StatusOK, status: http.StatusOK,
contentType: "application/json; charset=utf-8", contentType: "application/json; charset=utf-8",
body: []string{ body: []string{
`[{"time":1521514800,"txs":1,"received":"1","sent":"0","rates":{"usd":2001}}]`, `[{"time":1521514800,"txs":1,"received":"1","sent":"0","sentToSelf":"0","rates":{"usd":2001}}]`,
}, },
}, },
{ {
@ -839,7 +839,7 @@ func httpTestsBitcoinType(t *testing.T, ts *httptest.Server) {
status: http.StatusOK, status: http.StatusOK,
contentType: "application/json; charset=utf-8", contentType: "application/json; charset=utf-8",
body: []string{ body: []string{
`[{"time":1521594000,"txs":1,"received":"118641975500","sent":"1","rates":{"eur":1303,"usd":2003}}]`, `[{"time":1521594000,"txs":1,"received":"118641975500","sent":"1","sentToSelf":"118641975500","rates":{"eur":1303,"usd":2003}}]`,
}, },
}, },
{ {
@ -1370,7 +1370,7 @@ func websocketTestsBitcoinType(t *testing.T, ts *httptest.Server) {
"descriptor": "mtGXQvBowMkBpnhLckhxhbwYK44Gs9eEtz", "descriptor": "mtGXQvBowMkBpnhLckhxhbwYK44Gs9eEtz",
}, },
}, },
want: `{"id":"32","data":[{"time":1521514800,"txs":1,"received":"24690","sent":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"0","sent":"12345","rates":{"eur":1303,"usd":2003}}]}`, want: `{"id":"32","data":[{"time":1521514800,"txs":1,"received":"24690","sent":"0","sentToSelf":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"0","sent":"12345","sentToSelf":"0","rates":{"eur":1303,"usd":2003}}]}`,
}, },
{ {
name: "websocket getBalanceHistory xpub", name: "websocket getBalanceHistory xpub",
@ -1380,7 +1380,7 @@ func websocketTestsBitcoinType(t *testing.T, ts *httptest.Server) {
"descriptor": dbtestdata.Xpub, "descriptor": dbtestdata.Xpub,
}, },
}, },
want: `{"id":"33","data":[{"time":1521514800,"txs":1,"received":"1","sent":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"118641975500","sent":"1","rates":{"eur":1303,"usd":2003}}]}`, want: `{"id":"33","data":[{"time":1521514800,"txs":1,"received":"1","sent":"0","sentToSelf":"0","rates":{"eur":1301,"usd":2001}},{"time":1521594000,"txs":1,"received":"118641975500","sent":"1","sentToSelf":"118641975500","rates":{"eur":1303,"usd":2003}}]}`,
}, },
{ {
name: "websocket getBalanceHistory xpub from=1521504000&to=1521590400 currencies=[usd]", name: "websocket getBalanceHistory xpub from=1521504000&to=1521590400 currencies=[usd]",
@ -1393,7 +1393,7 @@ func websocketTestsBitcoinType(t *testing.T, ts *httptest.Server) {
"currencies": []string{"usd"}, "currencies": []string{"usd"},
}, },
}, },
want: `{"id":"34","data":[{"time":1521514800,"txs":1,"received":"1","sent":"0","rates":{"usd":2001}}]}`, want: `{"id":"34","data":[{"time":1521514800,"txs":1,"received":"1","sent":"0","sentToSelf":"0","rates":{"usd":2001}}]}`,
}, },
{ {
name: "websocket getBalanceHistory xpub from=1521504000&to=1521590400 currencies=[usd, eur, incorrect]", name: "websocket getBalanceHistory xpub from=1521504000&to=1521590400 currencies=[usd, eur, incorrect]",
@ -1406,7 +1406,7 @@ func websocketTestsBitcoinType(t *testing.T, ts *httptest.Server) {
"currencies": []string{"usd", "eur", "incorrect"}, "currencies": []string{"usd", "eur", "incorrect"},
}, },
}, },
want: `{"id":"35","data":[{"time":1521514800,"txs":1,"received":"1","sent":"0","rates":{"eur":1301,"incorrect":-1,"usd":2001}}]}`, want: `{"id":"35","data":[{"time":1521514800,"txs":1,"received":"1","sent":"0","sentToSelf":"0","rates":{"eur":1301,"incorrect":-1,"usd":2001}}]}`,
}, },
{ {
name: "websocket getBalanceHistory xpub from=1521504000&to=1521590400 currencies=[]", name: "websocket getBalanceHistory xpub from=1521504000&to=1521590400 currencies=[]",
@ -1419,7 +1419,7 @@ func websocketTestsBitcoinType(t *testing.T, ts *httptest.Server) {
"currencies": []string{}, "currencies": []string{},
}, },
}, },
want: `{"id":"36","data":[{"time":1521514800,"txs":1,"received":"1","sent":"0","rates":{"eur":1301,"usd":2001}}]}`, want: `{"id":"36","data":[{"time":1521514800,"txs":1,"received":"1","sent":"0","sentToSelf":"0","rates":{"eur":1301,"usd":2001}}]}`,
}, },
} }