mirror of
https://github.com/status-im/status-lib.git
synced 2025-02-18 07:16:40 +00:00
4eab2fa86b
- all unused/unnecessary files remove - `statusgo_backend_new` content promoted to main content - only necessary submodules for `status-lib` are kept
67 lines
3.3 KiB
Nim
67 lines
3.3 KiB
Nim
import json
|
|
import core, utils
|
|
import response_type
|
|
|
|
export response_type
|
|
|
|
proc fetchMessages*(chatId: string, cursorVal: string, limit: int): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [chatId, cursorVal, limit]
|
|
result = callPrivateRPC("chatMessages".prefix, payload)
|
|
|
|
proc fetchPinnedMessages*(chatId: string, cursorVal: string, limit: int): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [chatId, cursorVal, limit]
|
|
result = callPrivateRPC("chatPinnedMessages".prefix, payload)
|
|
|
|
proc fetchReactions*(chatId: string, cursorVal: string, limit: int): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [chatId, cursorVal, limit]
|
|
result = callPrivateRPC("emojiReactionsByChatID".prefix, payload)
|
|
|
|
proc addReaction*(chatId: string, messageId: string, emojiId: int): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [chatId, messageId, emojiId]
|
|
result = callPrivateRPC("sendEmojiReaction".prefix, payload)
|
|
|
|
proc removeReaction*(reactionId: string): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [reactionId]
|
|
result = callPrivateRPC("sendEmojiReactionRetraction".prefix, payload)
|
|
|
|
proc pinUnpinMessage*(chatId: string, messageId: string, pin: bool): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %*[{
|
|
"message_id": messageId,
|
|
"pinned": pin,
|
|
"chat_id": chatId
|
|
}]
|
|
result = callPrivateRPC("sendPinMessage".prefix, payload)
|
|
|
|
proc fetchMessageByMessageId*(messageId: string): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [messageId]
|
|
result = callPrivateRPC("messageByMessageID".prefix, payload)
|
|
|
|
proc fetchReactionsForMessageWithId*(chatId: string, messageId: string): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [chatId, messageId]
|
|
result = callPrivateRPC("emojiReactionsByChatIDMessageID".prefix, payload)
|
|
|
|
proc fetchAllMessagesFromChatWhichMatchTerm*(chatId: string, searchTerm: string, caseSensitive: bool):
|
|
RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [chatId, searchTerm, caseSensitive]
|
|
result = callPrivateRPC("allMessagesFromChatWhichMatchTerm".prefix, payload)
|
|
|
|
proc fetchAllMessagesFromChatsAndCommunitiesWhichMatchTerm*(communityIds: seq[string], chatIds: seq[string],
|
|
searchTerm: string, caseSensitive: bool): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [communityIds, chatIds, searchTerm, caseSensitive]
|
|
result = callPrivateRPC("allMessagesFromChatsAndCommunitiesWhichMatchTerm".prefix, payload)
|
|
|
|
proc markAllMessagesFromChatWithIdAsRead*(chatId: string): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [chatId]
|
|
result = callPrivateRPC("markAllRead".prefix, payload)
|
|
|
|
proc markCertainMessagesFromChatWithIdAsRead*(chatId: string, messageIds: seq[string]):
|
|
RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
let payload = %* [chatId, messageIds]
|
|
result = callPrivateRPC("markMessagesSeen".prefix, payload)
|
|
|
|
proc deleteMessageAndSend*(messageID: string): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
result = callPrivateRPC("deleteMessageAndSend".prefix, %* [messageID])
|
|
|
|
proc editMessage*(messageId: string, msg: string): RpcResponse[JsonNode] {.raises: [Exception].} =
|
|
result = callPrivateRPC("editMessage".prefix, %* [{"id": messageId, "text": msg}])
|