/
module.go
48 lines (37 loc) · 1.01 KB
/
module.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
package p2p
import (
"log"
"github.com/pokt-network/pocket/shared/config"
cryptoPocket "github.com/pokt-network/pocket/shared/crypto"
"github.com/pokt-network/pocket/shared/modules"
"github.com/pokt-network/pocket/shared/types"
"google.golang.org/protobuf/types/known/anypb"
)
type p2pModule struct {
bus modules.Bus
}
var _ modules.P2PModule = &p2pModule{}
func Create(config *config.Config) (modules.P2PModule, error) {
return &p2pModule{}, nil
}
func (m *p2pModule) Start() error {
panic("Not implemented")
}
func (m *p2pModule) Stop() error {
panic("Not implemented")
}
func (m *p2pModule) SetBus(bus modules.Bus) {
m.bus = bus
}
func (m *p2pModule) GetBus() modules.Bus {
if m.bus == nil {
log.Fatalf("PocketBus is not initialized")
}
return m.bus
}
func (m *p2pModule) Broadcast(msg *anypb.Any, topic types.PocketTopic) error {
panic("Broadcast not implemented")
}
func (m *p2pModule) Send(addr cryptoPocket.Address, msg *anypb.Any, topic types.PocketTopic) error {
panic("Send not implemented")
}