Method batchInsertActivity

server/src/db/catalog-db.ts:845–865

(
    client: PoolClient,
    entries: Array<{ property_rid: string; member_id: string; provenance_type: string; provenance_context: string | null }>
  )

  }

  private async batchInsertActivity(
    client: PoolClient,
    entries: Array<{ property_rid: string; member_id: string; provenance_type: string; provenance_context: string | null }>
  ): Promise<void> {
    if (entries.length === 0) return;

    const values: any[] = [];
    const placeholders: string[] = [];
    let idx = 1;

    for (const entry of entries) {
      placeholders.push(`($${idx++}, $${idx++}, $${idx++}, $${idx++}, $${idx++})`);
      values.push(uuidv7(), entry.property_rid, entry.member_id, entry.provenance_type, entry.provenance_context);
    }

    await client.query(
      `INSERT INTO catalog_activity (id, property_rid, member_id, provenance_type, provenance_context)
       VALUES ${placeholders.join(', ')}`,
      values
    );
  }

  // ─── Public Registry ────────────────────────────────────────────────────────