From 998885b2a1bc029ab06a06244ba884bb022431df Mon Sep 17 00:00:00 2001
From: Sergiotarxz <sergiotarxz@posteo.net>
Date: Thu, 23 May 2024 17:12:11 +0200
Subject: [PATCH] Perfectly synced all things should be.

---
 lib/TgMagicPdf/Telegram.pm | 129 ++++++++++++++++++++++---------------
 1 file changed, 77 insertions(+), 52 deletions(-)

diff --git a/lib/TgMagicPdf/Telegram.pm b/lib/TgMagicPdf/Telegram.pm
index 74afffa..7394f0c 100644
--- a/lib/TgMagicPdf/Telegram.pm
+++ b/lib/TgMagicPdf/Telegram.pm
@@ -30,7 +30,7 @@ sub run ($self) {
     $self->_dispatch_updates;
     my $promise_dispatch;
     while (1) {
-        if (defined $promise_dispatch) {
+        if ( defined $promise_dispatch ) {
             $promise_dispatch->wait;
         }
         $promise_dispatch = $self->_dispatch_updates;
@@ -39,31 +39,53 @@ sub run ($self) {
 
 sub _dispatch_updates ($self) {
     my $updates_p = $self->_get_updates;
-    my @promises;
+    my $promise   = Mojo::Promise->new;
     $updates_p->then(
         sub ($res) {
             my $updates = $res->result->json->{result};
-            for my $update (@$updates) {
-                push @promises, $self->_dispatch_update($update);
-            }
+            $self->_dispatch_updates_one_to_one($promise, $updates);
         }
     )->catch(
         sub ($err) {
+            $promise->resolve;
             warn $err;
         }
     );
-    return Mojo::Promise->all($updates_p, @promises);;
+    return $promise;
 }
 
-sub _dispatch_update ( $self, $update ) {
-    if ( !defined $self->_last_offset_update
-        || $self->_last_offset_update < $update->{update_id} )
-    {
-        $self->_last_offset_update( $update->{update_id} );
+sub _dispatch_updates_one_to_one($self, $promise, $updates) {
+    my $update = shift @$updates;
+    if (!defined $update) {
+        $promise->resolve;
+        return;
     }
-    my $promise;
-    if ( defined $update->{message} ) {
-        $promise = $self->_handle_message( $update->{message} );
+    $self->_dispatch_update($update)->then(sub {
+        $self->_dispatch_updates_one_to_one($promise, $updates);
+    })->catch(sub($err){
+        $self->_dispatch_updates_one_to_one($promise, $updates);
+        warn $err;
+    });
+}
+
+
+sub _dispatch_update ( $self, $update ) {
+    my $promise = Mojo::Promise->new;;
+    {
+        if ( !defined $self->_last_offset_update
+            || $self->_last_offset_update < $update->{update_id} )
+        {
+            $self->_last_offset_update( $update->{update_id} );
+        }
+        if ( !defined $update->{message} ) {
+            $promise->resolve;
+            next;    
+        }
+        $self->_handle_message( $update->{message} )->then(sub {
+            $promise->resolve;
+        })->catch(sub {
+            $promise->resolve;
+        });
     }
     return $promise;
 }
@@ -80,56 +102,59 @@ sub _handle_message ( $self, $message ) {
         my $chat_type = $message->{chat}{type};
         if ( $chat_type ne 'private' ) {
             $promise->resolve;
-            return;
+            next;
         }
         my $chat_id = $message->{chat}{id};
         my $text    = $message->{text};
         if ( !defined $text ) {
             $promise->resolve;
-            return;
+            next;
         }
         $self->sendMessage( $chat_id,
-            'Got your message, attempting to generate a pdf.' )->wait;
-        my $pdf_builder = TgMagicPdf::PdfBuilder->new;
-        $pdf_builder->from_text($text)->then(
-            sub ($pdf) {
-                $self->sendDocument( $chat_id, 'mtgprint.pdf', $pdf )->wait;
-                $promise->resolve;
-            }
-        )->catch(
-            sub ($err) {
-                $promise->resolve;
-                my $match = 0;
-                for my $known_error (
-                    $TgMagicPdf::PdfBuilder::ERR_INVALID_CARD,
-                    $TgMagicPdf::PdfBuilder::ERR_UNABLE_TO_FIND_IMAGE,
-                    $TgMagicPdf::PdfBuilder::ERR_TOO_MANY_CARDS
-                  )
-                {
-                    $match = 1 if ( index( $err, $known_error ) != -1 );
+            'Got your message, attempting to generate a pdf.' )->then(sub {
+            my $pdf_builder = TgMagicPdf::PdfBuilder->new;
+            $pdf_builder->from_text($text)->then(
+                sub ($pdf) {
+                    $self->sendDocument( $chat_id, 'mtgprint.pdf', $pdf )->then(sub {;
+                        $promise->resolve;
+                    });
                 }
-                if ($match) {
-                    my $error_to_user .= $err =~ s/ at.*$//r;
-                    if ( -1 != index $err,
-                        $TgMagicPdf::PdfBuilder::ERR_INVALID_CARD )
+            )->catch(
+                sub ($err) {
+                    $promise->resolve;
+                    my $match = 0;
+                    for my $known_error (
+                        $TgMagicPdf::PdfBuilder::ERR_INVALID_CARD,
+                        $TgMagicPdf::PdfBuilder::ERR_UNABLE_TO_FIND_IMAGE,
+                        $TgMagicPdf::PdfBuilder::ERR_TOO_MANY_CARDS
+                      )
                     {
-                        $error_to_user .= ' ' . $pdf_builder->last_invalid_card;
+                        $match = 1 if ( index( $err, $known_error ) != -1 );
                     }
-                    if ( -1 != index $err,
-                        $TgMagicPdf::PdfBuilder::ERR_UNABLE_TO_FIND_IMAGE )
-                    {
-                        $error_to_user .= ' ' . $pdf_builder->last_invalid_card;
+                    if ($match) {
+                        my $error_to_user .= $err =~ s/ at.*$//r;
+                        if ( -1 != index $err,
+                            $TgMagicPdf::PdfBuilder::ERR_INVALID_CARD )
+                        {
+                            $error_to_user .= ' ' . $pdf_builder->last_invalid_card;
+                        }
+                        if ( -1 != index $err,
+                            $TgMagicPdf::PdfBuilder::ERR_UNABLE_TO_FIND_IMAGE )
+                        {
+                            $error_to_user .= ' ' . $pdf_builder->last_invalid_card;
+                        }
+                        $self->sendMessage( $chat_id,
+    'I could not process your deck take a look to this details: '
+                              . $error_to_user )->wait;
+                        return;
                     }
+                    warn $err;
                     $self->sendMessage( $chat_id,
-'I could not process your deck take a look to this details: '
-                          . $error_to_user )->wait;
-                    return;
+                        'I could not process your deck because of a server error' )
+                      ->wait;
                 }
-                warn $err;
-                $self->sendMessage( $chat_id,
-                    'I could not process your deck because of a server error' )->wait;
-            }
-        );
+            );
+        });
     }
     return $promise;
 }
@@ -157,7 +182,7 @@ sub _pdf_builder {
 
 sub _build__ua ($self) {
     my $ua = Mojo::UserAgent->new->with_roles('+Queued');
-    $ua->max_active(5); 
+    $ua->max_active(5);
     $ua->inactivity_timeout(60);
     return $ua;
 }