export async function PostProcessOutput()

in src/handlers/provider-ace.ts [140:163]


export async function PostProcessOutput(event: ProcessingStepResult[]): Promise<PartnerResult> {
    /**
     * Some postprocessing logic, i.e. calculating hashes
     */

    const objetsFromS3 = await Promise.all(event.map((ev) => S3.getObject({
        Bucket: ev.Bucket,
        Key: ev.Key
    }).promise() as GetObjectOutput));

    const checksums = objetsFromS3
        .map((obj) => obj.Body as string)
        .map((body) => crypto.createHash("md5").update(body, "utf8").digest("hex"));

    return {
        Output: {
            Bucket: event[0].Bucket,
            Checksums: checksums,
            Files: event.map((ev) => ev.Key)
        },
        Provider: "ACE",
        Status: "PROCESS_OK"
    };
}