notifications

Documentation

Index

• Constants
• func NewNip47NotificationQueue() *nip47NotificationQueue
• type Nip47NotificationQueue
• type Nip47Notifier
  • func NewNip47Notifier(relay Relay, db *gorm.DB, cfg config.Config, keys keys.Keys, ...) *Nip47Notifier
  • func (notifier *Nip47Notifier) ConsumeEvent(ctx context.Context, event *events.Event) error
• type Notification
• type PaymentReceivedNotification
• type PaymentSentNotification
• type Relay

Constants

const (
	PAYMENT_RECEIVED_NOTIFICATION = "payment_received"
	PAYMENT_SENT_NOTIFICATION     = "payment_sent"
)

Functions

func NewNip47NotificationQueue

func NewNip47NotificationQueue() *nip47NotificationQueue

Queue events that will be consumed when the relay connection is online

Types

type Nip47NotificationQueue

type Nip47NotificationQueue interface {
	events.EventSubscriber
	Channel() <-chan *events.Event
}

type Nip47Notifier

type Nip47Notifier struct {
	// contains filtered or unexported fields
}

func NewNip47Notifier

func NewNip47Notifier(relay Relay, db *gorm.DB, cfg config.Config, keys keys.Keys, permissionsSvc permissions.PermissionsService, lnClient lnclient.LNClient) *Nip47Notifier

func (*Nip47Notifier) ConsumeEvent

func (notifier *Nip47Notifier) ConsumeEvent(ctx context.Context, event *events.Event) error

type Notification

type Notification struct {
	Notification     interface{} `json:"notification,omitempty"`
	NotificationType string      `json:"notification_type"`
}

type PaymentReceivedNotification

type PaymentReceivedNotification struct {
	models.Transaction
}

type PaymentSentNotification

type PaymentSentNotification struct {
	models.Transaction
}

type Relay

type Relay interface {
	Publish(ctx context.Context, event nostr.Event) error
}