feat: Added ses service configurations

Author: Marco Franceschi

src/services/ses/data.ts

@@ -0,0 +1,110 @@
+import SES, {
+  ListConfigurationSetsResponse,
+  ConfigurationSet,
+  ListTemplatesResponse,
+  TemplateMetadata,
+} from 'aws-sdk/clients/ses'
+import { AWSError } from 'aws-sdk/lib/error'
+import { Config } from 'aws-sdk/lib/config'
+
+import CloudGraph from '@cloudgraph/sdk'
+import groupBy from 'lodash/groupBy'
+
+import awsLoggerText from '../../properties/logger'
+import { initTestEndpoint } from '../../utils'
+import AwsErrorLog from '../../utils/errorLog'
+
+const lt = { ...awsLoggerText }
+const { logger } = CloudGraph
+const serviceName = 'SES '
+const errorLog = new AwsErrorLog(serviceName)
+const endpoint = initTestEndpoint(serviceName)
+
+/**
+ * SES 
+ */
+export interface RawAwsSes {
+  ConfigurationSets: ConfigurationSet[]
+  EmailTemplates: TemplateMetadata[]
+  region: string
+}
+
+
+const getEmailTemplates = async (ses: SES): Promise<TemplateMetadata[]> =>
+  new Promise(resolve => {
+    try {
+      ses.listTemplates(
+        (err: AWSError, data: ListTemplatesResponse) => {
+          if (err) {
+            errorLog.generateAwsErrorLog({
+              functionName: 'ses:listTemplates',
+              err,
+            })
+            return resolve([])
+          }
+          const { TemplatesMetadata = [] } = data || {}
+          resolve(TemplatesMetadata)
+        }
+      )
+    } catch (error) {
+      resolve([])
+    }
+  })
+
+const getConfigurationSets = async (ses: SES): Promise<ConfigurationSet[]> =>
+  new Promise(resolve => {
+    try {
+      ses.listConfigurationSets(
+        (err: AWSError, data: ListConfigurationSetsResponse) => {
+          if (err) {
+            errorLog.generateAwsErrorLog({
+              functionName: 'ses:listConfigurationSets',
+              err,
+            })
+            return resolve([])
+          }
+          const { ConfigurationSets = [] } = data || {}
+          resolve(ConfigurationSets)
+        }
+      )
+    } catch (error) {
+      resolve([])
+    }
+  })
+
+export default async ({
+  regions,
+  config,
+}: {
+  regions: string
+  config: Config
+}): Promise<{ [property: string]: RawAwsSes[] }> =>
+  new Promise(async resolve => {
+    const sesData: RawAwsSes[] = []
+    const regionPromises = []
+
+    regions.split(',').map(region => {
+      const regionPromise = new Promise<void>(async resolveRegion => {
+        const ses = new SES({ ...config, region, endpoint })
+
+        const configurationSets = await getConfigurationSets(ses)
+        const emailTemplates = await getEmailTemplates(ses)
+
+        sesData.push({
+          ConfigurationSets: configurationSets,
+          EmailTemplates: emailTemplates,
+          region
+        })
+        resolveRegion()
+
+
+      })
+      regionPromises.push(regionPromise)
+    })
+
+
+    await Promise.all(regionPromises)
+    errorLog.reset()
+
+    resolve(groupBy(sesData, 'region'))
+  })

src/services/ses/format.ts

@@ -0,0 +1,37 @@
+import { RawAwsSes } from './data'
+import { AwsSes } from '../../types/generated'
+import { generateUniqueId } from '@cloudgraph/sdk'
+
+/**
+ * SES 
+ */
+
+export default ({
+  service,
+  account,
+  region,
+}: {
+  service: RawAwsSes
+  account: string
+  region: string
+}): AwsSes => {
+  const {
+    ConfigurationSets = [],
+    EmailTemplates = [],
+  } = service
+
+  const configurationSets = ConfigurationSets.map(cs => cs.Name)
+  const emailTemplates = EmailTemplates.map(e => e.Name)
+
+  return {
+    id: generateUniqueId({
+      ...service,
+      account,
+      region
+    }),
+    accountId: account,
+    region,
+    configurationSets,
+    emailTemplates,
+  }
+}

src/services/ses/index.ts

@@ -0,0 +1,13 @@
+import { Service } from '@cloudgraph/sdk'
+import BaseService from '../base'
+import format from './format'
+import getData from './data'
+import mutation from './mutation'
+
+export default class SES extends BaseService implements Service {
+  format = format.bind(this)
+
+  getData = getData.bind(this)
+
+  mutation = mutation
+}

src/services/ses/mutation.ts

@@ -0,0 +1,5 @@
+export default `mutation($input: [AddawsSesInput!]!) {
+  addawsSes(input: $input, upsert: true) {
+    numUids
+  }
+}`

src/services/ses/schema.graphql

@@ -0,0 +1,4 @@
+type awsSes implements awsOptionalService @key(fields: "id") {
+  configurationSets: [String] @search(by: [hash])
+  emailTemplates: [String] @search(by: [hash])
+}