From 77d5329ca6f33c7607f4bf3211503214457a569f Mon Sep 17 00:00:00 2001 From: Pavel Murygin Date: Thu, 14 Jan 2021 19:47:26 +0300 Subject: [PATCH] Rename message -> entry everywhere --- client/src/app/{App1.tsx => App.tsx} | 4 ++-- client/src/app/CollaborativeEditor.tsx | 18 +++++++++--------- client/src/fluence/calls.ts | 22 ++++++++++------------ 3 files changed, 21 insertions(+), 23 deletions(-) rename client/src/app/{App1.tsx => App.tsx} (93%) diff --git a/client/src/app/App1.tsx b/client/src/app/App.tsx similarity index 93% rename from client/src/app/App1.tsx rename to client/src/app/App.tsx index d5a392c..33e1cb8 100644 --- a/client/src/app/App1.tsx +++ b/client/src/app/App.tsx @@ -3,7 +3,7 @@ import React, { useEffect, useState } from 'react'; import { connect } from 'src/fluence'; import './App.scss'; -import { FluenceClientContext, useFluenceClient } from './FluenceClientContext'; +import { FluenceClientContext } from './FluenceClientContext'; import { UserList } from './UserList'; import * as calls from 'src/fluence/calls'; import { CollaborativeEditor } from './CollaborativeEditor'; @@ -70,7 +70,7 @@ const App = () => {
{isInRoom && client && }
- {/*
{isInRoom && client && }
*/} +
{isInRoom && client && }
diff --git a/client/src/app/CollaborativeEditor.tsx b/client/src/app/CollaborativeEditor.tsx index a826e7f..72573e4 100644 --- a/client/src/app/CollaborativeEditor.tsx +++ b/client/src/app/CollaborativeEditor.tsx @@ -42,24 +42,24 @@ const getUpdatedDocFromText = (oldDoc: TextDoc | null, newText: string) => { return newDoc; }; -const parseState = (message: calls.Message) => { +const parseState = (entry: calls.Entry) => { try { - const obj = JSON.parse(message.body); + const obj = JSON.parse(entry.body); if (obj.fluentPadState) { return Automerge.load(obj.fluentPadState) as TextDoc; } return null; } catch (e) { - console.log('couldnt parse state format: ' + message.body); + console.log('couldnt parse state format: ' + entry.body); return null; } }; -const applyStates = (startingDoc: TextDoc | null, messages: calls.Message[]) => { +const applyStates = (startingDoc: TextDoc | null, entries: calls.Entry[]) => { let res = startingDoc; - for (let m of messages) { - const state = parseState(m) as TextDoc; + for (let entry of entries) { + const state = parseState(entry) as TextDoc; if (state) { if (!res) { res = state; @@ -107,12 +107,12 @@ export const CollaborativeEditor = () => { // don't block setImmediate(async () => { - const message = { + const entry = { fluentPadState: Automerge.save(newDoc), }; - const messageStr = JSON.stringify(message); + const entryStr = JSON.stringify(entry); - await calls.addMessage(client, messageStr); + await calls.addEntry(client, entryStr); }); }; diff --git a/client/src/fluence/calls.ts b/client/src/fluence/calls.ts index a97d6e5..8fe1a31 100644 --- a/client/src/fluence/calls.ts +++ b/client/src/fluence/calls.ts @@ -1,6 +1,4 @@ import { FluenceClient } from '@fluencelabs/fluence'; -import { idText } from 'typescript'; -import { fluenceClient } from '.'; import { fluentPadServiceId, historyNodePid, @@ -25,7 +23,7 @@ export interface User { name: string; } -export interface Message { +export interface Entry { id: number; body: string; } @@ -34,8 +32,8 @@ interface GetUsersResult extends ServiceResult { users: Array; } -interface GetMessagesResult extends ServiceResult { - messages: Message[]; +interface GetEntries extends ServiceResult { + entries: Entry[]; } const throwIfError = (result: ServiceResult) => { @@ -209,7 +207,7 @@ export const getHistory = async (client: FluenceClient) => { let getHistoryAir = ` (seq (call userlistNode (userlist "is_authenticated") [] token) - (call historyNode (history "get_all") [token.$.is_authenticated] messages) + (call historyNode (history "get_all") [token.$.is_authenticated] entries) ) `; @@ -219,12 +217,12 @@ export const getHistory = async (client: FluenceClient) => { data.set('userlistNode', userListNodePid); data.set('historyNode', historyNodePid); - const [result] = await client.fetch<[GetMessagesResult]>(getHistoryAir, ['messages'], data); + const [result] = await client.fetch<[GetEntries]>(getHistoryAir, ['entries'], data); throwIfError(result); - return result.messages; + return result.entries; }; -export const addMessage = async (client: FluenceClient, messageBody: string) => { +export const addEntry = async (client: FluenceClient, entry: string) => { const particle = new Particle( ` (seq @@ -234,12 +232,12 @@ export const addMessage = async (client: FluenceClient, messageBody: string) => (seq (call userlistNode (userlist "get_users") [] allUsers) (seq - (call node (history "add") [message token.$.["is_authenticated"]]) + (call node (history "add") [entry token.$.["is_authenticated"]]) (fold allUsers.$.users! u (par (seq (call u.$.relay_id ("op" "identity") []) - (call u.$.peer_id (fluentPadServiceId notifyTextUpdate) [message token.$.["is_authenticated"]]) + (call u.$.peer_id (fluentPadServiceId notifyTextUpdate) [entry token.$.["is_authenticated"]]) ) (next u) ) @@ -253,7 +251,7 @@ export const addMessage = async (client: FluenceClient, messageBody: string) => { userlistNode: userListNodePid, historyNode: historyNodePid, - message: messageBody, + entry: entry, userlist: userListServiceId, history: historyServiceId, myRelay: client.relayPeerID.toB58String(),