chore(CE): Add Slack App to DB (#1364)

Co-authored-by: TivonB-AI2 <[email protected]>

Author: aisquared-ci-bot[bot]

server/app/models/agents/workflow.rb

@@ -9,6 +9,7 @@ class Workflow < ApplicationRecord
     has_many :components, dependent: :destroy
     has_many :workflow_runs, dependent: :destroy
     has_many :visual_components, as: :configurable, dependent: :destroy
+    has_one :workflow_integration, dependent: :nullify
 
     enum status: { draft: 0, published: 1 }
     enum trigger_type: { website_chatbot: 0, chat_assistant: 1, scheduled: 2, api_trigger: 3 }

server/app/models/schema_validations/integration/configuration_slack.json

@@ -0,0 +1,11 @@
+{
+    "client_id": {
+        "type": "string"
+    },
+    "client_secret": {
+        "type": "string"
+    },
+    "signing_signature": {
+        "type": "string"
+    }
+}

server/app/models/workflow_integration.rb

@@ -0,0 +1,26 @@
+# frozen_string_literal: true
+
+class WorkflowIntegration < ApplicationRecord
+  SLACK_CONFIG_JSON_SCHEMA = Rails.root.join("app/models/schema_validations/integrations/configuration_slack.json")
+
+  belongs_to :workflow, class_name: "Agents::Workflow"
+  belongs_to :workspace
+
+  enum app_type: { slack: 0 }
+
+  validates :connection_configuration, presence: true, json: { schema: lambda {
+                                                                         connection_configuration_schema_validation
+                                                                       } }, if: :requires_configuration?
+
+  validates :workflow_id, :workspace_id, :app_type, :metadata, presence: true
+
+  def requires_configuration?
+    %w[slack].include?(app_type)
+  end
+
+  def connection_configuration_schema_validation
+    return unless slack?
+
+    SLACK_CONFIG_JSON_SCHEMA
+  end
+end

server/app/models/workspace.rb

@@ -30,6 +30,7 @@ class Workspace < ApplicationRecord
   has_many :workflows, class_name: "Agents::Workflow", dependent: :destroy
   has_many :workflow_runs, class_name: "Agents::WorkflowRun", dependent: :destroy
   has_many :workflow_logs, class_name: "Agents::WorkflowLog", dependent: :nullify
+  has_many :workflow_integrations, dependent: :nullify
 
   belongs_to :organization
   has_many :sso_configurations, through: :organization

server/db/migrate/20250925150504_create_workflow_integration.rb

@@ -0,0 +1,13 @@
+class CreateWorkflowIntegration < ActiveRecord::Migration[7.1]
+  def change
+    create_table :workflow_integrations, id: :uuid do |t|
+      t.jsonb :metadata, null: false
+      t.integer :workspace_id, null: false
+      t.string :workflow_id, null: false
+
+      t.timestamps
+    end
+
+    add_foreign_key :workflow_integrations, :workspaces, validate: false
+  end
+end

server/db/migrate/20251006204127_add_connection_configuration_for_workflow_integration.rb

@@ -0,0 +1,21 @@
+class AddConnectionConfigurationForWorkflowIntegration < ActiveRecord::Migration[7.1]
+  def up
+    unless column_exists?(:workflow_integrations, :app_type)
+      add_column :workflow_integrations, :app_type, :integer, null: false
+    end
+
+    unless column_exists?(:workflow_integrations, :connection_configuration)
+      add_column :workflow_integrations, :connection_configuration, :jsonb, null: false
+    end
+  end
+
+  def down
+    if column_exists?(:workflow_integrations, :app_type)
+      safety_assured { remove_column :workflow_integrations, :app_type }
+    end
+
+    if column_exists?(:workflow_integrations, :connection_configuration)
+      safety_assured { remove_column :workflow_integrations, :connection_configuration }
+    end
+  end
+end

server/db/migrate/20251009173752_change_workflow_id_from_stringto_uuid_in_workflow_integration.rb

@@ -0,0 +1,11 @@
+class ChangeWorkflowIdFromStringtoUuidInWorkflowIntegration < ActiveRecord::Migration[7.1]
+  def up
+    safety_assured { change_column :workflow_integrations, :workflow_id, 'uuid USING workflow_id::uuid' }
+    add_foreign_key :workflow_integrations, :workflows, column: :workflow_id, validate: false
+  end
+
+  def down
+    safety_assured { change_column :workflow_integrations, :workflow_id, :string }
+    remove_foreign_key :workflow_integrations, column: :workflow_id
+  end
+end

server/db/schema.rb

@@ -0,0 +1,24 @@
+# frozen_string_literal: true
+
+FactoryBot.define do
+  factory :workflow_integration, class: "WorkflowIntegration" do
+    workspace
+    workflow
+    app_type { 0 }
+    connection_configuration do
+      {
+        "client_id" => Faker::Alphanumeric.alphanumeric(number: 10),
+        "client_secret" => Faker::Alphanumeric.alphanumeric(number: 10),
+        "signing_signature" => Faker::Alphanumeric.alphanumeric(number: 10),
+        "bot_token" => Faker::Alphanumeric.alphanumeric(number: 10)
+      }
+    end
+    metadata do
+      {
+        "data_app_id" => Faker::Alphanumeric.alphanumeric(number: 10),
+        "workflow_id" => Faker::Alphanumeric.alphanumeric(number: 10),
+        "visual_component_id" => Faker::Alphanumeric.alphanumeric(number: 10)
+      }
+    end
+  end
+end