15561477203

Committed 10 Jun 2025 01:54PM UTC coverage: 58.351% (-10.1%) from 68.487%

Build # 15561477203

Build Type

Pull #9356

github

Committed by

web-flow

Commit Message

Merge 6440b25db into c6d6d4c0b

Pull Request Pull Request #9356: lnrpc: add incoming/outgoing channel ids filter to forwarding history request

Run Details

33 of 36 new or added lines in 2 files covered. (91.67%)

28366 existing lines in 455 files now uncovered.

97715 of 167461 relevant lines covered (58.35%)

1.81 hits per line

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

0.0

/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
UNCOV 20	func NewMockBackend() *MockBackend {	×
UNCOV 21	return &MockBackend{	×
UNCOV 22	blocks: make(chan *chainntnfs.BlockEpoch),	×
UNCOV 23	epochs: make(map[chainhash.Hash]*wire.MsgBlock),	×
UNCOV 24	quit: make(chan struct{}),	×
UNCOV 25	}	×
UNCOV 26	}	×
27
28	func (m MockBackend) RegisterBlockEpochNtfn(chainntnfs.BlockEpoch) (
UNCOV 29	*chainntnfs.BlockEpochEvent, error) {	×
UNCOV 30		×
UNCOV 31	return &chainntnfs.BlockEpochEvent{	×
UNCOV 32	Epochs: m.blocks,	×
UNCOV 33	}, nil	×
UNCOV 34	}	×
35
UNCOV 36	func (m MockBackend) GetBlock(hash chainhash.Hash) (*wire.MsgBlock, error) {	×
UNCOV 37	m.mu.RLock()	×
UNCOV 38	defer m.mu.RUnlock()	×
UNCOV 39		×
UNCOV 40	block, ok := m.epochs[*hash]	×
UNCOV 41	if !ok {	×
42	return nil, fmt.Errorf("unknown block for hash %x", hash)	×
43	}	×
44
UNCOV 45	return block, nil	×
46	}
47
48	func (m MockBackend) ConnectEpoch(epoch chainntnfs.BlockEpoch,
UNCOV 49	block *wire.MsgBlock) {	×
UNCOV 50		×
UNCOV 51	m.mu.Lock()	×
UNCOV 52	m.epochs[*epoch.Hash] = block	×
UNCOV 53	m.mu.Unlock()	×
UNCOV 54		×
UNCOV 55	select {	×
UNCOV 56	case m.blocks <- epoch:	×
57	case <-m.quit:	×
58	}
59	}

lightningnetwork / lnd / 15561477203

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