pepepper/fluxer
1
0
Fork 0
mirror of https://github.com/fluxerapp/fluxer synced 2026-10-07 19:22:14 +09:00
Code Issues Packages Projects Releases Wiki Activity

refactor(api): remove the pneumatic post system dm system (#1983)

Browse Source
This commit is contained in:
Hampus
2026-08-24 19:56:13 +02:00
committed by GitHub
parent 86497155cd
commit 3afad20e36
10 changed files with 0 additions and 1390 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fluxer_api/src/api/rpc/RpcService.ts
-13
View File
@@ -40,7 +40,6 @@ import {
import {Config} from '../Config';
import {mapChannelToResponse} from '../channel/ChannelMappers';
import type {IChannelRepository} from '../channel/IChannelRepository';
import type {ChannelService} from '../channel/services/ChannelService';
import {buildBroadcastMessageData} from '../channel/services/message/MessageGatewayDispatch';
import {ensurePersonalNotesChannelExists} from '../channel/services/PersonalNotesChannelRepair';
import {mapFavoriteMemeToResponse} from '../favorite_meme/FavoriteMemeModel';
@@ -83,12 +82,9 @@ import type {BotAuthService} from '../oauth/BotAuthService';
import {sendApnsPush} from '../push/ApnsPushService';
import {encodeReadStatesResponseProto, mapReadStateResponse} from '../read_state/ReadStateResponseMapper';
import type {ReadStateService} from '../read_state/ReadStateService';
import {PneumaticPostRepository} from '../system/PneumaticPostRepository';
import {PneumaticPostService} from '../system/PneumaticPostService';
import type {IUserRepository} from '../user/IUserRepository';
import {PaymentRepository} from '../user/repositories/PaymentRepository';
import {CustomStatusValidator} from '../user/services/CustomStatusValidator';
import type {UserChannelService} from '../user/services/UserChannelService';
import {getCachedUserPartialResponse} from '../user/UserCacheHelpers';
import {
mapRelationshipToResponse,
@@ -247,8 +243,6 @@ export class RpcService {
private webhookRepository: IWebhookRepository,
private storageService: IStorageService,
private avatarService: AvatarService,
private channelService: ChannelService,
private userChannelService: UserChannelService,
private rateLimitService: IRateLimitService,
private readonly limitConfigService: LimitConfigService,
private readonly kvClient: IKVProvider,
@@ -270,13 +264,6 @@ export class RpcService {
gatewayService: this.gatewayService,
discriminatorService: this.discriminatorService,
paymentRepository: new PaymentRepository(),
pneumaticPostService: new PneumaticPostService({
repository: new PneumaticPostRepository(),
userRepository: this.userRepository,
userChannelService: this.userChannelService,
channelService: this.channelService,
userCacheService: this.userCacheService,
}),
});
}
fluxer_api/src/api/rpc/RpcSessionStartService.ts
-8
View File
@@ -50,10 +50,6 @@ interface SessionStartDiscriminatorService extends Pick<IDiscriminatorService, '
interface SessionStartPaymentRepository extends Pick<PaymentRepository, 'hasEverPaidSuccessfully'> {}
interface SessionStartPneumaticPostService {
considerPlutoniumMobileBetaDispatch(user: User, settings: UserData['settings']): Promise<void>;
}
interface SessionStartDeps {
userRepository: SessionStartUserRepository;
guildRepository: SessionStartGuildRepository;
@@ -61,7 +57,6 @@ interface SessionStartDeps {
gatewayService: SessionStartGatewayService;
discriminatorService: SessionStartDiscriminatorService;
paymentRepository: SessionStartPaymentRepository;
pneumaticPostService: SessionStartPneumaticPostService;
}
interface ProcessSessionStartParams {
@@ -284,9 +279,6 @@ export class RpcSessionStartService {
}
});
}
await timings.time('consider_pneumatic_post_dispatches', async () => {
await this.deps.pneumaticPostService.considerPlutoniumMobileBetaDispatch(user, userData.settings);
});
return {user, flagsToUpdate, timings: timings.finalize()};
}