Function getFileEntity

apps/hash-api/src/storage/index.ts:92–153

(
  context: ImpureGraphContext,
  authentication: AuthenticationContext,
  params: { entityId: EntityId; key: string; includeDrafts?: boolean },
)

  blockProtocolPropertyTypes.fileUrl.propertyTypeBaseUrl in entity.properties;

const getFileEntity = async (
  context: ImpureGraphContext,
  authentication: AuthenticationContext,
  params: { entityId: EntityId; key: string; includeDrafts?: boolean },
) => {
  const { entityId, key, includeDrafts = false } = params;
  const [webId, entityUuid] = splitEntityId(entityId);

  const { entities: fileEntityRevisions } = await queryEntities(
    context,
    authentication,
    {
      filter: {
        all: [
          {
            equal: [{ path: ["uuid"] }, { parameter: entityUuid }],
          },
          {
            equal: [{ path: ["webId"] }, { parameter: webId }],
          },
          {
            equal: [
              {
                path: [
                  "properties",
                  systemPropertyTypes.fileStorageKey.propertyTypeBaseUrl,
                ],
              },
              { parameter: key },
            ],
          },
        ],
      },
      temporalAxes: fullDecisionTimeAxis,
      includeDrafts,
      includePermissions: false,
    },
  );

  const latestFileEntityRevision = fileEntityRevisions.reduce<
    Entity | undefined
  >((previousLatestRevision, currentRevision) => {
    if (!previousLatestRevision) {
      return currentRevision;
    }

    const currentCreatedAt = new Date(
      currentRevision.metadata.temporalVersioning.decisionTime.start.limit,
    );

    const previousLatestRevisionCreatedAt = new Date(
      previousLatestRevision.metadata.temporalVersioning.decisionTime.start
        .limit,
    );

    return previousLatestRevisionCreatedAt < currentCreatedAt
      ? currentRevision
      : previousLatestRevision;