aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/job-queue/handlers/activitypub-follow.ts
diff options
context:
space:
mode:
authorChocobozzz <me@florianbigard.com>2023-07-31 14:34:36 +0200
committerChocobozzz <me@florianbigard.com>2023-08-11 15:02:33 +0200
commit3a4992633ee62d5edfbb484d9c6bcb3cf158489d (patch)
treee4510b39bdac9c318fdb4b47018d08f15368b8f0 /server/lib/job-queue/handlers/activitypub-follow.ts
parent04d1da5621d25d59bd5fa1543b725c497bf5d9a8 (diff)
downloadPeerTube-3a4992633ee62d5edfbb484d9c6bcb3cf158489d.tar.gz
PeerTube-3a4992633ee62d5edfbb484d9c6bcb3cf158489d.tar.zst
PeerTube-3a4992633ee62d5edfbb484d9c6bcb3cf158489d.zip
Migrate server to ESM
Sorry for the very big commit that may lead to git log issues and merge conflicts, but it's a major step forward: * Server can be faster at startup because imports() are async and we can easily lazy import big modules * Angular doesn't seem to support ES import (with .js extension), so we had to correctly organize peertube into a monorepo: * Use yarn workspace feature * Use typescript reference projects for dependencies * Shared projects have been moved into "packages", each one is now a node module (with a dedicated package.json/tsconfig.json) * server/tools have been moved into apps/ and is now a dedicated app bundled and published on NPM so users don't have to build peertube cli tools manually * server/tests have been moved into packages/ so we don't compile them every time we want to run the server * Use isolatedModule option: * Had to move from const enum to const (https://www.typescriptlang.org/docs/handbook/enums.html#objects-vs-enums) * Had to explictely specify "type" imports when used in decorators * Prefer tsx (that uses esbuild under the hood) instead of ts-node to load typescript files (tests with mocha or scripts): * To reduce test complexity as esbuild doesn't support decorator metadata, we only test server files that do not import server models * We still build tests files into js files for a faster CI * Remove unmaintained peertube CLI import script * Removed some barrels to speed up execution (less imports)
Diffstat (limited to 'server/lib/job-queue/handlers/activitypub-follow.ts')
-rw-r--r--server/lib/job-queue/handlers/activitypub-follow.ts82
1 files changed, 0 insertions, 82 deletions
diff --git a/server/lib/job-queue/handlers/activitypub-follow.ts b/server/lib/job-queue/handlers/activitypub-follow.ts
deleted file mode 100644
index a68c32ba0..000000000
--- a/server/lib/job-queue/handlers/activitypub-follow.ts
+++ /dev/null
@@ -1,82 +0,0 @@
1import { Job } from 'bullmq'
2import { getLocalActorFollowActivityPubUrl } from '@server/lib/activitypub/url'
3import { ActivitypubFollowPayload } from '@shared/models'
4import { sanitizeHost } from '../../../helpers/core-utils'
5import { retryTransactionWrapper } from '../../../helpers/database-utils'
6import { logger } from '../../../helpers/logger'
7import { REMOTE_SCHEME, WEBSERVER } from '../../../initializers/constants'
8import { sequelizeTypescript } from '../../../initializers/database'
9import { ActorModel } from '../../../models/actor/actor'
10import { ActorFollowModel } from '../../../models/actor/actor-follow'
11import { MActor, MActorFull } from '../../../types/models'
12import { getOrCreateAPActor, loadActorUrlOrGetFromWebfinger } from '../../activitypub/actors'
13import { sendFollow } from '../../activitypub/send'
14import { Notifier } from '../../notifier'
15
16async function processActivityPubFollow (job: Job) {
17 const payload = job.data as ActivitypubFollowPayload
18 const host = payload.host
19
20 logger.info('Processing ActivityPub follow in job %s.', job.id)
21
22 let targetActor: MActorFull
23 if (!host || host === WEBSERVER.HOST) {
24 targetActor = await ActorModel.loadLocalByName(payload.name)
25 } else {
26 const sanitizedHost = sanitizeHost(host, REMOTE_SCHEME.HTTP)
27 const actorUrl = await loadActorUrlOrGetFromWebfinger(payload.name + '@' + sanitizedHost)
28 targetActor = await getOrCreateAPActor(actorUrl, 'all')
29 }
30
31 if (payload.assertIsChannel && !targetActor.VideoChannel) {
32 logger.warn('Do not follow %s@%s because it is not a channel.', payload.name, host)
33 return
34 }
35
36 const fromActor = await ActorModel.load(payload.followerActorId)
37
38 return retryTransactionWrapper(follow, fromActor, targetActor, payload.isAutoFollow)
39}
40// ---------------------------------------------------------------------------
41
42export {
43 processActivityPubFollow
44}
45
46// ---------------------------------------------------------------------------
47
48async function follow (fromActor: MActor, targetActor: MActorFull, isAutoFollow = false) {
49 if (fromActor.id === targetActor.id) {
50 throw new Error('Follower is the same as target actor.')
51 }
52
53 // Same server, direct accept
54 const state = !fromActor.serverId && !targetActor.serverId ? 'accepted' : 'pending'
55
56 const actorFollow = await sequelizeTypescript.transaction(async t => {
57 const [ actorFollow ] = await ActorFollowModel.findOrCreateCustom({
58 byActor: fromActor,
59 state,
60 targetActor,
61 activityId: getLocalActorFollowActivityPubUrl(fromActor, targetActor),
62 transaction: t
63 })
64
65 // Send a notification to remote server if our follow is not already accepted
66 if (actorFollow.state !== 'accepted') sendFollow(actorFollow, t)
67
68 return actorFollow
69 })
70
71 const followerFull = await ActorModel.loadFull(fromActor.id)
72
73 const actorFollowFull = Object.assign(actorFollow, {
74 ActorFollowing: targetActor,
75 ActorFollower: followerFull
76 })
77
78 if (actorFollow.state === 'accepted') Notifier.Instance.notifyOfNewUserFollow(actorFollowFull)
79 if (isAutoFollow === true) Notifier.Instance.notifyOfAutoInstanceFollowing(actorFollowFull)
80
81 return actorFollow
82}