aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib')
-rw-r--r--server/lib/activitypub/actor.ts35
1 files changed, 25 insertions, 10 deletions
diff --git a/server/lib/activitypub/actor.ts b/server/lib/activitypub/actor.ts
index 897acee85..b7114bbee 100644
--- a/server/lib/activitypub/actor.ts
+++ b/server/lib/activitypub/actor.ts
@@ -12,12 +12,13 @@ import { logger } from '../../helpers/logger'
12import { createPrivateAndPublicKeys } from '../../helpers/peertube-crypto' 12import { createPrivateAndPublicKeys } from '../../helpers/peertube-crypto'
13import { doRequest, doRequestAndSaveToFile } from '../../helpers/requests' 13import { doRequest, doRequestAndSaveToFile } from '../../helpers/requests'
14import { getUrlFromWebfinger } from '../../helpers/webfinger' 14import { getUrlFromWebfinger } from '../../helpers/webfinger'
15import { IMAGE_MIMETYPE_EXT, CONFIG, sequelizeTypescript } from '../../initializers' 15import { IMAGE_MIMETYPE_EXT, CONFIG, sequelizeTypescript, CONSTRAINTS_FIELDS } from '../../initializers'
16import { AccountModel } from '../../models/account/account' 16import { AccountModel } from '../../models/account/account'
17import { ActorModel } from '../../models/activitypub/actor' 17import { ActorModel } from '../../models/activitypub/actor'
18import { AvatarModel } from '../../models/avatar/avatar' 18import { AvatarModel } from '../../models/avatar/avatar'
19import { ServerModel } from '../../models/server/server' 19import { ServerModel } from '../../models/server/server'
20import { VideoChannelModel } from '../../models/video/video-channel' 20import { VideoChannelModel } from '../../models/video/video-channel'
21import { truncate } from 'lodash'
21 22
22// Set account keys, this could be long so process after the account creation and do not block the client 23// Set account keys, this could be long so process after the account creation and do not block the client
23function setAsyncActorKeys (actor: ActorModel) { 24function setAsyncActorKeys (actor: ActorModel) {
@@ -166,6 +167,24 @@ async function fetchAvatarIfExists (actorJSON: ActivityPubActor) {
166 return undefined 167 return undefined
167} 168}
168 169
170function normalizeActor (actor: any) {
171 if (!actor) return
172
173 if (!actor.url || typeof actor.url !== 'string') {
174 actor.url = actor.url.href || actor.url.url
175 }
176
177 if (actor.summary && typeof actor.summary === 'string') {
178 actor.summary = truncate(actor.summary, { length: CONSTRAINTS_FIELDS.USERS.DESCRIPTION.max })
179
180 if (actor.summary.length < CONSTRAINTS_FIELDS.USERS.DESCRIPTION.min) {
181 actor.summary = null
182 }
183 }
184
185 return
186}
187
169export { 188export {
170 getOrCreateActorAndServerAndModel, 189 getOrCreateActorAndServerAndModel,
171 buildActorInstance, 190 buildActorInstance,
@@ -173,7 +192,8 @@ export {
173 fetchActorTotalItems, 192 fetchActorTotalItems,
174 fetchAvatarIfExists, 193 fetchAvatarIfExists,
175 updateActorInstance, 194 updateActorInstance,
176 updateActorAvatarInstance 195 updateActorAvatarInstance,
196 normalizeActor
177} 197}
178 198
179// --------------------------------------------------------------------------- 199// ---------------------------------------------------------------------------
@@ -255,7 +275,9 @@ async function fetchRemoteActor (actorUrl: string): Promise<FetchRemoteActorResu
255 logger.info('Fetching remote actor %s.', actorUrl) 275 logger.info('Fetching remote actor %s.', actorUrl)
256 276
257 const requestResult = await doRequest(options) 277 const requestResult = await doRequest(options)
258 const actorJSON: ActivityPubActor = normalizeActor(requestResult.body) 278 normalizeActor(requestResult.body)
279
280 const actorJSON: ActivityPubActor = requestResult.body
259 281
260 if (isActorObjectValid(actorJSON) === false) { 282 if (isActorObjectValid(actorJSON) === false) {
261 logger.debug('Remote actor JSON is not valid.', { actorJSON: actorJSON }) 283 logger.debug('Remote actor JSON is not valid.', { actorJSON: actorJSON })
@@ -372,10 +394,3 @@ async function refreshActorIfNeeded (actor: ActorModel) {
372 return actor 394 return actor
373 } 395 }
374} 396}
375
376function normalizeActor (actor: any) {
377 if (actor && actor.url && typeof actor.url === 'string') return actor
378
379 actor.url = actor.url.href || actor.url.url
380 return actor
381}