re-enqueue ga4 import if auth expires

Author: ewdurbin

lib/plausible/google/ga4/api.ex

@@ -170,6 +170,9 @@ defmodule Plausible.Google.GA4.API do
       {:error, {:rate_limit_exceeded, details}} ->
         {:error, {:rate_limit_exceeded, details}}
 
+      {:error, {:authentication_failed, details}} ->
+        {:error, {:authentication_failed, details}}
+
       {:error, cause} ->
         if attempt >= @max_attempts do
           Logger.debug(

lib/plausible/google/ga4/http.ex

@@ -69,6 +69,18 @@ defmodule Plausible.Google.GA4.HTTP do
         {:error,
          {:rate_limit_exceeded, dataset: report_request.dataset, offset: report_request.offset}}
 
+      {:error, %{reason: %{status: 401, body: body}} = error} ->
+        log_ce_error("retrieving report for #{report_request.dataset}", error)
+
+        Logger.debug(
+          "[#{inspect(__MODULE__)}:#{report_request.property}] Request failed for #{report_request.dataset} due to invalid auth."
+        )
+
+        Sentry.Context.set_extra_context(%{ga_response: %{body: body, status: 401}})
+
+        {:error,
+         {:authentication_failed, dataset: report_request.dataset, offset: report_request.offset}}
+
       {:error, %{reason: %{status: status, body: body}} = error} ->
         log_ce_error("retrieving report for #{report_request.dataset}", error)
 

lib/plausible/imported/google_analytics4.ex

@@ -123,6 +123,34 @@ defmodule Plausible.Imported.GoogleAnalytics4 do
 
           {:error, :rate_limit_exceeded, skip_purge?: true, skip_mark_failed?: true}
 
+        {:error, {:authentication_failed, details}} ->
+          site_import = Repo.preload(site_import, [:site, :imported_by])
+          dataset = Keyword.fetch!(details, :dataset)
+          offset = Keyword.fetch!(details, :offset)
+          {access_token, refresh_token, token_expires_at} = auth
+
+          resume_import_opts = [
+            property: property,
+            label: property,
+            start_date: date_range.first,
+            end_date: date_range.last,
+            access_token: access_token,
+            refresh_token: refresh_token,
+            token_expires_at: token_expires_at,
+            resume_from_import_id: site_import.id,
+            resume_from_dataset: dataset,
+            resume_from_offset: offset,
+            job_opts: [schedule_in: {65, :minutes}, unique: nil]
+          ]
+
+          new_import(
+            site_import.site,
+            site_import.imported_by,
+            resume_import_opts
+          )
+
+          {:error, :authentication_failed, skip_purge?: true, skip_mark_failed?: true}
+
         other ->
           other
       end