Function get_iq_data

api/handlers/iq.py:45–79

(
    request: Request,
    filepath: str,
    block_indexes_str: str,
    block_size: int, # we grab 2x this many ints/floats
    format: str,
    datasource: DataSource = Depends(datasource_repo.get),
    azure_client: AzureBlobClient = Depends(AzureBlobClient),
    access_allowed=Depends(check_access),
)

)
@cancel_on_disconnect
async def get_iq_data(
    request: Request,
    filepath: str,
    block_indexes_str: str,
    block_size: int, # we grab 2x this many ints/floats
    format: str,
    datasource: DataSource = Depends(datasource_repo.get),
    azure_client: AzureBlobClient = Depends(AzureBlobClient),
    access_allowed=Depends(check_access),
):
    if access_allowed is None:
        raise HTTPException(status_code=403, detail="No Access")
    if not datasource:
        raise HTTPException(status_code=404, detail="Datasource not found")
    if hasattr(datasource, "sasToken"):
        if datasource.sasToken:
            azure_client.set_sas_token(decrypt(datasource.sasToken.get_secret_value()))

    try:
        block_indexes = [int(num) for num in block_indexes_str.split(",")]

        return StreamingResponse(
            calculate_iq_data(
                block_indexes,
                block_size,
                get_bytes_per_iq_sample(format),
                get_file_name(filepath, ApiType.IQDATA),
                azure_client,
                request,
            ),
            media_type="application/octet-stream",
        )

    except Exception as e:
        raise HTTPException(status_code=400, detail=str(e))


async def calculate_iq_data(