public void publish()

in functions/source/amazon-chime-recordandtranscribe/src/main/java/com/amazonaws/kvstranscribestreaming/publisher/DynamoDBTranscriptionPublisher.java [69:98]

• 24 lines of code
• 5 McCabe index (conditional complexity)

    public void publish(TranscriptEvent transcriptEvent) {
        List<Result> results = transcriptEvent.transcript().results();
        if (results.size() > 0) {

            Result result = results.get(0);

            // we're only saving final transcripts here (note:  this will make the Ux appear slower)
            //logger.info("the result - " + result);
            if (!result.isPartial()) {
                try {

                    Item ddbItem = toDynamoDbItem(result);
                    Gson gson = new Gson();
                    String jsonDB = gson.toJson(ddbItem.asMap());
                    logger.info("Json is - " +jsonDB);
                    if (ddbItem != null) {
                        getDdbClient().getTable(TABLE_TRANSCRIPT).putItem(ddbItem);
                        String messageBody = jsonDB;
                        SendMessageRequest send_msg_request = new SendMessageRequest()
                                .withQueueUrl(this.SQS_URL)
                                .withMessageBody(jsonDB);
                        getSQSClient().sendMessage(send_msg_request); 
                    }

                } catch (Exception e) {
                    logger.error("Exception while writing to DDB: ", e);
                }
            }
        }
    }