diff options
author | Chocobozzz <florian.bigard@gmail.com> | 2017-11-21 13:43:29 +0100 |
---|---|---|
committer | Chocobozzz <florian.bigard@gmail.com> | 2017-11-27 19:40:52 +0100 |
commit | 0f91ae62df8a37194fea84ce1efa9e733d9c1fd8 (patch) | |
tree | 1cb0fccadebb629d02632dc8e21fae7ba521c464 /server/helpers | |
parent | 81de19482b89342c3dbc098a9f512ef7f1056e45 (diff) | |
download | PeerTube-0f91ae62df8a37194fea84ce1efa9e733d9c1fd8.tar.gz PeerTube-0f91ae62df8a37194fea84ce1efa9e733d9c1fd8.tar.zst PeerTube-0f91ae62df8a37194fea84ce1efa9e733d9c1fd8.zip |
Add follow tests
Diffstat (limited to 'server/helpers')
-rw-r--r-- | server/helpers/database-utils.ts | 13 | ||||
-rw-r--r-- | server/helpers/webfinger.ts | 8 |
2 files changed, 12 insertions, 9 deletions
diff --git a/server/helpers/database-utils.ts b/server/helpers/database-utils.ts index 169b80065..dacd747c9 100644 --- a/server/helpers/database-utils.ts +++ b/server/helpers/database-utils.ts | |||
@@ -4,12 +4,15 @@ import * as Bluebird from 'bluebird' | |||
4 | import { logger } from './logger' | 4 | import { logger } from './logger' |
5 | 5 | ||
6 | type RetryTransactionWrapperOptions = { errorMessage: string, arguments?: any[] } | 6 | type RetryTransactionWrapperOptions = { errorMessage: string, arguments?: any[] } |
7 | function retryTransactionWrapper (functionToRetry: (...args) => Promise<any> | Bluebird<any>, options: RetryTransactionWrapperOptions) { | 7 | function retryTransactionWrapper <T> ( |
8 | functionToRetry: (...args) => Promise<T> | Bluebird<T>, | ||
9 | options: RetryTransactionWrapperOptions | ||
10 | ): Promise<T> { | ||
8 | const args = options.arguments ? options.arguments : [] | 11 | const args = options.arguments ? options.arguments : [] |
9 | 12 | ||
10 | return transactionRetryer(callback => { | 13 | return transactionRetryer<T>(callback => { |
11 | functionToRetry.apply(this, args) | 14 | functionToRetry.apply(this, args) |
12 | .then(result => callback(null, result)) | 15 | .then((result: T) => callback(null, result)) |
13 | .catch(err => callback(err)) | 16 | .catch(err => callback(err)) |
14 | }) | 17 | }) |
15 | .catch(err => { | 18 | .catch(err => { |
@@ -18,8 +21,8 @@ function retryTransactionWrapper (functionToRetry: (...args) => Promise<any> | B | |||
18 | }) | 21 | }) |
19 | } | 22 | } |
20 | 23 | ||
21 | function transactionRetryer (func: Function) { | 24 | function transactionRetryer <T> (func: (err: any, data: T) => any) { |
22 | return new Promise((res, rej) => { | 25 | return new Promise<T>((res, rej) => { |
23 | retry({ | 26 | retry({ |
24 | times: 5, | 27 | times: 5, |
25 | 28 | ||
diff --git a/server/helpers/webfinger.ts b/server/helpers/webfinger.ts index b7408c845..a5b4785fe 100644 --- a/server/helpers/webfinger.ts +++ b/server/helpers/webfinger.ts | |||
@@ -1,9 +1,9 @@ | |||
1 | import * as WebFinger from 'webfinger.js' | 1 | import * as WebFinger from 'webfinger.js' |
2 | import { WebFingerData } from '../../shared' | 2 | import { WebFingerData } from '../../shared' |
3 | import { fetchRemoteAccount } from '../lib/activitypub/account' | ||
3 | 4 | ||
4 | import { isTestInstance } from './core-utils' | 5 | import { isTestInstance } from './core-utils' |
5 | import { isActivityPubUrlValid } from './custom-validators' | 6 | import { isActivityPubUrlValid } from './custom-validators' |
6 | import { fetchRemoteAccountAndCreateServer } from '../lib/activitypub/account' | ||
7 | 7 | ||
8 | const webfinger = new WebFinger({ | 8 | const webfinger = new WebFinger({ |
9 | webfist_fallback: false, | 9 | webfist_fallback: false, |
@@ -22,10 +22,10 @@ async function getAccountFromWebfinger (nameWithHost: string) { | |||
22 | throw new Error('Cannot find self link or href is not a valid URL.') | 22 | throw new Error('Cannot find self link or href is not a valid URL.') |
23 | } | 23 | } |
24 | 24 | ||
25 | const res = await fetchRemoteAccountAndCreateServer(selfLink.href) | 25 | const account = await fetchRemoteAccount(selfLink.href) |
26 | if (res === undefined) throw new Error('Cannot fetch and create server of remote account ' + selfLink.href) | 26 | if (account === undefined) throw new Error('Cannot fetch remote account ' + selfLink.href) |
27 | 27 | ||
28 | return res.account | 28 | return account |
29 | } | 29 | } |
30 | 30 | ||
31 | // --------------------------------------------------------------------------- | 31 | // --------------------------------------------------------------------------- |