export function retrieveBucketAndKey()

in src/utils/elasticsearch.js [37:75]

37 lines of code
3 McCabe index (conditional complexity)


export function retrieveBucketAndKey(transactionid) {
  return Auth.currentCredentials().then(creds => {
    const lambda = new AWS.Lambda({
      region: defaultRegion,
      credentials: Auth.essentialCredentials(creds),
    });
    const params = {
      FunctionName: config.searchFunctionName,
      InvocationType: 'RequestResponse',
    };

    const esParams = {
      index: ELASTIC_SEARCH_INDEX_NAMES.WAVFILE,
      type: '_doc',
      body: {
        size: 2,
        query: {
          query_string: {
            default_field: TRANSCRIPT_TABLE_KEYS.TRANSACTION_ID,
            query: transactionid,
          },
        },
      },
      output: ['Bucket', 'Key', 'Time'],
    };
    params['Payload'] = Buffer.from(JSON.stringify(esParams));

    return lambda
      .invoke(params)
      .promise()
      .then((data) => {
        const body = JSON.parse(data.Payload).body;
        if (body === undefined || body === []) {
          return [];
        }
        return JSON.parse(data.Payload).body.Records;
      });
  });
}