import java.util.ArrayList;
import java.util.List;

import static java.util.Collections.singletonList;

public class GcsClient {

    private static final Logger LOGGER = LoggerFactory.getLogger(GcsClient.class);

    private final Storage storage;

    public static GcsClient create(GcsConnectionProperties gcsConnectionProperties) throws GeneralSecurityException, IOException {

    private final GcsClient gcsClient;

    public GcsResourceConnector(GcsClient gcsClient) {
        this.gcsClient = gcsClient;
    }

    @Nullable
    @Override
    public List<String> list(ExternalResourceName parent) throws ResourceException {
        LOGGER.debug("Listing parent resources: {}", parent);
        return gcsClient.list(parent.getUri());
    }

    @Nullable

    def name = new ExternalResourceName(uri)

    def "should list resources"() {
        GcsClient gcsClient = Mock()
        when:
        new GcsResourceConnector(gcsClient).list(name)
        then:
        1 * gcsClient.list(uri)
    }

    def "should get a resource"() {
        GcsClient gcsClient = Mock {
            1 * getResource(uri) >> new StorageObject()
        }

        when:

        }

        when:
        gcsClient.put(Mock(InputStream), 0, uri)
        then:
        def ex = thrown(ResourceException)
        ex.message.startsWith("Could not write to resource 'https://somehost/file.txt'")
    }

    def "should not fail on GcsClient.list() returning null"() {
        def gcsStorageClient = Mock(Storage)
        GcsClient gcsClient = new GcsClient(gcsStorageClient)

        builder.setServicePath("/")

        GcsClient gcsClient = new GcsClient(builder.build())
        def uri = new URI("gcs://${bucketName}/maven/release/$FILE_NAME")

        when:
        server.stubPutFile(file, bucketName)
        def stream = new FileInputStream(file)

        then:
        gcsClient.put(stream, file.length(), uri)

        when:

public class GcsResource implements ExternalResourceReadResponse {

    private final GcsClient gcsClient;
    private final StorageObject gcsObject;
    private final URI uri;

    public GcsResource(GcsClient gcsClient, StorageObject gcsObject, URI uri) {
        this.gcsClient = gcsClient;
        this.gcsObject = gcsObject;
        this.uri = uri;
    }

    @Override

        storageObject.setSize(BigInteger.ONE)
        storageObject.setContentType(contentType)
        storageObject.setEtag(Integer.toString(5))

        when:
        def metaData = new GcsResource(Mock(GcsClient), storageObject, uri).getMetaData()

        then:
        metaData != null
        metaData.location == uri
        metaData.lastModified == new Date(lastModified.value)

        return emptySet();
    }

    @Override
    public ExternalResourceConnector createResourceConnector(ResourceConnectorSpecification connectionDetails) {
        try {
            return new GcsResourceConnector(GcsClient.create(new GcsConnectionProperties()));
        } catch (Exception e) {
            throw UncheckedException.throwAsUncheckedException(e);
        }
    }

	}

	return c.nodeExpandWithClient(resizeOptions, csiSource, csClient, fsVolume)
}

func (c *csiPlugin) nodeExpandWithClient(
	resizeOptions volume.NodeResizeOptions,
	csiSource *api.CSIPersistentVolumeSource,
	csClient csiClient,
	fsVolume bool) (bool, error) {
	driverName := csiSource.Driver

				DeviceStagePath: "/foo/bar",
				DevicePath:      "/mnt/foobar",
			}
			csiSource, _ := getCSISourceFromSpec(resizeOptions.VolumeSpec)
			csClient := setupClientWithExpansion(t, tc.nodeStageSet, tc.nodeExpansion)

			fakeCSIClient, _ := csClient.(*fakeCsiDriverClient)
			fakeNodeClient := fakeCSIClient.nodeClient

			if tc.enableCSINodeExpandSecret {