summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/processors/db/export-notes.ts2
-rw-r--r--src/queue/processors/inbox.ts10
2 files changed, 0 insertions, 12 deletions
diff --git a/src/queue/processors/db/export-notes.ts b/src/queue/processors/db/export-notes.ts
index 94a4302e05..0fd8c02c4a 100644
--- a/src/queue/processors/db/export-notes.ts
+++ b/src/queue/processors/db/export-notes.ts
@@ -128,8 +128,6 @@ function serialize(note: Note, poll: Poll | null = null): any {
viaMobile: note.viaMobile,
visibility: note.visibility,
visibleUserIds: note.visibleUserIds,
- appId: note.appId,
- geo: note.geo,
localOnly: note.localOnly
};
}
diff --git a/src/queue/processors/inbox.ts b/src/queue/processors/inbox.ts
index 1a583ec865..74108f354b 100644
--- a/src/queue/processors/inbox.ts
+++ b/src/queue/processors/inbox.ts
@@ -3,7 +3,6 @@ import * as httpSignature from 'http-signature';
import { IRemoteUser } from '../../models/entities/user';
import perform from '../../remote/activitypub/perform';
import { resolvePerson, updatePerson } from '../../remote/activitypub/models/person';
-import { publishApLogStream } from '../../services/stream';
import Logger from '../../services/logger';
import { registerOrFetchInstanceDoc } from '../../services/register-or-fetch-instance-doc';
import { Instances, Users, UserPublickeys } from '../../models';
@@ -89,15 +88,6 @@ export default async (job: Bull.Job): Promise<void> => {
return;
}
- //#region Log
- publishApLogStream({
- direction: 'in',
- activity: activity.type,
- host: user.host,
- actor: user.username
- });
- //#endregion
-
// Update stats
registerOrFetchInstanceDoc(user.host).then(i => {
Instances.update(i.id, {