updateStreamFeed.ts

const _updateStreamFeed = async (
  prediction: Prediction,
  toUpdate: Record<string, unknown>,
) => {
  try {
    const streamClient = getStreamClient();
    const ref: firestore.DocumentReference = prediction.ref;
    const time = new Date().toISOString();
    const activity: ActivityPartialChanges<DefaultGenerics> = {
      foreign_id: ref.id,
      time,
      set: {
        ...toUpdate,
      },
    };
    const updated = await streamClient.activityPartialUpdate(activity);
    console.log('Updated stream feed', updated);
    return;
  } catch (error) {
    console.error('Error updating stream feed', error);
    return Promise.reject(error);
  }
};