diff --git a/services/gunDB/Mediator/index.js b/services/gunDB/Mediator/index.js index d6c93292..009ef65f 100644 --- a/services/gunDB/Mediator/index.js +++ b/services/gunDB/Mediator/index.js @@ -510,6 +510,7 @@ class Mediator { this.generateHandshakeNode ) this.socket.on('GENERATE_ORDER_ADDRESS', this.generateOrderAddress) + this.socket.on('INIT_FEED_WALL', this.initWall) this.socket.on(Action.SEND_HANDSHAKE_REQUEST, this.sendHandshakeRequest) this.socket.on( Action.SEND_HANDSHAKE_REQUEST_WITH_INITIAL_MSG, @@ -772,6 +773,32 @@ class Mediator { } } + /** + * @param {Readonly<{ token: string }>} body + */ + initWall = async body => { + try { + const { token } = body + + await throwOnInvalidToken(token) + + await API.Actions.initWall() + + this.socket.emit('INIT_FEED_WALL', { + ok: true, + msg: null, + origBody: body + }) + } catch (err) { + logger.info(err) + this.socket.emit('INIT_FEED_WALL', { + ok: false, + msg: err.message, + origBody: body + }) + } + } + /** * @param {Readonly<{ recipientPublicKey: string , token: string }>} body */ diff --git a/services/gunDB/contact-api/actions.js b/services/gunDB/contact-api/actions.js index 39f5e1b9..74cc77b0 100644 --- a/services/gunDB/contact-api/actions.js +++ b/services/gunDB/contact-api/actions.js @@ -1424,7 +1424,7 @@ const createPost = async (tags, title, content) => { if (!Common.Schema.isPost(completePost)) { throw new Error( `completePost not a Post inside Actions.createPost(): ${JSON.stringify( - createPost + completePost )}` ) }