// a single SQS record
const sqsRecordSchema = S.Struct({
name: S.NonEmpty,
});
// an SQS event
const sqsEventSchema = S.Struct({
Records: S.Array(
S.Struct({
body: S.String.pipe(S.decodeUnknown(parseJson(sqsRecordSchema))),
}),
),
});
// a single SQS record
const sqsRecordSchema = S.Struct({
name: S.NonEmpty,
});
// an SQS event
const sqsEventSchema = S.Struct({
Records: S.Array(
S.Struct({
body: S.String.pipe(S.decodeUnknown(parseJson(sqsRecordSchema))),
}),
),
});