From ccfd77d9568dce55ea8ce29ea114b2487f7bc0b9 Mon Sep 17 00:00:00 2001
From: f <f@sutty.nl>
Date: Wed, 8 Feb 2023 17:08:02 -0300
Subject: [PATCH] =?UTF-8?q?feat:=20guardar=20un=20log=20y=20mostrarlo=20en?=
 =?UTF-8?q?=20output=20tambi=C3=A9n?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/models/deploy_distributed_press.rb    | 24 ++++++++++++++++++-----
 app/models/distributed_press_publisher.rb | 22 ++++++++++++++++++++-
 2 files changed, 40 insertions(+), 6 deletions(-)

diff --git a/app/models/deploy_distributed_press.rb b/app/models/deploy_distributed_press.rb
index 38cb59e3..d805e923 100644
--- a/app/models/deploy_distributed_press.rb
+++ b/app/models/deploy_distributed_press.rb
@@ -22,19 +22,32 @@ class DeployDistributedPress < Deploy
   # @param :output [Bool]
   # @return [Bool]
   def deploy
+    status = false
+    log = []
+
     time_start
 
-    status = false
-
     site_client.tap do |c|
+      stdout = Thread.new(publisher.logger_out) do |io|
+        until io.eof?
+          line = io.gets
+
+          puts line if output
+          log << line
+        end
+      end
+
       update remote_info: c.show(publishing_site).to_h
 
       status = c.publish(publishing_site, deploy_local.destination)
+
+      publisher.logger.close
+      stdout.join
     end
 
     time_stop
 
-    create_stat! status
+    create_stat! status, log.join
 
     status
   end
@@ -95,9 +108,10 @@ class DeployDistributedPress < Deploy
   # Registra lo que sucedió
   #
   # @param status [Bool]
+  # @param log [String]
   # @return [nil]
-  def create_stat!(status)
-    build_stats.create action: publisher.to_s, seconds: time_spent_in_seconds, bytes: size, status: status
+  def create_stat!(status, log)
+    build_stats.create action: publisher.to_s,log: log, seconds: time_spent_in_seconds, bytes: size, status: status
     nil
   end
 end
diff --git a/app/models/distributed_press_publisher.rb b/app/models/distributed_press_publisher.rb
index acfc4226..089f63c6 100644
--- a/app/models/distributed_press_publisher.rb
+++ b/app/models/distributed_press_publisher.rb
@@ -8,6 +8,11 @@ class DistributedPressPublisher < ApplicationRecord
   # Cifrar la información del token en la base de datos
   has_encrypted :token
 
+  # La salida del log
+  #
+  # @return [IO]
+  attr_reader :logger_out
+
   # La instancia es única
   validates_uniqueness_of :instance
 
@@ -27,7 +32,7 @@ class DistributedPressPublisher < ApplicationRecord
   #
   # @return [DistributedPress::V1::Client]
   def client
-    @client ||= DistributedPress::V1::Client.new(url: instance, token: token)
+    @client ||= DistributedPress::V1::Client.new(url: instance, token: token, logger: logger)
   end
 
   # @return [String]
@@ -35,8 +40,23 @@ class DistributedPressPublisher < ApplicationRecord
     "Distributed Press <#{instance}>"
   end
 
+  # @return [Logger]
+  def logger
+    @logger ||=
+      begin
+        @logger_out, @logger_in = IO.pipe
+        ::Logger.new @logger_in, formatter: formatter
+      end
+  end
+
   private
 
+  def formatter
+    @formatter ||= lambda do |_, _, _, msg|
+      "#{msg}\n"
+    end
+  end
+
   # Actualiza o desactiva la fecha de vencimiento a partir de la
   # información del token.
   #