checking in changes for ios and android add ons

Author: taimoorq

app/assets/stylesheets/application.tailwind.css

@@ -472,6 +472,15 @@
   .project-type-icon-dotnet {
     @apply bg-violet-50 text-violet-800 ring-1 ring-violet-200;
   }
+  .project-type-icon-cloudflare_pages {
+    @apply bg-orange-50 text-orange-700 ring-1 ring-orange-200;
+  }
+  .project-type-icon-android {
+    @apply bg-lime-50 text-lime-800 ring-1 ring-lime-200;
+  }
+  .project-type-icon-ios {
+    @apply bg-zinc-50 text-zinc-800 ring-1 ring-zinc-200;
+  }
   .project-type-icon-http_api {
     @apply bg-emerald-50 text-emerald-800 ring-1 ring-emerald-200;
   }

app/controllers/concerns/project_settings_context.rb

@@ -13,6 +13,10 @@ def load_project_settings_context
                         .select(:id, :uuid, :project_id, :name, :last_used_at, :revoked_at, :created_at)
                         .order(created_at: :desc)
     @notification_preference ||= ProjectNotificationPreference.for(user: current_user, project: @project)
+    @cloudflare_integration_setting ||= ProjectIntegrationSetting.for(
+      project: @project,
+      provider: ProjectIntegrationSetting::PROVIDERS[:cloudflare_pages]
+    ) if @project.integration_cloudflare_pages?
     @assignment_summary = ProjectAssignmentSummary.new(@project)
     @retention_policy ||= ProjectRetentionPolicy.for(project: @project) if @project.owned_by?(current_user)
     @public_api_rate_limit_defaults = {

app/controllers/project_integration_settings_controller.rb

@@ -0,0 +1,39 @@
+class ProjectIntegrationSettingsController < ApplicationController
+  include ProjectScope
+  include ProjectSettingsContext
+
+  before_action :authenticate_user!
+  before_action :set_owned_project
+
+  def update
+    @integration_setting = ProjectIntegrationSetting.for(
+      project: @project,
+      provider: integration_setting_params.fetch(:provider)
+    )
+    @integration_setting.assign_attributes(integration_setting_params)
+
+    if @integration_setting.save
+      redirect_to settings_project_path(@project, anchor: "platform-integration"),
+                  notice: "#{@integration_setting.provider.humanize} settings updated."
+    else
+      @cloudflare_integration_setting = @integration_setting if @integration_setting.provider_cloudflare_pages?
+      load_project_settings_context
+      render "projects/settings", status: :unprocessable_content
+    end
+  end
+
+  private
+
+  def integration_setting_params
+    params.require(:project_integration_setting).permit(
+      :provider,
+      :enabled,
+      :account_id,
+      :external_project_id,
+      :external_project_name,
+      :credential_reference
+    ).tap do |permitted|
+      permitted[:enabled] = ActiveModel::Type::Boolean.new.cast(permitted[:enabled]) if permitted.key?(:enabled)
+    end
+  end
+end

app/controllers/projects_controller.rb

@@ -62,7 +62,7 @@ def new
   end
 
   def create
-    @project = current_user.projects.new(project_params)
+    @project = current_user.projects.new(project_create_params)
     if @project.save
       redirect_to settings_project_path(@project, anchor: "integration-guide"),
                   notice: "Project created. Follow the #{@project.integration_label} setup guide to start ingesting events."
@@ -75,7 +75,7 @@ def edit
   end
 
   def update
-    if @project.update(project_params)
+    if @project.update(project_update_params)
       redirect_to settings_project_path(@project), notice: "Project updated."
     else
       render :edit, status: :unprocessable_content
@@ -165,10 +165,14 @@ def legacy_inbox_request?
     (request.query_parameters.keys & LEGACY_INBOX_PARAMS).any?
   end
 
-  def project_params
+  def project_create_params
     params.require(:project).permit(:name, :description, :integration_kind)
   end
 
+  def project_update_params
+    params.require(:project).permit(:name, :description)
+  end
+
   def filtered_projects(scope, filter)
     case filter
     when "archived" then scope.archived

app/helpers/application_helper.rb

@@ -35,6 +35,9 @@ module ApplicationHelper
     "javascript" => :project_javascript,
     "python" => :project_python,
     "dotnet" => :project_dotnet,
+    "cloudflare_pages" => :external,
+    "android" => :projects,
+    "ios" => :projects,
     "http_api" => :external
   }.freeze
 

app/helpers/projects_helper.rb

@@ -10,6 +10,21 @@ module ProjectsHelper
       badge: "NuGet",
       description: "ASP.NET Core apps, .NET workers, C# services, and custom metrics with logister-dotnet."
     },
+    "cloudflare_pages" => {
+      label: "Cloudflare Pages",
+      badge: "Importer",
+      description: "Pages deployments, Web Analytics, traffic rollups, build health, and domain-level site signals."
+    },
+    "android" => {
+      label: "Android app",
+      badge: "Gradle",
+      description: "Android app telemetry from logister-android, plus optional Google Play vitals imports."
+    },
+    "ios" => {
+      label: "iOS app",
+      badge: "SPM",
+      description: "iOS app telemetry from logister-ios, plus optional App Store Connect analytics imports."
+    },
     "cfml" => {
       label: "CFML",
       badge: "CFML",
@@ -44,6 +59,9 @@ def project_integration_docs_path(project)
     return docs_site_url(:javascript_integration) if project&.integration_javascript?
     return docs_site_url(:python_integration) if project&.integration_python?
     return docs_site_url(:http_api) if project&.integration_http_api?
+    return docs_site_url(:http_api) if project&.integration_cloudflare_pages?
+    return docs_site_url(:http_api) if project&.integration_android?
+    return docs_site_url(:http_api) if project&.integration_ios?
 
     docs_site_url(:ruby_integration)
   end
@@ -54,6 +72,9 @@ def project_integration_docs_label(project)
     return "JavaScript integration docs" if project&.integration_javascript?
     return "Python integration docs" if project&.integration_python?
     return "HTTP API docs" if project&.integration_http_api?
+    return "HTTP API docs" if project&.integration_cloudflare_pages?
+    return "HTTP API docs" if project&.integration_android?
+    return "HTTP API docs" if project&.integration_ios?
 
     "Ruby integration docs"
   end

app/jobs/cloudflare_pages_import_job.rb

@@ -0,0 +1,8 @@
+class CloudflarePagesImportJob < ApplicationJob
+  queue_as :default
+
+  def perform(project_integration_setting_id)
+    setting = ProjectIntegrationSetting.find_by(id: project_integration_setting_id)
+    Logister::CloudflarePagesImporter.call(setting)
+  end
+end

app/models/project.rb

@@ -15,6 +15,7 @@ class Project < ApplicationRecord
   has_many :check_in_monitors, dependent: :destroy
   has_many :project_memberships, dependent: :destroy
   has_many :project_notification_preferences, dependent: :destroy
+  has_many :integration_settings, class_name: "ProjectIntegrationSetting", dependent: :destroy
   has_many :email_notification_deliveries, dependent: :destroy
   has_one :retention_policy, class_name: "ProjectRetentionPolicy", dependent: :destroy
   has_many :telemetry_archives, dependent: :destroy
@@ -23,12 +24,17 @@ class Project < ApplicationRecord
   before_validation :ensure_uuid
   before_validation :normalize_slug
 
+  validate :integration_kind_cannot_change, on: :update
+
   enum :integration_kind, {
     ruby: "ruby",
     cfml: "cfml",
     javascript: "javascript",
     python: "python",
     dotnet: "dotnet",
+    cloudflare_pages: "cloudflare_pages",
+    android: "android",
+    ios: "ios",
     http_api: "http_api"
   }, default: :ruby, validate: true, prefix: :integration
 
@@ -111,6 +117,9 @@ def integration_label
       "javascript" => "JavaScript / TypeScript",
       "python" => "Python",
       "dotnet" => ".NET / ASP.NET Core",
+      "cloudflare_pages" => "Cloudflare Pages",
+      "android" => "Android app",
+      "ios" => "iOS app",
       "http_api" => "Manual / HTTP API"
     }.fetch(integration_kind, integration_kind.to_s.humanize)
   end
@@ -130,6 +139,9 @@ def public_api_auth_failure_rate_limit_requests_effective(default)
   def self.integration_options
     [
       [ "Manual / HTTP API (custom client)", "http_api" ],
+      [ "Cloudflare Pages", "cloudflare_pages" ],
+      [ "Android app (logister-android)", "android" ],
+      [ "iOS app (logister-ios)", "ios" ],
       [ "Ruby gem", "ruby" ],
       [ ".NET / ASP.NET Core (logister-dotnet)", "dotnet" ],
       [ "JavaScript / TypeScript (logister-js)", "javascript" ],
@@ -241,4 +253,10 @@ def normalize_slug
     base = slug.presence || name
     self.slug = base.to_s.parameterize
   end
+
+  def integration_kind_cannot_change
+    return unless will_save_change_to_integration_kind?
+
+    errors.add(:integration_kind, "cannot be changed after project creation")
+  end
 end

app/models/project_integration_setting.rb

@@ -0,0 +1,66 @@
+class ProjectIntegrationSetting < ApplicationRecord
+  PROVIDERS = {
+    cloudflare_pages: "cloudflare_pages",
+    google_play: "google_play",
+    app_store_connect: "app_store_connect"
+  }.freeze
+
+  belongs_to :project
+
+  before_validation :ensure_uuid
+  before_validation :normalize_fields
+
+  enum :provider, PROVIDERS, validate: true, prefix: true
+
+  validates :uuid, presence: true, uniqueness: true
+  validates :provider, presence: true, uniqueness: { scope: :project_id }
+  validates :account_id, presence: true, if: :provider_cloudflare_pages?
+  validates :external_project_name, presence: true, if: :provider_cloudflare_pages?
+  validate :provider_matches_project_integration
+
+  scope :enabled, -> { where(enabled: true) }
+  scope :cloudflare_pages, -> { where(provider: PROVIDERS[:cloudflare_pages]) }
+  scope :due_for_import, ->(before: 15.minutes.ago) {
+    enabled.where("last_imported_at IS NULL OR last_imported_at <= ?", before)
+  }
+
+  def to_param
+    uuid
+  end
+
+  def self.for(project:, provider:)
+    find_or_initialize_by(project: project, provider: provider.to_s)
+  end
+
+  def configured?
+    case provider
+    when PROVIDERS[:cloudflare_pages]
+      enabled? && account_id.present? && external_project_name.present? && credential_reference.present?
+    else
+      enabled?
+    end
+  end
+
+  private
+
+  def ensure_uuid
+    self.uuid ||= SecureRandom.uuid
+  end
+
+  def normalize_fields
+    self.account_id = account_id.to_s.strip.presence
+    self.external_project_id = external_project_id.to_s.strip.presence
+    self.external_project_name = external_project_name.to_s.strip.presence
+    self.credential_reference = credential_reference.to_s.strip.presence
+    self.metadata = metadata.is_a?(Hash) ? metadata : {}
+  end
+
+  def provider_matches_project_integration
+    return if project.blank? || provider.blank?
+    return if provider_cloudflare_pages? && project.integration_cloudflare_pages?
+    return if provider_google_play? && project.integration_android?
+    return if provider_app_store_connect? && project.integration_ios?
+
+    errors.add(:provider, "does not match this project's integration type")
+  end
+end

app/services/logister/cloudflare_pages_importer.rb

@@ -0,0 +1,31 @@
+module Logister
+  class CloudflarePagesImporter
+    Result = Data.define(:status, :reason, :setting) do
+      def imported? = status == :imported
+      def skipped? = status == :skipped
+    end
+
+    def self.call(setting)
+      new(setting).call
+    end
+
+    def initialize(setting)
+      @setting = setting
+    end
+
+    def call
+      return Result.new(status: :skipped, reason: :missing_setting, setting: nil) unless setting
+      return Result.new(status: :skipped, reason: :wrong_provider, setting: setting) unless setting.provider_cloudflare_pages?
+      return Result.new(status: :skipped, reason: :not_configured, setting: setting) unless setting.configured?
+
+      # The API fetcher lands here next. Keeping the job/service boundary now
+      # lets settings, scheduling, and result handling settle before credentials
+      # or Cloudflare API calls enter the code path.
+      Result.new(status: :skipped, reason: :fetcher_not_implemented, setting: setting)
+    end
+
+    private
+
+    attr_reader :setting
+  end
+end