feat: add kinesis schemas (#12)

* chore: upgrade dependencies

* feat: add apigateway schemas

* feat: add eventbridge schemas

* feat: add firehose schemas

* feat: add lambda schemas

* feat: add kinesis schemas

src/lib/aws/kinesis/index.ts

@@ -0,0 +1 @@
+export * from './kinesis.type'

src/lib/aws/kinesis/kindesis.spec.ts

@@ -0,0 +1,8 @@
+import type { KinesisStreamEvent } from './kinesis.type'
+
+import type { KinesisStreamEvent as LambdaKinesisStreamEvent } from 'aws-lambda'
+
+test('type is compatible', () => {
+    const _test: KinesisStreamEvent = {} as unknown as LambdaKinesisStreamEvent
+    const _test2: LambdaKinesisStreamEvent = {} as unknown as KinesisStreamEvent
+})

src/lib/aws/kinesis/kinesis.schema.ts

@@ -0,0 +1,28 @@
+import { $array, $ref, $string, $validator, $number, $object } from '@skyleague/therefore'
+
+export const kinesisStreamRecordPayload = $object({
+    approximateArrivalTimestamp: $number,
+    data: $string,
+    kinesisSchemaVersion: $string,
+    partitionKey: $string,
+    sequenceNumber: $string,
+})
+
+export const kinesisStreamRecord = $validator(
+    $object({
+        awsRegion: $string,
+        eventID: $string,
+        eventName: $string,
+        eventSource: $string,
+        eventSourceARN: $string,
+        eventVersion: $string,
+        invokeIdentityArn: $string,
+        kinesis: $ref(kinesisStreamRecordPayload),
+    })
+)
+
+export const kinesisStreamEvent = $validator(
+    $object({
+        Records: $array($ref(kinesisStreamRecord)),
+    })
+)

src/lib/aws/kinesis/kinesis.type.ts

@@ -0,0 +1,62 @@
+/**
+ * Generated by @skyleague/therefore@v1.0.0-local
+ * Do not manually touch this
+ */
+/* eslint-disable */
+import AjvValidator from 'ajv'
+import type { ValidateFunction } from 'ajv'
+
+export interface KinesisStreamRecordPayload {
+    approximateArrivalTimestamp: number
+    data: string
+    kinesisSchemaVersion: string
+    partitionKey: string
+    sequenceNumber: string
+}
+
+export interface KinesisStreamRecord {
+    awsRegion: string
+    eventID: string
+    eventName: string
+    eventSource: string
+    eventSourceARN: string
+    eventVersion: string
+    invokeIdentityArn: string
+    kinesis: KinesisStreamRecordPayload
+}
+
+export const KinesisStreamRecord = {
+    validate: require('./schemas/kinesis-stream-record.schema.js') as ValidateFunction<KinesisStreamRecord>,
+    get schema() {
+        return KinesisStreamRecord.validate.schema
+    },
+    get errors() {
+        return KinesisStreamRecord.validate.errors ?? undefined
+    },
+    is: (o: unknown): o is KinesisStreamRecord => KinesisStreamRecord.validate(o) === true,
+    assert: (o: unknown) => {
+        if (!KinesisStreamRecord.validate(o)) {
+            throw new AjvValidator.ValidationError(KinesisStreamRecord.errors ?? [])
+        }
+    },
+} as const
+
+export interface KinesisStreamEvent {
+    Records: KinesisStreamRecord[]
+}
+
+export const KinesisStreamEvent = {
+    validate: require('./schemas/kinesis-stream-event.schema.js') as ValidateFunction<KinesisStreamEvent>,
+    get schema() {
+        return KinesisStreamEvent.validate.schema
+    },
+    get errors() {
+        return KinesisStreamEvent.validate.errors ?? undefined
+    },
+    is: (o: unknown): o is KinesisStreamEvent => KinesisStreamEvent.validate(o) === true,
+    assert: (o: unknown) => {
+        if (!KinesisStreamEvent.validate(o)) {
+            throw new AjvValidator.ValidationError(KinesisStreamEvent.errors ?? [])
+        }
+    },
+} as const