{"version":3,"file":"delete_thread.cjs","names":[],"sources":["../../src/spec/delete_thread.ts"],"sourcesContent":["import {\n  emptyCheckpoint,\n  type CheckpointMetadata,\n  type BaseCheckpointSaver,\n} from \"@langchain/langgraph-checkpoint\";\nimport { CheckpointerTestInitializer } from \"../types.js\";\n\nexport function deleteThreadTests<T extends BaseCheckpointSaver>(\n  initializer: CheckpointerTestInitializer<T>\n) {\n  describe(`${initializer.checkpointerName}#deleteThread`, () => {\n    let checkpointer: T;\n    beforeAll(async () => {\n      checkpointer = await initializer.createCheckpointer();\n    });\n\n    afterAll(async () => {\n      await initializer.destroyCheckpointer?.(checkpointer);\n    });\n\n    it(\"should delete thread\", async () => {\n      const thread1 = { configurable: { thread_id: \"1\", checkpoint_ns: \"\" } };\n      const thread2 = { configurable: { thread_id: \"2\", checkpoint_ns: \"\" } };\n\n      const meta: CheckpointMetadata = {\n        source: \"update\",\n        step: -1,\n        parents: {},\n      };\n\n      await checkpointer.put(thread1, emptyCheckpoint(), meta, {});\n      await checkpointer.put(thread2, emptyCheckpoint(), meta, {});\n\n      expect(await checkpointer.getTuple(thread1)).toBeDefined();\n\n      await checkpointer.deleteThread(\"1\");\n\n      expect(await checkpointer.getTuple(thread1)).toBeUndefined();\n      expect(await checkpointer.getTuple(thread2)).toBeDefined();\n    });\n  });\n}\n"],"mappings":";;;AAOA,SAAgB,kBACd,aACA;AACA,UAAS,GAAG,YAAY,iBAAiB,sBAAsB;EAC7D,IAAI;AACJ,YAAU,YAAY;AACpB,kBAAe,MAAM,YAAY,oBAAoB;IACrD;AAEF,WAAS,YAAY;AACnB,SAAM,YAAY,sBAAsB,aAAa;IACrD;AAEF,KAAG,wBAAwB,YAAY;GACrC,MAAM,UAAU,EAAE,cAAc;IAAE,WAAW;IAAK,eAAe;IAAI,EAAE;GACvE,MAAM,UAAU,EAAE,cAAc;IAAE,WAAW;IAAK,eAAe;IAAI,EAAE;GAEvE,MAAM,OAA2B;IAC/B,QAAQ;IACR,MAAM;IACN,SAAS,EAAE;IACZ;AAED,SAAM,aAAa,IAAI,UAAA,GAAA,gCAAA,kBAA0B,EAAE,MAAM,EAAE,CAAC;AAC5D,SAAM,aAAa,IAAI,UAAA,GAAA,gCAAA,kBAA0B,EAAE,MAAM,EAAE,CAAC;AAE5D,UAAO,MAAM,aAAa,SAAS,QAAQ,CAAC,CAAC,aAAa;AAE1D,SAAM,aAAa,aAAa,IAAI;AAEpC,UAAO,MAAM,aAAa,SAAS,QAAQ,CAAC,CAAC,eAAe;AAC5D,UAAO,MAAM,aAAa,SAAS,QAAQ,CAAC,CAAC,aAAa;IAC1D;GACF"}