session_repositroy_test.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. package repositories
  2. import (
  3. "context"
  4. "fmt"
  5. "log"
  6. "testing"
  7. "sikey.com/websocket/config"
  8. "sikey.com/websocket/pkg/dbx"
  9. )
  10. func getSessionRepository() SessionRepository {
  11. config.MustLoadConfig("../etc/websocket.toml")
  12. source := dbx.GetConnect()
  13. return NewSessionRepository(source)
  14. }
  15. func TestSessionRepository_GetJoinedSessions(t *testing.T) {
  16. repo := getSessionRepository()
  17. sessions, err := repo.GetJoinedSessions(context.Background(), "2d2e78e8-eb61-47c5-8ebc-8e4d7313f577")
  18. if err != nil {
  19. log.Fatalln(err)
  20. }
  21. fmt.Println(sessions)
  22. }
  23. func TestSessionRepository_GetSessionMembers(t *testing.T) {
  24. repo := getSessionRepository()
  25. members, err := repo.GetSessionMembers(context.Background(), "S_1742730237273182208")
  26. if err != nil {
  27. log.Fatalln(err)
  28. }
  29. fmt.Println(members)
  30. }
  31. func TestSessionRepository_GetSessionMembersRemoveOneself(t *testing.T) {
  32. repo := getSessionRepository()
  33. members, err := repo.GetSessionMembersRemoveOneself(context.Background(), "S_1742730237273182208", "2d2e78e8-eb61-47c5-8ebc-8e4d7313f577")
  34. if err != nil {
  35. log.Fatalln(err)
  36. }
  37. fmt.Println(members)
  38. }