message

package

v1.0.5 Latest Latest Go to latest Published: Feb 10, 2023 License: MIT Imports: 20 Imported by: 0

Details

View Source

const (
	SESSION_TYPE_MESSAGE = iota
	SESSION_TYPE_NOTIFY
)

This section is empty.

This section is empty.

type IMessageService struct {
	pb.UnimplementedIMessageServer
	// contains filtered or unexported fields
}

func NewIMessageService(imBiz *biz.IMBiz, log log.Logger, conf *conf.Bootstrap) *IMessageService

func (s *IMessageService) CreateMessage(ctx context.Context, req *pb.MessageReq) (*pb.MessageReply, error)

func (s *IMessageService) ListLastMessages(ctx context.Context, req *pb.ListLastMessageReq) (*pb.ListLastMessageReply, error)

func (s *IMessageService) ListMessage(ctx context.Context, req *pb.ListMessageReq) (*pb.ListMessageReply, error)

type MessageService struct {
	pb.UnimplementedMessageServer
	// contains filtered or unexported fields
}

func NewMessageService(conf *conf.Bootstrap, d biz.DataRepo, svr *socketio.SocketioServer, log log.Logger) *MessageService

func (s *MessageService) CreateMessage(ctx context.Context, req *pb.CreateMessageRequest) (*emptypb.Empty, error)

func (s *MessageService) GetAlismsCode(ctx context.Context, req *pb.Phone) (*emptypb.Empty, error)

func (s *MessageService) PostAlismsCode(ctx context.Context, req *pb.SMSCode) (*emptypb.Empty, error)

type SessionService struct {
	pb.UnimplementedSessionServer
	// contains filtered or unexported fields
}

func NewSessionService(imBiz *biz.IMBiz, logger log.Logger, conf *conf.Bootstrap) *SessionService

func (s *SessionService) CreateSession(ctx context.Context, req *pb.CreateSessionReq) (*pb.CreateSessionReply, error)

func (s *SessionService) CreateSessionUser(ctx context.Context, req *pb.CreateSessionUserReq) (*pb.CreateSessionUserReply, error)

func (s *SessionService) DeleteSessionUser(ctx context.Context, req *pb.DeleteSessionUserReq) (*pb.DeleteSessionUserReply, error)

func (s *SessionService) ListSessionUser(ctx context.Context, req *pb.ListSessionUserReq) (*pb.ListSessionUserReply, error)

func (s *SessionService) ListUserSession(ctx context.Context, req *pb.ListUserSessionReq) (*pb.ListSessionReply, error)

func (s *SessionService) PutSession(ctx context.Context, req *pb.PutSessionReq) (*pb.CreateSessionReply, error)

func (s *SessionService) User(ctx context.Context, req *pb.UserReq) (*pb.UserReply, error)

type SystemService struct {
	pb.UnimplementedSystemServer
	// contains filtered or unexported fields
}

func NewSystemService(imBiz *biz.IMBiz, logger log.Logger, conf *conf.Bootstrap) *SystemService

func (s *SystemService) CreatePlugin(ctx context.Context, req *pb.CreatePluginsReq) (*pb.CreatePluginsReply, error)

func (s *SystemService) DeletePlugin(ctx context.Context, req *pb.DeletePluginsReq) (*pb.DeletePluginsReply, error)

func (s *SystemService) ListPlugin(ctx context.Context, req *pb.ListPluginsReq) (*pb.CreatePluginsReply, error)

func (s *SystemService) PutPlugin(ctx context.Context, req *pb.PluginReply) (*pb.PluginReply, error)

func (s *SystemService) PutSystemConfig(ctx context.Context, req *pb.PutSystemConfigReq) (*pb.PutSystemConfigReply, error)