notification/example/main.go

package main

import (
	"fmt"

	"git.selly.red/Selly-Modules/natsio"

	"git.selly.red/Selly-Modules/notification"
)

func main() {
	c, err := notification.NewClient(notification.Config{
		APIKey: "UWvieSs2erFfhwvl1g8CavEY2V7ouc3",
		Nats: natsio.Config{
			URL:      "127.0.0.1:4222",
			User:     "",
			Password: "",
			TLS:      nil,
		},
	})
	if err != nil {
		panic(err)
	}

	userID := "61a499ad8d5770f8872b03d8"
	requestID, err := c.PushToUsers(notification.PushRequest{
		Title:    "Notification 1",
		Body:     "nats stream view notification",
		Data:     "{}",
		Users:    []string{userID},
		Label:    "tracking-label",
		Category: "order",
	})
	if err != nil {
		fmt.Println("Push err: ", err)
	}
	fmt.Println("Request id: ", requestID)

	total, err := c.CountUnread(notification.CountUnread{
		User:     userID,
		Category: "order",
	})
	fmt.Println("Count: ", total, err)

	res, err := c.Query(notification.Query{
		User:     userID,
		Category: "order",
		Page:     0,
		Limit:    20,
	})
	fmt.Println("Query : ", res, err)

	total, err = c.CountUnread(notification.CountUnread{
		User:     userID,
		Category: "order",
	})
	fmt.Println("Count: 2", total, err)

	err = c.Subscribe("test", []string{
		"eX1gEc7WokSHh-zJ3WR5Hn:APA91bFZDuzkjjFFL6TNpMg0ot93a0wsypWi4aCdm7M2x6AihgjS_QWsbKSFCT4hNhv_d8wKGy-DG6_3e8OlwPiWiJB4R33xLbbUekgxKcfCiiFooIC1E1OE3XWkvUtn4egn8aLG5jqv",
	})
	fmt.Println("Subscribe err: ", err)
}