15951470896

Committed 29 Jun 2025 04:23AM UTC coverage: 67.594% (-0.01%) from 67.606%

Build # 15951470896

Build Type

Pull #9751

github

Committed by

web-flow

Commit Message

Merge 599d9b051 into 6290edf14

Pull Request Pull Request #9751: multi: update Go to 1.23.10 and update some packages

Run Details

135088 of 199851 relevant lines covered (67.59%)

21909.44 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

90.32

/watchtower/lookout/mock.go

package lookout

import (
        "fmt"
        "sync"

        "github.com/btcsuite/btcd/chaincfg/chainhash"
        "github.com/btcsuite/btcd/wire"
        "github.com/lightningnetwork/lnd/chainntnfs"
)

type MockBackend struct {
        mu sync.RWMutex

        blocks chan *chainntnfs.BlockEpoch
        epochs map[chainhash.Hash]*wire.MsgBlock
        quit   chan struct{}
}

func NewMockBackend() *MockBackend {
        return &MockBackend{
                blocks: make(chan *chainntnfs.BlockEpoch),
                epochs: make(map[chainhash.Hash]*wire.MsgBlock),
                quit:   make(chan struct{}),
        }
}

func (m *MockBackend) RegisterBlockEpochNtfn(*chainntnfs.BlockEpoch) (
        *chainntnfs.BlockEpochEvent, error) {

        return &chainntnfs.BlockEpochEvent{
                Epochs: m.blocks,
        }, nil
}

func (m *MockBackend) GetBlock(hash *chainhash.Hash) (*wire.MsgBlock, error) {
        m.mu.RLock()
        defer m.mu.RUnlock()

        block, ok := m.epochs[*hash]
        if !ok {
                return nil, fmt.Errorf("unknown block for hash %x", hash)
        }

        return block, nil
}

func (m *MockBackend) ConnectEpoch(epoch *chainntnfs.BlockEpoch,
        block *wire.MsgBlock) {

        m.mu.Lock()
        m.epochs[*epoch.Hash] = block
        m.mu.Unlock()

        select {
        case m.blocks <- epoch:
        case <-m.quit:
        }
}

1	package lookout
2
3	import (
4	"fmt"
5	"sync"
6
7	"github.com/btcsuite/btcd/chaincfg/chainhash"
8	"github.com/btcsuite/btcd/wire"
9	"github.com/lightningnetwork/lnd/chainntnfs"
10	)
11
12	type MockBackend struct {
13	mu sync.RWMutex
14
15	blocks chan *chainntnfs.BlockEpoch
16	epochs map[chainhash.Hash]*wire.MsgBlock
17	quit chan struct{}
18	}
19
20	func NewMockBackend() *MockBackend {	1✔
21	return &MockBackend{	1✔
22	blocks: make(chan *chainntnfs.BlockEpoch),	1✔
23	epochs: make(map[chainhash.Hash]*wire.MsgBlock),	1✔
24	quit: make(chan struct{}),	1✔
25	}	1✔
26	}	1✔
27
28	func (m MockBackend) RegisterBlockEpochNtfn(chainntnfs.BlockEpoch) (
29	*chainntnfs.BlockEpochEvent, error) {	1✔
30		1✔
31	return &chainntnfs.BlockEpochEvent{	1✔
32	Epochs: m.blocks,	1✔
33	}, nil	1✔
34	}	1✔
35
36	func (m MockBackend) GetBlock(hash chainhash.Hash) (*wire.MsgBlock, error) {	2✔
37	m.mu.RLock()	2✔
38	defer m.mu.RUnlock()	2✔
39		2✔
40	block, ok := m.epochs[*hash]	2✔
41	if !ok {	2✔
42	return nil, fmt.Errorf("unknown block for hash %x", hash)	×
43	}	×
44
45	return block, nil	2✔
46	}
47
48	func (m MockBackend) ConnectEpoch(epoch chainntnfs.BlockEpoch,
49	block *wire.MsgBlock) {	2✔
50		2✔
51	m.mu.Lock()	2✔
52	m.epochs[*epoch.Hash] = block	2✔
53	m.mu.Unlock()	2✔
54		2✔
55	select {	2✔
56	case m.blocks <- epoch:	2✔
57	case <-m.quit:	×
58	}
59	}

lightningnetwork / lnd / 15951470896

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous