message

package
v0.0.0-...-5349944 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 28, 2023 License: MIT Imports: 14 Imported by: 1

Documentation

Index

Constants

View Source
const (
	API_SEND_PRIVATE_MSG = "send_private_msg"
	API_SEND_GROUP_MSG   = "send_group_msg"
	// API_SEND_MSG         = "send_msg"
	API_GET_MSG                  = "get_msg"
	API_DELETE_MSG               = "delete_msg"
	API_MARK_MSG_AS_READ         = "mark_msg_as_read"
	API_GET_FORWARD_MSG          = "get_forward_msg"
	API_SEND_GROUP_FORWARD_MSG   = "send_group_forward_msg"
	API_SEND_PRIVATE_FORWARD_MSG = "send_private_forward_msg"
	API_GET_GROUP_MSG_HISTORY    = "get_group_msg_history"
)

Variables

View Source
var File_api_message_proto protoreflect.FileDescriptor

Functions

func RegisterOnebotApiMessageGRPCServiceServer

func RegisterOnebotApiMessageGRPCServiceServer(s *grpc.Server, srv OnebotApiMessageGRPCServiceServer)

Types

type ChannelApiMessageClient

type ChannelApiMessageClient struct {
	channel.ApiChannel
	// contains filtered or unexported fields
}

func (*ChannelApiMessageClient) DeleteMsg

func (cli *ChannelApiMessageClient) DeleteMsg(id int64) error

撤回消息 delete_msg

func (*ChannelApiMessageClient) GetForwardMsg

获取合并转发消息 get_forward_msg

func (*ChannelApiMessageClient) GetGroupMsgHistory

func (cli *ChannelApiMessageClient) GetGroupMsgHistory(message_seq int64, groupId int64) (*model.MessagesResult, error)

获取群消息历史记录 get_group_msg_history

func (*ChannelApiMessageClient) GetMsg

获取消息 get_msg

func (*ChannelApiMessageClient) MarkMsgAsRead

func (cli *ChannelApiMessageClient) MarkMsgAsRead(id int64) error

标记消息已读 mark_msg_as_read

func (*ChannelApiMessageClient) SendGroupForwardMsg

func (cli *ChannelApiMessageClient) SendGroupForwardMsg(groupId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)

发送合并转发 ( 群聊 ) send_group_forward_msg

func (*ChannelApiMessageClient) SendGroupMsg

func (cli *ChannelApiMessageClient) SendGroupMsg(msg *model.GroupMsg) (*model.SendMessageResult, error)

发送群消息 send_group_msg msg 消息

func (*ChannelApiMessageClient) SendMsg

发送消息

func (*ChannelApiMessageClient) SendPrivateForwardMsg

func (cli *ChannelApiMessageClient) SendPrivateForwardMsg(userId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)

发送合并转发 ( 好友 ) send_private_forward_msg

func (*ChannelApiMessageClient) SendPrivateMsg

func (cli *ChannelApiMessageClient) SendPrivateMsg(msg *model.PrivateMsg) (*model.SendMessageResult, error)

发送私信 send_private_msg msg 消息

type GetGroupMsgHistoryRequest

type GetGroupMsgHistoryRequest struct {
	GroupId    int64 `protobuf:"varint,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
	MessageSeq int64 `protobuf:"varint,2,opt,name=message_seq,json=messageSeq,proto3" json:"message_seq,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGroupMsgHistoryRequest) Descriptor deprecated

func (*GetGroupMsgHistoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetGroupMsgHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetGroupMsgHistoryRequest) GetGroupId

func (x *GetGroupMsgHistoryRequest) GetGroupId() int64

func (*GetGroupMsgHistoryRequest) GetMessageSeq

func (x *GetGroupMsgHistoryRequest) GetMessageSeq() int64

func (*GetGroupMsgHistoryRequest) ProtoMessage

func (*GetGroupMsgHistoryRequest) ProtoMessage()

func (*GetGroupMsgHistoryRequest) ProtoReflect

func (*GetGroupMsgHistoryRequest) Reset

func (x *GetGroupMsgHistoryRequest) Reset()

func (*GetGroupMsgHistoryRequest) String

func (x *GetGroupMsgHistoryRequest) String() string

type OnebotApiMessageClient

type OnebotApiMessageClient interface {
	// 发送私信
	// send_private_msg
	// msg 消息
	SendPrivateMsg(msg *model.PrivateMsg) (*model.SendMessageResult, error)
	// 发送群消息
	// send_group_msg
	// msg 消息
	SendGroupMsg(msg *model.GroupMsg) (*model.SendMessageResult, error)
	// 发送消息
	SendMsg(msg *model.MsgForSend) (*model.SendMessageResult, error)
	// 获取消息
	// get_msg
	GetMsg(id int64) (*model.MessageDataResult, error)
	// 撤回消息
	// delete_msg
	DeleteMsg(id int64) error
	// 标记消息已读
	// mark_msg_as_read
	MarkMsgAsRead(id int64) error
	// 获取合并转发消息
	// get_forward_msg
	GetForwardMsg(id int64) (*model.ForwardMessageDataResult, error)
	// 发送合并转发 ( 群聊 )
	// send_group_forward_msg
	SendGroupForwardMsg(groupId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)
	// 发送合并转发 ( 好友 )
	// send_private_forward_msg
	SendPrivateForwardMsg(userId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)
	// 获取群消息历史记录
	// get_group_msg_history
	GetGroupMsgHistory(message_seq, groupId int64) (*model.MessagesResult, error)
}

func NewChannelApiMessageClient

func NewChannelApiMessageClient(channel channel.ApiChannel, conf *config.OnebotApiConfig) (OnebotApiMessageClient, error)

type OnebotApiMessageGRPCServiceClient

type OnebotApiMessageGRPCServiceClient interface {
	// 发送私信
	// send_private_msg
	// msg 消息
	SendPrivateMsg(ctx context.Context, in *model.PrivateMsgGRPC, opts ...grpc.CallOption) (*model.SendMessageResultGRPC, error)
	// 发送群消息
	// send_group_msg
	// msg 消息
	SendGroupMsg(ctx context.Context, in *model.GroupMsgGRPC, opts ...grpc.CallOption) (*model.SendMessageResultGRPC, error)
	// 发送消息
	SendMsg(ctx context.Context, in *model.MsgForSendGRPC, opts ...grpc.CallOption) (*model.SendMessageResultGRPC, error)
	// 获取消息
	// get_msg
	GetMsg(ctx context.Context, in *wrapperspb.Int64Value, opts ...grpc.CallOption) (*model.MessageDataResultGRPC, error)
	// 撤回消息
	// delete_msg
	DeleteMsg(ctx context.Context, in *wrapperspb.Int64Value, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 标记消息已读
	// mark_msg_as_read
	MarkMsgAsRead(ctx context.Context, in *wrapperspb.Int64Value, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 获取合并转发消息
	// get_forward_msg
	GetForwardMsg(ctx context.Context, in *wrapperspb.Int64Value, opts ...grpc.CallOption) (*model.ForwardMessageDataResultGRPC, error)
	// 发送合并转发 ( 群聊 )
	// send_group_forward_msg
	SendGroupForwardMsg(ctx context.Context, in *SendGroupForwardMsgRequest, opts ...grpc.CallOption) (*model.SendForwardMessageDataResultGRPC, error)
	// 发送合并转发 ( 好友 )
	// send_private_forward_msg
	SendPrivateForwardMsg(ctx context.Context, in *SendPrivateForwardMsgGRPC, opts ...grpc.CallOption) (*model.SendForwardMessageDataResultGRPC, error)
	// 获取群消息历史记录
	// get_group_msg_history
	GetGroupMsgHistory(ctx context.Context, in *GetGroupMsgHistoryRequest, opts ...grpc.CallOption) (*model.MessagesResultGRPC, error)
}

OnebotApiMessageGRPCServiceClient is the client API for OnebotApiMessageGRPCService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type OnebotApiMessageGRPCServiceServer

type OnebotApiMessageGRPCServiceServer interface {
	// 发送私信
	// send_private_msg
	// msg 消息
	SendPrivateMsg(context.Context, *model.PrivateMsgGRPC) (*model.SendMessageResultGRPC, error)
	// 发送群消息
	// send_group_msg
	// msg 消息
	SendGroupMsg(context.Context, *model.GroupMsgGRPC) (*model.SendMessageResultGRPC, error)
	// 发送消息
	SendMsg(context.Context, *model.MsgForSendGRPC) (*model.SendMessageResultGRPC, error)
	// 获取消息
	// get_msg
	GetMsg(context.Context, *wrapperspb.Int64Value) (*model.MessageDataResultGRPC, error)
	// 撤回消息
	// delete_msg
	DeleteMsg(context.Context, *wrapperspb.Int64Value) (*emptypb.Empty, error)
	// 标记消息已读
	// mark_msg_as_read
	MarkMsgAsRead(context.Context, *wrapperspb.Int64Value) (*emptypb.Empty, error)
	// 获取合并转发消息
	// get_forward_msg
	GetForwardMsg(context.Context, *wrapperspb.Int64Value) (*model.ForwardMessageDataResultGRPC, error)
	// 发送合并转发 ( 群聊 )
	// send_group_forward_msg
	SendGroupForwardMsg(context.Context, *SendGroupForwardMsgRequest) (*model.SendForwardMessageDataResultGRPC, error)
	// 发送合并转发 ( 好友 )
	// send_private_forward_msg
	SendPrivateForwardMsg(context.Context, *SendPrivateForwardMsgGRPC) (*model.SendForwardMessageDataResultGRPC, error)
	// 获取群消息历史记录
	// get_group_msg_history
	GetGroupMsgHistory(context.Context, *GetGroupMsgHistoryRequest) (*model.MessagesResultGRPC, error)
}

OnebotApiMessageGRPCServiceServer is the server API for OnebotApiMessageGRPCService service.

type SendGroupForwardMsgRequest

type SendGroupForwardMsgRequest struct {
	GroupId  int64                       `protobuf:"varint,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
	Messages []*model.MessageSegmentGRPC `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*SendGroupForwardMsgRequest) Descriptor deprecated

func (*SendGroupForwardMsgRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendGroupForwardMsgRequest.ProtoReflect.Descriptor instead.

func (*SendGroupForwardMsgRequest) GetGroupId

func (x *SendGroupForwardMsgRequest) GetGroupId() int64

func (*SendGroupForwardMsgRequest) GetMessages

func (*SendGroupForwardMsgRequest) ProtoMessage

func (*SendGroupForwardMsgRequest) ProtoMessage()

func (*SendGroupForwardMsgRequest) ProtoReflect

func (*SendGroupForwardMsgRequest) Reset

func (x *SendGroupForwardMsgRequest) Reset()

func (*SendGroupForwardMsgRequest) String

func (x *SendGroupForwardMsgRequest) String() string

type SendPrivateForwardMsgGRPC

type SendPrivateForwardMsgGRPC struct {
	UserId   int64                       `protobuf:"varint,1,opt,name=userId,proto3" json:"userId,omitempty"`
	Messages []*model.MessageSegmentGRPC `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*SendPrivateForwardMsgGRPC) Descriptor deprecated

func (*SendPrivateForwardMsgGRPC) Descriptor() ([]byte, []int)

Deprecated: Use SendPrivateForwardMsgGRPC.ProtoReflect.Descriptor instead.

func (*SendPrivateForwardMsgGRPC) GetMessages

func (*SendPrivateForwardMsgGRPC) GetUserId

func (x *SendPrivateForwardMsgGRPC) GetUserId() int64

func (*SendPrivateForwardMsgGRPC) ProtoMessage

func (*SendPrivateForwardMsgGRPC) ProtoMessage()

func (*SendPrivateForwardMsgGRPC) ProtoReflect

func (*SendPrivateForwardMsgGRPC) Reset

func (x *SendPrivateForwardMsgGRPC) Reset()

func (*SendPrivateForwardMsgGRPC) String

func (x *SendPrivateForwardMsgGRPC) String() string

type UnimplementedOnebotApiMessageGRPCServiceServer

type UnimplementedOnebotApiMessageGRPCServiceServer struct {
}

UnimplementedOnebotApiMessageGRPCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedOnebotApiMessageGRPCServiceServer) DeleteMsg

func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetForwardMsg

func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetGroupMsgHistory

func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetMsg

func (*UnimplementedOnebotApiMessageGRPCServiceServer) MarkMsgAsRead

func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendGroupForwardMsg

func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendGroupMsg

func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendMsg

func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendPrivateForwardMsg

func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendPrivateMsg

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL