enh: add version (superseded | latest) to content frags

front/lib/api/assistant/conversation.ts

@@ -1780,6 +1780,7 @@ export async function postNewContentFragment(
           userContextEmail: context?.email,
           userContextFullName: context?.fullName,
           userContextUsername: context?.username,
+          version: "latest",
         },
         t
       );

front/lib/resources/content_fragment_resource.ts

@@ -201,6 +201,8 @@ export class ContentFragmentResource extends BaseResource<ContentFragmentModel>
         email: this.userContextEmail,
         username: this.userContextUsername,
       },
+      contentFragmentId: this.sId,
+      contentFragmentVersion: this.version,
     };
   }
 }

front/lib/resources/storage/models/content_fragment.ts

@@ -1,4 +1,7 @@
-import type { SupportedContentFragmentType } from "@dust-tt/types";
+import type {
+  ContentFragmentVersion,
+  SupportedContentFragmentType,
+} from "@dust-tt/types";
 import type {
   CreationOptional,
   ForeignKey,
@@ -36,6 +39,8 @@ export class ContentFragmentModel extends Model<
 
   declare userId: ForeignKey<User["id"]> | null;
   declare fileId: ForeignKey<FileModel["id"]> | null;
+
+  declare version: ContentFragmentVersion;
 }
 
 ContentFragmentModel.init(
@@ -91,11 +96,16 @@ ContentFragmentModel.init(
       type: DataTypes.STRING,
       allowNull: true,
     },
+    version: {
+      type: DataTypes.STRING,
+      allowNull: false,
+      defaultValue: "latest",
+    },
   },
   {
     modelName: "content_fragment",
     sequelize: frontSequelize,
-    indexes: [{ fields: ["fileId"] }, { fields: ["sId"] }],
+    indexes: [{ fields: ["fileId"] }, { fields: ["sId", "version"] }],
   }
 );
 

front/migrations/db/migration_114.sql

@@ -0,0 +1,11 @@
+-- Add version column
+ALTER TABLE
+    "public"."content_fragments"
+ADD
+    COLUMN "version" VARCHAR(255) NOT NULL DEFAULT 'latest';
+
+-- Create the composite index concurrently to avoid locking
+CREATE INDEX CONCURRENTLY "content_fragments_s_id_version" ON "content_fragments" ("sId", "version");
+
+-- Drop the old single-column index if it exists
+DROP INDEX CONCURRENTLY IF EXISTS "content_fragments_s_id";

types/src/front/content_fragment.ts

@@ -35,6 +35,8 @@ export function getSupportedContentFragmentTypeCodec(): t.Mixed {
   ]);
 }
 
+export type ContentFragmentVersion = "superseded" | "latest";
+
 export type ContentFragmentType = {
   id: ModelId;
   sId: string;
@@ -49,6 +51,8 @@ export type ContentFragmentType = {
   title: string;
   contentType: SupportedContentFragmentType;
   context: ContentFragmentContextType;
+  contentFragmentId: string;
+  contentFragmentVersion: ContentFragmentVersion;
 };
 
 export type UploadedContentFragment = {