Первый воркшоп

app/admin/book.rb

@@ -43,7 +43,7 @@ def scoped_collection
   FIO_FIELDS = %i[first_name last_name middle_name]
 
   member_action :download, method: :post do
-    info = Books::Extract.call(id: params[:id])
+    info = Books::ExtractService.call(id: params[:id])
 
     send_file info[:tempfile], type: 'application/octet-stream', filename: info[:filename]
   end

app/services/authors/counter_cache.rb → app/contexts/authors/counter_cache_command.rb

@@ -1,4 +1,4 @@
-class Authors::CounterCache
+class Authors::CounterCacheCommand
   include Callable
 
   QUERY = <<~SQL

app/services/authors/parse.rb → app/contexts/authors/parse_service.rb

@@ -1,4 +1,4 @@
-class Authors::Parse
+class Authors::ParseService
   include Callable
   extend Dry::Initializer
 

app/services/books/extract.rb → app/contexts/books/extract_service.rb

@@ -1,4 +1,4 @@
-class Books::Extract
+class Books::ExtractService
   include Callable
   extend Dry::Initializer
 

app/services/books/links.rb → app/contexts/books/links_service.rb

@@ -1,4 +1,4 @@
-class Books::Links
+class Books::LinksService
   include Callable
   extend Dry::Initializer
 

app/services/books/parse.rb → app/contexts/books/parse_service.rb

@@ -1,4 +1,4 @@
-class Books::Parse
+class Books::ParseService
   include Callable
   extend Dry::Initializer
 

app/services/folders/parse.rb → app/contexts/folders/parse_service.rb

@@ -1,4 +1,4 @@
-class Folders::Parse
+class Folders::ParseService
   include Callable
   extend Dry::Initializer
 

app/services/genres/counter_cache.rb → app/contexts/genres/counter_cache_command.rb

@@ -1,4 +1,4 @@
-class Genres::CounterCache
+class Genres::CounterCacheCommand
   include Callable
 
   QUERY = <<~SQL

app/services/genres/parse.rb → app/contexts/genres/parse_service.rb

@@ -1,4 +1,4 @@
-class Genres::Parse
+class Genres::ParseService
   include Callable
   extend Dry::Initializer
 

app/services/keywords/counter_cache.rb → app/contexts/keywords/counter_cache_command.rb

@@ -1,4 +1,4 @@
-class Keywords::CounterCache
+class Keywords::CounterCacheCommand
   include Callable
 
   QUERY = <<~SQL

app/services/keywords/parse.rb → app/contexts/keywords/parse_service.rb

@@ -1,4 +1,4 @@
-class Keywords::Parse
+class Keywords::ParseService
   include Callable
   extend Dry::Initializer
 

app/services/languages/counter_cache.rb → app/contexts/languages/counter_cache_command.rb

@@ -1,4 +1,4 @@
-class Languages::CounterCache
+class Languages::CounterCacheCommand
   include Callable
 
   QUERY = <<~SQL

app/services/languages/parse.rb → app/contexts/languages/parse_service.rb

@@ -1,4 +1,4 @@
-class Languages::Parse
+class Languages::ParseService
   include Callable
   extend Dry::Initializer
 

db/seeds.rb

@@ -1,8 +1,8 @@
 if (File.exist? Settings.app.sql_dump_path)
   Seeds::SqlDumpLoad.call(filename: Settings.app.sql_dump_path)
-  Authors::CounterCache.call
-  Genres::CounterCache.call
-  Keywords::CounterCache.call
+  Authors::CounterCacheCommand.call
+  Genres::CounterCacheCommand.call
+  Keywords::CounterCacheCommand.call
 else
   Book.destroy_all
   Seeds::GenreLoad.call(filename: 'db/seeds/genres.yml')

lib/connector.rb

@@ -0,0 +1,3 @@
+class Connector
+  include Singleton
+end

lib/setting.rb

@@ -0,0 +1,9 @@
+class Setting
+  include Singleton
+  extend Forwardable
+  def_delegators :@list, :[]=, :[]
+
+  def initialize
+    @list = {}
+  end
+end

lib/tasks/inpx.rake

@@ -45,7 +45,7 @@ namespace :inpx do
     puts title
     folders = Parallel.map(Range.new(0, count - 1), in_processes: count) do |index|
                 start = Time.zone.now
-                folders = Folders::Parse.call(books: chunks[index])
+                folders = Folders::ParseService.call(books: chunks[index])
                 finish = Time.zone.now
                 puts format("Процесс %d: %0.2f сек", index, (finish - start))
                 folders.uniq
@@ -57,7 +57,7 @@ namespace :inpx do
     puts title
     Parallel.map(Range.new(0, count - 1), in_processes: count) do |index|
       start = Time.zone.now
-      Books::Parse.call(books: chunks[index])
+      Books::ParseService.call(books: chunks[index])
       finish = Time.zone.now
       puts format("Процесс %d: %0.2f сек", index, (finish - start))
     end
@@ -67,7 +67,7 @@ namespace :inpx do
     puts title
     authors = Parallel.map(Range.new(0, count - 1), in_processes: count) do |index|
                 start = Time.zone.now
-                authors = Authors::Parse.call(books: chunks[index])
+                authors = Authors::ParseService.call(books: chunks[index])
                 finish = Time.zone.now
                 puts format("Процесс %d: %0.2f сек", index, (finish - start))
                 authors.flatten.uniq
@@ -79,7 +79,7 @@ namespace :inpx do
     puts title
     keywords = Parallel.map(Range.new(0, count - 1), in_processes: count) do |index|
                 start = Time.zone.now
-                keywords = Keywords::Parse.call(books: chunks[index])
+                keywords = Keywords::ParseService.call(books: chunks[index])
                 finish = Time.zone.now
                 puts format("Процесс %d: %0.2f сек", index, (finish - start))
                 keywords.uniq
@@ -96,7 +96,7 @@ namespace :inpx do
 
     Parallel.map(Range.new(0, count - 1), in_processes: count) do |index|
       start = Time.zone.now
-      Books::Links.call(
+      Books::LinksService.call(
         books: chunks[index],
         genres_map: genres_map,
         keywords_map: keywords_map,
@@ -106,10 +106,10 @@ namespace :inpx do
       puts format("Процесс %d: %0.2f сек", index, (finish - start))
     end
 
-    Authors::CounterCache.call
-    Genres::CounterCache.call
-    Keywords::CounterCache.call
-    Languages::CounterCache.call
+    Authors::CounterCacheCommand.call
+    Genres::CounterCacheCommand.call
+    Keywords::CounterCacheCommand.call
+    Languages::CounterCacheCommand.call
 
     puts "Связей книг и авторов #{BooksAuthor.count}"
     puts "Связей книг и ключевых слов #{BooksKeyword.count}"

spec/services/authors/counter_cache_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Authors::CounterCache do
+RSpec.describe Authors::CounterCacheCommand do
   subject(:operation) { described_class }
 
   let(:fio) { 'Алешкин,Тимофей,Владимирович' }

spec/services/authors/parse_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Authors::Parse do
+RSpec.describe Authors::ParseService do
   subject(:operation) { described_class }
 
   let(:books) { File.readlines('spec/fixtures/fb2-ru-ok-sf.inp') }

spec/services/books/extract_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Books::Extract do
+RSpec.describe Books::ExtractService do
   subject(:operation) { described_class }
   let(:book) { create(:extract_book) }
 

spec/services/books/links_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Books::Links do
+RSpec.describe Books::LinksService do
   subject(:operation) { described_class }
 
   let(:books) { File.readlines('spec/fixtures/fb2-ru-ok-sf.inp') }

spec/services/books/parse_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Books::Parse do
+RSpec.describe Books::ParseService do
   subject(:operation) { described_class }
 
   let(:books) { File.readlines('spec/fixtures/fb2-ru-ok-sf.inp') }

spec/services/folders/parse_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Folders::Parse do
+RSpec.describe Folders::ParseService do
   subject(:operation) { described_class }
 
   let(:books) { File.readlines('spec/fixtures/fb2-ru-ok-sf.inp') }

spec/services/genres/counter_cache_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Genres::CounterCache do
+RSpec.describe Genres::CounterCacheCommand do
   subject(:operation) { described_class }
 
   before { inp_full_load('spec/fixtures/fb2-ru-ok-sf.inp') }

spec/services/genres/parse_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Genres::Parse do
+RSpec.describe Genres::ParseService do
   subject(:operation) { described_class }
 
   let(:filename) { 'spec/fixtures/fb2-ru-ok-sf.inp' }

spec/services/keywords/counter_cache_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Keywords::CounterCache do
+RSpec.describe Keywords::CounterCacheCommand do
   subject(:operation) { described_class }
 
   before { inp_full_load('spec/fixtures/fb2-ru-ok-sf.inp') }

spec/services/keywords/parse_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Keywords::Parse do
+RSpec.describe Keywords::ParseService do
   subject(:operation) { described_class }
 
   let(:books) { File.readlines('spec/fixtures/fb2-ru-ok-sf.inp') }

spec/services/languages/counter_cache_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Languages::CounterCache do
+RSpec.describe Languages::CounterCacheCommand do
   subject(:operation) { described_class }
 
   before { inp_full_load('spec/fixtures/fb2-ru-ok-sf.inp') }

spec/services/languages/parse_spec.rb

@@ -1,4 +1,4 @@
-RSpec.describe Languages::Parse do
+RSpec.describe Languages::ParseService do
   subject(:operation) { described_class }
 
   let(:filename) { 'spec/fixtures/fb2-ru-ok-sf.inp' }

spec/support/loader_helpers.rb

@@ -17,7 +17,7 @@ def inp_full_load(path)
 
     lines = File.readlines(path)
 
-    Books::Links.call(
+    Books::LinksService.call(
       books: lines,
       genres_map: Genre.pluck(:slug, :id).to_h,
       keywords_map: Keyword.pluck(:name, :id).to_h,
@@ -51,21 +51,21 @@ def load_languages
   end
 
   def load_folders(lines)
-    folders = Folders::Parse.call(books: lines)
+    folders = Folders::ParseService.call(books: lines)
     Folder.create(folders.map { |f| { name: f } })
   end
 
   def load_books(lines)
-    Books::Parse.call(books: lines)
+    Books::ParseService.call(books: lines)
   end
 
   def load_keywords(lines)
-    keywords = Keywords::Parse.call(books: lines)
+    keywords = Keywords::ParseService.call(books: lines)
     Keyword.import keywords.uniq.map { |name| Keyword.new(name: name) }
   end
 
   def load_authors(lines)
-    authors = Authors::Parse.call(books: lines)
+    authors = Authors::ParseService.call(books: lines)
     Author.import authors.flatten.uniq.map { |attr| Author.new(attr) }
   end
 end