connect/repositories/firebase_messaging_queue_repository_test.go

package repositories_test

import (
	"context"
	"fmt"
	"testing"

	"sikey.com/websocket/models"
	"sikey.com/websocket/pkg/confx"
	"sikey.com/websocket/pkg/dbx"
	"sikey.com/websocket/repositories"
)

func TestFirebaseMessageQueueRepository_Create(t *testing.T) {
	confx.LoadConfig("../etc/websocket.debug.yaml")
	repository := repositories.NewFirebaseMessageQueueRepository(dbx.GetConnect())
	err := repository.Create(context.Background(), &models.FirebaseMessagingQueue{
		Title: "New message",
		Body:  "received a new message",
		Data:  string("{}"),
		// Status:           -1,
		RemainingRetries: 3,
	})
	if err != nil {
		panic(err)
	}
}
func TestFirebaseMessageQueueRepository_FindRetrieableQueue(t *testing.T) {
	confx.LoadConfig("../etc/websocket.debug.yaml")
	repository := repositories.NewFirebaseMessageQueueRepository(dbx.GetConnect())
	queues, err := repository.FindRetrieableQueue(context.Background())
	if err != nil {
		panic(err)
	}
	fmt.Println(queues)
}