dbservice

package

v1.9.4 Latest Latest Go to latest Published: Oct 31, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(ctx context.Context, db *gorm.DB, logger *logrus.Logger) *DatabaseService

func (s *DatabaseService) DeleteAnalyticByFileId(fileId string) (int64, error)

func (s *DatabaseService) DeleteRecording(recordId string) (int64, error)

func (s *DatabaseService) GetActiveRoomsInfo() ([]dbmodels.RoomInfo, error)

func (s *DatabaseService) GetAnalyticByFileId(fileId string) (*dbmodels.Analytics, error)

func (s *DatabaseService) GetAnalyticByRoomTableId(roomTableId uint64) (*dbmodels.Analytics, error)

func (s *DatabaseService) GetAnalytics(roomIds []string, offset, limit uint64, direction *string) ([]dbmodels.Analytics, int64, error)

func (s *DatabaseService) GetPastRooms(roomIds []string, offset, limit uint64, direction *string) ([]dbmodels.RoomInfo, int64, error)

func (s *DatabaseService) GetRecording(recordId string) (*dbmodels.Recording, error)

func (s *DatabaseService) GetRecordings(roomIds []string, offset, limit uint64, direction *string) ([]dbmodels.Recording, int64, error)

func (s *DatabaseService) GetRecordingsForBBB(recordIds, meetingIds []string, offset, limit uint64) ([]dbmodels.Recording, int64, error)

func (s *DatabaseService) GetRoomInfoByRoomId(roomId string, isRunning int) (*dbmodels.RoomInfo, error)

func (s *DatabaseService) GetRoomInfoBySid(sId string, isRunning *int) (*dbmodels.RoomInfo, error)

func (s *DatabaseService) GetRoomInfoByTableId(tableId uint64) (*dbmodels.RoomInfo, error)

func (s *DatabaseService) IncrementOrDecrementNumParticipants(sId, operator string) (int64, error)

IncrementOrDecrementNumParticipants will increment or decrement the number of Participants

func (s *DatabaseService) InsertAnalyticsData(info *dbmodels.Analytics) (int64, error)

func (s *DatabaseService) InsertOrUpdateRoomInfo(info *dbmodels.RoomInfo) (int64, error)

InsertOrUpdateRoomInfo will insert if sid do not duplicate otherwise it will update if table ID was sent

func (s *DatabaseService) InsertRecordingData(info *dbmodels.Recording) (int64, error)

func (s *DatabaseService) UpdateNumParticipants(sId string, num int64) (int64, error)

func (s *DatabaseService) UpdateRoomRTMPStatus(roomTableId uint64, isActiveRtmp int, rtmpNodeId *string) (int64, error)

func (s *DatabaseService) UpdateRoomRecordingStatus(roomTableId uint64, isRecording int, recorderId *string) (int64, error)

func (s *DatabaseService) UpdateRoomStatus(info *dbmodels.RoomInfo) (int64, error)