connect/repositories/session_repositroy_test.go

package repositories

import (
	"context"
	"fmt"
	"log"
	"testing"

	"sikey.com/websocket/config"
	"x.sikey.com.cn/serverx/dbx"
)

func getSessionRepository() SessionRepository {
	config.MustLoadConfig("../etc/websocket.toml")
	source := dbx.GetConnect()
	return NewSessionRepository(source)
}

func TestSessionRepository_GetJoinedSessions(t *testing.T) {
	repo := getSessionRepository()
	sessions, err := repo.GetJoinedSessions(context.Background(), "2d2e78e8-eb61-47c5-8ebc-8e4d7313f577")
	if err != nil {
		log.Fatalln(err)
	}
	fmt.Println(sessions)
}

func TestSessionRepository_GetSessionMembers(t *testing.T) {
	repo := getSessionRepository()
	members, err := repo.GetSessionMembers(context.Background(), "S_1742730237273182208")
	if err != nil {
		log.Fatalln(err)
	}
	fmt.Println(members)
}

func TestSessionRepository_GetSessionMembersRemoveOneself(t *testing.T) {
	repo := getSessionRepository()
	members, err := repo.GetSessionMembersRemoveOneself(context.Background(), "S_1742730237273182208", "2d2e78e8-eb61-47c5-8ebc-8e4d7313f577")
	if err != nil {
		log.Fatalln(err)
	}
	fmt.Println(members)
}