summaryrefslogtreecommitdiff
path: root/src/common
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-04-01 21:24:25 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-04-01 21:24:25 +0900
commit79f87b69433cf10746580cf2a8144375dafb7e37 (patch)
tree18770012d35c875ba8ef42a673dfea1d1071d25c /src/common
parentBetter variable name (diff)
downloadsharkey-79f87b69433cf10746580cf2a8144375dafb7e37.tar.gz
sharkey-79f87b69433cf10746580cf2a8144375dafb7e37.tar.bz2
sharkey-79f87b69433cf10746580cf2a8144375dafb7e37.zip
Some fixes and refactors
Diffstat (limited to 'src/common')
-rw-r--r--src/common/remote/activitypub/act/create.ts2
-rw-r--r--src/common/remote/activitypub/create.ts11
-rw-r--r--src/common/remote/activitypub/resolve-person.ts6
-rw-r--r--src/common/remote/activitypub/resolver.ts12
-rw-r--r--src/common/remote/activitypub/type.ts2
-rw-r--r--src/common/remote/resolve-user.ts2
-rw-r--r--src/common/remote/webfinger.ts6
7 files changed, 21 insertions, 20 deletions
diff --git a/src/common/remote/activitypub/act/create.ts b/src/common/remote/activitypub/act/create.ts
index 6c62f7ab9e..9eb74800ea 100644
--- a/src/common/remote/activitypub/act/create.ts
+++ b/src/common/remote/activitypub/act/create.ts
@@ -2,7 +2,7 @@ import create from '../create';
export default (resolver, actor, activity) => {
if ('actor' in activity && actor.account.uri !== activity.actor) {
- throw new Error;
+ throw new Error();
}
return create(resolver, actor, activity.object);
diff --git a/src/common/remote/activitypub/create.ts b/src/common/remote/activitypub/create.ts
index 4aaaeb3060..ea780f01ea 100644
--- a/src/common/remote/activitypub/create.ts
+++ b/src/common/remote/activitypub/create.ts
@@ -3,6 +3,7 @@ import config from '../../../conf';
import Post from '../../../models/post';
import RemoteUserObject, { IRemoteUserObject } from '../../../models/remote-user-object';
import uploadFromUrl from '../../drive/upload_from_url';
+import Resolver from './resolver';
const createDOMPurify = require('dompurify');
function createRemoteUserObject($ref, $id, { id }) {
@@ -17,7 +18,7 @@ function createRemoteUserObject($ref, $id, { id }) {
async function createImage(actor, object) {
if ('attributedTo' in object && actor.account.uri !== object.attributedTo) {
- throw new Error;
+ throw new Error();
}
const { _id } = await uploadFromUrl(object.url, actor);
@@ -26,7 +27,7 @@ async function createImage(actor, object) {
async function createNote(resolver, actor, object) {
if ('attributedTo' in object && actor.account.uri !== object.attributedTo) {
- throw new Error;
+ throw new Error();
}
const mediaIds = 'attachment' in object &&
@@ -69,10 +70,10 @@ async function createNote(resolver, actor, object) {
return createRemoteUserObject('posts', _id, object);
}
-export default async function create(parentResolver, actor, value): Promise<Promise<IRemoteUserObject>[]> {
+export default async function create(parentResolver: Resolver, actor, value): Promise<Array<Promise<IRemoteUserObject>>> {
const results = await parentResolver.resolveRemoteUserObjects(value);
- return results.map(asyncResult => asyncResult.then(({ resolver, object }) => {
+ return results.map(promisedResult => promisedResult.then(({ resolver, object }) => {
switch (object.type) {
case 'Image':
return createImage(actor, object);
@@ -83,4 +84,4 @@ export default async function create(parentResolver, actor, value): Promise<Prom
return null;
}));
-};
+}
diff --git a/src/common/remote/activitypub/resolve-person.ts b/src/common/remote/activitypub/resolve-person.ts
index 999a37eea1..b8c507d358 100644
--- a/src/common/remote/activitypub/resolve-person.ts
+++ b/src/common/remote/activitypub/resolve-person.ts
@@ -12,10 +12,10 @@ async function isCollection(collection) {
export default async (value, usernameLower, hostLower, acctLower) => {
if (!validateUsername(usernameLower)) {
- throw new Error;
+ throw new Error();
}
- const { resolver, object } = await (new Resolver).resolveOne(value);
+ const { resolver, object } = await new Resolver().resolveOne(value);
if (
object === null ||
@@ -25,7 +25,7 @@ export default async (value, usernameLower, hostLower, acctLower) => {
!isValidName(object.name) ||
!isValidDescription(object.summary)
) {
- throw new Error;
+ throw new Error();
}
const [followers, following, outbox, finger] = await Promise.all([
diff --git a/src/common/remote/activitypub/resolver.ts b/src/common/remote/activitypub/resolver.ts
index 50ac1b0b19..43f0d63cb3 100644
--- a/src/common/remote/activitypub/resolver.ts
+++ b/src/common/remote/activitypub/resolver.ts
@@ -29,7 +29,7 @@ async function resolveUnrequestedOne(this: Resolver, value) {
!object['@context'].includes('https://www.w3.org/ns/activitystreams') :
object['@context'] !== 'https://www.w3.org/ns/activitystreams'
)) {
- throw new Error;
+ throw new Error();
}
return { resolver, object };
@@ -57,13 +57,13 @@ async function resolveCollection(this: Resolver, value) {
}
export default class Resolver {
- requesting: Set<string>;
+ private requesting: Set<string>;
constructor(iterable?: Iterable<string>) {
this.requesting = new Set(iterable);
}
- async resolve(value): Promise<Promise<IResult>[]> {
+ public async resolve(value): Promise<Array<Promise<IResult>>> {
const collection = await resolveCollection.call(this, value);
return collection
@@ -71,15 +71,15 @@ export default class Resolver {
.map(resolveUnrequestedOne.bind(this));
}
- resolveOne(value) {
+ public resolveOne(value) {
if (this.requesting.has(value)) {
- throw new Error;
+ throw new Error();
}
return resolveUnrequestedOne.call(this, value);
}
- async resolveRemoteUserObjects(value) {
+ public async resolveRemoteUserObjects(value) {
const collection = await resolveCollection.call(this, value);
return collection.filter(element => !this.requesting.has(element)).map(element => {
diff --git a/src/common/remote/activitypub/type.ts b/src/common/remote/activitypub/type.ts
index 5c4750e140..94e2c350a2 100644
--- a/src/common/remote/activitypub/type.ts
+++ b/src/common/remote/activitypub/type.ts
@@ -1,3 +1,3 @@
export type IObject = {
type: string;
-}
+};
diff --git a/src/common/remote/resolve-user.ts b/src/common/remote/resolve-user.ts
index 13d155830e..4959539da6 100644
--- a/src/common/remote/resolve-user.ts
+++ b/src/common/remote/resolve-user.ts
@@ -16,7 +16,7 @@ export default async (username, host, option) => {
const finger = await webFinger(acctLower, acctLower);
const self = finger.links.find(link => link.rel && link.rel.toLowerCase() === 'self');
if (!self) {
- throw new Error;
+ throw new Error();
}
user = await resolvePerson(self.href, usernameLower, hostLower, acctLower);
diff --git a/src/common/remote/webfinger.ts b/src/common/remote/webfinger.ts
index 23f0aaa55f..9f1b916c9f 100644
--- a/src/common/remote/webfinger.ts
+++ b/src/common/remote/webfinger.ts
@@ -5,12 +5,12 @@ const webFinger = new WebFinger({});
type ILink = {
href: string;
rel: string;
-}
+};
type IWebFinger = {
- links: Array<ILink>;
+ links: ILink[];
subject: string;
-}
+};
export default (query, verifier): Promise<IWebFinger> => new Promise((res, rej) => webFinger.lookup(query, (error, result) => {
if (error) {