Merge pull request #21 from gustavothecoder/finish-domain-layer

Finish domain layer

Author: gustavothecoder

lib/pod/cli.rb

@@ -3,7 +3,6 @@
 require "thor"
 
 require_relative "commands"
-require_relative "outputs/text"
 require_relative "infrastructure/storage/sql"
 require_relative "infrastructure/shell_interface"
 
@@ -24,9 +23,9 @@ def version
     def init
       puts "Creating config files..."
 
-      result = Pod::Commands::Init.call
+      result = Pod::Commands::Init::Runner.call
 
-      puts Pod::Outputs::Text::Init.call(result)
+      puts Pod::Commands::Init::Output.call(result)
     end
 
     desc "add FEED", "Adds a podcast to the Pod database"
@@ -42,9 +41,9 @@ def add(feed)
     desc "podcasts", "List the podcast records"
     method_option :fields, type: :array, default: [], desc: "Select the fields that will be displayed."
     def podcasts
-      result = Pod::Commands::Podcasts.call(options)
+      result = Pod::Commands::Podcasts::Runner.call(options)
 
-      puts Pod::Outputs::Text::Podcasts.call(result)
+      puts Pod::Commands::Podcasts::Output.call(result)
     end
 
     desc "episodes PODCAST_ID", "List the podcast episodes"
@@ -61,11 +60,11 @@ def episodes(podcast_id)
     method_option :browser, type: :string, default: "firefox", desc: "Choose the browser."
     method_option :archive, type: :boolean, default: false, desc: "Archive the episode."
     def open(episode_id)
-      result = Pod::Commands::Open.call(episode_id, options)
+      result = Pod::Commands::Open::Runner.call(episode_id, options)
 
       Infrastructure::ShellInterface.call(result[:metadata])
 
-      puts Pod::Outputs::Text::Open.call(result)
+      puts Pod::Commands::Open::Output.call(result)
     end
 
     desc "archive EPISODE_ID", "Archive the episode"
@@ -91,17 +90,17 @@ def delete(podcast_id)
 
     desc "sync PODCAST_ID", "Sync the podcast."
     def sync(podcast_id)
-      result = Pod::Commands::Sync.call(podcast_id)
+      result = Pod::Commands::Sync::Runner.call(podcast_id)
 
-      puts Pod::Outputs::Text::Sync.call(result)
+      puts Pod::Commands::Sync::Output.call(result)
     end
 
     desc "update PODCAST_ID", "Update the podcast attributes."
     method_option :feed, type: :string, default: "", desc: "Define the podcast feed."
     def update(podcast_id)
-      result = Pod::Commands::Update.call(podcast_id, options)
+      result = Pod::Commands::Update::Runner.call(podcast_id, options)
 
-      puts Pod::Outputs::Text::Update.call(result)
+      puts Pod::Commands::Update::Output.call(result)
     end
   end
 end

lib/pod/commands.rb

@@ -12,12 +12,16 @@
 require_relative "commands/delete/output"
 require_relative "commands/episodes/runner"
 require_relative "commands/episodes/output"
-
-require_relative "commands/init"
-require_relative "commands/podcasts"
-require_relative "commands/open"
-require_relative "commands/sync"
-require_relative "commands/update"
+require_relative "commands/init/runner"
+require_relative "commands/init/output"
+require_relative "commands/open/runner"
+require_relative "commands/open/output"
+require_relative "commands/podcasts/runner"
+require_relative "commands/podcasts/output"
+require_relative "commands/sync/runner"
+require_relative "commands/sync/output"
+require_relative "commands/update/runner"
+require_relative "commands/update/output"
 
 module Pod
   module Commands; end

lib/pod/commands/init.rb

@@ -1,9 +1,9 @@
 # frozen_string_literal: true
 
 module Pod
-  module Outputs
-    module Text
-      class Init < ::Pod::Commands::BaseOutput
+  module Commands
+    module Init
+      class Output < ::Pod::Commands::BaseOutput
         def call
           case @context[:details]
           when :already_initialized

lib/pod/outputs/text/init.rb renamed to lib/pod/commands/init/output.rb

@@ -0,0 +1,47 @@
+# frozen_string_literal: true
+
+require "fileutils"
+
+module Pod
+  module Commands
+    module Init
+      class Runner < Pod::Commands::BaseRunner
+        def call
+          return build_failure_response(details: :home_not_found) if home_dir.nil?
+
+          return build_failure_response(details: :already_initialized) if Dir.exist?(pod_config_dir)
+
+          FileUtils.mkdir_p(pod_config_dir)
+
+          db = Infrastructure::Storage::SQL.new(db: pod_db_dir)
+          db.execute <<-SQL
+            create table podcasts (
+              id integer primary key,
+              name text not null,
+              description text,
+              feed text not null unique,
+              website text
+            );
+          SQL
+          db.execute <<-SQL
+            create table episodes (
+              id integer primary key,
+              title text not null,
+              release_date text,
+              duration text,
+              link text not null,
+              archived_at text,
+              external_id string unique,
+              podcast_id integer not null,
+              foreign key(podcast_id) references podcasts(id)
+            );
+          SQL
+
+          build_success_response(details: :successfully_initialized)
+        rescue SystemCallError, Infrastructure::Storage::Exceptions::CantStartConnection
+          build_failure_response(details: :cannot_create_initial_config)
+        end
+      end
+    end
+  end
+end

lib/pod/commands/init/runner.rb

@@ -1,9 +1,9 @@
 # frozen_string_literal: true
 
 module Pod
-  module Outputs
-    module Text
-      class Open < ::Pod::Commands::BaseOutput
+  module Commands
+    module Open
+      class Output < ::Pod::Commands::BaseOutput
         def call
           case @context[:details]
           when :not_found

lib/pod/commands/open.rb

@@ -0,0 +1,24 @@
+module Pod
+  module Commands
+    module Open
+      class Runner < Pod::Commands::BaseRunner
+        def call(episode_id, options = {})
+          parsed_options = parse_options(options)
+
+          db = Infrastructure::Storage::SQL.new(db: pod_db_dir)
+          episode = db.query("select link from episodes where id = #{episode_id}")[0]
+          return build_failure_response(details: :not_found) if episode.nil?
+
+          browser = parsed_options["browser"] || "firefox"
+          cmd = "#{browser} #{episode.link}"
+          cmd << " && bundle exec pod archive #{episode_id}" if parsed_options["archive"]
+
+          build_success_response(
+            details: :episode_found,
+            metadata: {cmd: cmd}
+          )
+        end
+      end
+    end
+  end
+end

lib/pod/outputs/text/open.rb renamed to lib/pod/commands/open/output.rb

@@ -1,9 +1,9 @@
 # frozen_string_literal: true
 
 module Pod
-  module Outputs
-    module Text
-      class Podcasts < ::Pod::Commands::BaseOutput
+  module Commands
+    module Podcasts
+      class Output < ::Pod::Commands::BaseOutput
         def call
           case @context[:details]
           when :records_found