server/tests/utils/server/follows.ts

   1 import * as request from 'supertest'
   2 import { ServerInfo } from './servers'
   3 import { waitJobs } from './jobs'
   4
   5 function getFollowersListPaginationAndSort (url: string, start: number, count: number, sort: string, search?: string) {
   6   const path = '/api/v1/server/followers'
   7
   8   return request(url)
   9     .get(path)
  10     .query({ start })
  11     .query({ count })
  12     .query({ sort })
  13     .query({ search })
  14     .set('Accept', 'application/json')
  15     .expect(200)
  16     .expect('Content-Type', /json/)
  17 }
  18
  19 function getFollowingListPaginationAndSort (url: string, start: number, count: number, sort: string, search?: string) {
  20   const path = '/api/v1/server/following'
  21
  22   return request(url)
  23     .get(path)
  24     .query({ start })
  25     .query({ count })
  26     .query({ sort })
  27     .query({ search })
  28     .set('Accept', 'application/json')
  29     .expect(200)
  30     .expect('Content-Type', /json/)
  31 }
  32
  33 async function follow (follower: string, following: string[], accessToken: string, expectedStatus = 204) {
  34   const path = '/api/v1/server/following'
  35
  36   const followingHosts = following.map(f => f.replace(/^http:\/\//, ''))
  37   const res = await request(follower)
  38     .post(path)
  39     .set('Accept', 'application/json')
  40     .set('Authorization', 'Bearer ' + accessToken)
  41     .send({ 'hosts': followingHosts })
  42     .expect(expectedStatus)
  43
  44   return res
  45 }
  46
  47 async function unfollow (url: string, accessToken: string, target: ServerInfo, expectedStatus = 204) {
  48   const path = '/api/v1/server/following/' + target.host
  49
  50   const res = await request(url)
  51     .delete(path)
  52     .set('Accept', 'application/json')
  53     .set('Authorization', 'Bearer ' + accessToken)
  54     .expect(expectedStatus)
  55
  56   return res
  57 }
  58
  59 async function doubleFollow (server1: ServerInfo, server2: ServerInfo) {
  60   await Promise.all([
  61     follow(server1.url, [ server2.url ], server1.accessToken),
  62     follow(server2.url, [ server1.url ], server2.accessToken)
  63   ])
  64
  65   // Wait request propagation
  66   await waitJobs([ server1, server2 ])
  67
  68   return true
  69 }
  70
  71 // ---------------------------------------------------------------------------
  72
  73 export {
  74   getFollowersListPaginationAndSort,
  75   getFollowingListPaginationAndSort,
  76   unfollow,
  77   follow,
  78   doubleFollow
  79 }