pushnotification

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 2, 2026 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dispatcher 

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

func NewDispatcher 

func NewDispatcher(eventBus *eventbus.Bus, interactionRepo interaction.Repository, taskRepo task.Repository, sender *Sender) *Dispatcher

func (*Dispatcher) Start 

func (d *Dispatcher) Start(ctx context.Context)

type NotificationPayload 

type NotificationPayload struct {
	Title string `json:"title"`
	Body  string `json:"body"`
	URL   string `json:"url,omitempty"`
	Tag   string `json:"tag,omitempty"`
}

type Sender 

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

func NewSender 

func NewSender(vapidEnv *config.VAPIDEnv, repo pushsubscription.Repository) *Sender

func (*Sender) SendToAll 

func (s *Sender) SendToAll(ctx context.Context, payload *NotificationPayload)

type Server 

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

func NewServer 

func NewServer(vapidEnv *config.VAPIDEnv, repo pushsubscription.Repository, sender *Sender) *Server

func (*Server) GetVapidPublicKey 

func (s *Server) GetVapidPublicKey(_ context.Context, _ *connect.Request[taskguildv1.GetVapidPublicKeyRequest]) (*connect.Response[taskguildv1.GetVapidPublicKeyResponse], error)

func (*Server) RegisterPushSubscription 

func (s *Server) RegisterPushSubscription(ctx context.Context, req *connect.Request[taskguildv1.RegisterPushSubscriptionRequest]) (*connect.Response[taskguildv1.RegisterPushSubscriptionResponse], error)

func (*Server) SendTestNotification 

func (s *Server) SendTestNotification(ctx context.Context, _ *connect.Request[taskguildv1.SendTestNotificationRequest]) (*connect.Response[taskguildv1.SendTestNotificationResponse], error)

func (*Server) UnregisterPushSubscription 

func (s *Server) UnregisterPushSubscription(ctx context.Context, req *connect.Request[taskguildv1.UnregisterPushSubscriptionRequest]) (*connect.Response[taskguildv1.UnregisterPushSubscriptionResponse], error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.