feat(bot): add safe group unsetup flow

packages/adapters-db/src/household-config-repository.ts

@@ -503,6 +503,12 @@ export function createDbHouseholdConfigurationRepository(databaseUrl: string): {
       return rows.map(toHouseholdTopicBindingRecord)
     },
 
+    async clearHouseholdTopicBindings(householdId) {
+      await db
+        .delete(schema.householdTopicBindings)
+        .where(eq(schema.householdTopicBindings.householdId, householdId))
+    },
+
     async listReminderTargets() {
       const rows = await db
         .select({

packages/adapters-db/src/telegram-pending-action-repository.ts

@@ -151,6 +151,19 @@ export function createDbTelegramPendingActionRepository(databaseUrl: string): {
             eq(schema.telegramPendingActions.telegramUserId, telegramUserId)
           )
         )
+    },
+
+    async clearPendingActionsForChat(telegramChatId, action) {
+      await db
+        .delete(schema.telegramPendingActions)
+        .where(
+          action
+            ? and(
+                eq(schema.telegramPendingActions.telegramChatId, telegramChatId),
+                eq(schema.telegramPendingActions.action, action)
+              )
+            : eq(schema.telegramPendingActions.telegramChatId, telegramChatId)
+        )
     }
   }
 

packages/application/src/household-admin-service.test.ts

@@ -60,6 +60,7 @@ function createRepositoryStub() {
     getHouseholdTopicBinding: async () => null,
     findHouseholdTopicByTelegramContext: async () => null,
     listHouseholdTopicBindings: async () => [],
+    clearHouseholdTopicBindings: async () => {},
     listReminderTargets: async () => [],
     upsertHouseholdJoinToken: async (input) =>
       ({

packages/application/src/household-onboarding-service.test.ts

@@ -55,6 +55,7 @@ function createRepositoryStub() {
     async listHouseholdTopicBindings() {
       return []
     },
+    async clearHouseholdTopicBindings() {},
     async listReminderTargets() {
       return []
     },

packages/application/src/household-setup-service.test.ts

@@ -93,6 +93,9 @@ function createRepositoryStub() {
     async listHouseholdTopicBindings(householdId) {
       return bindings.get(householdId) ?? []
     },
+    async clearHouseholdTopicBindings(householdId) {
+      bindings.set(householdId, [])
+    },
     async listReminderTargets() {
       return []
     },
@@ -514,4 +517,56 @@ describe('createHouseholdSetupService', () => {
       reason: 'not_topic_message'
     })
   })
+
+  test('clears topic bindings when unsetup is run by a group admin', async () => {
+    const { repository } = createRepositoryStub()
+    const service = createHouseholdSetupService(repository)
+    const setup = await service.setupGroupChat({
+      actorIsAdmin: true,
+      telegramChatId: '-100123',
+      telegramChatType: 'supergroup',
+      title: 'Kojori House'
+    })
+
+    expect(setup.status).toBe('created')
+    if (setup.status === 'rejected') {
+      return
+    }
+
+    await service.bindTopic({
+      actorIsAdmin: true,
+      telegramChatId: '-100123',
+      role: 'purchase',
+      telegramThreadId: '777',
+      topicName: 'Shared purchases'
+    })
+
+    const result = await service.unsetupGroupChat({
+      actorIsAdmin: true,
+      telegramChatId: '-100123',
+      telegramChatType: 'supergroup'
+    })
+
+    expect(result).toEqual({
+      status: 'reset',
+      household: setup.household
+    })
+    expect(await repository.listHouseholdTopicBindings(setup.household.householdId)).toEqual([])
+    expect(await repository.getTelegramHouseholdChat('-100123')).toEqual(setup.household)
+  })
+
+  test('treats repeated unsetup as a no-op', async () => {
+    const { repository } = createRepositoryStub()
+    const service = createHouseholdSetupService(repository)
+
+    const result = await service.unsetupGroupChat({
+      actorIsAdmin: true,
+      telegramChatId: '-100123',
+      telegramChatType: 'supergroup'
+    })
+
+    expect(result).toEqual({
+      status: 'noop'
+    })
+  })
 })

packages/application/src/household-setup-service.ts

@@ -41,6 +41,23 @@ export interface HouseholdSetupService {
         reason: 'not_admin' | 'household_not_found' | 'not_topic_message'
       }
   >
+  unsetupGroupChat(input: {
+    actorIsAdmin: boolean
+    telegramChatId: string
+    telegramChatType: string
+  }): Promise<
+    | {
+        status: 'reset'
+        household: HouseholdTelegramChatRecord
+      }
+    | {
+        status: 'noop'
+      }
+    | {
+        status: 'rejected'
+        reason: 'not_admin' | 'invalid_chat_type'
+      }
+  >
 }
 
 function isSupportedGroupChat(chatType: string): boolean {
@@ -146,6 +163,36 @@ export function createHouseholdSetupService(
         household,
         binding
       }
+    },
+
+    async unsetupGroupChat(input) {
+      if (!input.actorIsAdmin) {
+        return {
+          status: 'rejected',
+          reason: 'not_admin'
+        }
+      }
+
+      if (!isSupportedGroupChat(input.telegramChatType)) {
+        return {
+          status: 'rejected',
+          reason: 'invalid_chat_type'
+        }
+      }
+
+      const household = await repository.getTelegramHouseholdChat(input.telegramChatId)
+      if (!household) {
+        return {
+          status: 'noop'
+        }
+      }
+
+      await repository.clearHouseholdTopicBindings(household.householdId)
+
+      return {
+        status: 'reset',
+        household
+      }
     }
   }
 }

packages/application/src/locale-preference-service.test.ts

@@ -38,6 +38,7 @@ function createRepository(): HouseholdConfigurationRepository {
     getHouseholdTopicBinding: async () => null,
     findHouseholdTopicByTelegramContext: async () => null,
     listHouseholdTopicBindings: async () => [],
+    clearHouseholdTopicBindings: async () => {},
     listReminderTargets: async () => [],
     upsertHouseholdJoinToken: async () => ({
       householdId: household.householdId,

packages/application/src/miniapp-admin-service.test.ts

@@ -35,6 +35,7 @@ function repository(): HouseholdConfigurationRepository {
         topicName: 'Общие покупки'
       }
     ],
+    clearHouseholdTopicBindings: async () => {},
     listReminderTargets: async () => [],
     upsertHouseholdJoinToken: async () => ({
       householdId: 'household-1',

packages/ports/src/household-config.ts

@@ -103,6 +103,7 @@ export interface HouseholdConfigurationRepository {
     telegramThreadId: string
   }): Promise<HouseholdTopicBindingRecord | null>
   listHouseholdTopicBindings(householdId: string): Promise<readonly HouseholdTopicBindingRecord[]>
+  clearHouseholdTopicBindings(householdId: string): Promise<void>
   listReminderTargets(): Promise<readonly ReminderTarget[]>
   upsertHouseholdJoinToken(input: {
     householdId: string

packages/ports/src/telegram-pending-actions.ts

@@ -23,4 +23,8 @@ export interface TelegramPendingActionRepository {
     telegramUserId: string
   ): Promise<TelegramPendingActionRecord | null>
   clearPendingAction(telegramChatId: string, telegramUserId: string): Promise<void>
+  clearPendingActionsForChat(
+    telegramChatId: string,
+    action?: TelegramPendingActionType
+  ): Promise<void>
 }