adding send action and fields (#3369)

Author: mdkhan-tw

packages/destination-actions/src/destinations/aws-kinesis/index.ts

@@ -1,6 +1,8 @@
 import type { DestinationDefinition } from '@segment/actions-core'
 import type { Settings } from './generated-types'
 
+import send from './send'
+
 const destination: DestinationDefinition<Settings> = {
   name: 'Aws Kinesis',
   slug: 'actions-aws-kinesis',
@@ -22,7 +24,9 @@ const destination: DestinationDefinition<Settings> = {
     // implement this function and should remove it completely.
   },
 
-  actions: {}
+  actions: {
+    send
+  }
 }
 
 export default destination

packages/destination-actions/src/destinations/aws-kinesis/send/generated-types.ts

@@ -0,0 +1,44 @@
+import type { ActionDefinition } from '@segment/actions-core'
+import type { Settings } from '../generated-types'
+import type { Payload } from './generated-types'
+
+const action: ActionDefinition<Settings, Payload> = {
+  title: 'Send',
+  description: 'Send event to AWS Kinesis',
+  defaultSubscription: 'type = "track" or type = "identify" or type = "page" or type = "screen" or type = "group"',
+  fields: {
+    payload: {
+      label: 'Payload',
+      description: 'The data to send to AWS Kinesis',
+      type: 'object',
+      required: true,
+      default: { '@path': '$.' }
+    },
+    partitionKey: {
+      label: 'Partition Key',
+      description: 'The partition key to use for the record',
+      type: 'string',
+      required: true,
+      default: { '@path': '$.messageId' }
+    },
+    streamName: {
+      label: 'Stream Name',
+      description: 'The name of the Kinesis stream to send records to',
+      type: 'string',
+      required: true,
+      default: { '@path': '$.properties.streamName' }
+    },
+    awsRegion: {
+      label: 'AWS Region',
+      description: 'The AWS region where the Kinesis stream is located',
+      type: 'string',
+      required: true,
+      default: { '@path': '$.properties.awsRegion' }
+    }
+  },
+  perform: async (_request, _data) => {
+    // Todo implement functionality
+  }
+}
+
+export default action