1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
/**
* @copyright Copyright (c) 2019 Marco Ambrosini <marcoambrosini@pm.me>
*
* @author Marco Ambrosini <marcoambrosini@pm.me>
*
* @license AGPL-3.0-or-later
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/
import axios from '@nextcloud/axios'
import { generateOcsUrl } from '@nextcloud/router'
import SHA256 from 'crypto-js/sha256'
import Hex from 'crypto-js/enc-hex'
/**
* Fetches messages that belong to a particular conversation
* specified with its token.
*
* @param {object} data the wrapping object;
* @param {string} data.token the conversation token;
* @param {string} data.lastKnownMessageId last known message id;
* @param {boolean} data.includeLastKnown whether to include the last known message in the response;
* @param {object} options options;
*/
const fetchMessages = async function({ token, lastKnownMessageId, includeLastKnown }, options) {
return axios.get(generateOcsUrl('apps/spreed/api/v1/chat/{token}', { token }), Object.assign(options, {
params: {
setReadMarker: 0,
lookIntoFuture: 0,
lastKnownMessageId,
includeLastKnown: includeLastKnown ? 1 : 0,
},
}))
}
/**
* Fetches newly created messages that belong to a particular conversation
* specified with its token.
*
* @param {object} data the wrapping object;
* @param {number} data.lastKnownMessageId The id of the last message in the store.
* @param {string} data.token The conversation token;
* @param {object} options options
*/
const lookForNewMessages = async ({ token, lastKnownMessageId }, options) => {
return axios.get(generateOcsUrl('apps/spreed/api/v1/chat/{token}', { token }), Object.assign(options, {
params: {
setReadMarker: 0,
lookIntoFuture: 1,
lastKnownMessageId,
includeLastKnown: 0,
},
}))
}
/**
* Posts a new message to the server.
*
* @param {object} param0 The message object that is destructured
* @param {string} param0.token The conversation token
* @param {string} param0.message The message object
* @param {string} param0.actorDisplayName The display name of the actor
* @param {string} param0.referenceId A reference id to identify the message later again
* @param {number} param0.parent The id of the message to be replied to
* @param {object} options request options
*/
const postNewMessage = async function({ token, message, actorDisplayName, referenceId, parent }, options) {
return axios.post(generateOcsUrl('apps/spreed/api/v1/chat/{token}', { token }), {
message,
actorDisplayName,
referenceId,
replyTo: parent,
}, options)
}
/**
* Deletes a message from the server.
*
* @param {object} param0 The message object that is destructured
* @param {string} param0.token The conversation token
* @param {string} param0.id The id of the message to be deleted
*/
const deleteMessage = async function({ token, id }) {
return axios.delete(generateOcsUrl('apps/spreed/api/v1/chat/{token}/{id}', { token, id }))
}
/**
* Post a rich object to a conversation
*
* @param {string} token conversation token
* @param {object} data the wrapping object;
* @param {string} data.objectType object type
* @param {string} data.objectId object id
* @param {string} data.metaData JSON metadata of the rich object encoded as string
* @param {string} data.referenceId generated reference id, leave empty to generate it based on the other args
*/
const postRichObjectToConversation = async function(token, { objectType, objectId, metaData, referenceId }) {
if (!referenceId) {
const tempId = 'richobject-' + objectType + '-' + objectId + '-' + token + '-' + (new Date().getTime())
referenceId = Hex.stringify(SHA256(tempId))
}
return axios.post(generateOcsUrl('apps/spreed/api/v1/chat/{token}/share', { token }), {
objectType,
objectId,
metaData,
referenceId,
})
}
/**
* Updates the last read message id
*
* @param {string} token The token of the conversation to be removed from favorites
* @param {number} lastReadMessage id of the last read message to set
*/
const updateLastReadMessage = async function(token, lastReadMessage) {
return axios.post(generateOcsUrl('apps/spreed/api/v1/chat/{token}/read', { token }), {
lastReadMessage,
})
}
export {
fetchMessages,
lookForNewMessages,
postNewMessage,
deleteMessage,
postRichObjectToConversation,
updateLastReadMessage,
}
|
