Method insert

packages/partykit/facade/vectorize.ts:116–155

(
    vectors: VectorizeVector[],
    upsert = false
  )

  }

  async insert(
    vectors: VectorizeVector[],
    upsert = false
  ): Promise<VectorizeVectorMutation> {
    let vectorInsertCount = 0;
    const insertedIds: string[] = [];
    for await (const batch of getBatchFromArray(vectors)) {
      const formData = new FormData();
      formData.append(
        "vectors",
        new File([batch.join(`\n`)], "vectors.ndjson", {
          type: "application/x-ndjson"
        })
      );

      const idxPart = await this.fetch<VectorizeVectorMutation>(
        `/vectorize/${this.namespace}/indexes/${this.index_name}/${
          upsert ? "upsert" : "insert"
        }`,
        {
          method: "POST",
          body: formData
        }
      );
      vectorInsertCount += idxPart.count;
      insertedIds.push(...idxPart.ids);

      if (vectorInsertCount > VECTORIZE_MAX_UPSERT_VECTOR_RECORDS) {
        console.warn(
          `🚧 While Vectorize is in beta, we've limited uploads to 100k vectors per run. You may run this again with another batch to upload further`
        );
        break;
      }
    }

    return {
      count: vectorInsertCount,
      ids: insertedIds
    };
  }

  async upsert(vectors: VectorizeVector[]): Promise<VectorizeVectorMutation> {
    return this.insert(vectors, true);