# frozen_string_literal: true

require "thor"
require "dotenv"
require "json_schemer"
require "polyn/cli/configuration"
require "polyn/cli/consumer_generator"
require "polyn/cli/naming"
require "polyn/cli/schema_generator"
require "polyn/cli/stream_generator"
require "polyn/cli/cloud_event"
require "polyn/cli/schema_loader"
require "polyn/cli/version"
require "json"
require "nats/client"

Dotenv.load

module Polyn
  ##
  # CLI for Polyn for configuring NATS server
  class Cli
    ##
    # Proxy to Thor start
    def self.start(args)
      Commands.start(args)
    end

    class Error < StandardError; end
    class ValidationError < Error; end

    ##
    # Configuration information for Polyn
    def self.configuration
      @configuration ||= Polyn::Cli::Configuration.new
    end

    ##
    # Thor commands for the CLI. Subclassed so other classes can be in the CLI namespace
    class Commands < Thor
      include Thor::Actions

      source_root File.join(File.expand_path(__dir__), "templates")

      # https://github.com/rails/thor/wiki/Making-An-Executable
      def self.exit_on_failure?
        true
      end

      method_option :dir, default: Dir.getwd
      desc "init", "initializes a Polyn event repository"
      def init
        say "Initializing Polyn event repository"
        directory "tf", File.join(options.dir, "tf")
        directory "events", File.join(options.dir, "events")
        template "docker-compose.yml", File.join(options.dir, "docker-compose.yml")
        template "gitignore", File.join(options.dir, ".gitignore")
        template "README.md", File.join(options.dir, "README.md")
        run tf_init
        say "Initializing git"
        inside options.dir do
          run "git init"
        end
        say "Repository initialized"
      end

      method_option :dir, default: Dir.getwd
      desc "tf_init", "Initializes Terraform for configuration"
      def tf_init
        say "Initializing Terraform"
        inside File.join(options.dir, "tf") do
          run "terraform init"
        end
      end

      desc "up", "updates the JetStream streams and consumers, as well the Polyn event registry"
      def up
        if polyn_env == "development"
          say "Starting NATS"
          run "docker compose up --detach"
        end

        say "Updating JetStream configuration"
        inside "tf" do
          run tf_apply
        end

        say "Updating Polyn event registry"
        Polyn::Cli::SchemaLoader.new(self).load_events
      end

      private

      def polyn_env
        Polyn::Cli.configuration.polyn_env
      end

      def nats_servers
        Polyn::Cli.configuration.nats_servers
      end

      def tf_apply
        if polyn_env == "development"
          %(terraform apply -var "jetstream_servers=#{nats_servers}" -auto-approve)
        else
          %(terraform apply -var "jetstream_servers=#{nats_servers}")
        end
      end

      register(Polyn::Cli::SchemaGenerator, "gen:schema", "gen:schema EVENT_TYPE",
        "Generates a new JSON Schema file for an event")
      register(Polyn::Cli::StreamGenerator, "gen:stream", "gen:stream NAME",
        "Generates a new stream configuration with boilerplate")
      register(Polyn::Cli::ConsumerGenerator, "gen:consumer",
        "gen:consumer STREAM_NAME DESTINATION_NAME EVENT_TYPE",
        "Generates a new NATS Consumer configuration with boilerplate")
    end
  end
end