// Code generated by goctl. DO NOT EDIT.
// goctl 1.7.3
// Source: rtc.proto

package server

import (
	"context"

	"self-im-rtc/internal/logic/rtcservice"
	"self-im-rtc/internal/svc"
	"self-im-rtc/pb/rtc"
)

type RtcServiceServer struct {
	svcCtx *svc.ServiceContext
	rtc.UnimplementedRtcServiceServer
}

func NewRtcServiceServer(svcCtx *svc.ServiceContext) *RtcServiceServer {
	return &RtcServiceServer{
		svcCtx: svcCtx,
	}
}

func (s *RtcServiceServer) SignalMessageAssemble(ctx context.Context, in *rtc.SignalMessageAssembleReq) (*rtc.SignalMessageAssembleResp, error) {
	l := rtcservicelogic.NewSignalMessageAssembleLogic(ctx, s.svcCtx)
	return l.SignalMessageAssemble(in)
}

func (s *RtcServiceServer) SignalGetRoomByGroupID(ctx context.Context, in *rtc.SignalGetRoomByGroupIDReq) (*rtc.SignalGetRoomByGroupIDResp, error) {
	l := rtcservicelogic.NewSignalGetRoomByGroupIDLogic(ctx, s.svcCtx)
	return l.SignalGetRoomByGroupID(in)
}

func (s *RtcServiceServer) SignalGetTokenByRoomID(ctx context.Context, in *rtc.SignalGetTokenByRoomIDReq) (*rtc.SignalGetTokenByRoomIDResp, error) {
	l := rtcservicelogic.NewSignalGetTokenByRoomIDLogic(ctx, s.svcCtx)
	return l.SignalGetTokenByRoomID(in)
}

func (s *RtcServiceServer) SignalGetRooms(ctx context.Context, in *rtc.SignalGetRoomsReq) (*rtc.SignalGetRoomsResp, error) {
	l := rtcservicelogic.NewSignalGetRoomsLogic(ctx, s.svcCtx)
	return l.SignalGetRooms(in)
}

func (s *RtcServiceServer) GetSignalInvitationInfo(ctx context.Context, in *rtc.GetSignalInvitationInfoReq) (*rtc.GetSignalInvitationInfoResp, error) {
	l := rtcservicelogic.NewGetSignalInvitationInfoLogic(ctx, s.svcCtx)
	return l.GetSignalInvitationInfo(in)
}

func (s *RtcServiceServer) GetSignalInvitationInfoStartApp(ctx context.Context, in *rtc.GetSignalInvitationInfoStartAppReq) (*rtc.GetSignalInvitationInfoStartAppResp, error) {
	l := rtcservicelogic.NewGetSignalInvitationInfoStartAppLogic(ctx, s.svcCtx)
	return l.GetSignalInvitationInfoStartApp(in)
}

// meeting
func (s *RtcServiceServer) SignalCreateMeeting(ctx context.Context, in *rtc.SignalCreateMeetingReq) (*rtc.SignalCreateMeetingResp, error) {
	l := rtcservicelogic.NewSignalCreateMeetingLogic(ctx, s.svcCtx)
	return l.SignalCreateMeeting(in)
}

func (s *RtcServiceServer) SignalJoinMeeting(ctx context.Context, in *rtc.SignalJoinMeetingReq) (*rtc.SignalJoinMeetingResp, error) {
	l := rtcservicelogic.NewSignalJoinMeetingLogic(ctx, s.svcCtx)
	return l.SignalJoinMeeting(in)
}

func (s *RtcServiceServer) SignalUpdateMeetingInfo(ctx context.Context, in *rtc.SignalUpdateMeetingInfoReq) (*rtc.SignalUpdateMeetingInfoResp, error) {
	l := rtcservicelogic.NewSignalUpdateMeetingInfoLogic(ctx, s.svcCtx)
	return l.SignalUpdateMeetingInfo(in)
}

func (s *RtcServiceServer) SignalCloseRoom(ctx context.Context, in *rtc.SignalCloseRoomReq) (*rtc.SignalCloseRoomResp, error) {
	l := rtcservicelogic.NewSignalCloseRoomLogic(ctx, s.svcCtx)
	return l.SignalCloseRoom(in)
}

func (s *RtcServiceServer) SignalGetMeetings(ctx context.Context, in *rtc.SignalGetMeetingsReq) (*rtc.SignalGetMeetingsResp, error) {
	l := rtcservicelogic.NewSignalGetMeetingsLogic(ctx, s.svcCtx)
	return l.SignalGetMeetings(in)
}

func (s *RtcServiceServer) SignalOperateStream(ctx context.Context, in *rtc.SignalOperateStreamReq) (*rtc.SignalOperateStreamResp, error) {
	l := rtcservicelogic.NewSignalOperateStreamLogic(ctx, s.svcCtx)
	return l.SignalOperateStream(in)
}

// custom signal
func (s *RtcServiceServer) SignalSendCustomSignal(ctx context.Context, in *rtc.SignalSendCustomSignalReq) (*rtc.SignalSendCustomSignalResp, error) {
	l := rtcservicelogic.NewSignalSendCustomSignalLogic(ctx, s.svcCtx)
	return l.SignalSendCustomSignal(in)
}

// rtc cms
func (s *RtcServiceServer) GetSignalInvitationRecords(ctx context.Context, in *rtc.GetSignalInvitationRecordsReq) (*rtc.GetSignalInvitationRecordsResp, error) {
	l := rtcservicelogic.NewGetSignalInvitationRecordsLogic(ctx, s.svcCtx)
	return l.GetSignalInvitationRecords(in)
}

func (s *RtcServiceServer) DeleteSignalRecords(ctx context.Context, in *rtc.DeleteSignalRecordsReq) (*rtc.DeleteSignalRecordsResp, error) {
	l := rtcservicelogic.NewDeleteSignalRecordsLogic(ctx, s.svcCtx)
	return l.DeleteSignalRecords(in)
}

func (s *RtcServiceServer) GetMeetingRecords(ctx context.Context, in *rtc.GetMeetingRecordsReq) (*rtc.GetMeetingRecordsResp, error) {
	l := rtcservicelogic.NewGetMeetingRecordsLogic(ctx, s.svcCtx)
	return l.GetMeetingRecords(in)
}

func (s *RtcServiceServer) DeleteMeetingRecords(ctx context.Context, in *rtc.DeleteMeetingRecordsReq) (*rtc.DeleteMeetingRecordsResp, error) {
	l := rtcservicelogic.NewDeleteMeetingRecordsLogic(ctx, s.svcCtx)
	return l.DeleteMeetingRecords(in)
}