Stars ref

(cherry picked from commit 7d3ab98)

Author: Isaac

submodules/AccountContext/Sources/AccountContext.swift

@@ -896,10 +896,10 @@ public enum JoinAffiliateProgramScreenMode {
 
     public final class Active {
         public let targetPeer: EnginePeer
-        public let bot: TelegramConnectedStarRefBotList.Item
-        public let copyLink: (TelegramConnectedStarRefBotList.Item) -> Void
+        public let bot: EngineConnectedStarRefBotsContext.Item
+        public let copyLink: (EngineConnectedStarRefBotsContext.Item) -> Void
 
-        public init(targetPeer: EnginePeer, bot: TelegramConnectedStarRefBotList.Item, copyLink: @escaping (TelegramConnectedStarRefBotList.Item) -> Void) {
+        public init(targetPeer: EnginePeer, bot: EngineConnectedStarRefBotsContext.Item, copyLink: @escaping (EngineConnectedStarRefBotsContext.Item) -> Void) {
             self.targetPeer = targetPeer
             self.bot = bot
             self.copyLink = copyLink

submodules/TelegramCore/Sources/State/AccountStateManager.swift

@@ -333,6 +333,11 @@ public final class AccountStateManager {
             return self.sentScheduledMessageIdsPipe.signal()
         }
 
+        fileprivate let starRefBotConnectionEventsPipe = ValuePipe<StarRefBotConnectionEvent>()
+        public var starRefBotConnectionEvents: Signal<StarRefBotConnectionEvent, NoError> {
+            return self.starRefBotConnectionEventsPipe.signal()
+        }
+        
         private var updatedWebpageContexts: [MediaId: UpdatedWebpageSubscriberContext] = [:]
         private var updatedPeersNearbyContext = UpdatedPeersNearbySubscriberContext()
         private var updatedRevenueBalancesContext = UpdatedRevenueBalancesSubscriberContext()
@@ -1804,6 +1809,10 @@ public final class AccountStateManager {
                 self.removePossiblyDeliveredMessagesUniqueIds.merge(uniqueIds, uniquingKeysWith: { _, rhs in rhs })
             }
         }
+        
+        func addStarRefBotConnectionEvent(event: StarRefBotConnectionEvent) {
+            self.starRefBotConnectionEventsPipe.putNext(event)
+        }
     }
 
     private let impl: QueueLocalObject<Impl>
@@ -2183,6 +2192,18 @@ public final class AccountStateManager {
     public func synchronouslyIsMessageDeletedRemotely(ids: [EngineMessage.Id]) -> [EngineMessage.Id] {
         return self.messagesRemovedContext.synchronouslyIsMessageDeletedRemotely(ids: ids)
     }
+    
+    func starRefBotConnectionEvents() -> Signal<StarRefBotConnectionEvent, NoError> {
+        return self.impl.signalWith { impl, subscriber in
+            return impl.starRefBotConnectionEventsPipe.signal().start(next: subscriber.putNext)
+        }
+    }
+    
+    func addStarRefBotConnectionEvent(event: StarRefBotConnectionEvent) {
+        self.impl.with { impl in
+            impl.addStarRefBotConnectionEvent(event: event)
+        }
+    }
 }
 
 func resolveNotificationSettings(list: [TelegramPeerNotificationSettings], defaultSettings: MessageNotificationSettings) -> (sound: PeerMessageSound, notify: Bool, displayContents: Bool) {