Compare commits
4
Commits
810bca8154
..
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
83070ce195 | ||
|
|
e56c9fde81 | ||
|
|
515ecf0ea0 | ||
|
|
9593b8ec62 |
+463
-106
@@ -27,6 +27,7 @@ const path = require('path')
|
|||||||
|
|
||||||
const addressCacheDir = '/data/cache/addresses'
|
const addressCacheDir = '/data/cache/addresses'
|
||||||
const addressCacheMaxAgeMs = 60000
|
const addressCacheMaxAgeMs = 60000
|
||||||
|
const addressTransactionPageSize = 50
|
||||||
const addressRefreshes = new Map()
|
const addressRefreshes = new Map()
|
||||||
|
|
||||||
function ensureAddressCacheDir() {
|
function ensureAddressCacheDir() {
|
||||||
@@ -149,7 +150,11 @@ function refreshAddressCache(
|
|||||||
return refresh
|
return refresh
|
||||||
}
|
}
|
||||||
|
|
||||||
function queryFulcrum(fulcrumUrl, method, params = []) {
|
function queryFulcrum(
|
||||||
|
fulcrumUrl,
|
||||||
|
method,
|
||||||
|
params = [],
|
||||||
|
) {
|
||||||
return new Promise((resolve) => {
|
return new Promise((resolve) => {
|
||||||
if (!fulcrumUrl) {
|
if (!fulcrumUrl) {
|
||||||
resolve({
|
resolve({
|
||||||
@@ -225,7 +230,9 @@ function queryFulcrum(fulcrumUrl, method, params = []) {
|
|||||||
params,
|
params,
|
||||||
}) + '\n'
|
}) + '\n'
|
||||||
|
|
||||||
console.log(`Sending Fulcrum request: ${request.trim()}`)
|
console.log(
|
||||||
|
`Sending Fulcrum request: ${request.trim()}`,
|
||||||
|
)
|
||||||
|
|
||||||
socket.write(request)
|
socket.write(request)
|
||||||
})
|
})
|
||||||
@@ -233,7 +240,9 @@ function queryFulcrum(fulcrumUrl, method, params = []) {
|
|||||||
socket.on('data', (data) => {
|
socket.on('data', (data) => {
|
||||||
const chunk = data.toString()
|
const chunk = data.toString()
|
||||||
|
|
||||||
console.log(`Fulcrum response data: ${chunk.trim()}`)
|
console.log(
|
||||||
|
`Fulcrum response data: ${chunk.trim()}`,
|
||||||
|
)
|
||||||
|
|
||||||
response += chunk
|
response += chunk
|
||||||
|
|
||||||
@@ -316,15 +325,19 @@ function queryFulcrum(fulcrumUrl, method, params = []) {
|
|||||||
finish({
|
finish({
|
||||||
ok: false,
|
ok: false,
|
||||||
result: null,
|
result: null,
|
||||||
error: 'Connection closed before a response was received',
|
error:
|
||||||
|
'Connection closed before a response was received',
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
async function getFulcrumStatus(fulcrumUrl) {
|
async function getFulcrumStatus(
|
||||||
const version = await queryFulcrum(
|
fulcrumUrl,
|
||||||
|
) {
|
||||||
|
const version =
|
||||||
|
await queryFulcrum(
|
||||||
fulcrumUrl,
|
fulcrumUrl,
|
||||||
'server.version',
|
'server.version',
|
||||||
['Munin Bitcoin', '1.4'],
|
['Munin Bitcoin', '1.4'],
|
||||||
@@ -332,7 +345,9 @@ async function getFulcrumStatus(fulcrumUrl) {
|
|||||||
|
|
||||||
if (!version.ok) {
|
if (!version.ok) {
|
||||||
return {
|
return {
|
||||||
configured: Boolean(fulcrumUrl),
|
configured: Boolean(
|
||||||
|
fulcrumUrl,
|
||||||
|
),
|
||||||
connected: false,
|
connected: false,
|
||||||
url: fulcrumUrl,
|
url: fulcrumUrl,
|
||||||
serverVersion: null,
|
serverVersion: null,
|
||||||
@@ -341,28 +356,43 @@ async function getFulcrumStatus(fulcrumUrl) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
const headers = await queryFulcrum(
|
const headers =
|
||||||
|
await queryFulcrum(
|
||||||
fulcrumUrl,
|
fulcrumUrl,
|
||||||
'blockchain.headers.subscribe',
|
'blockchain.headers.subscribe',
|
||||||
[],
|
[],
|
||||||
)
|
)
|
||||||
|
|
||||||
return {
|
return {
|
||||||
configured: Boolean(fulcrumUrl),
|
configured: Boolean(
|
||||||
|
fulcrumUrl,
|
||||||
|
),
|
||||||
connected: true,
|
connected: true,
|
||||||
url: fulcrumUrl,
|
url: fulcrumUrl,
|
||||||
serverVersion: version.result,
|
serverVersion:
|
||||||
|
version.result,
|
||||||
blockchainHeight:
|
blockchainHeight:
|
||||||
headers.ok && headers.result
|
headers.ok &&
|
||||||
? headers.result.height ?? null
|
headers.result
|
||||||
|
? headers.result.height ??
|
||||||
|
null
|
||||||
: null,
|
: null,
|
||||||
error: headers.ok ? null : headers.error,
|
error:
|
||||||
|
headers.ok
|
||||||
|
? null
|
||||||
|
: headers.error,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async function getStatus() {
|
async function getStatus() {
|
||||||
const fulcrumUrl = process.env.MUNIN_FULCRUM_URL || null
|
const fulcrumUrl =
|
||||||
const fulcrum = await getFulcrumStatus(fulcrumUrl)
|
process.env.MUNIN_FULCRUM_URL ||
|
||||||
|
null
|
||||||
|
|
||||||
|
const fulcrum =
|
||||||
|
await getFulcrumStatus(
|
||||||
|
fulcrumUrl,
|
||||||
|
)
|
||||||
|
|
||||||
return {
|
return {
|
||||||
service: 'running',
|
service: 'running',
|
||||||
@@ -379,7 +409,8 @@ async function getAddressDataFromFulcrum(
|
|||||||
scripthash,
|
scripthash,
|
||||||
) {
|
) {
|
||||||
const fulcrumUrl =
|
const fulcrumUrl =
|
||||||
process.env.MUNIN_FULCRUM_URL || null
|
process.env.MUNIN_FULCRUM_URL ||
|
||||||
|
null
|
||||||
|
|
||||||
if (!fulcrumUrl) {
|
if (!fulcrumUrl) {
|
||||||
throw new Error(
|
throw new Error(
|
||||||
@@ -387,7 +418,8 @@ async function getAddressDataFromFulcrum(
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
const balance = await queryFulcrum(
|
const balance =
|
||||||
|
await queryFulcrum(
|
||||||
fulcrumUrl,
|
fulcrumUrl,
|
||||||
'blockchain.scripthash.get_balance',
|
'blockchain.scripthash.get_balance',
|
||||||
[scripthash],
|
[scripthash],
|
||||||
@@ -399,7 +431,8 @@ async function getAddressDataFromFulcrum(
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
const utxos = await queryFulcrum(
|
const utxos =
|
||||||
|
await queryFulcrum(
|
||||||
fulcrumUrl,
|
fulcrumUrl,
|
||||||
'blockchain.scripthash.listunspent',
|
'blockchain.scripthash.listunspent',
|
||||||
[scripthash],
|
[scripthash],
|
||||||
@@ -411,7 +444,8 @@ async function getAddressDataFromFulcrum(
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
const history = await queryFulcrum(
|
const history =
|
||||||
|
await queryFulcrum(
|
||||||
fulcrumUrl,
|
fulcrumUrl,
|
||||||
'blockchain.scripthash.get_history',
|
'blockchain.scripthash.get_history',
|
||||||
[scripthash],
|
[scripthash],
|
||||||
@@ -427,15 +461,25 @@ async function getAddressDataFromFulcrum(
|
|||||||
address,
|
address,
|
||||||
scripthash,
|
scripthash,
|
||||||
confirmedBalance:
|
confirmedBalance:
|
||||||
Number(balance.result?.confirmed || 0),
|
Number(
|
||||||
|
balance.result?.confirmed ||
|
||||||
|
0,
|
||||||
|
),
|
||||||
unconfirmedBalance:
|
unconfirmedBalance:
|
||||||
Number(balance.result?.unconfirmed || 0),
|
Number(
|
||||||
|
balance.result?.unconfirmed ||
|
||||||
|
0,
|
||||||
|
),
|
||||||
utxos:
|
utxos:
|
||||||
Array.isArray(utxos.result)
|
Array.isArray(
|
||||||
|
utxos.result,
|
||||||
|
)
|
||||||
? utxos.result
|
? utxos.result
|
||||||
: [],
|
: [],
|
||||||
history:
|
history:
|
||||||
Array.isArray(history.result)
|
Array.isArray(
|
||||||
|
history.result,
|
||||||
|
)
|
||||||
? history.result
|
? history.result
|
||||||
: [],
|
: [],
|
||||||
lastSynced:
|
lastSynced:
|
||||||
@@ -443,12 +487,16 @@ async function getAddressDataFromFulcrum(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async function getAddressData(address) {
|
async function getAddressData(
|
||||||
|
address,
|
||||||
|
) {
|
||||||
let scripthash
|
let scripthash
|
||||||
|
|
||||||
try {
|
try {
|
||||||
scripthash =
|
scripthash =
|
||||||
addressToScripthash(address)
|
addressToScripthash(
|
||||||
|
address,
|
||||||
|
)
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
throw new Error(
|
throw new Error(
|
||||||
error instanceof Error
|
error instanceof Error
|
||||||
@@ -458,7 +506,9 @@ async function getAddressData(address) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const cached =
|
const cached =
|
||||||
readAddressCache(scripthash)
|
readAddressCache(
|
||||||
|
scripthash,
|
||||||
|
)
|
||||||
|
|
||||||
if (cached) {
|
if (cached) {
|
||||||
if (
|
if (
|
||||||
@@ -490,25 +540,80 @@ async function getAddressData(address) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function getAddressTransactionPage(
|
||||||
|
history,
|
||||||
|
offset = 0,
|
||||||
|
limit =
|
||||||
|
addressTransactionPageSize,
|
||||||
|
) {
|
||||||
|
const safeOffset =
|
||||||
|
Math.max(
|
||||||
|
0,
|
||||||
|
Number(offset) || 0,
|
||||||
|
)
|
||||||
|
|
||||||
|
const safeLimit =
|
||||||
|
Math.min(
|
||||||
|
addressTransactionPageSize,
|
||||||
|
Math.max(
|
||||||
|
1,
|
||||||
|
Number(limit) ||
|
||||||
|
addressTransactionPageSize,
|
||||||
|
),
|
||||||
|
)
|
||||||
|
|
||||||
|
return history.slice(
|
||||||
|
safeOffset,
|
||||||
|
safeOffset + safeLimit,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
async function getAddressesWithData() {
|
async function getAddressesWithData() {
|
||||||
const addresses = await listAddresses()
|
const addresses =
|
||||||
|
await listAddresses()
|
||||||
|
|
||||||
const results = []
|
const results = []
|
||||||
|
|
||||||
for (const entry of addresses) {
|
for (const entry of addresses) {
|
||||||
try {
|
try {
|
||||||
const data = await getAddressData(entry.address)
|
const data =
|
||||||
|
await getAddressData(
|
||||||
|
entry.address,
|
||||||
|
)
|
||||||
|
|
||||||
|
const history =
|
||||||
|
Array.isArray(
|
||||||
|
data.history,
|
||||||
|
)
|
||||||
|
? data.history
|
||||||
|
: []
|
||||||
|
|
||||||
results.push({
|
results.push({
|
||||||
...entry,
|
...entry,
|
||||||
scripthash: data.scripthash,
|
scripthash:
|
||||||
confirmedBalance: data.confirmedBalance,
|
data.scripthash,
|
||||||
unconfirmedBalance: data.unconfirmedBalance,
|
confirmedBalance:
|
||||||
utxos: data.utxos,
|
data.confirmedBalance,
|
||||||
history: data.history,
|
unconfirmedBalance:
|
||||||
|
data.unconfirmedBalance,
|
||||||
|
utxos:
|
||||||
|
data.utxos,
|
||||||
|
history:
|
||||||
|
getAddressTransactionPage(
|
||||||
|
history,
|
||||||
|
),
|
||||||
|
transactionCount:
|
||||||
|
history.length,
|
||||||
|
transactionOffset: 0,
|
||||||
|
transactionLimit:
|
||||||
|
addressTransactionPageSize,
|
||||||
lastSynced:
|
lastSynced:
|
||||||
data.lastSynced || null,
|
data.lastSynced ||
|
||||||
|
null,
|
||||||
cacheAgeMs:
|
cacheAgeMs:
|
||||||
Number(data.cacheAgeMs || 0),
|
Number(
|
||||||
|
data.cacheAgeMs || 0,
|
||||||
|
),
|
||||||
error: null,
|
error: null,
|
||||||
})
|
})
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
@@ -518,6 +623,10 @@ async function getAddressesWithData() {
|
|||||||
unconfirmedBalance: null,
|
unconfirmedBalance: null,
|
||||||
utxos: [],
|
utxos: [],
|
||||||
history: [],
|
history: [],
|
||||||
|
transactionCount: 0,
|
||||||
|
transactionOffset: 0,
|
||||||
|
transactionLimit:
|
||||||
|
addressTransactionPageSize,
|
||||||
lastSynced: null,
|
lastSynced: null,
|
||||||
cacheAgeMs: null,
|
cacheAgeMs: null,
|
||||||
error:
|
error:
|
||||||
@@ -531,8 +640,13 @@ async function getAddressesWithData() {
|
|||||||
return results
|
return results
|
||||||
}
|
}
|
||||||
|
|
||||||
const server = http.createServer(async (req, res) => {
|
const server =
|
||||||
if (req.method === 'POST' && req.url === '/api/login') {
|
http.createServer(
|
||||||
|
async (req, res) => {
|
||||||
|
if (
|
||||||
|
req.method === 'POST' &&
|
||||||
|
req.url === '/api/login'
|
||||||
|
) {
|
||||||
let body = ''
|
let body = ''
|
||||||
|
|
||||||
req.on('data', (chunk) => {
|
req.on('data', (chunk) => {
|
||||||
@@ -541,29 +655,40 @@ const server = http.createServer(async (req, res) => {
|
|||||||
|
|
||||||
req.on('end', () => {
|
req.on('end', () => {
|
||||||
try {
|
try {
|
||||||
const input = JSON.parse(body)
|
const input =
|
||||||
|
JSON.parse(body)
|
||||||
|
|
||||||
if (!checkPassword(input.password)) {
|
if (
|
||||||
|
!checkPassword(
|
||||||
|
input.password,
|
||||||
|
)
|
||||||
|
) {
|
||||||
res.writeHead(401, {
|
res.writeHead(401, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Invalid password',
|
error:
|
||||||
|
'Invalid password',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
const token = createSession()
|
const token =
|
||||||
|
createSession()
|
||||||
|
|
||||||
res.writeHead(200, {
|
res.writeHead(200, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
'Set-Cookie':
|
'Set-Cookie':
|
||||||
'munin_session=' +
|
'munin_session=' +
|
||||||
encodeURIComponent(token) +
|
encodeURIComponent(
|
||||||
|
token,
|
||||||
|
) +
|
||||||
'; HttpOnly; Secure; SameSite=Strict; Path=/; Max-Age=86400',
|
'; HttpOnly; Secure; SameSite=Strict; Path=/; Max-Age=86400',
|
||||||
})
|
})
|
||||||
|
|
||||||
@@ -574,12 +699,14 @@ const server = http.createServer(async (req, res) => {
|
|||||||
)
|
)
|
||||||
} catch {
|
} catch {
|
||||||
res.writeHead(400, {
|
res.writeHead(400, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Invalid request',
|
error:
|
||||||
|
'Invalid request',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
@@ -588,15 +715,22 @@ const server = http.createServer(async (req, res) => {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if (req.url === '/api/status') {
|
if (
|
||||||
if (!isValidSession(req)) {
|
req.url ===
|
||||||
|
'/api/status'
|
||||||
|
) {
|
||||||
|
if (
|
||||||
|
!isValidSession(req)
|
||||||
|
) {
|
||||||
res.writeHead(401, {
|
res.writeHead(401, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Authentication required',
|
error:
|
||||||
|
'Authentication required',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -604,13 +738,19 @@ const server = http.createServer(async (req, res) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const status = await getStatus()
|
const status =
|
||||||
|
await getStatus()
|
||||||
|
|
||||||
res.writeHead(200, {
|
res.writeHead(200, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(JSON.stringify(status))
|
res.end(
|
||||||
|
JSON.stringify(
|
||||||
|
status,
|
||||||
|
),
|
||||||
|
)
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error(
|
console.error(
|
||||||
'Failed to get service status:',
|
'Failed to get service status:',
|
||||||
@@ -618,13 +758,16 @@ const server = http.createServer(async (req, res) => {
|
|||||||
)
|
)
|
||||||
|
|
||||||
res.writeHead(500, {
|
res.writeHead(500, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
service: 'running',
|
service:
|
||||||
error: 'Failed to determine service status',
|
'running',
|
||||||
|
error:
|
||||||
|
'Failed to determine service status',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
@@ -632,15 +775,23 @@ const server = http.createServer(async (req, res) => {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if (req.method === 'GET' && req.url === '/api/addresses') {
|
if (
|
||||||
if (!isValidSession(req)) {
|
req.method === 'GET' &&
|
||||||
|
req.url ===
|
||||||
|
'/api/addresses'
|
||||||
|
) {
|
||||||
|
if (
|
||||||
|
!isValidSession(req)
|
||||||
|
) {
|
||||||
res.writeHead(401, {
|
res.writeHead(401, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Authentication required',
|
error:
|
||||||
|
'Authentication required',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -648,10 +799,12 @@ const server = http.createServer(async (req, res) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const addresses = await listAddresses()
|
const addresses =
|
||||||
|
await listAddresses()
|
||||||
|
|
||||||
res.writeHead(200, {
|
res.writeHead(200, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
@@ -666,12 +819,14 @@ const server = http.createServer(async (req, res) => {
|
|||||||
)
|
)
|
||||||
|
|
||||||
res.writeHead(500, {
|
res.writeHead(500, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Failed to list addresses',
|
error:
|
||||||
|
'Failed to list addresses',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
@@ -681,16 +836,21 @@ const server = http.createServer(async (req, res) => {
|
|||||||
|
|
||||||
if (
|
if (
|
||||||
req.method === 'GET' &&
|
req.method === 'GET' &&
|
||||||
req.url === '/api/addresses/data'
|
req.url ===
|
||||||
|
'/api/addresses/data'
|
||||||
|
) {
|
||||||
|
if (
|
||||||
|
!isValidSession(req)
|
||||||
) {
|
) {
|
||||||
if (!isValidSession(req)) {
|
|
||||||
res.writeHead(401, {
|
res.writeHead(401, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Authentication required',
|
error:
|
||||||
|
'Authentication required',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -698,10 +858,12 @@ const server = http.createServer(async (req, res) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const addresses = await getAddressesWithData()
|
const addresses =
|
||||||
|
await getAddressesWithData()
|
||||||
|
|
||||||
res.writeHead(200, {
|
res.writeHead(200, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
@@ -716,12 +878,155 @@ const server = http.createServer(async (req, res) => {
|
|||||||
)
|
)
|
||||||
|
|
||||||
res.writeHead(500, {
|
res.writeHead(500, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Failed to get address data',
|
error:
|
||||||
|
'Failed to get address data',
|
||||||
|
}),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if (
|
||||||
|
req.method === 'GET' &&
|
||||||
|
req.url.startsWith(
|
||||||
|
'/api/addresses/transactions',
|
||||||
|
)
|
||||||
|
) {
|
||||||
|
if (
|
||||||
|
!isValidSession(req)
|
||||||
|
) {
|
||||||
|
res.writeHead(401, {
|
||||||
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
|
})
|
||||||
|
|
||||||
|
res.end(
|
||||||
|
JSON.stringify({
|
||||||
|
error:
|
||||||
|
'Authentication required',
|
||||||
|
}),
|
||||||
|
)
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
const url =
|
||||||
|
new URL(
|
||||||
|
req.url,
|
||||||
|
`http://${
|
||||||
|
req.headers.host ||
|
||||||
|
'localhost'
|
||||||
|
}`,
|
||||||
|
)
|
||||||
|
|
||||||
|
const address =
|
||||||
|
url.searchParams.get(
|
||||||
|
'address',
|
||||||
|
)
|
||||||
|
|
||||||
|
if (!address) {
|
||||||
|
throw new Error(
|
||||||
|
'Address is required',
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
const offset =
|
||||||
|
Math.max(
|
||||||
|
0,
|
||||||
|
Number(
|
||||||
|
url.searchParams.get(
|
||||||
|
'offset',
|
||||||
|
),
|
||||||
|
) || 0,
|
||||||
|
)
|
||||||
|
|
||||||
|
const limit =
|
||||||
|
Math.min(
|
||||||
|
addressTransactionPageSize,
|
||||||
|
Math.max(
|
||||||
|
1,
|
||||||
|
Number(
|
||||||
|
url.searchParams.get(
|
||||||
|
'limit',
|
||||||
|
),
|
||||||
|
) ||
|
||||||
|
addressTransactionPageSize,
|
||||||
|
),
|
||||||
|
)
|
||||||
|
|
||||||
|
const data =
|
||||||
|
await getAddressData(
|
||||||
|
address,
|
||||||
|
)
|
||||||
|
|
||||||
|
const history =
|
||||||
|
Array.isArray(
|
||||||
|
data.history,
|
||||||
|
)
|
||||||
|
? data.history
|
||||||
|
: []
|
||||||
|
|
||||||
|
const transactions =
|
||||||
|
getAddressTransactionPage(
|
||||||
|
history,
|
||||||
|
offset,
|
||||||
|
limit,
|
||||||
|
)
|
||||||
|
|
||||||
|
res.writeHead(200, {
|
||||||
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
|
})
|
||||||
|
|
||||||
|
res.end(
|
||||||
|
JSON.stringify({
|
||||||
|
address,
|
||||||
|
scripthash:
|
||||||
|
data.scripthash,
|
||||||
|
transactions,
|
||||||
|
total:
|
||||||
|
history.length,
|
||||||
|
offset,
|
||||||
|
limit,
|
||||||
|
hasMore:
|
||||||
|
offset +
|
||||||
|
transactions.length <
|
||||||
|
history.length,
|
||||||
|
lastSynced:
|
||||||
|
data.lastSynced ||
|
||||||
|
null,
|
||||||
|
cacheAgeMs:
|
||||||
|
Number(
|
||||||
|
data.cacheAgeMs ||
|
||||||
|
0,
|
||||||
|
),
|
||||||
|
}),
|
||||||
|
)
|
||||||
|
} catch (error) {
|
||||||
|
console.error(
|
||||||
|
'Failed to get address transactions:',
|
||||||
|
error,
|
||||||
|
)
|
||||||
|
|
||||||
|
res.writeHead(400, {
|
||||||
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
|
})
|
||||||
|
|
||||||
|
res.end(
|
||||||
|
JSON.stringify({
|
||||||
|
error:
|
||||||
|
error instanceof Error
|
||||||
|
? error.message
|
||||||
|
: 'Failed to get address transactions',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
@@ -731,16 +1036,21 @@ const server = http.createServer(async (req, res) => {
|
|||||||
|
|
||||||
if (
|
if (
|
||||||
req.method === 'POST' &&
|
req.method === 'POST' &&
|
||||||
req.url === '/api/addresses'
|
req.url ===
|
||||||
|
'/api/addresses'
|
||||||
|
) {
|
||||||
|
if (
|
||||||
|
!isValidSession(req)
|
||||||
) {
|
) {
|
||||||
if (!isValidSession(req)) {
|
|
||||||
res.writeHead(401, {
|
res.writeHead(401, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Authentication required',
|
error:
|
||||||
|
'Authentication required',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -753,23 +1063,33 @@ const server = http.createServer(async (req, res) => {
|
|||||||
body += chunk
|
body += chunk
|
||||||
})
|
})
|
||||||
|
|
||||||
req.on('end', async () => {
|
req.on(
|
||||||
|
'end',
|
||||||
|
async () => {
|
||||||
try {
|
try {
|
||||||
const input = JSON.parse(body)
|
const input =
|
||||||
|
JSON.parse(body)
|
||||||
|
|
||||||
const entry = await addAddress(
|
const entry =
|
||||||
|
await addAddress(
|
||||||
input.address,
|
input.address,
|
||||||
input.label,
|
input.label,
|
||||||
)
|
)
|
||||||
|
|
||||||
res.writeHead(201, {
|
res.writeHead(201, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(JSON.stringify(entry))
|
res.end(
|
||||||
|
JSON.stringify(
|
||||||
|
entry,
|
||||||
|
),
|
||||||
|
)
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
res.writeHead(400, {
|
res.writeHead(400, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
@@ -781,23 +1101,29 @@ const server = http.createServer(async (req, res) => {
|
|||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
})
|
},
|
||||||
|
)
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if (
|
if (
|
||||||
req.method === 'DELETE' &&
|
req.method === 'DELETE' &&
|
||||||
req.url === '/api/addresses'
|
req.url ===
|
||||||
|
'/api/addresses'
|
||||||
|
) {
|
||||||
|
if (
|
||||||
|
!isValidSession(req)
|
||||||
) {
|
) {
|
||||||
if (!isValidSession(req)) {
|
|
||||||
res.writeHead(401, {
|
res.writeHead(401, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Authentication required',
|
error:
|
||||||
|
'Authentication required',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -810,14 +1136,20 @@ const server = http.createServer(async (req, res) => {
|
|||||||
body += chunk
|
body += chunk
|
||||||
})
|
})
|
||||||
|
|
||||||
req.on('end', async () => {
|
req.on(
|
||||||
|
'end',
|
||||||
|
async () => {
|
||||||
try {
|
try {
|
||||||
const input = JSON.parse(body)
|
const input =
|
||||||
|
JSON.parse(body)
|
||||||
|
|
||||||
await removeAddress(input.address)
|
await removeAddress(
|
||||||
|
input.address,
|
||||||
|
)
|
||||||
|
|
||||||
res.writeHead(200, {
|
res.writeHead(200, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
@@ -827,7 +1159,8 @@ const server = http.createServer(async (req, res) => {
|
|||||||
)
|
)
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
res.writeHead(400, {
|
res.writeHead(400, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
@@ -839,44 +1172,64 @@ const server = http.createServer(async (req, res) => {
|
|||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
})
|
},
|
||||||
|
)
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if (
|
if (
|
||||||
req.method === 'GET' &&
|
req.method === 'GET' &&
|
||||||
req.url.startsWith('/api/transactions/')
|
req.url.startsWith(
|
||||||
|
'/api/transactions/',
|
||||||
|
)
|
||||||
|
) {
|
||||||
|
if (
|
||||||
|
!isValidSession(req)
|
||||||
) {
|
) {
|
||||||
if (!isValidSession(req)) {
|
|
||||||
res.writeHead(401, {
|
res.writeHead(401, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
error: 'Authentication required',
|
error:
|
||||||
|
'Authentication required',
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
const txid = decodeURIComponent(
|
const txid =
|
||||||
req.url.slice('/api/transactions/'.length),
|
decodeURIComponent(
|
||||||
|
req.url.slice(
|
||||||
|
'/api/transactions/'
|
||||||
|
.length,
|
||||||
|
),
|
||||||
)
|
)
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const transaction = await getTransaction(txid)
|
const transaction =
|
||||||
|
await getTransaction(
|
||||||
|
txid,
|
||||||
|
)
|
||||||
|
|
||||||
res.writeHead(200, {
|
res.writeHead(200, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(JSON.stringify(transaction))
|
res.end(
|
||||||
|
JSON.stringify(
|
||||||
|
transaction,
|
||||||
|
),
|
||||||
|
)
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
res.writeHead(400, {
|
res.writeHead(400, {
|
||||||
'Content-Type': 'application/json',
|
'Content-Type':
|
||||||
|
'application/json',
|
||||||
})
|
})
|
||||||
|
|
||||||
res.end(
|
res.end(
|
||||||
@@ -894,10 +1247,14 @@ const server = http.createServer(async (req, res) => {
|
|||||||
|
|
||||||
res.writeHead(404)
|
res.writeHead(404)
|
||||||
res.end('Not found')
|
res.end('Not found')
|
||||||
})
|
},
|
||||||
|
)
|
||||||
|
|
||||||
server.listen(port, () => {
|
server.listen(
|
||||||
|
port,
|
||||||
|
() => {
|
||||||
console.log(
|
console.log(
|
||||||
`Status API listening on port ${port}`,
|
`Status API listening on port ${port}`,
|
||||||
)
|
)
|
||||||
})
|
},
|
||||||
|
)
|
||||||
+149
-78
@@ -221,7 +221,7 @@
|
|||||||
|
|
||||||
.wallet-header {
|
.wallet-header {
|
||||||
display: grid;
|
display: grid;
|
||||||
grid-template-columns: minmax(0, 1fr) auto auto;
|
grid-template-columns: minmax(0, 1fr) auto auto auto;
|
||||||
align-items: center;
|
align-items: center;
|
||||||
gap: 24px;
|
gap: 24px;
|
||||||
width: 100%;
|
width: 100%;
|
||||||
@@ -281,6 +281,13 @@
|
|||||||
font-weight: 650;
|
font-weight: 650;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.wallet-chevron {
|
||||||
|
width: 20px;
|
||||||
|
color: var(--muted);
|
||||||
|
text-align: center;
|
||||||
|
font-size: 18px;
|
||||||
|
}
|
||||||
|
|
||||||
.wallet-content {
|
.wallet-content {
|
||||||
padding: 0 18px 18px;
|
padding: 0 18px 18px;
|
||||||
border-top: 1px solid var(--border);
|
border-top: 1px solid var(--border);
|
||||||
@@ -503,9 +510,6 @@
|
|||||||
text-align: right;
|
text-align: right;
|
||||||
}
|
}
|
||||||
|
|
||||||
.transaction-chevron {
|
|
||||||
display: none;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Login */
|
/* Login */
|
||||||
|
|
||||||
@@ -870,6 +874,7 @@
|
|||||||
|
|
||||||
const expandedWallets = new Set();
|
const expandedWallets = new Set();
|
||||||
const expandedTransactions = new Set();
|
const expandedTransactions = new Set();
|
||||||
|
const visibleTransactionCounts = new Map();
|
||||||
|
|
||||||
const transactionCache = new Map();
|
const transactionCache = new Map();
|
||||||
|
|
||||||
@@ -1074,38 +1079,6 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
function formatDateDateOnly(timestamp) {
|
|
||||||
const value = Number(timestamp);
|
|
||||||
|
|
||||||
if (!Number.isFinite(value)) {
|
|
||||||
return 'Unknown';
|
|
||||||
}
|
|
||||||
|
|
||||||
const date = new Date(value * 1000);
|
|
||||||
|
|
||||||
if (Number.isNaN(date.getTime())) {
|
|
||||||
return 'Unknown';
|
|
||||||
}
|
|
||||||
|
|
||||||
const pad = (number) => String(number).padStart(2, '0');
|
|
||||||
const year = date.getFullYear();
|
|
||||||
const shortYear = String(year).slice(-2);
|
|
||||||
const month = pad(date.getMonth() + 1);
|
|
||||||
const day = pad(date.getDate());
|
|
||||||
|
|
||||||
switch (dateFormat) {
|
|
||||||
case 'DD.MM.YYYY HH:MM':
|
|
||||||
case 'DD.MM.YY HH:MM':
|
|
||||||
return `${day}.${month}.${dateFormat.includes('YYYY') ? year : shortYear}`;
|
|
||||||
case 'YYYY-MM-DD HH:MM':
|
|
||||||
return `${year}-${month}-${day}`;
|
|
||||||
case 'MM/DD/YY HH:MM':
|
|
||||||
return `${month}/${day}/${shortYear}`;
|
|
||||||
default:
|
|
||||||
return `${day}.${month}.${shortYear}`;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function formatSyncAge(date) {
|
function formatSyncAge(date) {
|
||||||
if (!date) {
|
if (!date) {
|
||||||
return 'Not synced';
|
return 'Not synced';
|
||||||
@@ -1426,7 +1399,9 @@
|
|||||||
const lastActivity = getTransactionDateForLatest(wallet, latest);
|
const lastActivity = getTransactionDateForLatest(wallet, latest);
|
||||||
|
|
||||||
const lastActivityText = lastActivity
|
const lastActivityText = lastActivity
|
||||||
? formatDateDateOnly(lastActivity)
|
? formatDate(lastActivity)
|
||||||
|
: latest
|
||||||
|
? `Block ${latest.height}`
|
||||||
: 'No activity';
|
: 'No activity';
|
||||||
|
|
||||||
return `
|
return `
|
||||||
@@ -1465,6 +1440,10 @@
|
|||||||
${escapeHtml(lastActivityText)}
|
${escapeHtml(lastActivityText)}
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
|
<div class="wallet-chevron">
|
||||||
|
${expanded ? 'v' : '>'}
|
||||||
|
</div>
|
||||||
</button>
|
</button>
|
||||||
|
|
||||||
${
|
${
|
||||||
@@ -1498,8 +1477,115 @@
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
function renderWalletContent(wallet, transactionCount) {
|
async function showMoreTransactions(encodedAddress) {
|
||||||
const transactions = getWalletTransactions(wallet);
|
const address =
|
||||||
|
decodeURIComponent(
|
||||||
|
encodedAddress,
|
||||||
|
);
|
||||||
|
|
||||||
|
const wallet =
|
||||||
|
wallets.find(
|
||||||
|
(item) =>
|
||||||
|
item.address === address,
|
||||||
|
);
|
||||||
|
|
||||||
|
if (!wallet) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const current =
|
||||||
|
getWalletTransactions(wallet).length;
|
||||||
|
|
||||||
|
const total =
|
||||||
|
Number(wallet.transactionCount) ||
|
||||||
|
current;
|
||||||
|
|
||||||
|
if (current >= total) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const button =
|
||||||
|
document.querySelector(
|
||||||
|
`[data-show-more-address="${encodeURIComponent(address)}"]`,
|
||||||
|
);
|
||||||
|
|
||||||
|
if (button) {
|
||||||
|
button.disabled = true;
|
||||||
|
button.textContent = 'Loading...';
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
const response =
|
||||||
|
await fetch(
|
||||||
|
`/api/addresses/transactions?address=${encodeURIComponent(address)}&offset=${current}&limit=50`,
|
||||||
|
{
|
||||||
|
credentials:
|
||||||
|
'same-origin',
|
||||||
|
},
|
||||||
|
);
|
||||||
|
|
||||||
|
if (
|
||||||
|
response.status === 401
|
||||||
|
) {
|
||||||
|
showLogin();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!response.ok) {
|
||||||
|
throw new Error(
|
||||||
|
`HTTP ${response.status}`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
const data =
|
||||||
|
await response.json();
|
||||||
|
|
||||||
|
const transactions =
|
||||||
|
Array.isArray(
|
||||||
|
data.transactions,
|
||||||
|
)
|
||||||
|
? data.transactions
|
||||||
|
: [];
|
||||||
|
|
||||||
|
wallet.history = [
|
||||||
|
...getWalletTransactions(wallet),
|
||||||
|
...transactions,
|
||||||
|
];
|
||||||
|
|
||||||
|
wallet.transactionCount =
|
||||||
|
Number(data.total) ||
|
||||||
|
wallet.history.length;
|
||||||
|
|
||||||
|
wallet.transactionOffset =
|
||||||
|
current;
|
||||||
|
|
||||||
|
renderWallets();
|
||||||
|
} catch (error) {
|
||||||
|
console.error(
|
||||||
|
'Failed to load more transactions:',
|
||||||
|
error,
|
||||||
|
);
|
||||||
|
|
||||||
|
renderWallets();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function renderWalletContent(
|
||||||
|
wallet,
|
||||||
|
transactionCount,
|
||||||
|
) {
|
||||||
|
const transactions =
|
||||||
|
getWalletTransactions(wallet);
|
||||||
|
|
||||||
|
const visibleCount =
|
||||||
|
transactions.length;
|
||||||
|
|
||||||
|
const total =
|
||||||
|
Number(wallet.transactionCount) ||
|
||||||
|
transactions.length;
|
||||||
|
|
||||||
|
const hasMore =
|
||||||
|
visibleCount < total;
|
||||||
|
|
||||||
return `
|
return `
|
||||||
<div class="wallet-content">
|
<div class="wallet-content">
|
||||||
@@ -1509,13 +1595,32 @@
|
|||||||
|
|
||||||
${
|
${
|
||||||
transactions.length
|
transactions.length
|
||||||
? renderTransactions(wallet, transactions)
|
? renderTransactions(
|
||||||
|
wallet,
|
||||||
|
transactions,
|
||||||
|
)
|
||||||
: `
|
: `
|
||||||
<div class="empty">
|
<div class="empty">
|
||||||
No transactions found for this wallet.
|
No transactions found for this wallet.
|
||||||
</div>
|
</div>
|
||||||
`
|
`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
${
|
||||||
|
hasMore
|
||||||
|
? `
|
||||||
|
<button
|
||||||
|
class="button"
|
||||||
|
type="button"
|
||||||
|
data-show-more-address="${encodeURIComponent(wallet.address)}"
|
||||||
|
onclick="showMoreTransactions('${encodeURIComponent(wallet.address)}')"
|
||||||
|
style="width: 100%; margin-top: 14px;"
|
||||||
|
>
|
||||||
|
Show more (${visibleCount} of ${total})
|
||||||
|
</button>
|
||||||
|
`
|
||||||
|
: ''
|
||||||
|
}
|
||||||
</div>
|
</div>
|
||||||
`;
|
`;
|
||||||
}
|
}
|
||||||
@@ -1539,7 +1644,10 @@
|
|||||||
|
|
||||||
const dateText = timestamp
|
const dateText = timestamp
|
||||||
? formatDate(timestamp)
|
? formatDate(timestamp)
|
||||||
: 'Loading...';
|
: transaction.height === null ||
|
||||||
|
transaction.height === undefined
|
||||||
|
? 'Pending'
|
||||||
|
: `Block ${transaction.height}`;
|
||||||
|
|
||||||
const directionLabel =
|
const directionLabel =
|
||||||
display.direction === 'sent' ? 'Sent' : 'Received';
|
display.direction === 'sent' ? 'Sent' : 'Received';
|
||||||
@@ -1710,19 +1818,6 @@
|
|||||||
|
|
||||||
renderWallets();
|
renderWallets();
|
||||||
|
|
||||||
const wallet =
|
|
||||||
wallets.find(
|
|
||||||
(item) =>
|
|
||||||
item.address === address,
|
|
||||||
);
|
|
||||||
|
|
||||||
if (!wallet) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
await loadWalletTransactionDetails(
|
|
||||||
wallet,
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
async function toggleTransaction(
|
async function toggleTransaction(
|
||||||
@@ -1760,30 +1855,6 @@
|
|||||||
await loadTransaction(txid);
|
await loadTransaction(txid);
|
||||||
}
|
}
|
||||||
|
|
||||||
async function loadWalletTransactionDetails(
|
|
||||||
wallet,
|
|
||||||
) {
|
|
||||||
const transactions =
|
|
||||||
getWalletTransactions(wallet);
|
|
||||||
|
|
||||||
if (!transactions.length) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Load transaction details in parallel so the
|
|
||||||
* list can populate dates and amounts without
|
|
||||||
* requiring the user to open each transaction.
|
|
||||||
*
|
|
||||||
* Cached transactions are skipped by loadTransaction().
|
|
||||||
*/
|
|
||||||
await Promise.all(
|
|
||||||
transactions.map((transaction) =>
|
|
||||||
loadTransaction(transaction.txid),
|
|
||||||
),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
async function loadTransaction(
|
async function loadTransaction(
|
||||||
txid,
|
txid,
|
||||||
) {
|
) {
|
||||||
|
|||||||
Reference in New Issue
Block a user