import com.google.cloud.storage.Bucket; //导入依赖的package包/类
@Bean
public static Storage mockStorage() throws Exception {
	Storage storage = mock(Storage.class);
	BlobId validBlob = BlobId.of("test-spring", "images/spring.png");
	Bucket mockedBucket = mock(Bucket.class);
	Blob mockedBlob = mock(Blob.class);
	WriteChannel writeChannel = mock(WriteChannel.class);
	when(mockedBlob.exists()).thenReturn(true);
	when(mockedBucket.exists()).thenReturn(true);
	when(mockedBlob.getSize()).thenReturn(4096L);
	when(storage.get(eq(validBlob))).thenReturn(mockedBlob);
	when(storage.get("test-spring")).thenReturn(mockedBucket);
	when(mockedBucket.getName()).thenReturn("test-spring");
	when(mockedBlob.writer()).thenReturn(writeChannel);
	return storage;
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
@Override
public Component getListCellRendererComponent(
    JList<? extends Bucket> list,
    Bucket bucket,
    int index,
    boolean isSelected,
    boolean cellHasFocus) {
  setIcon(GoogleCloudToolsIcons.CLOUD_STORAGE_BUCKET);
  setText(bucket.getName());

  if (isSelected) {
    setBackground(list.getSelectionBackground());
    setForeground(list.getSelectionForeground());
  } else {
    setBackground(list.getBackground());
    setForeground(list.getForeground());
  }

  return this;
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
private void showRightClickMenu(MouseEvent event) {
  JPopupMenu rightClickMenu = new JPopupMenu();
  JMenuItem copyBucketNameMenuItem =
      new JMenuItem(GctBundle.message("gcs.content.explorer.right.click.menu.copy.bucket.text"));
  rightClickMenu.add(copyBucketNameMenuItem);

  int index = bucketList.locationToIndex(event.getPoint());
  Bucket bucket = bucketListModel.getElementAt(index);

  if (bucket != null) {
    copyBucketNameMenuItem.addActionListener(
        e ->
            UsageTrackerProvider.getInstance()
                .trackEvent(GctTracking.GCS_BUCKET_LIST_ACTION_COPY_BUCKET_NAME)
                .ping());
    copyBucketNameMenuItem.addActionListener(new CopyToClipboardActionListener(bucket.getName()));
    rightClickMenu.show(event.getComponent(), event.getX(), event.getY());
  }
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
static GcsBucketVirtualFile setupVirtualFileWithBucketMocks(
    GcsBucketVirtualFile gcsBucketVirtualFile) {
  Bucket bucket = mock(Bucket.class);
  Page<Blob> page = mock(Page.class);
  Iterable<Blob> blobIterable = mock(Iterable.class);
  Iterator<Blob> blobIterator = mock(Iterator.class);

  when(gcsBucketVirtualFile.getBucket()).thenReturn(bucket);
  when(bucket.list()).thenReturn(page);
  when(bucket.list(any(BlobListOption.class), any(BlobListOption.class))).thenReturn(page);
  when(page.iterateAll()).thenReturn(blobIterable);
  when(blobIterable.iterator()).thenReturn(blobIterator);

  return gcsBucketVirtualFile;
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
@Test
public void testCloudStorageSignUrl() throws IOException {
  StorageClient storage = StorageClient.getInstance(IntegrationTestUtils.ensureDefaultApp());
  Bucket bucket = storage.bucket();
  Blob blob = createTextBlob(bucket, "Signed URL Test");
  URL url = blob.signUrl(3600, TimeUnit.SECONDS);
  try (InputStream in = url.openStream()) {
    String result = CharStreams.toString(new InputStreamReader(in));
    assertEquals("Signed URL Test", result);
  } finally {
    blob.delete();
  }
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
private void testBucket(Bucket bucket) {
  assertEquals(IntegrationTestUtils.getStorageBucket(), bucket.getName());
  String fileName = createTextBlob(bucket, "Hello World").getName();

  Blob blob = bucket.get(fileName);
  byte[] content = blob.getContent();
  assertEquals("Hello World", new String(content));

  assertTrue(blob.delete());
  assertNull(bucket.get(fileName));
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
@Test
public void testBucket() throws IOException {
  FirebaseApp app = FirebaseApp.initializeApp(new FirebaseOptions.Builder()
      .setCredentials(GoogleCredentials.fromStream(ServiceAccount.EDITOR.asStream()))
      .setStorageBucket("mock-bucket-name")
      .build());
  Storage mockStorage = Mockito.mock(Storage.class);
  Bucket mockBucket = Mockito.mock(Bucket.class);
  Mockito.when(mockStorage.get("mock-bucket-name")).thenReturn(mockBucket);
  StorageClient client = new StorageClient(app, mockStorage);
  assertSame(mockBucket, client.bucket());
  assertSame(mockBucket, client.bucket("mock-bucket-name"));
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
/**
 * Gives the raw JS Scripts sepcified
 * @return list of raw JS Script data as strings
 */
public List<String> getScripts() {
  if (Strings.isNullOrEmpty(gcsJSPath())) {
    return new ArrayList<>();
  }

  String bucketName = gcsJSPath().replace("gs://", "").split("/")[0];
  String prefixPath = gcsJSPath().replace("gs://" + bucketName + "/", "");

  Bucket bucket = getStorageService().get(bucketName);
  if (bucket == null || !bucket.exists()) {
    throw new IllegalArgumentException(
        "Bucket does not exist, or do not have adequate permissions");
  }

  ArrayList<String> filePaths = new ArrayList<>();
  if (prefixPath.endsWith(".js")) {
    filePaths.add(prefixPath);
  } else {
    Page<Blob> blobs = bucket.list(BlobListOption.prefix(prefixPath));
    blobs.iterateAll().forEach((Blob blob) -> {
      if (blob.getName().endsWith(".js")) {
        filePaths.add(blob.getName());
      }
    });
  }

  List<String> scripts = new ArrayList<>();
  for (String filePath : filePaths) {
    Blob b = bucket.get(filePath);
    if (b == null || !b.exists()) {
      throw new IllegalArgumentException(
          "File does not exist, or do not have adequate permissions");
    }
    scripts.add(new String(b.getContent()));
  }

  return scripts;
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
void destroyBucket(String name) {
    String bName = environment + name.replaceAll("\\.", "").toLowerCase();
    Bucket bukkit = storage.get(bName);
    if (bukkit != null) {
        for (Blob blob : this.listBlobs(name)) {
            storage.delete(blob.getBlobId());
        }
        try {
            storage.delete(bName);
        } catch (Exception e) {
            System.err.println("Cannot delete bucket " + name + " : " + e.getMessage());
        }
    }
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
public TestApp() {
	try
	{
		HttpTransport httpTransport = new NetHttpTransport();             
		JacksonFactory jsonFactory = new JacksonFactory();
		//ComputeCredential credential = new ComputeCredential.Builder(httpTransport, jsonFactory).build();	
		GoogleCredential credential = GoogleCredential.getApplicationDefault(httpTransport,jsonFactory);				            
		if (credential.createScopedRequired())
		    credential = credential.createScoped(Arrays.asList(Oauth2Scopes.USERINFO_EMAIL));           				            
		Oauth2 service = new Oauth2.Builder(httpTransport, jsonFactory, credential)
		            .setApplicationName("oauth client")   
		            .build();				            
		Userinfoplus ui = service.userinfo().get().execute();
		System.out.println(ui.getEmail());



         // Using Google Cloud APIs
	  Storage  storage_service = StorageOptions.defaultInstance().service();
       
         Iterator<Bucket> bucketIterator = storage_service.list().iterateAll();
         while (bucketIterator.hasNext()) {
           System.out.println(bucketIterator.next());
         }	

	} 
	catch (Exception ex) {
		System.out.println("Error:  " + ex);
	}
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
public void doGet(HttpServletRequest req, HttpServletResponse resp)
		throws IOException {
	resp.setContentType("text/plain");
	resp.getWriter().println("Hello, world");
			
	HttpTransport httpTransport = new UrlFetchTransport();        
	JacksonFactory jsonFactory = new JacksonFactory();

	/*
	AppIdentityService appIdentity = AppIdentityServiceFactory.getAppIdentityService();    
	AppIdentityService.GetAccessTokenResult accessToken = appIdentity.getAccessToken(Arrays.asList(Oauth2Scopes.USERINFO_EMAIL));         
	GoogleCredential credential = new GoogleCredential.Builder()
		.setTransport(httpTransport)
		.setJsonFactory(jsonFactory).build();
    credential.setAccessToken(accessToken.getAccessToken());
	*/

	GoogleCredential credential = GoogleCredential.getApplicationDefault(httpTransport,jsonFactory);    
	if (credential.createScopedRequired())
	    credential = credential.createScoped(Arrays.asList(Oauth2Scopes.USERINFO_EMAIL));           

	Oauth2 service = new Oauth2.Builder(httpTransport, jsonFactory, credential)
	    .setApplicationName("oauth client").build();

	Userinfoplus ui = service.userinfo().get().execute(); 
	resp.getWriter().println(ui.getEmail());
    

         // Using Google Cloud APIs
	  Storage  storage_service = StorageOptions.defaultInstance().service();
       
         Iterator<Bucket> bucketIterator = storage_service.list().iterateAll();
         while (bucketIterator.hasNext()) {
           System.out.println(bucketIterator.next());
         }		

}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
public static void main(String... args) throws Exception {
  // Instantiates a client
  Storage storage = StorageOptions.getDefaultInstance().getService();

  // The name for the new bucket
  String bucketName = args[0];  // "my-new-bucket";

  // Creates the new bucket
  Bucket bucket = storage.create(BucketInfo.of(bucketName));

  System.out.printf("Bucket %s created.%n", bucket.getName());
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
private void loadBucketContents(@NotNull Bucket bucket) {
  FileEditorManager editorManager = FileEditorManager.getInstance(project);

  editorManager.openEditor(
      new OpenFileDescriptor(
          project,
          findOpenGcsVirtualFile(bucket).orElseGet(() -> new GcsBucketVirtualFile(bucket)),
          1 /*offset*/),
      true /*focusEditor*/);
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
/**
 * Searches for an open editor who's {@link VirtualFile} matches the bucket that was opened. This
 * prevents the same editor window being opened multiple times for the same bucket.
 */
private Optional<GcsBucketVirtualFile> findOpenGcsVirtualFile(@NotNull Bucket bucket) {
  FileEditorManager editorManager = FileEditorManager.getInstance(project);

  return Arrays.stream(editorManager.getOpenFiles())
      .filter(openFile -> openFile instanceof GcsBucketVirtualFile)
      .map(openGcsFile -> (GcsBucketVirtualFile) openGcsFile)
      .filter(openGcsFile -> openGcsFile.getBucket().equals(bucket))
      .findFirst();
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
/**
 * Gets the list of child files of the current directory
 *
 * @return A list of file/folders
 * @throws Exception
 */
@Override protected String[] doListChildren() throws Exception {
  List<String> items = new ArrayList<>();
  Map<String, List<String>> folders = new HashMap<>();
  Bucket bucket = storage.get( getBucketName() );
  if ( bucket != null && bucket.exists() ) {
    folders.put( "", new ArrayList<>() );
    for ( Blob blob : bucket.list().iterateAll() ) {
      String path = blob.getName();
      boolean isDirectory = path.endsWith( DELIMITER );
      String parent = "";
      if ( path.contains( DELIMITER ) ) {
        parent = path.substring( 0, path.lastIndexOf( DELIMITER ) );
      }
      String[] parts = path.split( DELIMITER );
      String name = parts[ parts.length - 1 ];
      if ( isDirectory ) {
        folders.put( fixSlashes( path, false ), new ArrayList<>() );
        name = name.concat( DELIMITER );
        parent = path.substring( 0, path.lastIndexOf( DELIMITER ) );
        if ( parent.contains( DELIMITER ) ) {
          parent = parent.substring( 0, parent.lastIndexOf( DELIMITER ) );
        } else {
          parent = "";
        }
      }
      List<String> folderList = folders.getOrDefault( fixSlashes( parent, true ), new ArrayList<>() );
      folderList.add( name );
      folders.put( fixSlashes( parent, true ), folderList );
    }
    items = folders.getOrDefault( fixSlashes( getName().getPath(), true ), Collections.emptyList() );
  }

  return items.toArray( new String[ items.size() ] );
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
/**
 * Gets the blob from the Google Cloud Storage api for the file/folder
 *
 * @return The Blob that represents the file/folder
 */
public Blob getBlob() {
  URLFileName urlFileName = (URLFileName) this.getName();
  Bucket bucket = storage.get( urlFileName.getHostName() );
  if ( urlFileName.getPath().equals( DELIMITER ) ) {
    return null;
  }
  String stripped = urlFileName.getPath().substring( 1, urlFileName.getPath().length() );
  Blob blob = bucket.get( stripped );
  if ( blob == null ) {
    blob = bucket.get( stripped.concat( DELIMITER ) );
  }
  return blob;
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
private Blob createTextBlob(Bucket bucket, String contents) {
  String fileName = "data_" + System.currentTimeMillis() + ".txt";
  return bucket.create(fileName, contents.getBytes(), "text/plain");
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
public Bucket checkBucket(String bucketName) {
  return Objects.requireNonNull(storage.get(bucketName, Storage.BucketGetOption.fields()),
          "No such bucket");
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
public Bucket createBucket(String bucketName) {
  Bucket bucket = storage.create(BucketInfo.newBuilder(bucketName)
          .setLocation("europe-west1")
          .build());
  return bucket;
}
 

import com.google.cloud.storage.Bucket; //导入依赖的package包/类
public Page<Blob> listBucket(String bucketName, String directory) {
  Bucket bucket = Objects.requireNonNull(storage.get(bucketName, Storage.BucketGetOption.fields()),
          "Please provide bucket name.");
  Page<Blob> blobs = bucket.list(Storage.BlobListOption.prefix(directory));
  return blobs;
}