Added no-op crypto provider for initial definition of crypto provider

Signed-off-by: Vikas Bansal <43470111+vikasvb90@users.noreply.github.com>

libs/encryption-sdk/src/main/java/org/opensearch/encryption/CryptoManagerFactory.java

@@ -15,8 +15,6 @@
 import org.opensearch.common.crypto.MasterKeyProvider;
 import org.opensearch.common.unit.TimeValue;
 import org.opensearch.common.util.concurrent.AbstractRefCounted;
-import org.opensearch.encryption.frame.FrameCryptoProvider;
-import org.opensearch.encryption.frame.core.AwsCrypto;
 import org.opensearch.encryption.keyprovider.CryptoMasterKey;
 
 import java.security.SecureRandom;
@@ -40,6 +38,7 @@ public CryptoManagerFactory(String algorithm, TimeValue keyRefreshInterval, int
     }
 
     private String validateAndGetAlgorithmId(String algorithm) {
+        // Supporting only 256 bit algorithm
         switch (algorithm) {
             case "ALG_AES_256_GCM_HKDF_SHA512_COMMIT_KEY":
                 return CryptoAlgorithm.ALG_AES_256_GCM_HKDF_SHA512_COMMIT_KEY.getDataKeyAlgo();
@@ -71,20 +70,7 @@ CryptoProvider createCryptoProvider(
         CachingCryptoMaterialsManager materialsManager,
         MasterKeyProvider masterKeyProvider
     ) {
-        switch (algorithm) {
-            case "ALG_AES_256_GCM_HKDF_SHA512_COMMIT_KEY":
-                return new FrameCryptoProvider(
-                    new AwsCrypto(materialsManager, CryptoAlgorithm.ALG_AES_256_GCM_HKDF_SHA512_COMMIT_KEY),
-                    masterKeyProvider.getEncryptionContext()
-                );
-            case "ALG_AES_256_GCM_HKDF_SHA512_COMMIT_KEY_ECDSA_P384":
-                return new FrameCryptoProvider(
-                    new AwsCrypto(materialsManager, CryptoAlgorithm.ALG_AES_256_GCM_HKDF_SHA512_COMMIT_KEY_ECDSA_P384),
-                    masterKeyProvider.getEncryptionContext()
-                );
-            default:
-                throw new IllegalArgumentException("Unsupported algorithm: " + algorithm);
-        }
+        return new NoOpCryptoProvider();
     }
 
     // Package private for tests

libs/encryption-sdk/src/main/java/org/opensearch/encryption/NoOpCryptoProvider.java

@@ -0,0 +1,128 @@
+/*
+ * SPDX-License-Identifier: Apache-2.0
+ *
+ * The OpenSearch Contributors require contributions made to
+ * this file be licensed under the Apache-2.0 license or a
+ * compatible open source license.
+ */
+
+package org.opensearch.encryption;
+
+import org.opensearch.common.crypto.CryptoProvider;
+import org.opensearch.common.crypto.DecryptedRangedStreamProvider;
+import org.opensearch.common.crypto.EncryptedHeaderContentSupplier;
+import org.opensearch.common.io.InputStreamContainer;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+public class NoOpCryptoProvider implements CryptoProvider {
+
+    /**
+     * No op - Initialises metadata store used in encryption.
+     * @return crypto metadata object constructed with encryption metadata like data key pair, encryption algorithm, etc.
+     */
+    public Object initEncryptionMetadata() {
+        return new Object();
+    }
+
+    /**
+     * No op content size adjustment of length of a partial content used in partial encryption.
+     *
+     * @param cryptoContextObj stateful object for a request consisting of materials required in encryption.
+     * @param streamSize Size of the stream to be adjusted.
+     * @return Adjusted size of the stream.
+     */
+    public long adjustContentSizeForPartialEncryption(Object cryptoContextObj, long streamSize) {
+        return streamSize;
+    }
+
+    /**
+     * No op - Estimate length of the encrypted stream.
+     *
+     * @param cryptoMetadataObj crypto metadata instance
+     * @param contentLength Size of the raw content
+     * @return Calculated size of the encrypted stream for the provided raw stream.
+     */
+    public long estimateEncryptedLengthOfEntireContent(Object cryptoMetadataObj, long contentLength) {
+        return contentLength;
+    }
+
+    /**
+     * No op length estimation for a given content length.
+     *
+     * @param cryptoMetadataObj crypto metadata instance
+     * @param contentLength Size of the encrypted content
+     * @return Calculated size of the encrypted stream for the provided raw stream.
+     */
+    public long estimateDecryptedLength(Object cryptoMetadataObj, long contentLength) {
+        return contentLength;
+    }
+
+    /**
+     * No op encrypting stream wrapper.
+     *
+     * @param cryptoContextObj consists encryption metadata.
+     * @param stream Raw InputStream to encrypt
+     * @return encrypting stream wrapped around raw InputStream.
+     */
+    public InputStreamContainer createEncryptingStream(Object cryptoContextObj, InputStreamContainer stream) {
+        return stream;
+    }
+
+    /**
+     * No op encrypting stream provider for a part of content.
+     *
+     * @param cryptoContextObj stateful object for a request consisting of materials required in encryption.
+     * @param stream raw stream for which encrypted stream has to be created.
+     * @param totalStreams Number of streams being used for the entire content.
+     * @param streamIdx Index of the current stream.
+     * @return Encrypted stream for the provided raw stream.
+     */
+    public InputStreamContainer createEncryptingStreamOfPart(
+        Object cryptoContextObj,
+        InputStreamContainer stream,
+        int totalStreams,
+        int streamIdx
+    ) {
+        return stream;
+    }
+
+    /**
+     *
+     * @param encryptedHeaderContentSupplier Supplier used to fetch bytes from source for header creation
+     * @return parsed encryption metadata object
+     * @throws IOException if content fetch for header creation fails
+     */
+    public Object loadEncryptionMetadata(EncryptedHeaderContentSupplier encryptedHeaderContentSupplier) throws IOException {
+        return new Object();
+    }
+
+    /**
+     * No op decrypting stream provider.
+     *
+     * @param encryptedStream to be decrypted.
+     * @return Decrypting wrapper stream
+     */
+    public InputStream createDecryptingStream(InputStream encryptedStream) {
+        return encryptedStream;
+    }
+
+    /**
+     * No Op decrypted stream range provider
+     *
+     * @param cryptoContext crypto metadata instance consisting of encryption metadata used in encryption.
+     * @param startPosOfRawContent starting position in the raw/decrypted content
+     * @param endPosOfRawContent ending position in the raw/decrypted content
+     * @return stream provider for decrypted stream for the specified range of content including adjusted range
+     */
+    public DecryptedRangedStreamProvider createDecryptingStreamOfRange(
+        Object cryptoContext,
+        long startPosOfRawContent,
+        long endPosOfRawContent
+    ) {
+        long[] range = { startPosOfRawContent, endPosOfRawContent };
+        return new DecryptedRangedStreamProvider(range, (encryptedStream) -> encryptedStream);
+    }
+
+}

libs/encryption-sdk/src/main/java/org/opensearch/encryption/frame/TrimmingStream.java → libs/encryption-sdk/src/main/java/org/opensearch/encryption/TrimmingStream.java

@@ -6,7 +6,7 @@
  * compatible open source license.
  */
 
-package org.opensearch.encryption.frame;
+package org.opensearch.encryption;
 
 import java.io.IOException;
 import java.io.InputStream;