Add loop for archive and pvpc data retrieval

.foreman

@@ -0,0 +1 @@
+port: 3000

Dockerfile

@@ -60,4 +60,4 @@ ENTRYPOINT ["/rails/bin/docker-entrypoint"]
 
 # Start the server by default, this can be overwritten at runtime
 EXPOSE 3000
-CMD ["./bin/rails", "server"]
+CMD ["./bin/foreman", "start"]

Gemfile

@@ -21,6 +21,8 @@ gem "turbo-rails"
 
 ## LIBRARIES
 gem "bootsnap", require: false
+gem "clockwork"
+gem "foreman"
 gem "http"
 gem "huawei_solar"
 

Gemfile.lock

@@ -119,6 +119,9 @@ GEM
       rack-test (>= 0.6.3)
       regexp_parser (>= 1.5, < 3.0)
       xpath (~> 3.2)
+    clockwork (3.0.2)
+      activesupport
+      tzinfo
     concurrent-ruby (1.2.2)
     connection_pool (2.4.1)
     crass (1.0.6)
@@ -138,6 +141,7 @@ GEM
     ffi-compiler (1.0.1)
       ffi (>= 1.0.0)
       rake
+    foreman (0.87.2)
     globalid (1.1.0)
       activesupport (>= 5.0)
     http (5.1.1)
@@ -305,9 +309,11 @@ DEPENDENCIES
   better_errors
   bootsnap
   capybara
+  clockwork
   debug
   dotenv-rails
   error_highlight
+  foreman
   http
   huawei_solar
   importmap-rails

Procfile

@@ -0,0 +1,2 @@
+web: bin/puma -C config/puma.rb
+clock: bin/clockwork config/clockwork.rb

app/lib/config.rb

@@ -5,8 +5,8 @@ def loop_interval
     ENV.fetch("SOLARIS_LOOP_INTERVAL", 30).to_i
   end
 
-  def storage_interval
-    ENV.fetch("SOLARIS_STORAGE_INTERVAL", 300).to_i
+  def archive_interval
+    ENV.fetch("SOLARIS_ARCHIVE_INTERVAL", 300).to_i
   end
 
   def esios_api_key

app/lib/solaris/esios.rb

@@ -0,0 +1,46 @@
+module Solaris
+  class ESIOS
+    def self.run
+      new.run
+    end
+
+    def run
+      perform_pvpc if condition_for_pvpc
+    end
+
+    private
+
+    def perform_pvpc
+      pvpc_import
+      pvpc_export
+    end
+
+    def condition_for_pvpc
+      PVPC.where(datetime: tomorrow_range).count != 24
+    end
+
+    def tomorrow
+      Date.tomorrow
+    end
+
+    def tomorrow_range
+      tomorrow.all_day
+    end
+
+    def pvpc_import
+      ESIOS::Import.for_date(tomorrow).each do |data|
+        pvpc = PVPC.find_or_initialize_by(datetime: data[:datetime])
+        pvpc.assign_attributes(import: data[:value])
+        pvpc.save
+      end
+    end
+
+    def pvpc_export
+      ESIOS::Export.for_date(tomorrow).each do |data|
+        pvpc = PVPC.find_or_initialize_by(datetime: data[:datetime])
+        pvpc.assign_attributes(export: data[:value])
+        pvpc.save
+      end
+    end
+  end
+end

app/lib/solaris/loop.rb

@@ -0,0 +1,29 @@
+module Solaris
+  class Loop
+    def self.run
+      new.run
+    end
+
+    def run
+      perform_archive if condition_for_archive
+    end
+
+    private
+
+    def last_archive
+      Archive.order(created_at: :desc).first
+    end
+
+    def condition_for_archive
+      last_archive.nil? || last_archive.created_at < Config.archive_interval.seconds.ago
+    end
+
+    def perform_archive
+      loop do
+        break if Archive.create_from_inverter.persisted?
+      rescue Errno::ECONNRESET
+        Rails.logger.error "Connection reset, retrying..."
+      end
+    end
+  end
+end

bin/clockwork

@@ -0,0 +1,27 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+#
+# This file was generated by Bundler.
+#
+# The application 'clockwork' is installed as part of a gem, and
+# this file is here to facilitate running it.
+#
+
+ENV["BUNDLE_GEMFILE"] ||= File.expand_path("../Gemfile", __dir__)
+
+bundle_binstub = File.expand_path("bundle", __dir__)
+
+if File.file?(bundle_binstub)
+  if File.read(bundle_binstub, 300) =~ /This file was generated by Bundler/
+    load(bundle_binstub)
+  else
+    abort("Your `bin/bundle` was not generated by Bundler, so this binstub cannot run.
+Replace `bin/bundle` by running `bundle binstubs bundler --force`, then run this command again.")
+  end
+end
+
+require "rubygems"
+require "bundler/setup"
+
+load Gem.bin_path("clockwork", "clockwork")

bin/clockworkd

@@ -0,0 +1,27 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+#
+# This file was generated by Bundler.
+#
+# The application 'clockworkd' is installed as part of a gem, and
+# this file is here to facilitate running it.
+#
+
+ENV["BUNDLE_GEMFILE"] ||= File.expand_path("../Gemfile", __dir__)
+
+bundle_binstub = File.expand_path("bundle", __dir__)
+
+if File.file?(bundle_binstub)
+  if File.read(bundle_binstub, 300) =~ /This file was generated by Bundler/
+    load(bundle_binstub)
+  else
+    abort("Your `bin/bundle` was not generated by Bundler, so this binstub cannot run.
+Replace `bin/bundle` by running `bundle binstubs bundler --force`, then run this command again.")
+  end
+end
+
+require "rubygems"
+require "bundler/setup"
+
+load Gem.bin_path("clockwork", "clockworkd")

bin/foreman

@@ -0,0 +1,27 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+#
+# This file was generated by Bundler.
+#
+# The application 'foreman' is installed as part of a gem, and
+# this file is here to facilitate running it.
+#
+
+ENV["BUNDLE_GEMFILE"] ||= File.expand_path("../Gemfile", __dir__)
+
+bundle_binstub = File.expand_path("bundle", __dir__)
+
+if File.file?(bundle_binstub)
+  if File.read(bundle_binstub, 300) =~ /This file was generated by Bundler/
+    load(bundle_binstub)
+  else
+    abort("Your `bin/bundle` was not generated by Bundler, so this binstub cannot run.
+Replace `bin/bundle` by running `bundle binstubs bundler --force`, then run this command again.")
+  end
+end
+
+require "rubygems"
+require "bundler/setup"
+
+load Gem.bin_path("foreman", "foreman")

bin/puma

@@ -0,0 +1,27 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+#
+# This file was generated by Bundler.
+#
+# The application 'puma' is installed as part of a gem, and
+# this file is here to facilitate running it.
+#
+
+ENV["BUNDLE_GEMFILE"] ||= File.expand_path("../Gemfile", __dir__)
+
+bundle_binstub = File.expand_path("bundle", __dir__)
+
+if File.file?(bundle_binstub)
+  if File.read(bundle_binstub, 300) =~ /This file was generated by Bundler/
+    load(bundle_binstub)
+  else
+    abort("Your `bin/bundle` was not generated by Bundler, so this binstub cannot run.
+Replace `bin/bundle` by running `bundle binstubs bundler --force`, then run this command again.")
+  end
+end
+
+require "rubygems"
+require "bundler/setup"
+
+load Gem.bin_path("puma", "puma")

bin/pumactl

@@ -0,0 +1,27 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+#
+# This file was generated by Bundler.
+#
+# The application 'pumactl' is installed as part of a gem, and
+# this file is here to facilitate running it.
+#
+
+ENV["BUNDLE_GEMFILE"] ||= File.expand_path("../Gemfile", __dir__)
+
+bundle_binstub = File.expand_path("bundle", __dir__)
+
+if File.file?(bundle_binstub)
+  if File.read(bundle_binstub, 300) =~ /This file was generated by Bundler/
+    load(bundle_binstub)
+  else
+    abort("Your `bin/bundle` was not generated by Bundler, so this binstub cannot run.
+Replace `bin/bundle` by running `bundle binstubs bundler --force`, then run this command again.")
+  end
+end
+
+require "rubygems"
+require "bundler/setup"
+
+load Gem.bin_path("puma", "pumactl")

config/clockwork.rb

@@ -0,0 +1,15 @@
+require_relative "environment"
+
+module Clockwork
+  configure do |config|
+    config[:tz] = ENV.fetch("SOLARIS_TIMEZONE", "Europe/Madrid").to_s
+  end
+
+  every(Config.loop_interval.seconds, "solaris.loop", thread: true) do
+    Solaris::Loop.run
+  end
+
+  every(1.day, "solaris.esios", at: ["20:30", "21:30", "22:30", "23:30"], thread: true) do
+    Solaris::ESIOS.run
+  end
+end