fix: добавили много логики для токенов, но сломался стрим файла, надо будет сверить с девелопом, где все рабаотло

Author: RahatMelsov

api/proto/file/v1/file.proto

@@ -1,11 +1,31 @@
+
 syntax = "proto3";
 
 package file.v1;
 option go_package = "github.com/rtmelsov/adv-keeper/gen/go/file/v1;filev1";
 
+import "google/protobuf/timestamp.proto";
+
 service FileService {
   // Клиент шлёт поток кусков, сервер в конце отвечает сводкой
   rpc Upload(stream UploadRequest) returns (UploadResponse);
+  // Список файлов текущего пользователя (берём user_id из контекста)
+  rpc GetFiles(GetFilesRequest) returns (GetFilesResponse);
+}
+
+message GetFilesRequest {
+  int32 limit  = 1; // по умолчанию 50
+  int32 offset = 2; // по умолчанию 0
+}
+
+message FileItem {
+  string filename = 1;
+  int64  size     = 2;
+  google.protobuf.Timestamp created_at = 3;
+}
+
+message GetFilesResponse {
+  repeated FileItem files = 1;
 }
 
 message UploadRequest {
@@ -21,12 +41,15 @@ message FileInfo {
 }
 
 message FileChunk {
-  bytes  content = 1;   // данные куска (< 4 MiB — лимит gRPC на сообщение)
-  int64  offset  = 2;   // сдвиг от начала файла (полезно для резюмации)
+  bytes content = 1;  // данные куска (< 4 MiB — лимит gRPC на сообщение)
+  int64 offset  = 2;  // сдвиг от начала файла (полезно для резюмации)
 }
 
 message UploadResponse {
   string stored_as      = 1; // путь/имя сохранённого файла на сервере
   int64  bytes_received = 2; // сколько байт приняли
   string sha256         = 3; // контрольная сумма принятого
 }
+
+
+

cmd/server/main.go

@@ -10,7 +10,6 @@ import (
 	commonv1 "github.com/rtmelsov/adv-keeper/gen/go/proto/common/v1"
 	filev1 "github.com/rtmelsov/adv-keeper/gen/go/proto/file/v1"
 	db "github.com/rtmelsov/adv-keeper/internal/db"
-	"github.com/rtmelsov/adv-keeper/internal/file"
 	"github.com/rtmelsov/adv-keeper/internal/helpers"
 	"github.com/rtmelsov/adv-keeper/internal/middleware"
 	"github.com/rtmelsov/adv-keeper/internal/server"
@@ -50,7 +49,7 @@ func main() {
 		}),
 	)
 	commonv1.RegisterAuthServiceServer(s, server.New(q))
-	filev1.RegisterFileServiceServer(s, file.New(q))
+	filev1.RegisterFileServiceServer(s, server.NewFile(q))
 
 	reflection.Register(s)
 

db/queries/auth.sql

@@ -1,4 +1,4 @@
--- name: RegisterWithDevice :one
+-- name: Register :one
 INSERT INTO users (email, pwd_phc, e2ee_pub)
 VALUES ($1, $2, $3)
 RETURNING id;
@@ -9,16 +9,18 @@ FROM users
 WHERE email = $1;
 
 -- name: AddFile :one
-INSERT INTO files (user_id, name, path)
-VALUES ($1, $2, $3)
-RETURNING id, user_id, name, path, created_at;
+INSERT INTO files (user_id, filename, path, size_bytes)
+VALUES ($1, $2, $3, $4)
+RETURNING id, user_id, filename, path, size_bytes, created_at;
 
 -- name: ListFilesByUser :many
-SELECT id, name, path, created_at
+SELECT id, filename, path, size_bytes, created_at
 FROM files
 WHERE user_id = $1
 ORDER BY created_at DESC;
 
--- name: DeleteFile :exec
+-- name: DeleteFile :one
 DELETE FROM files
-WHERE id = $1 AND user_id = $2;
+WHERE id = $1 AND user_id = $2
+RETURNING id;  -- проще понять, удалилось или нет
+