misskey/src/stream.ts

59 lines
2.1 KiB
TypeScript
Raw Normal View History

2016-12-28 23:49:51 +01:00
import * as mongo from 'mongodb';
2018-07-30 00:20:27 +02:00
import Xev from 'xev';
2016-12-28 23:49:51 +01:00
2018-07-30 00:20:27 +02:00
const ev = new Xev();
2017-11-16 15:46:36 +01:00
2018-07-30 00:20:27 +02:00
type ID = string | mongo.ObjectID;
2017-03-20 05:54:59 +01:00
2018-07-30 00:20:27 +02:00
function publish(channel: string, type: string, value?: any): void {
const message = type == null ? value : value == null ?
{ type: type } :
{ type: type, body: value };
2018-04-25 11:04:16 +02:00
2018-09-11 18:48:30 +02:00
ev.emit(channel, message);
2018-07-30 00:20:27 +02:00
}
2017-05-24 13:50:17 +02:00
2018-07-30 00:20:27 +02:00
export function publishUserStream(userId: ID, type: string, value?: any): void {
publish(`user-stream:${userId}`, type, typeof value === 'undefined' ? null : value);
}
2017-11-13 16:54:16 +01:00
2018-07-30 00:20:27 +02:00
export function publishDriveStream(userId: ID, type: string, value?: any): void {
publish(`drive-stream:${userId}`, type, typeof value === 'undefined' ? null : value);
}
2018-03-07 03:40:40 +01:00
2018-07-30 00:20:27 +02:00
export function publishNoteStream(noteId: ID, type: string): void {
2018-07-30 00:23:44 +02:00
publish(`note-stream:${noteId}`, null, noteId);
2018-07-30 00:20:27 +02:00
}
2018-03-07 09:48:32 +01:00
2018-07-30 00:20:27 +02:00
export function publishUserListStream(listId: ID, type: string, value?: any): void {
publish(`user-list-stream:${listId}`, type, typeof value === 'undefined' ? null : value);
}
2018-07-30 00:20:27 +02:00
export function publishMessagingStream(userId: ID, otherpartyId: ID, type: string, value?: any): void {
publish(`messaging-stream:${userId}-${otherpartyId}`, type, typeof value === 'undefined' ? null : value);
}
2018-07-11 02:36:30 +02:00
2018-07-30 00:20:27 +02:00
export function publishMessagingIndexStream(userId: ID, type: string, value?: any): void {
publish(`messaging-index-stream:${userId}`, type, typeof value === 'undefined' ? null : value);
}
2018-07-30 00:20:27 +02:00
export function publishReversiStream(userId: ID, type: string, value?: any): void {
publish(`reversi-stream:${userId}`, type, typeof value === 'undefined' ? null : value);
}
2017-05-24 13:50:17 +02:00
2018-07-30 00:20:27 +02:00
export function publishReversiGameStream(gameId: ID, type: string, value?: any): void {
publish(`reversi-game-stream:${gameId}`, type, typeof value === 'undefined' ? null : value);
2016-12-28 23:49:51 +01:00
}
2018-07-30 00:20:27 +02:00
export function publishLocalTimelineStream(note: any): void {
publish('local-timeline', null, note);
}
2016-12-28 23:49:51 +01:00
2018-07-30 00:20:27 +02:00
export function publishHybridTimelineStream(userId: ID, note: any): void {
publish(userId ? `hybrid-timeline:${userId}` : 'hybrid-timeline', null, note);
}
2016-12-28 23:49:51 +01:00
2018-07-30 00:20:27 +02:00
export function publishGlobalTimelineStream(note: any): void {
publish('global-timeline', null, note);
}