From 373d87e14881c3bd6488161d9f3bd0cae6ccb704 Mon Sep 17 00:00:00 2001 From: Pavel Prichodko <14926950+prichodko@users.noreply.github.com> Date: Thu, 9 Jun 2022 14:44:23 +0200 Subject: [PATCH] add methods for sending messages --- packages/status-js/src/client.ts | 37 ++++- .../src/client/community/community.ts | 149 +++++++++++++++++- 2 files changed, 184 insertions(+), 2 deletions(-) diff --git a/packages/status-js/src/client.ts b/packages/status-js/src/client.ts index 5395ff3b..742e9657 100644 --- a/packages/status-js/src/client.ts +++ b/packages/status-js/src/client.ts @@ -15,10 +15,12 @@ // todo?: ignore messages of not yet approved users // todo?: ignore messages with invalid signature -import { Waku } from 'js-waku' +import { hexToBytes } from 'ethereum-cryptography/utils' +import { Waku, WakuMessage } from 'js-waku' import { Account } from './account' import { Community } from './client/community/community' +import * as ams from './proto/status/v1/application_metadata_message' export interface ClientOptions { publicKey: string @@ -67,6 +69,9 @@ class Client { public createAccount = (): Account => { this.account = new Account() + // TODO: joining part of creation of an account + // await this.community.requestToJoin() + return this.account } @@ -74,6 +79,36 @@ class Client { // public deleteAccount = () => { // this.account = undefined // } + + public sendMessage = async ( + type: keyof typeof ams.ApplicationMetadataMessage_Type, + payload: Uint8Array, + contentTopic: string, + symKey: Uint8Array + ) => { + if (!this.waku) { + throw new Error('Waku not started') + } + + if (!this.account) { + throw new Error('Account not created') + } + + const signature = await this.account.sign(payload) + + const message = ams.ApplicationMetadataMessage.encode({ + type: ams.ApplicationMetadataMessage_Type[type], + signature, + payload, + }).finish() + + const wakuMesage = await WakuMessage.fromBytes(message, contentTopic, { + sigPrivKey: hexToBytes(this.account.privateKey), + symKey, + }) + + await this.waku.relay.send(wakuMesage) + } } export async function createClient(options: ClientOptions): Promise { diff --git a/packages/status-js/src/client/community/community.ts b/packages/status-js/src/client/community/community.ts index 3ab27270..88e3723e 100644 --- a/packages/status-js/src/client/community/community.ts +++ b/packages/status-js/src/client/community/community.ts @@ -1,6 +1,11 @@ import { waku_message } from 'js-waku' +import { hexToBytes } from 'js-waku/build/main/lib/utils' import difference from 'lodash/difference' +import { CommunityRequestToJoin, MessageType } from '~/protos/communities' +import { EmojiReaction } from '~/protos/emoji-reaction' + +import { ChatMessage } from '../../../protos/chat-message' import { idToContentTopic } from '../../contentTopic' import { createSymKeyFromPassword } from '../../encryption' import { createChannelContentTopics } from './create-channel-content-topics' @@ -8,10 +13,10 @@ import { fetchChannelChatMessages } from './fetch-channel-chat-messages' import { handleChannelChatMessage } from './handle-channel-chat-message' import { handleCommunity } from './handle-community' -import type { ChatMessage } from '../../../protos/chat-message' import type { Client } from '../../client' import type { CommunityDescription } from '../../wire/community_description' import type { Reactions } from './get-reactions' +import type { ImageMessage } from '~/src/proto/communities/v1/chat_message' import type { Waku, WakuMessage } from 'js-waku' export type CommunityMetadataType = CommunityDescription['proto'] @@ -237,4 +242,146 @@ export class Community { delete this.channelMessagesCallbacks[channelId] } } + + public sendTextMessage = async (chatUuid: string, message: string) => { + const chat = this.communityMetadata.chats[chatUuid] + + if (!chat) { + throw new Error('Chat not found') + } + + const chatId = `${this.communityPublicKey}${chatUuid}` + const channelContentTopic = idToContentTopic(chatId) + const symKey = await createSymKeyFromPassword(chatId) + + // TODO: protos does not support optional fields + // @ts-ignore + const payload = ChatMessage.encode({ + clock: BigInt(Date.now()), + timestamp: BigInt(Date.now()), + text: message, // string + responseTo: '', // string + ensName: '', // string + chatId: chatId, // string + messageType: MessageType.COMMUNITY_CHAT, + contentType: ChatMessage.ContentType.TEXT_PLAIN, + // sticker: '', // StickerMessage + // image: '', // ImageMessage + // audio: '', // AudioMessage + // community: '', // Uint8Array + // grant: '', // Uint8Array + // displayName: '', // string + }) + + await this.client.sendMessage( + 'TYPE_CHAT_MESSAGE', + payload, + channelContentTopic, + symKey + ) + } + + public sendImageMessage = async (chatUuid: string, image: ImageMessage) => { + const chat = this.communityMetadata.chats[chatUuid] + + if (!chat) { + throw new Error('Chat not found') + } + + // TODO: move to chat instance + const chatId = `${this.communityPublicKey}${chatUuid}` + const channelContentTopic = idToContentTopic(chatId) + const symKey = await createSymKeyFromPassword(chatId) + + const payload = ChatMessage.encode({ + clock: BigInt(Date.now()), + timestamp: BigInt(Date.now()), + responseTo: '', // string + ensName: '', // string + chatId: chatId, // string + messageType: MessageType.COMMUNITY_CHAT, + contentType: ChatMessage.ContentType.IMAGE, + image: { + type: image.type, + payload: image.payload, + }, + // sticker: '', // StickerMessage + // image: '', // ImageMessage + // audio: '', // AudioMessage + // community: '', // Uint8Array + // grant: '', // Uint8Array + // displayName: '', // string + }) + + await this.client.sendMessage( + 'TYPE_CHAT_MESSAGE', + payload, + channelContentTopic, + symKey + ) + } + + public sendReaction = async ( + chatUuid: string, + messageId: string, + reaction: EmojiReaction.Type + ) => { + const chat = this.communityMetadata.chats[chatUuid] + + if (!chat) { + throw new Error('Chat not found') + } + + // TODO: move to chat instance + const chatId = `${this.communityPublicKey}${chatUuid}` + const channelContentTopic = idToContentTopic(chatId) + const symKey = await createSymKeyFromPassword(chatId) + + const payload = EmojiReaction.encode({ + clock: BigInt(Date.now()), + chatId, + messageType: MessageType.COMMUNITY_CHAT, + messageId, + type: reaction, + // TODO: get message by id and derive state + retracted: false, + grant: new Uint8Array([]), + }) + + await this.client.sendMessage( + 'TYPE_EMOJI_REACTION', + payload, + channelContentTopic, + symKey + ) + } + + public requestToJoin = async (chatUuid: string) => { + if (!this.client.account) { + throw new Error('Account not found') + } + + const chat = this.communityMetadata.chats[chatUuid] + + if (!chat) { + throw new Error('Chat not found') + } + + // TODO: move to chat instance + const chatId = `${this.communityPublicKey}${chatUuid}` + + const payload = CommunityRequestToJoin.encode({ + chatId, + clock: BigInt(Date.now()), + communityId: hexToBytes(this.communityPublicKey), + ensName: '', + }) + + await this.client.sendMessage( + 'TYPE_COMMUNITY_REQUEST_TO_JOIN', + payload, + this.communityContentTopic, + this.communityDecryptionKey + ) + } }