IGNITE-28207 IgniteClassPath

modules/binary/api/src/main/java/org/apache/ignite/binary/BinaryRawWriter.java

@@ -128,6 +128,14 @@ public interface BinaryRawWriter {
      */
     public void writeByteArray(@Nullable byte[] val) throws BinaryObjectException;
 
+    /**
+     * @param val Value to write.
+     * @param off Offset to start write from.
+     * @param len Count of bytes to write.
+     * @throws BinaryObjectException In case of error.
+     */
+    public void writeByteArray(@Nullable byte[] val, int off, int len) throws BinaryObjectException;
+
     /**
      * @param val Value to write.
      * @throws BinaryObjectException In case of error.

modules/binary/impl/src/main/java/org/apache/ignite/internal/binary/BinaryWriterExImpl.java

@@ -899,6 +899,21 @@ else if (ZERO_COPY)
         }
     }
 
+    /** {@inheritDoc} */
+    @Override public void writeByteArray(@Nullable byte[] val, int pos, int len) throws BinaryObjectException {
+        if (val == null)
+            out.writeByte(GridBinaryMarshaller.NULL);
+        else {
+            if (len > val.length)
+                throw new IllegalArgumentException("len must be less then val.length");
+
+            out.unsafeEnsure(1 + 4);
+            out.unsafeWriteByte(GridBinaryMarshaller.BYTE_ARR);
+            out.unsafeWriteInt(len);
+            out.writeByteArray(val, pos, len);
+        }
+    }
+
     /** {@inheritDoc} */
     @Override public void writeShortArray(String fieldName, @Nullable short[] val) throws BinaryObjectException {
         writeFieldId(fieldName);

modules/commons/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java

@@ -2153,4 +2153,18 @@ public static <T> Collection<T> emptyIfNull(@Nullable Collection<T> col) {
     public static <K, V> Map<K, V> emptyIfNull(@Nullable Map<K, V> map) {
         return map == null ? Collections.emptyMap() : map;
     }
+
+    /**
+     * @param arr Array.
+     * @param el Element.
+     * @return Element index or {@code -1} if not found.
+     */
+    public static <T> int indexOf(T[] arr, T el) {
+        for (int i = 0; i < arr.length; i++) {
+            if (Objects.equals(arr[i], el))
+                return i;
+        }
+
+        return -1;
+    }
 }

modules/control-utility/src/test/java/org/apache/ignite/internal/commandline/SecurityCommandHandlerPermissionsTest.java

@@ -39,6 +39,7 @@
 import org.apache.ignite.compute.ComputeTaskFuture;
 import org.apache.ignite.configuration.IgniteConfiguration;
 import org.apache.ignite.internal.IgniteEx;
+import org.apache.ignite.internal.classpath.ClassPathTestUtils;
 import org.apache.ignite.internal.client.thin.ServicesTest;
 import org.apache.ignite.internal.managers.systemview.GridSystemViewManager;
 import org.apache.ignite.internal.processors.security.impl.TestSecurityData;
@@ -67,6 +68,7 @@
 import static org.apache.ignite.internal.processors.job.GridJobProcessor.JOBS_VIEW;
 import static org.apache.ignite.internal.processors.task.GridTaskProcessor.TASKS_VIEW;
 import static org.apache.ignite.internal.util.IgniteUtils.resolveIgnitePath;
+import static org.apache.ignite.plugin.security.SecurityPermission.ADMIN_OPS;
 import static org.apache.ignite.plugin.security.SecurityPermission.CACHE_CREATE;
 import static org.apache.ignite.plugin.security.SecurityPermission.CACHE_DESTROY;
 import static org.apache.ignite.plugin.security.SecurityPermission.CACHE_READ;
@@ -150,6 +152,17 @@ public void testCacheClear() throws Exception {
         checkCommandPermissions(asList("--cache", "clear", "--caches", DEFAULT_CACHE_NAME), cachePermission(CACHE_REMOVE));
     }
 
+    /** */
+    @Test
+    public void testClassPathCreate() throws Exception {
+        String files = String.join(",", ClassPathTestUtils.fileArg(ClassPathTestUtils.files()));
+
+        checkCommandPermissions(
+            asList("--class-path", "create", "--name", "secured_app", "--files", files),
+            systemPermissions(ADMIN_OPS)
+        );
+    }
+
     /** */
     @Test
     public void testCacheCreate() throws Exception {

modules/control-utility/src/test/java/org/apache/ignite/testsuites/IgniteControlUtilityTestSuite2.java

@@ -22,6 +22,7 @@
 import org.apache.ignite.util.CacheMetricsCommandTest;
 import org.apache.ignite.util.CdcCommandTest;
 import org.apache.ignite.util.CdcResendCommandTest;
+import org.apache.ignite.util.GridCommandHandlerClassPathTest;
 import org.apache.ignite.util.GridCommandHandlerConsistencyBinaryTest;
 import org.apache.ignite.util.GridCommandHandlerConsistencySensitiveTest;
 import org.apache.ignite.util.GridCommandHandlerConsistencyTest;
@@ -73,7 +74,8 @@
 
     SecurityCommandHandlerPermissionsTest.class,
 
-    IdleVerifyDumpTest.class
+    IdleVerifyDumpTest.class,
+    GridCommandHandlerClassPathTest.class
 })
 public class IgniteControlUtilityTestSuite2 {
 }