PeerTube/shared/server-commands/server/follows-command.ts

140 lines
3.3 KiB
TypeScript
Raw Normal View History

import { pick } from '@shared/core-utils'
import { ActivityPubActorType, ActorFollow, FollowState, HttpStatusCode, ResultList, ServerFollowCreate } from '@shared/models'
2021-07-07 09:16:40 +02:00
import { AbstractCommand, OverrideCommandOptions } from '../shared'
2021-07-16 09:47:51 +02:00
import { PeerTubeServer } from './server'
2021-07-07 09:16:40 +02:00
export class FollowsCommand extends AbstractCommand {
getFollowers (options: OverrideCommandOptions & {
start: number
count: number
sort: string
search?: string
actorType?: ActivityPubActorType
state?: FollowState
}) {
const path = '/api/v1/server/followers'
const query = pick(options, [ 'start', 'count', 'sort', 'search', 'state', 'actorType' ])
2021-07-07 09:16:40 +02:00
return this.getRequestBody<ResultList<ActorFollow>>({
...options,
path,
query,
implicitToken: false,
2021-07-07 09:16:40 +02:00
defaultExpectedStatus: HttpStatusCode.OK_200
})
}
getFollowings (options: OverrideCommandOptions & {
start?: number
count?: number
sort?: string
2021-07-07 09:16:40 +02:00
search?: string
actorType?: ActivityPubActorType
state?: FollowState
} = {}) {
2021-07-07 09:16:40 +02:00
const path = '/api/v1/server/following'
const query = pick(options, [ 'start', 'count', 'sort', 'search', 'state', 'actorType' ])
2021-07-07 09:16:40 +02:00
return this.getRequestBody<ResultList<ActorFollow>>({
...options,
path,
query,
implicitToken: false,
2021-07-07 09:16:40 +02:00
defaultExpectedStatus: HttpStatusCode.OK_200
})
}
follow (options: OverrideCommandOptions & {
hosts?: string[]
handles?: string[]
2021-07-07 09:16:40 +02:00
}) {
const path = '/api/v1/server/following'
const fields: ServerFollowCreate = {}
if (options.hosts) {
fields.hosts = options.hosts.map(f => f.replace(/^http:\/\//, ''))
}
if (options.handles) {
fields.handles = options.handles
}
2021-07-07 09:16:40 +02:00
return this.postBodyRequest({
...options,
path,
fields,
implicitToken: true,
2021-07-07 09:16:40 +02:00
defaultExpectedStatus: HttpStatusCode.NO_CONTENT_204
})
}
async unfollow (options: OverrideCommandOptions & {
target: PeerTubeServer | string
2021-07-07 09:16:40 +02:00
}) {
const { target } = options
const handle = typeof target === 'string'
? target
: target.host
const path = '/api/v1/server/following/' + handle
2021-07-07 09:16:40 +02:00
return this.deleteRequest({
...options,
path,
implicitToken: true,
2021-07-07 09:16:40 +02:00
defaultExpectedStatus: HttpStatusCode.NO_CONTENT_204
})
}
acceptFollower (options: OverrideCommandOptions & {
follower: string
}) {
const path = '/api/v1/server/followers/' + options.follower + '/accept'
return this.postBodyRequest({
...options,
path,
implicitToken: true,
2021-07-07 09:16:40 +02:00
defaultExpectedStatus: HttpStatusCode.NO_CONTENT_204
})
}
rejectFollower (options: OverrideCommandOptions & {
follower: string
}) {
const path = '/api/v1/server/followers/' + options.follower + '/reject'
return this.postBodyRequest({
...options,
path,
implicitToken: true,
2021-07-07 09:16:40 +02:00
defaultExpectedStatus: HttpStatusCode.NO_CONTENT_204
})
}
removeFollower (options: OverrideCommandOptions & {
2021-07-16 09:47:51 +02:00
follower: PeerTubeServer
2021-07-07 09:16:40 +02:00
}) {
const path = '/api/v1/server/followers/peertube@' + options.follower.host
return this.deleteRequest({
...options,
path,
implicitToken: true,
2021-07-07 09:16:40 +02:00
defaultExpectedStatus: HttpStatusCode.NO_CONTENT_204
})
}
}