mirror of
https://github.com/lux-tel/session-ios.git
synced 2026-10-30 20:38:32 +00:00
Morgan Pretty
80eb4fef0d
• Updated the General cache to include the users seckey (rather than fetching it from the DB every time causing unneeded load) • Updated a bunch of Crypto usage to no longer need a `db` or `dependencies` instance passed to it • Added unit tests for General.Cache • Replaced `Identity.userExists` with `General.Cache.userExists` (no need for database access anymore) • Moved the SwarmPoller message handling logic into it's own function to make debugging stack traces a little easier • Cleaned up some hard-to-read logic
75 lines
3.0 KiB
Swift
75 lines
3.0 KiB
Swift
// Copyright © 2025 Rangeproof Pty Ltd. All rights reserved.
|
|
|
|
import Foundation
|
|
import Combine
|
|
import GRDB
|
|
import SessionUtilitiesKit
|
|
|
|
// MARK: - Log.Category
|
|
|
|
private extension Log.Category {
|
|
static let cat: Log.Category = .create("FailedGroupInvitesAndPromotionsJob", defaultLevel: .info)
|
|
}
|
|
|
|
// MARK: - FailedGroupInvitesAndPromotionsJob
|
|
|
|
public enum FailedGroupInvitesAndPromotionsJob: JobExecutor {
|
|
public static let maxFailureCount: Int = -1
|
|
public static let requiresThreadId: Bool = false
|
|
public static let requiresInteractionId: Bool = false
|
|
|
|
public static func run<S: Scheduler>(
|
|
_ job: Job,
|
|
scheduler: S,
|
|
success: @escaping (Job, Bool) -> Void,
|
|
failure: @escaping (Job, Error, Bool) -> Void,
|
|
deferred: @escaping (Job) -> Void,
|
|
using dependencies: Dependencies
|
|
) {
|
|
guard dependencies[cache: .general].userExists else { return success(job, false) }
|
|
guard !dependencies[cache: .libSession].isEmpty else {
|
|
return failure(job, JobRunnerError.missingRequiredDetails, false)
|
|
}
|
|
|
|
var invitationsCount: Int = -1
|
|
var promotionsCount: Int = -1
|
|
|
|
// Update all 'sending' message states to 'failed'
|
|
dependencies[singleton: .storage]
|
|
.writePublisher { db in
|
|
invitationsCount = try GroupMember
|
|
.filter(
|
|
GroupMember.Columns.groupId > SessionId.Prefix.group.rawValue &&
|
|
GroupMember.Columns.groupId < SessionId.Prefix.group.endOfRangeString
|
|
)
|
|
.filter(GroupMember.Columns.role == GroupMember.Role.standard)
|
|
.filter(GroupMember.Columns.roleStatus == GroupMember.RoleStatus.sending)
|
|
.updateAllAndConfig(
|
|
db,
|
|
GroupMember.Columns.roleStatus.set(to: GroupMember.RoleStatus.failed),
|
|
using: dependencies
|
|
)
|
|
promotionsCount = try GroupMember
|
|
.filter(
|
|
GroupMember.Columns.groupId > SessionId.Prefix.group.rawValue &&
|
|
GroupMember.Columns.groupId < SessionId.Prefix.group.endOfRangeString
|
|
)
|
|
.filter(GroupMember.Columns.role == GroupMember.Role.admin)
|
|
.filter(GroupMember.Columns.roleStatus == GroupMember.RoleStatus.sending)
|
|
.updateAllAndConfig(
|
|
db,
|
|
GroupMember.Columns.roleStatus.set(to: GroupMember.RoleStatus.failed),
|
|
using: dependencies
|
|
)
|
|
}
|
|
.subscribe(on: scheduler, using: dependencies)
|
|
.receive(on: scheduler, using: dependencies)
|
|
.sinkUntilComplete(
|
|
receiveCompletion: { _ in
|
|
Log.info(.cat, "Invites marked as failed: \(invitationsCount), Promotions marked as failed: \(promotionsCount)")
|
|
success(job, false)
|
|
}
|
|
)
|
|
}
|
|
}
|