| @@ -95,7 +95,7 @@ export class AntennaService implements OnApplicationShutdown { | ||||
| 		this.redisClient.xadd( | ||||
| 			`antennaTimeline:${antenna.id}`, | ||||
| 			'MAXLEN', '~', '200', | ||||
| 			`${this.idService.parse(note.id).date.getTime()}-*`, | ||||
| 			'*', | ||||
| 			'note', note.id); | ||||
| 		 | ||||
| 		this.globalEventService.publishAntennaStream(antenna.id, 'note', note); | ||||
|   | ||||
| @@ -329,7 +329,7 @@ export class NoteCreateService implements OnApplicationShutdown { | ||||
| 			this.redisClient.xadd( | ||||
| 				`channelTimeline:${data.channel.id}`, | ||||
| 				'MAXLEN', '~', '1000', | ||||
| 				`${this.idService.parse(note.id).date.getTime()}-*`, | ||||
| 				'*', | ||||
| 				'note', note.id); | ||||
| 		} | ||||
|  | ||||
|   | ||||
| @@ -99,7 +99,7 @@ export class NotificationService implements OnApplicationShutdown { | ||||
| 		const redisIdPromise = this.redisClient.xadd( | ||||
| 			`notificationTimeline:${notifieeId}`, | ||||
| 			'MAXLEN', '~', '300', | ||||
| 			`${this.idService.parse(notification.id).date.getTime()}-*`, | ||||
| 			'*', | ||||
| 			'data', JSON.stringify(notification)); | ||||
|  | ||||
| 		const packed = await this.notificationEntityService.pack(notification, notifieeId, {}); | ||||
|   | ||||
		Reference in New Issue
	
	Block a user
	 syuilo
					syuilo