feat: user delete backend

apis/api-gateway/schema.graphql

@@ -217,24 +217,28 @@ type Mutation @join__type(graph: API_ANALYTICS)  @join__type(graph: API_JOURNEYS
     journeyId: ID
   ): StepBlock! @join__field(graph: API_JOURNEYS_MODERN, override: "api-journeys") 
   stepBlockPositionUpdate(input: [StepBlockPositionUpdateInput!]!) : [StepBlock!]! @join__field(graph: API_JOURNEYS) 
-  textResponseBlockCreate(input: TextResponseBlockCreateInput!) : TextResponseBlock! @join__field(graph: API_JOURNEYS) 
+  textResponseBlockCreate(input: TextResponseBlockCreateInput!) : TextResponseBlock! @join__field(graph: API_JOURNEYS_MODERN, override: "api-journeys") 
   textResponseBlockUpdate(
     id: ID!
     input: TextResponseBlockUpdateInput!
     """
     drop this parameter after merging teams
     """
     journeyId: ID
-  ): TextResponseBlock @join__field(graph: API_JOURNEYS) 
-  typographyBlockCreate(input: TypographyBlockCreateInput!) : TypographyBlock! @join__field(graph: API_JOURNEYS) 
+  ): TextResponseBlock @join__field(
+    graph: API_JOURNEYS_MODERN
+    type: "TextResponseBlock!"
+    override: "api-journeys"
+  )
+  typographyBlockCreate(input: TypographyBlockCreateInput!) : TypographyBlock! @join__field(graph: API_JOURNEYS_MODERN, override: "api-journeys") 
   typographyBlockUpdate(
     id: ID!
     input: TypographyBlockUpdateInput!
     """
     drop this parameter after merging teams
     """
     journeyId: ID
-  ): TypographyBlock! @join__field(graph: API_JOURNEYS) 
+  ): TypographyBlock! @join__field(graph: API_JOURNEYS_MODERN, override: "api-journeys") 
   chatButtonCreate(journeyId: ID!, input: ChatButtonCreateInput) : ChatButton! @join__field(graph: API_JOURNEYS) 
   chatButtonUpdate(id: ID!, journeyId: ID!, input: ChatButtonUpdateInput!) : ChatButton! @join__field(graph: API_JOURNEYS) 
   chatButtonRemove(id: ID!) : ChatButton! @join__field(graph: API_JOURNEYS) 
@@ -412,6 +416,7 @@ type Mutation @join__type(graph: API_ANALYTICS)  @join__type(graph: API_JOURNEYS
   integrationDelete(id: ID!) : Integration! @join__field(graph: API_JOURNEYS_MODERN) 
   journeyTransferFromAnonymous(journeyId: ID!, teamId: ID) : Journey! @join__field(graph: API_JOURNEYS_MODERN) 
   journeyAiTranslateCreate(input: JourneyAiTranslateInput!) : Journey! @join__field(graph: API_JOURNEYS_MODERN) 
+  journeyCustomizationDescriptionTranslate(input: JourneyCustomizationDescriptionTranslateInput!) : Journey! @join__field(graph: API_JOURNEYS_MODERN) 
   createJourneyEventsExportLog(input: JourneyEventsExportLogInput!) : JourneyEventsExportLog! @join__field(graph: API_JOURNEYS_MODERN) 
   journeyLanguageAiDetect(input: MutationJourneyLanguageAiDetectInput!) : Boolean! @join__field(graph: API_JOURNEYS_MODERN) 
   journeyProfileUpdate(input: JourneyProfileUpdateInput!) : JourneyProfile! @join__field(graph: API_JOURNEYS_MODERN) 
@@ -426,6 +431,8 @@ type Mutation @join__type(graph: API_ANALYTICS)  @join__type(graph: API_JOURNEYS
     """
     timezone: String
   ): JourneyVisitorGoogleSheetExportResult! @join__field(graph: API_JOURNEYS_MODERN) 
+  userDeleteJourneysCheck(userId: String!) : UserDeleteJourneysCheckResult! @join__field(graph: API_JOURNEYS_MODERN) 
+  userDeleteJourneysConfirm(userId: String!) : UserDeleteJourneysConfirmResult! @join__field(graph: API_JOURNEYS_MODERN) 
   audioPreviewCreate(input: MutationAudioPreviewCreateInput!) : AudioPreview! @join__field(graph: API_LANGUAGES) 
   audioPreviewUpdate(input: MutationAudioPreviewUpdateInput!) : AudioPreview! @join__field(graph: API_LANGUAGES) 
   audioPreviewDelete(languageId: ID!) : AudioPreview! @join__field(graph: API_LANGUAGES) 
@@ -554,6 +561,7 @@ type Mutation @join__type(graph: API_ANALYTICS)  @join__type(graph: API_JOURNEYS
   userImpersonate(email: String!) : String @join__field(graph: API_USERS) 
   createVerificationRequest(input: CreateVerificationRequestInput) : Boolean @join__field(graph: API_USERS) 
   validateEmail(email: String!, token: String!) : AuthenticatedUser @join__field(graph: API_USERS) 
+  userDeleteCheck(idType: UserDeleteIdType!, id: String!) : UserDeleteCheckResult! @join__field(graph: API_USERS) 
 }
 
 type MutationSiteCreateSuccess @join__type(graph: API_ANALYTICS)  {
@@ -2532,8 +2540,16 @@ type PlausibleStatsResponse @join__type(graph: API_JOURNEYS_MODERN)  {
   timeOnPage: Float
 }
 
-type Subscription @join__type(graph: API_JOURNEYS_MODERN)  {
-  journeyAiTranslateCreateSubscription(input: JourneyAiTranslateInput!) : JourneyAiTranslateProgress!
+type Subscription @join__type(graph: API_JOURNEYS_MODERN)  @join__type(graph: API_USERS)  {
+  journeyAiTranslateCreateSubscription(input: JourneyAiTranslateInput!) : JourneyAiTranslateProgress! @join__field(graph: API_JOURNEYS_MODERN) 
+  userDeleteConfirm(
+    idType: UserDeleteIdType!
+    id: String!
+    deletedJourneyIds: [String!]!
+    deletedTeamIds: [String!]!
+    deletedUserJourneyIds: [String!]!
+    deletedUserTeamIds: [String!]!
+  ): UserDeleteConfirmProgress! @join__field(graph: API_USERS) 
 }
 
 type TemplateFamilyStatsAggregateResponse @join__type(graph: API_JOURNEYS_MODERN)  {
@@ -2555,6 +2571,31 @@ type TemplateFamilyStatsEventResponse @join__type(graph: API_JOURNEYS_MODERN)  {
   visitors: Int!
 }
 
+type UserDeleteJourneysCheckResult @join__type(graph: API_JOURNEYS_MODERN)  {
+  journeysToDelete: Int!
+  journeysToTransfer: Int!
+  journeysToRemove: Int!
+  teamsToDelete: Int!
+  teamsToTransfer: Int!
+  teamsToRemove: Int!
+  logs: [UserDeleteJourneysLogEntry!]!
+}
+
+type UserDeleteJourneysConfirmResult @join__type(graph: API_JOURNEYS_MODERN)  {
+  success: Boolean!
+  deletedJourneyIds: [String!]!
+  deletedTeamIds: [String!]!
+  deletedUserJourneyIds: [String!]!
+  deletedUserTeamIds: [String!]!
+  logs: [UserDeleteJourneysLogEntry!]!
+}
+
+type UserDeleteJourneysLogEntry @join__type(graph: API_JOURNEYS_MODERN)  {
+  message: String!
+  level: USER_DELETE_LOG_LEVEL!
+  timestamp: String!
+}
+
 type YouTube @join__type(graph: API_JOURNEYS_MODERN, key: "id primaryLanguageId", extension: true)  {
   id: ID!
   primaryLanguageId: ID
@@ -3304,6 +3345,25 @@ type AnonymousUser implements User @join__type(graph: API_USERS, key: "id")  @jo
   id: ID!
 }
 
+type UserDeleteCheckResult @join__type(graph: API_USERS)  {
+  userId: String!
+  userEmail: String
+  userFirstName: String!
+  logs: [UserDeleteLogEntry!]!
+}
+
+type UserDeleteConfirmProgress @join__type(graph: API_USERS)  {
+  log: UserDeleteLogEntry!
+  done: Boolean!
+  success: Boolean
+}
+
+type UserDeleteLogEntry @join__type(graph: API_USERS)  {
+  message: String!
+  level: USER_DELETE_LOG_LEVEL!
+  timestamp: String!
+}
+
 interface BaseError @join__type(graph: API_ANALYTICS)  @join__type(graph: API_MEDIA)  {
   message: String
 }
@@ -3782,6 +3842,12 @@ enum PlausibleEvent @join__type(graph: API_JOURNEYS_MODERN)  {
   journeyResponses @join__enumValue(graph: API_JOURNEYS_MODERN) 
 }
 
+enum USER_DELETE_LOG_LEVEL @join__type(graph: API_JOURNEYS_MODERN)  @join__type(graph: API_USERS)  {
+  INFO @join__enumValue(graph: API_JOURNEYS_MODERN)  @join__enumValue(graph: API_USERS) 
+  WARN @join__enumValue(graph: API_JOURNEYS_MODERN)  @join__enumValue(graph: API_USERS) 
+  ERROR @join__enumValue(graph: API_JOURNEYS_MODERN)  @join__enumValue(graph: API_USERS) 
+}
+
 enum LanguageRole @join__type(graph: API_LANGUAGES)  {
   publisher @join__enumValue(graph: API_LANGUAGES) 
 }
@@ -3914,6 +3980,12 @@ enum App @join__type(graph: API_USERS)  {
   JesusFilmOne @join__enumValue(graph: API_USERS) 
 }
 
+enum UserDeleteIdType @join__type(graph: API_USERS)  {
+  databaseId @join__enumValue(graph: API_USERS) 
+  email @join__enumValue(graph: API_USERS) 
+  jwt @join__enumValue(graph: API_USERS) 
+}
+
 input SiteCreateInput @join__type(graph: API_ANALYTICS)  {
   domain: String!
   goals: [String!]
@@ -4826,11 +4898,49 @@ input IntegrationGoogleUpdateInput @join__type(graph: API_JOURNEYS_MODERN)  {
 }
 
 input JourneyAiTranslateInput @join__type(graph: API_JOURNEYS_MODERN)  {
+  """
+  The ID of the journey to translate
+  """
   journeyId: ID!
+  """
+  The journey name to translate
+  """
   name: String!
+  """
+  The source language name of the journey content
+  """
   journeyLanguageName: String!
+  """
+  The target language ID for journey content (blocks, title, description)
+  """
   textLanguageId: ID!
+  """
+  The target language name for journey content (blocks, title, description)
+  """
   textLanguageName: String!
+  """
+  Language ID for customization text translation. Falls back to textLanguageId if not provided.
+  """
+  userLanguageId: ID
+  """
+  Language name for customization text translation. Falls back to textLanguageName if not provided.
+  """
+  userLanguageName: String
+}
+
+input JourneyCustomizationDescriptionTranslateInput @join__type(graph: API_JOURNEYS_MODERN)  {
+  """
+  The ID of the journey whose customization description to translate
+  """
+  journeyId: ID!
+  """
+  The current language of the customization description
+  """
+  sourceLanguageName: String!
+  """
+  The language to translate the customization description into
+  """
+  targetLanguageName: String!
 }
 
 input JourneyEventsExportLogInput @join__type(graph: API_JOURNEYS_MODERN)  {

apis/api-journeys-modern/infrastructure/locals.tf

@@ -3,6 +3,8 @@ locals {
   environment_variables = [
     "AWS_ACCESS_KEY_ID",
     "AWS_SECRET_ACCESS_KEY",
+    "CLOUDFLARE_ACCOUNT_ID",
+    "CLOUDFLARE_IMAGES_TOKEN",
     "CLOUDFLARE_UPLOAD_KEY",
     "FACEBOOK_APP_ID",
     "FACEBOOK_APP_SECRET",
@@ -24,6 +26,8 @@ locals {
     "MAILCHIMP_AUDIENCE_ID",
     "MAILCHIMP_MARKETING_API_KEY",
     "MAILCHIMP_MARKETING_API_SERVER_PREFIX",
+    "MUX_UGC_ACCESS_TOKEN_ID",
+    "MUX_UGC_SECRET_KEY",
     "NAT_ADDRESSES",
     "OPEN_AI_API_KEY",
     "PG_DATABASE_URL_JOURNEYS",

apis/api-journeys-modern/schema.graphql

@@ -827,11 +827,34 @@ type Journey
 }
 
 input JourneyAiTranslateInput {
+  """The ID of the journey to translate"""
   journeyId: ID!
+
+  """The journey name to translate"""
   name: String!
+
+  """The source language name of the journey content"""
   journeyLanguageName: String!
+
+  """
+  The target language ID for journey content (blocks, title, description)
+  """
   textLanguageId: ID!
+
+  """
+  The target language name for journey content (blocks, title, description)
+  """
   textLanguageName: String!
+
+  """
+  Language ID for customization text translation. Falls back to textLanguageId if not provided.
+  """
+  userLanguageId: ID
+
+  """
+  Language name for customization text translation. Falls back to textLanguageName if not provided.
+  """
+  userLanguageName: String
 }
 
 type JourneyAiTranslateProgress {
@@ -884,6 +907,17 @@ input JourneyCreateInput {
   slug: String
 }
 
+input JourneyCustomizationDescriptionTranslateInput {
+  """The ID of the journey whose customization description to translate"""
+  journeyId: ID!
+
+  """The current language of the customization description"""
+  sourceLanguageName: String!
+
+  """The language to translate the customization description into"""
+  targetLanguageName: String!
+}
+
 type JourneyCustomizationField
   @shareable
 {
@@ -1426,6 +1460,22 @@ type Mutation {
     """drop this parameter after merging teams"""
     journeyId: ID
   ): StepBlock! @override(from: "api-journeys")
+  textResponseBlockCreate(input: TextResponseBlockCreateInput!): TextResponseBlock! @override(from: "api-journeys")
+  textResponseBlockUpdate(
+    id: ID!
+    input: TextResponseBlockUpdateInput!
+
+    """drop this parameter after merging teams"""
+    journeyId: ID
+  ): TextResponseBlock! @override(from: "api-journeys")
+  typographyBlockCreate(input: TypographyBlockCreateInput!): TypographyBlock! @override(from: "api-journeys")
+  typographyBlockUpdate(
+    id: ID!
+    input: TypographyBlockUpdateInput!
+
+    """drop this parameter after merging teams"""
+    journeyId: ID
+  ): TypographyBlock! @override(from: "api-journeys")
   videoBlockCreate(input: VideoBlockCreateInput!): VideoBlock!
   videoBlockUpdate(
     id: ID!
@@ -1460,6 +1510,7 @@ type Mutation {
   integrationDelete(id: ID!): Integration!
   journeyTransferFromAnonymous(journeyId: ID!, teamId: ID): Journey!
   journeyAiTranslateCreate(input: JourneyAiTranslateInput!): Journey!
+  journeyCustomizationDescriptionTranslate(input: JourneyCustomizationDescriptionTranslateInput!): Journey!
   createJourneyEventsExportLog(input: JourneyEventsExportLogInput!): JourneyEventsExportLog!
   journeyLanguageAiDetect(input: MutationJourneyLanguageAiDetectInput!): Boolean!
   journeyProfileUpdate(input: JourneyProfileUpdateInput!): JourneyProfile!
@@ -1475,6 +1526,8 @@ type Mutation {
     """
     timezone: String
   ): JourneyVisitorGoogleSheetExportResult!
+  userDeleteJourneysCheck(userId: String!): UserDeleteJourneysCheckResult!
+  userDeleteJourneysConfirm(userId: String!): UserDeleteJourneysConfirmResult!
 }
 
 input MutationJourneyLanguageAiDetectInput {
@@ -2343,6 +2396,12 @@ enum TypographyVariant {
   overline
 }
 
+enum USER_DELETE_LOG_LEVEL {
+  INFO
+  WARN
+  ERROR
+}
+
 type User
   @key(fields: "id")
   @interfaceObject
@@ -2358,6 +2417,31 @@ type UserAgent
   os: OperatingSystem!
 }
 
+type UserDeleteJourneysCheckResult {
+  journeysToDelete: Int!
+  journeysToTransfer: Int!
+  journeysToRemove: Int!
+  teamsToDelete: Int!
+  teamsToTransfer: Int!
+  teamsToRemove: Int!
+  logs: [UserDeleteJourneysLogEntry!]!
+}
+
+type UserDeleteJourneysConfirmResult {
+  success: Boolean!
+  deletedJourneyIds: [String!]!
+  deletedTeamIds: [String!]!
+  deletedUserJourneyIds: [String!]!
+  deletedUserTeamIds: [String!]!
+  logs: [UserDeleteJourneysLogEntry!]!
+}
+
+type UserDeleteJourneysLogEntry {
+  message: String!
+  level: USER_DELETE_LOG_LEVEL!
+  timestamp: String!
+}
+
 type UserInvite
   @key(fields: "id")
   @shareable

apis/api-journeys-modern/src/env.ts

@@ -27,6 +27,10 @@ export const env = createEnv({
     PLAUSIBLE_URL: z.url().refine((url) => !url.endsWith('/'), {
       message: 'PLAUSIBLE_URL must not end with a trailing slash'
     }),
+    CLOUDFLARE_ACCOUNT_ID: z.string().trim().min(1),
+    CLOUDFLARE_IMAGES_TOKEN: z.string().trim().min(1),
+    MUX_UGC_ACCESS_TOKEN_ID: z.string().trim().min(1),
+    MUX_UGC_SECRET_KEY: z.string().trim().min(1),
     REDIS_PORT: z.coerce.number().int().positive().default(6379),
     REDIS_URL: z.string().trim().min(1).default('redis'),
     SERVICE_VERSION: z.string().trim().default('')

apis/api-journeys-modern/src/lib/google/sheets.ts

@@ -267,6 +267,12 @@ export async function readValues({
   return values
 }
 
+// Escape a sheet title for use in A1 notation ranges.
+// Per Google Sheets: wrap in single quotes, doubling any internal single quotes.
+export function escapeSheetName(name: string): string {
+  return `'${name.replace(/'/g, "''")}'`
+}
+
 // Convert a 0-based column index to A1 column letters
 export function columnIndexToA1(colIndexZeroBased: number): string {
   let n = colIndexZeroBased + 1