diff --git a/lib/record/upload.js b/lib/record/upload.js index 7b07ace..1829061 100644 --- a/lib/record/upload.js +++ b/lib/record/upload.js @@ -44,6 +44,10 @@ async function upload(logger, socket) { // Uploader const uploadStream = getUploader(Key, metadata, obj); + if (!uploadStream) { + logger.info('There is no available record uploader, close the socket.'); + socket.close(); + } /**encoder */ let encoder;