turns-00085.parquet:30247
69c7f07879360b60839b6742degenerate_repetitionAbsentFinal dense release
USER
package org.nsomatrix.supabase;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URI;
import java.net.http.*;
import java.net.http.HttpResponse.BodyHandlers;
import java.nio.file.Files;
import java.time.Duration;
import java.util.ArrayList;
import java.util.List;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
public class SupabaseStorageClient {
private final HttpClient httpClient;
private final ObjectMapper objectMapper;
private String accessToken; // User JWT token
private String userId; // User UUID, folder prefix
public SupabaseStorageClient() {
this.httpClient = HttpClient.newBuilder()
.connectTimeout(Duration.ofSeconds(15))
.build();
this.objectMapper = new ObjectMapper();
}
public void setAccessToken(String token) {
this.accessToken = token;
}
public void setUserId(String userId) {
this.userId = userId;
}
private String prefixPath(String path) {
if (userId == null || userId.isBlank()) {
throw new IllegalStateException("User ID must be set before calling storage methods");
}
if(path == null || path.isBlank()) {
return userId + "/";
}
return userId + "/" + path;
}
public List<String> listFiles() throws IOException, InterruptedException {
// List files in the user's folder
String prefix = prefixPath("");
HttpRequest request = HttpRequest.newBuilder()
.uri(URI.create(SupabaseConfig.SUPABASE_URL + "/storage/v1/object/list/" + SupabaseConfig.STORAGE_BUCKET + "?prefix=" + prefix))
.GET()
.header("apikey", SupabaseConfig.SUPABASE_ANON_KEY)
.header("Authorization", "Bearer " + accessToken)
.build();
HttpResponse<String> response = httpClient.send(request, BodyHandlers.ofString());
if (response.statusCode() != 200) {
throw new IOException("Failed to list files, status: " + response.statusCode() + ", body: " + response.body());
}
JsonNode root = objectMapper.readTree(response.body());
List<String> files = new ArrayList<>();
if (root.isArray()) {
for (JsonNode item : root) {
String fullName = item.get("name").asText();
// Strip userId + slash prefix from the returned file name
files.add(fullName.substring(prefix.length()));
}
}
return files;
}
public void uploadFile(File file) throws IOException, InterruptedException {
String path = prefixPath(file.getName());
HttpRequest.BodyPublisher bodyPublisher = HttpRequest.BodyPublishers.ofFile(file.toPath());
HttpRequest request = HttpRequest.newBuilder()
.uri(URI.create(SupabaseConfig.SUPABASE_URL + "/storage/v1/object/" + SupabaseConfig.STORAGE_BUCKET + "/" + path))
.header("apikey", SupabaseConfig.SUPABASE_ANON_KEY)
.header("Authorization", "Bearer " + accessToken)
.header("Content-Type", Files.probeContentType(file.toPath()))
.PUT(bodyPublisher)
.build();
HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
if (response.statusCode() != 200) {
throw new IOException("Failed to upload file, status: " + response.statusCode() + ", body: " + response.body());
}
}
public void downloadFile(String remoteFileName, File localFile) throws IOException, InterruptedException {
String path = prefixPath(remoteFileName);
HttpRequest request = HttpRequest.newBuilder()
// Use storage public object endpoint is NOT recommended here since bucket is private; Use auth
.uri(URI.create(SupabaseConfig.SUPABASE_URL + "/storage/v1/object/" + SupabaseConfig.STORAGE_BUCKET + "/" + path))
.GET()
.header("apikey", SupabaseConfig.SUPABASE_ANON_KEY)
.header("Authorization", "Bearer " + accessToken)
.build();
HttpResponse<InputStream> response = httpClient.send(request, BodyHandlers.ofInputStream());
if (response.statusCode() != 200) {
String body = new String(response.body().readAllBytes());
throw new IOException("Failed to download file, status: " + response.statusCode() + ", body: " + body);
}
try (InputStream is = response.body();
OutputStream os = Files.newOutputStream(localFile.toPath())) {
is.transferTo(os);
}
}
public void deleteFile(String remoteFileName) throws IOException, InterruptedException {
String path = prefixPath(remoteFileName);
HttpRequest request = HttpRequest.newBuilder()
.uri(URI.create(SupabaseConfig.SUPABASE_URL + "/storage/v1/object/" + SupabaseConfig.STORAGE_BUCKET + "/" + path))
.header("apikey", SupabaseConfig.SUPABASE_ANON_KEY)
.header("Authorization", "Bearer " + accessToken)
.DELETE()
.build();
HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
if (response.statusCode() != 204) {
throw new IOException("Failed to delete file, status: " + response.statusCode() + ", body: " + response.body());
}
}
}ASSISTANT
Your `SupabaseStorageClient` code is correct in principle — it sends the anon key in the `apikey` header and the logged-in user’s JWT in the `Authorization` header.
---
### Given your "bucket not found" (404) error, here are some suggestions and troubleshooting steps:
---
## 1. Debug logging — add this just before sending the request in `listFiles()`
```java
System.out.println("Listing files from URL: " + request.uri());
System.out.println("Authorization token (first 10 chars): " + (accessToken != null ? accessToken.substring(0, Math.min(10, accessToken.length())) + "..." : "null"));
System.out.println("Using bucket: " + SupabaseConfig.STORAGE_BUCKET);
```
This will confirm URL, bucket, and token presence.
---
## 2. Double check your `accessToken` value before making storage calls
- If your `accessToken` is `null` or empty, the request will fail.
- The anonymous key **cannot** access private buckets.
---
## 3. Manual test of your bucket access via curl
Copy the actual value of `accessToken` from your app logs, and run:
```bash
curl -v -X GET "https://izyvffrihiuwocphmaaz.supabase.co/storage/v1/object/list/user-uploads?prefix=" \
-H "apikey: eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9..." \
-H "Authorization: Bearer <accessToken>"
```
If this returns the **same 404 bucket not found**, problem is at Supabase side.
---
## 4. Check your bucket permission and policies in Supabase dashboard
- Go to Storage → user-uploads → Policies.
- Your RLS policies may sometimes cause the bucket access to appear denied.
- Temporarily disable RLS or set relaxed policies to test.
---
## 5. Verify bucket name casing and spelling (you did this, it looks fine).
---
## 6. Try **listFiles()** with no prefix first (empty string `""`) — your code does this correctly, but verify.
---
## 7. Alternative Storage endpoint for public buckets:
If your bucket was public (it likely is not in your case), you would use `/storage/v1/object/public/...` instead of `/storage/v1/object/...`.
Make sure you do NOT use the public endpoint when bucket is private.
---
## 8. Check HTTP response body for hints on error (you are printing it in exception).
---
# Summary checklist:
- Your `accessToken` is set and valid.
- Your bucket `user-uploads` exists exactly.
- You are calling `/storage/v1/object/list/user-uploads` (your code does it correctly).
- Your RLS policies allow the logged-in user to list files.
- Your anon key is present in `apikey` header (you do this).
- Your Authorization header has **user’s JWT**, not anon key.
---
If you want, I can help you write a quick test `main()` method to debug these assumptions and ensure your access token and storage calls are working properly.
---
### Debug snippet example (to add in some test or main method):
```java
public static void main(String[] args) throws Exception {
SupabaseStorageClient client = new SupabaseStorageClient();
client.setUserId("your-uuid-from-login"); // example
client.setAccessToken("your-access-token-from-login");
System.out.println("Listing files...");
try {
var files = client.listFiles();
System.out.println("Files:");
files.forEach(System.out::println);
} catch (Exception e) {
e.printStackTrace();
}
}
```
Replace `"your-uuid-from-login"` and `"your-access-token-from-login"` with actual values from login response.
---
Let me know if you want me to help you add such debug code or verify token values!