Function processEntityChange

apps/hash-api/src/integrations/linear/sync-back.ts:38–153

({
  entity,
  graphApi,
  vaultClient,
}: {
  entity: HashEntity;
  graphApi: GraphApi;
  vaultClient: VaultClient;
})

];

export const processEntityChange = async ({
  entity,
  graphApi,
  vaultClient,
}: {
  entity: HashEntity;
  graphApi: GraphApi;
  vaultClient: VaultClient;
}) => {
  const { entityTypeIds } = entity.metadata;

  if (
    !entityTypeIds.some(
      (entityTypeId) => !supportedLinearTypeIds.includes(entityTypeId),
    )
  ) {
    throw new Error(
      `Entity with entity type(s) ${entityTypeIds.join(", ")} passed to Linear sync back processor – supported types are ${supportedLinearEntityTypeIds.join(
        ", ",
      )}.`,
    );
  }

  const linearMachineActorId = await getMachineIdByIdentifier(
    { graphApi },
    { actorId: systemAccountId },
    { identifier: "linear" },
  ).then((maybeMachineId) => {
    if (!maybeMachineId) {
      throw new Error("Failed to get linear bot");
    }
    return maybeMachineId;
  });

  if (entity.metadata.provenance.edition.createdById === linearMachineActorId) {
    /**
     * To prevent update loops where changes from linear are saved in HASH, and
     * then propagate back to linear, only consider entity editions that weren't
     * created by the Linear machine account's actorId.
     */
    return;
  }

  const graphContext: ImpureGraphContext = {
    graphApi,
    provenance: {
      actorType: "machine",
      origin: {
        /**
         * @todo use correct EntityId for Flow when Linear integration migrated to Flows
         */
        id: "linear-integration",
        type: "flow",
      },
    },
  };

  const linearEntityToUpdate = entityTypeIds.some(