add poll answer

This commit is contained in:
Mikhail Filimonov 2026-03-19 14:30:40 +01:00
parent 1a08c3f0d0
commit d04f1d069f
2 changed files with 13 additions and 4 deletions

View file

@ -93,13 +93,22 @@ func _internal_requestMessageSelectPollOption(account: Account, messageId: Messa
}
}
func _internal_addPollAnswer(account: Account, messageId: MessageId, answerText: String, answerEntities: [MessageTextEntity]) -> Signal<TelegramMediaPoll?, RequestMessageSelectPollOptionError> {
func _internal_addPollAnswer(account: Account, messageId: MessageId, option: TelegramMediaPollOption) -> Signal<TelegramMediaPoll?, RequestMessageSelectPollOptionError> {
return account.postbox.loadedPeerWithId(messageId.peerId)
|> take(1)
|> castError(RequestMessageSelectPollOptionError.self)
|> mapToSignal { peer in
if let inputPeer = apiInputPeer(peer) {
let apiAnswer: Api.PollAnswer = .inputPollAnswer(.init(flags: 0, text: .textWithEntities(.init(text: answerText, entities: apiEntitiesFromMessageTextEntities(answerEntities, associatedPeers: SimpleDictionary()))), option: Buffer(data: Data()), media: nil))
var flags: Int32 = 0
var inputMedia: Api.InputMedia?
if let image = option.media as? TelegramMediaImage, let reference = image.reference, case let .cloud(id, accessHash, maybeFileReference) = reference, let fileReference = maybeFileReference {
flags |= (1 << 0)
inputMedia = .inputMediaPhoto(.init(flags: 0, id: .inputPhoto(.init(id: id, accessHash: accessHash, fileReference: Buffer(data: fileReference))), ttlSeconds: nil, video: nil))
} else if let file = option.media as? TelegramMediaFile, let resource = file.resource as? CloudDocumentMediaResource {
flags |= (1 << 0)
inputMedia = .inputMediaDocument(.init(flags: 0, id: .inputDocument(.init(id: resource.fileId, accessHash: resource.accessHash, fileReference: Buffer(data: resource.fileReference ?? Data()))), videoCover: nil, videoTimestamp: nil, ttlSeconds: nil, query: nil))
}
let apiAnswer: Api.PollAnswer = .inputPollAnswer(.init(flags: flags, text: .textWithEntities(.init(text: option.text, entities: apiEntitiesFromMessageTextEntities(option.entities, associatedPeers: SimpleDictionary()))), option: Buffer(data: option.opaqueIdentifier), media: inputMedia))
return account.network.request(Api.functions.messages.addPollAnswer(peer: inputPeer, msgId: messageId.id, answer: apiAnswer))
|> mapError { _ -> RequestMessageSelectPollOptionError in
return .generic

View file

@ -256,8 +256,8 @@ public extension TelegramEngine {
return _internal_requestClosePoll(postbox: self.account.postbox, network: self.account.network, stateManager: self.account.stateManager, messageId: messageId)
}
public func addPollAnswer(messageId: MessageId, answerText: String, answerEntities: [MessageTextEntity] = []) -> Signal<TelegramMediaPoll?, RequestMessageSelectPollOptionError> {
return _internal_addPollAnswer(account: self.account, messageId: messageId, answerText: answerText, answerEntities: answerEntities)
public func addPollAnswer(messageId: MessageId, option: TelegramMediaPollOption) -> Signal<TelegramMediaPoll?, RequestMessageSelectPollOptionError> {
return _internal_addPollAnswer(account: self.account, messageId: messageId, option: option)
}
public func pollResults(messageId: MessageId, poll: TelegramMediaPoll) -> PollResultsContext {