Common Fields Logic For Multiple Tables

export const base = {
  id: text()
    .primaryKey()
    .$defaultFn(() => Crypto.randomUUID()),
  local_created_at: integer({ mode: "timestamp_ms" })
    .notNull()
    .$defaultFn(() => new Date()),
  local_updated_at: integer({ mode: "timestamp_ms" })
    .notNull()
    .$defaultFn(() => new Date())
    .$onUpdateFn(() => new Date()),
  is_deleted: integer({ mode: "boolean" }).notNull().default(false),
  synched: integer({ mode: "boolean" }).notNull(),
}

export const table1 = {
  ...base,
  some_custom_fields...
}

export const table2 = {
  ...base,
  some_custom_fields...
}

export const base = {
  id: text()
    .primaryKey()
    .$defaultFn(() => Crypto.randomUUID()),
  local_created_at: integer({ mode: "timestamp_ms" })
    .notNull()
    .$defaultFn(() => new Date()),
  local_updated_at: integer({ mode: "timestamp_ms" })
    .notNull()
    .$defaultFn(() => new Date())
    .$onUpdateFn(() => new Date()),
  is_deleted: integer({ mode: "boolean" }).notNull().default(false),
  synched: integer({ mode: "boolean" }).notNull(),
}

export const table1 = {
  ...base,
  some_custom_fields...
}

export const table2 = {
  ...base,
  some_custom_fields...
}

export class BaseRepository<
  Schema extends SQLiteTable<TableConfig> & {
    id: AnySQLiteColumn & IndexColumn;
    local_created_at: AnySQLiteColumn;
    local_updated_at: AnySQLiteColumn;
    is_deleted: AnySQLiteColumn;
    synched: AnySQLiteColumn;
  }, {
  protected schema: Schema;

  constructor(schema: Schema) {
    this.schema = schema;
  }

  async save(payload: InferInsertModel<Schema>) {
    const results = await db
      .insert(this.schema)
      .values(payload)
      .onConflictDoUpdate({
        target: this.schema.id,
        set: payload,
      })
      .returning();

    return results?.[0];
  }

  async getAllNotSynced() {
    return await db
      .select()
      .from(this.schema)
      .where(eq(this.schema.synched, false));
  }

  other_cool_helper_functions...
}

export class BaseRepository<
  Schema extends SQLiteTable<TableConfig> & {
    id: AnySQLiteColumn & IndexColumn;
    local_created_at: AnySQLiteColumn;
    local_updated_at: AnySQLiteColumn;
    is_deleted: AnySQLiteColumn;
    synched: AnySQLiteColumn;
  }, {
  protected schema: Schema;

  constructor(schema: Schema) {
    this.schema = schema;
  }

  async save(payload: InferInsertModel<Schema>) {
    const results = await db
      .insert(this.schema)
      .values(payload)
      .onConflictDoUpdate({
        target: this.schema.id,
        set: payload,
      })
      .returning();

    return results?.[0];
  }

  async getAllNotSynced() {
    return await db
      .select()
      .from(this.schema)
      .where(eq(this.schema.synched, false));
  }

  other_cool_helper_functions...
}