diff --git a/lib/actions/thread-actions.js b/lib/actions/thread-actions.js --- a/lib/actions/thread-actions.js +++ b/lib/actions/thread-actions.js @@ -32,6 +32,11 @@ success: 'DELETE_THREAD_SUCCESS', failed: 'DELETE_THREAD_FAILED', }); + +const deleteThreadEndpointOptions = { + timeout: 60000, +}; + const deleteThread = ( callKeyserverEndpoint: CallKeyserverEndpoint, @@ -40,7 +45,11 @@ const keyserverID = extractKeyserverIDFromID(input.threadID); const requests = { [keyserverID]: input }; - const responses = await callKeyserverEndpoint('delete_thread', requests); + const responses = await callKeyserverEndpoint( + 'delete_thread', + requests, + deleteThreadEndpointOptions, + ); const response = responses[keyserverID]; return { updatesResult: response.updatesResult, @@ -57,6 +66,11 @@ success: 'CHANGE_THREAD_SETTINGS_SUCCESS', failed: 'CHANGE_THREAD_SETTINGS_FAILED', }); + +const changeThreadSettingsEndpointOptions = { + timeout: 60000, +}; + const changeThreadSettings = ( callKeyserverEndpoint: CallKeyserverEndpoint, @@ -69,7 +83,11 @@ const keyserverID = extractKeyserverIDFromID(input.threadID); const requests = { [keyserverID]: input }; - const responses = await callKeyserverEndpoint('update_thread', requests); + const responses = await callKeyserverEndpoint( + 'update_thread', + requests, + changeThreadSettingsEndpointOptions, + ); const response = responses[keyserverID]; return { threadID: input.threadID, @@ -94,6 +112,11 @@ success: 'REMOVE_USERS_FROM_THREAD_SUCCESS', failed: 'REMOVE_USERS_FROM_THREAD_FAILED', }); + +const removeMembersFromThreadEndpointOptions = { + timeout: 60000, +}; + const removeUsersFromThread = ( callKeyserverEndpoint: CallKeyserverEndpoint, @@ -104,7 +127,11 @@ const keyserverID = extractKeyserverIDFromID(input.threadID); const requests = { [keyserverID]: input }; - const responses = await callKeyserverEndpoint('remove_members', requests); + const responses = await callKeyserverEndpoint( + 'remove_members', + requests, + removeMembersFromThreadEndpointOptions, + ); const response = responses[keyserverID]; return { threadID: input.threadID, @@ -130,6 +157,11 @@ success: 'CHANGE_THREAD_MEMBER_ROLES_SUCCESS', failed: 'CHANGE_THREAD_MEMBER_ROLES_FAILED', }); + +const changeThreadMemberRoleEndpointOptions = { + timeout: 60000, +}; + const changeThreadMemberRoles = ( callKeyserverEndpoint: CallKeyserverEndpoint, @@ -147,7 +179,11 @@ }, }; - const responses = await callKeyserverEndpoint('update_role', requests); + const responses = await callKeyserverEndpoint( + 'update_role', + requests, + changeThreadMemberRoleEndpointOptions, + ); const response = responses[keyserverID]; return { threadID,