4 yJ K L MN JO P Q Q RST yQ U VW X YZ V[\ ]^ V_` a b ac d e f g h i j k l m nopq Rrst u v w xy xZ z x{| } ~   3   z   3 B  R      P   T V 3       a  Q c c    c R   q  t    {J                   Q     _   Y a     InnerClassesFileAudioStreamPublisherKVSAudioStreamPublisherREGIONLcom/amazonaws/regions/Regions;TRANSCRIBE_REGIONTRANSCRIBE_ENDPOINTLjava/lang/String;RECORDINGS_BUCKET_NAMERECORDINGS_KEY_PREFIXINPUT_KEY_PREFIXCONSOLE_LOG_TRANSCRIPT_FLAGZRECORDINGS_PUBLIC_READ_ACLSTART_SELECTOR_TYPETABLE_CALLER_TRANSCRIPT#TABLE_CALLER_TRANSCRIPT_TO_CUSTOMERloggerLorg/slf4j/Logger; metricsUtil2Lcom/amazonaws/kvstranscribestreaming/MetricsUtil; DATE_FORMATLjava/text/DateFormat;fromCustomerSegmentWriter?Lcom/amazonaws/kvstranscribestreaming/TranscribedSegmentWriter;toCustomerSegmentWriter()VCodeLineNumberTableLocalVariableTablethisCLcom/amazonaws/kvstranscribestreaming/KVSTranscribeStreamingLambda; handleRequest~(Lcom/amazonaws/kvstranscribestreaming/TranscriptionRequest;Lcom/amazonaws/services/lambda/runtime/Context;)Ljava/lang/String;builder?Lcom/amazonaws/services/dynamodbv2/AmazonDynamoDBClientBuilder;eLjava/lang/Exception;request;Lcom/amazonaws/kvstranscribestreaming/TranscriptionRequest;context/Lcom/amazonaws/services/lambda/runtime/Context; StackMapTablepstartKVSToTranscribeStreamingd(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Optional;Ljava/util/Optional;ZZ)VfromCustomerResult(Ljava/util/concurrent/CompletableFuture;toCustomerResultclientBLcom/amazonaws/transcribestreaming/TranscribeStreamingRetryClient;'Ljava/util/concurrent/TimeoutException; streamARNstartFragmentNum contactIdtranscribeEnabled languageCodeLjava/util/Optional;saveCallRecording isStreamAudioFromCustomerEnabledisStreamAudioToCustomerEnabled streamName kvsStreamTrackObjectFromCustomer;Lcom/amazonaws/kvstranscribestreaming/KVSStreamTrackObject;kvsStreamTrackObjectToCustomerLocalVariableTypeTable:Ljava/util/concurrent/CompletableFuture;(Ljava/util/Optional;)Ljava/util/Optional;| Exceptions Signature(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Optional;Ljava/util/Optional;ZZ)VstartFileToTranscribeStreaming)(Ljava/lang/String;Ljava/util/Optional;)Vresult inputFileName audioFilePath inputStreamLjava/io/InputStream;=(Ljava/lang/String;Ljava/util/Optional;)VcloseFileAndUploadRawAudiod(Lcom/amazonaws/kvstranscribestreaming/KVSStreamTrackObject;Ljava/lang/String;Ljava/util/Optional;)VdeletionResultLjava/lang/Boolean;kvsStreamTrackObject fileToDeleteLjava/io/File;y(Lcom/amazonaws/kvstranscribestreaming/KVSStreamTrackObject;Ljava/lang/String;Ljava/util/Optional;)VgetKVSStreamTrackObject(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/amazonaws/kvstranscribestreaming/KVSStreamTrackObject; trackNamekvsInputStreamstreamingMkvReader:Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader; tagProcessor=Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;fragmentVisitorELcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;fileNamesaveAudioFilePathLjava/nio/file/Path;fileOutputStreamLjava/io/FileOutputStream;$getStartStreamingTranscriptionFuture0(Lcom/amazonaws/kvstranscribestreaming/KVSStreamTrackObject;Ljava/util/Optional;Ljava/lang/String;Lcom/amazonaws/transcribestreaming/TranscribeStreamingRetryClient;Lcom/amazonaws/kvstranscribestreaming/TranscribedSegmentWriter;Ljava/lang/String;Ljava/lang/String;)Ljava/util/concurrent/CompletableFuture;transcribedSegmentWriter tableNamechannelV(Lcom/amazonaws/kvstranscribestreaming/KVSStreamTrackObject;Ljava/util/Optional;Ljava/lang/String;Lcom/amazonaws/transcribestreaming/TranscribeStreamingRetryClient;Lcom/amazonaws/kvstranscribestreaming/TranscribedSegmentWriter;Ljava/lang/String;Ljava/lang/String;)Ljava/util/concurrent/CompletableFuture;writeAudioBytesToKvsStreamP(Lcom/amazonaws/kvstranscribestreaming/KVSStreamTrackObject;Ljava/lang/String;)V audioBytes[B audioBufferLjava/nio/ByteBuffer;getAWSCredentials-()Lcom/amazonaws/auth/AWSCredentialsProvider;getTranscribeCredentialsB()Lsoftware/amazon/awssdk/auth/credentials/AwsCredentialsProvider; getRequest(Ljava/lang/Integer;Ljava/util/Optional;)Lsoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest;mediaSampleRateHertzLjava/lang/Integer; (Ljava/lang/Integer;Ljava/util/Optional;)Lsoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest;U(Ljava/lang/Object;Lcom/amazonaws/services/lambda/runtime/Context;)Ljava/lang/Object;Ljava/lang/Object;Lcom/amazonaws/services/lambda/runtime/RequestHandler; SourceFile!KVSTranscribeStreamingLambda.java java/lang/StringBuilderreceived request :      received context:     =com/amazonaws/kvstranscribestreaming/TranscribedSegmentWriter  3com/amazonaws/services/dynamodbv2/document/DynamoDB 0com/amazonaws/services/dynamodbv2/AmazonDynamoDB        ! " #$ % &$ '$ { "result": "Success" }java/lang/Exception)KVS to Transcribe Streaming failed with: (){ "result": "Failed" }/ *+ ,+ -./ 12  32@com/amazonaws/transcribestreaming/TranscribeStreamingRetryClient <= 4Calling Transcribe service.. -. 5 67 89 :java/lang/Throwable ;< %java/util/concurrent/TimeoutException4Timing out KVS to Transcribe Streaming after 890 sec =Error during streaming: Saving audio bytes to location 34/tmp/ :;> ?@java/io/FileInputStream  A >?Zcom/amazonaws/kvstranscribestreaming/KVSTranscribeStreamingLambda$FileAudioStreamPublisher BAcom/amazonaws/transcribestreaming/StreamTranscriptionBehaviorImpl CNone DE;Timing out Audio file to Transcribe Streaming after 890 sec FG HI J$ 8java/lang/Boolean K$ java/io/File LMN OP QRRSkipping upload to S3. saveCallRecording was disabled or audio file has 0 bytes: S$-Raw file for contactId {} deletion result: {} T U VWBcom/amazonaws/kinesisvideo/parser/ebml/InputStreamParserByteSource XY Z[;com/amazonaws/kvstranscribestreaming/KVSContactTagProcessor \]^ _` %s_%s_%s.rawjava/lang/Object java/util/Datea bc bd/tmpjava/lang/Stringe 8fjava/io/FileOutputStream9com/amazonaws/kvstranscribestreaming/KVSStreamTrackObject gYcom/amazonaws/kvstranscribestreaming/KVSTranscribeStreamingLambda$KVSAudioStreamPublisher hi jk lm n o pq rs 8t uvw xyz _{ |} ~    @Ysoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest9com/amazonaws/kvstranscribestreaming/TranscriptionRequest  APP_REGION  https://transcribestreaming..amazonaws.com Acom/amazonaws/kvstranscribestreaming/KVSTranscribeStreamingLambda 0com/amazonaws/kvstranscribestreaming/MetricsUtil  java/text/SimpleDateFormatyyyy-MM-dd'T'HH:mm:ss.SSSZ4com/amazonaws/services/lambda/runtime/RequestHandlerCcom/amazonaws/kvstranscribestreaming/KVSTranscribeStreamingLambda$1=com/amazonaws/services/dynamodbv2/AmazonDynamoDBClientBuilder-com/amazonaws/services/lambda/runtime/Contextjava/util/Optional&java/util/concurrent/CompletableFuturejava/io/InputStreamjava/io/IOExceptionjava/io/FileNotFoundExceptionjava/nio/ByteBufferBuilderasoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest$Builderjava/lang/Integerappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;toString()Ljava/lang/String;org/slf4j/Loggerinfo(Ljava/lang/String;)VvalidatestandardA()Lcom/amazonaws/services/dynamodbv2/AmazonDynamoDBClientBuilder;com/amazonaws/regions/RegionsgetName setRegiongetConnectContactIdbuild()Ljava/lang/Object;5(Lcom/amazonaws/services/dynamodbv2/AmazonDynamoDB;)VvalueOf(Z)Ljava/lang/Boolean;](Ljava/lang/String;Lcom/amazonaws/services/dynamodbv2/document/DynamoDB;Ljava/lang/Boolean;)VgetInputFileNamegetLanguageCode()Ljava/util/Optional; getStreamARNgetStartFragmentNumisTranscriptionEnabled()ZgetSaveCallRecordingisStreamAudioFromCustomerisStreamAudioToCustomererror*(Ljava/lang/String;Ljava/lang/Throwable;)VindexOf(Ljava/lang/String;)I lastIndexOf substring(II)Ljava/lang/String;7com/amazonaws/kvstranscribestreaming/KVSUtils$TrackName TrackNameAUDIO_FROM_CUSTOMER9Lcom/amazonaws/kvstranscribestreaming/KVSUtils$TrackName;AUDIO_TO_CUSTOMER(Lsoftware/amazon/awssdk/auth/credentials/AwsCredentialsProvider;Ljava/lang/String;Lcom/amazonaws/regions/Regions;Lcom/amazonaws/kvstranscribestreaming/MetricsUtil;)Vjava/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit;get4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;close addSuppressed(Ljava/lang/Throwable;)Vdebug/com/amazonaws/kvstranscribestreaming/AudioUtils fetchAudio(Lcom/amazonaws/regions/Regions;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lcom/amazonaws/auth/AWSCredentialsProvider;)V(I)Ljava/lang/Integer;](Ljava/io/InputStream;Lcom/amazonaws/kvstranscribestreaming/KVSTranscribeStreamingLambda$1;)VT(Lcom/amazonaws/kvstranscribestreaming/TranscribedSegmentWriter;Ljava/lang/String;)VstartStreamTranscription(Lsoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest;Lorg/reactivestreams/Publisher;Lcom/amazonaws/transcribestreaming/StreamTranscriptionBehavior;Ljava/lang/String;)Ljava/util/concurrent/CompletableFuture;getInputStream()Ljava/io/InputStream;getOutputStream()Ljava/io/FileOutputStream; isPresent booleanValuegetSaveAudioFilePath()Ljava/nio/file/Path;java/nio/file/Pathlength()JuploadRawAudio(Lcom/amazonaws/regions/Regions;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLcom/amazonaws/auth/AWSCredentialsProvider;)Vdelete9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V-com/amazonaws/kvstranscribestreaming/KVSUtilsgetInputStreamFromKVS(Ljava/lang/String;Lcom/amazonaws/regions/Regions;Ljava/lang/String;Lcom/amazonaws/auth/AWSCredentialsProvider;Ljava/lang/String;)Ljava/io/InputStream;(Ljava/io/InputStream;)V8com/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader createDefaultu(Lcom/amazonaws/kinesisvideo/parser/ebml/ParserByteSource;)Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader;of((Ljava/lang/Object;)Ljava/util/Optional;Ccom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitorcreate[(Ljava/util/Optional;)Lcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;java/text/DateFormatformat$(Ljava/util/Date;)Ljava/lang/String;9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;java/nio/file/Paths;(Ljava/lang/String;[Ljava/lang/String;)Ljava/nio/file/Path;(Ljava/io/InputStream;Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader;Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;Lcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;Ljava/nio/file/Path;Ljava/io/FileOutputStream;Ljava/lang/String;)VgetStreamingMkvReader<()Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader;getTagProcessor?()Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;getFragmentVisitorG()Lcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor; getTrackName>(Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader;Ljava/lang/String;Ljava/io/OutputStream;Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;Lcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;Ljava/lang/String;Lcom/amazonaws/kvstranscribestreaming/KVSTranscribeStreamingLambda$1;)VgetByteBufferFromStream(Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader;Lcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;Ljava/lang/String;Ljava/lang/String;)Ljava/nio/ByteBuffer; remaining()I([B)Ljava/nio/ByteBuffer;write([B)V5com/amazonaws/auth/DefaultAWSCredentialsProviderChain getInstance9()Lcom/amazonaws/auth/DefaultAWSCredentialsProviderChain;Bsoftware/amazon/awssdk/auth/credentials/DefaultCredentialsProviderF()Lsoftware/amazon/awssdk/auth/credentials/DefaultCredentialsProvider;e()Lsoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest$Builder;Fsoftware/amazon/awssdk/services/transcribestreaming/model/LanguageCodeEN_USHLsoftware/amazon/awssdk/services/transcribestreaming/model/LanguageCode;w(Ljava/lang/String;)Lsoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest$Builder;Gsoftware/amazon/awssdk/services/transcribestreaming/model/MediaEncodingPCMILsoftware/amazon/awssdk/services/transcribestreaming/model/MediaEncoding; mediaEncoding(Lsoftware/amazon/awssdk/services/transcribestreaming/model/MediaEncoding;)Lsoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest$Builder;x(Ljava/lang/Integer;)Lsoftware/amazon/awssdk/services/transcribestreaming/model/StartStreamTranscriptionRequest$Builder;java/lang/Systemgetenv&(Ljava/lang/String;)Ljava/lang/String;fromName3(Ljava/lang/String;)Lcom/amazonaws/regions/Regions; parseBoolean(Ljava/lang/String;)Zorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;?com/amazonaws/services/cloudwatch/AmazonCloudWatchClientBuilder defaultClient6()Lcom/amazonaws/services/cloudwatch/AmazonCloudWatch;7(Lcom/amazonaws/services/cloudwatch/AmazonCloudWatch;)V!y A***>R S  Y+  Y ,  +N-*Y+Y-*Y+Y-+*++'*++ ++!++"+#+$%&N(-)*<'N_`<d@gDhNihjqkloptuvty{|}4D# +++,`++-.: : : * ,/0-1: * ,20-1: c3Y45678: : 9 :: * - *:/0;: * - *<20;:=?@W=?@W U  AH: C< A4:: : !  A: C A * -D l* -D`: FG * -D A* -D5: H ) : * -D * -DeI  * -J * -J * -D 0* -D$: * -D * -D BaBaBI*IEI*t'I*IUt</4DIaknqv*/8=IKUZchtv neqb^ K v             *neqb  k/KQ GH   PPP   P  '    YK+ NLYM+ -NOPY-Q:3Y45678::9 @R,STYUVY*:WXY:=?@WUAH:C<A4:::!A:  CA#:ZG:H)BWBWB?E?'R5?Waf\  T  ?  n  GH  BN'W+[\+]^-_G-`ab:cY+defg "Lh+de,iNj&Yk+de cY+def:l:m,n2 :PSY| ">   Y"-@ +,Nop:qYrs:tYu:vw:xyYSYz{Y|}SY-S~: Y S: Y e: Y  -"013)436W7g8w:z | n!")c#$3Y%&W5' g%() w*+ ,-. :@R,SY+-+]+++VYWY"BDFHIJ"K6BR::::::/:0:1 :234M+++,+N-3-:-W+]+++,+Ṉ2 Z[Z]^$_+`4a9bEaIcLd4$%56MMM878 96' :;j <=s >?6+_ +` *"(-56@A6 6TBCBDAE4 *+,>  F6Y6 5LhMio:<Y7Yz:@ AB6C>DFENFYGdHlItJ|LMNGHI*T  x0@