streampark-common/src/test/scala/org/apache/streampark/common/util/ImplicitsUtilsTest.scala

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.streampark.common.util

import org.apache.streampark.common.util.ImplicitsUtils.{AutoCloseImplicits, StringImplicits}

import org.scalatest.funsuite.AnyFunSuite

class ImplicitsUtilsTest extends AnyFunSuite {
  test(
    "AutoCloseImplicits.autoClose should close the resource after execution and handle exceptions") {
    class MockResource extends AutoCloseable {
      var closed = false
      def close(): Unit = closed = true
    }

    def operation(resource: MockResource): Unit = {
      throw new RuntimeException("Simulated exception")
    }

    val mockResource = new MockResource
    assertThrows[RuntimeException] {
      mockResource.autoClose(operation)
    }
    assert(mockResource.closed)
  }

  test("StringImplicits.cast should convert string to the specified type") {
    val intString = "123"
    val doubleString = "3.14"
    val booleanString = "true"

    assert(intString.cast[Int](classOf[Int]) == 123)
    assert(doubleString.cast[Double](classOf[Double]) == 3.14)
    assert(booleanString.cast[Boolean](classOf[Boolean]))
  }

  test("StringImplicits.cast should throw IllegalArgumentException for unsupported type") {
    val unsupportedString = "test"
    assertThrows[IllegalArgumentException] {
      unsupportedString.cast[Unit](classOf[Unit])
    }
  }
}