status-im/waku-react-native
2
0
Fork 0
mirror of https://github.com/status-im/waku-react-native.git synced 2025-02-18 01:06:24 +00:00
Code Issues Projects Releases Wiki Activity

fix: add serializers for encrypted payloads

Browse Source 
The encrypted functions have slightly different APIs, so we decorate the
WakuMessage and only change its toJSON function.
This commit is contained in:
Brice Stacey 2023-02-09 15:14:48 -05:00 committed by RichΛrd
parent dd1f2a222b
commit dc6ab3cf27
1 changed files with 29 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/index.tsx
View File

@ -377,6 +377,27 @@ export function peerCnt(): Promise<Number> {
}); });
} }
export class EncryptedPayload extends WakuMessage {
constructor(msg: WakuMessage) {
super();
this.contentTopic = msg.contentTopic;
this.version = msg.version;
this.timestamp = msg.timestamp;
this.payload = msg.payload;
}
toJSON() {
return {
contentTopic: this.contentTopic,
version: this.version,
timestamp: this.timestamp
? bigInt(this.timestamp.valueOf()).multiply(OneMillion).toJSNumber()
: 0,
payload: Buffer.from(Array.from(this.payload)).toString('base64'),
};
}
}
export class DecodedPayload { export class DecodedPayload {
payload: Uint8Array = new Uint8Array(); payload: Uint8Array = new Uint8Array();
padding: Uint8Array = new Uint8Array(); padding: Uint8Array = new Uint8Array();
@ -404,7 +425,8 @@ export function decodeSymmetric(
symmetricKey: String symmetricKey: String
): Promise<DecodedPayload> { ): Promise<DecodedPayload> {
return new Promise<DecodedPayload>(async (resolve, reject) => { return new Promise<DecodedPayload>(async (resolve, reject) => {
let messageJSON = JSON.stringify(msg); let message = new EncryptedPayload(msg);
let messageJSON = JSON.stringify(message);
let response = JSON.parse( let response = JSON.parse(
await ReactNative.decodeSymmetric(messageJSON, symmetricKey) await ReactNative.decodeSymmetric(messageJSON, symmetricKey)
); );
@ -432,7 +454,8 @@ export function decodeAsymmetric(
privateKey: String privateKey: String
): Promise<DecodedPayload> { ): Promise<DecodedPayload> {
return new Promise<DecodedPayload>(async (resolve, reject) => { return new Promise<DecodedPayload>(async (resolve, reject) => {
let messageJSON = JSON.stringify(msg); let message = new EncryptedPayload(msg);
let messageJSON = JSON.stringify(message);
let response = JSON.parse( let response = JSON.parse(
await ReactNative.decodeAsymmetric(messageJSON, privateKey) await ReactNative.decodeAsymmetric(messageJSON, privateKey)
); );
@ -534,7 +557,8 @@ export function lightpushPublishEncAsymmetric(
timeoutMs: Number = 0 timeoutMs: Number = 0
): Promise<string> { ): Promise<string> {
return new Promise<string>(async (resolve, reject) => { return new Promise<string>(async (resolve, reject) => {
let messageJSON = JSON.stringify(msg); let message = new EncryptedPayload(msg);
let messageJSON = JSON.stringify(message);
let response = JSON.parse( let response = JSON.parse(
await ReactNative.lightpushPublishEncodeAsymmetric( await ReactNative.lightpushPublishEncodeAsymmetric(
messageJSON, messageJSON,
@ -572,7 +596,8 @@ export function lightpushPublishEncSymmetric(
timeoutMs: Number = 0 timeoutMs: Number = 0
): Promise<string> { ): Promise<string> {
return new Promise<string>(async (resolve, reject) => { return new Promise<string>(async (resolve, reject) => {
let messageJSON = JSON.stringify(msg); let message = new EncryptedPayload(msg);
let messageJSON = JSON.stringify(message);
let response = JSON.parse( let response = JSON.parse(
await ReactNative.lightpushPublishEncodeAsymmetric( await ReactNative.lightpushPublishEncodeAsymmetric(
messageJSON, messageJSON,