From 0fc7b8b94d485cd8f0d7370e54bcb256021f96c1 Mon Sep 17 00:00:00 2001 From: Lizandro Guarnizo <77708265+lizandrogd@users.noreply.github.com> Date: Wed, 10 Jun 2026 00:18:42 -0500 Subject: [PATCH] contrato: M2M infra linking (servidores, conx_dbs, ai_configs) --- .gitignore | 4 +- .task-project | 3 -- cmd/count-oss/main.go | 35 ------------ cmd/migrate-oss/main.go | 114 ---------------------------------------- u_site.db | 0 5 files changed, 3 insertions(+), 153 deletions(-) delete mode 100644 .task-project delete mode 100644 cmd/count-oss/main.go delete mode 100644 cmd/migrate-oss/main.go delete mode 100644 u_site.db diff --git a/.gitignore b/.gitignore index e37874e..3529cfd 100755 --- a/.gitignore +++ b/.gitignore @@ -15,4 +15,6 @@ awstatsicons icon/ stats/ pnpm-lock.yaml -package-lock.json \ No newline at end of file +package-lock.json +.task-project +*.db \ No newline at end of file diff --git a/.task-project b/.task-project deleted file mode 100644 index 350741f..0000000 --- a/.task-project +++ /dev/null @@ -1,3 +0,0 @@ -{ - "project": "soft_usite" -} \ No newline at end of file diff --git a/cmd/count-oss/main.go b/cmd/count-oss/main.go deleted file mode 100644 index d0bc519..0000000 --- a/cmd/count-oss/main.go +++ /dev/null @@ -1,35 +0,0 @@ -package main - -import ( - "context" - "fmt" - "log" - - "github.com/minio/minio-go/v7" - "github.com/minio/minio-go/v7/pkg/credentials" -) - -func main() { - minioClient, err := minio.New("135.181.2.237:9000", &minio.Options{ - Creds: credentials.NewStaticV4("admin", "lsE6TAihW98iaXKDWG+6gGLYAFdyp2iC", ""), - Secure: false, - BucketLookup: minio.BucketLookupPath, - }) - if err != nil { - log.Fatalf("Error: %v", err) - } - - ctx := context.Background() - var count int64 - opts := minio.ListObjectsOptions{Recursive: true} - for obj := range minioClient.ListObjects(ctx, "vcard-usite", opts) { - if obj.Err != nil { - log.Fatalf("Error: %v", obj.Err) - } - count++ - if count%500 == 0 { - fmt.Printf("MinIO: %d objetos...\n", count) - } - } - fmt.Printf("\nTotal en MinIO: %d objetos\n", count) -} diff --git a/cmd/migrate-oss/main.go b/cmd/migrate-oss/main.go deleted file mode 100644 index 168f9e4..0000000 --- a/cmd/migrate-oss/main.go +++ /dev/null @@ -1,114 +0,0 @@ -package main - -import ( - "context" - "fmt" - "log" - "time" - - "github.com/aliyun/aliyun-oss-go-sdk/oss" - "github.com/minio/minio-go/v7" - "github.com/minio/minio-go/v7/pkg/credentials" -) - -func main() { - alibabaEndpoint := "oss-eu-central-1.aliyuncs.com" - alibabaKey := "LTAI5tCxbGnEBAj9RS5JpLWw" - alibabaSecret := "qAS8Rsi3MpRrV043fgxnW6fmUsQ8GN" - bucketName := "vcard-usite" - - minioEndpoint := "135.181.2.237:9000" - minioKey := "admin" - minioSecret := "lsE6TAihW98iaXKDWG+6gGLYAFdyp2iC" - - log.Println("Conectando a Alibaba OSS...") - alibabaClient, err := oss.New(alibabaEndpoint, alibabaKey, alibabaSecret) - if err != nil { - log.Fatalf("Error conectando a Alibaba: %v", err) - } - alibabaBucket, err := alibabaClient.Bucket(bucketName) - if err != nil { - log.Fatalf("Error obteniendo bucket Alibaba: %v", err) - } - - log.Println("Conectando a MinIO S3...") - minioClient, err := minio.New(minioEndpoint, &minio.Options{ - Creds: credentials.NewStaticV4(minioKey, minioSecret, ""), - Secure: false, - BucketLookup: minio.BucketLookupPath, - }) - if err != nil { - log.Fatalf("Error conectando a MinIO: %v", err) - } - - ctx := context.Background() - - // Asegurar que el bucket existe en MinIO - exists, err := minioClient.BucketExists(ctx, bucketName) - if err != nil { - log.Fatalf("Error verificando bucket MinIO: %v", err) - } - if !exists { - err = minioClient.MakeBucket(ctx, bucketName, minio.MakeBucketOptions{Region: "us-east-1"}) - if err != nil { - log.Fatalf("Error creando bucket MinIO: %v", err) - } - log.Printf("Bucket '%s' creado en MinIO", bucketName) - } - - log.Println("Listando objetos de Alibaba OSS...") - var totalObjects, skipped int64 - marker := oss.Marker("vcf/vcf-Guido_Maffet-nxh4.vcf") - for { - resp, err := alibabaBucket.ListObjects(oss.MaxKeys(1000), marker) - if err != nil { - log.Fatalf("Error listando objetos Alibaba: %v", err) - } - - for _, obj := range resp.Objects { - totalObjects++ - // Saltar si ya existe en MinIO (mismo tamaño) - info, err := minioClient.StatObject(ctx, bucketName, obj.Key, minio.StatObjectOptions{}) - if err == nil && info.Size == obj.Size { - skipped++ - continue - } - - fmt.Printf("[%d] Migrando: %s (%s)...\n", totalObjects, obj.Key, formatSize(obj.Size)) - - reader, err := alibabaBucket.GetObject(obj.Key) - if err != nil { - log.Printf(" ERROR leyendo de Alibaba: %v", err) - continue - } - - _, err = minioClient.PutObject(ctx, bucketName, obj.Key, reader, obj.Size, minio.PutObjectOptions{}) - reader.Close() - if err != nil { - log.Printf(" ERROR subiendo a MinIO: %v", err) - continue - } - - fmt.Printf(" ✓ OK\n") - time.Sleep(10 * time.Millisecond) - } - - if !resp.IsTruncated { - break - } - marker = oss.Marker(resp.NextMarker) - } - - log.Printf("Migración completada. %d objetos totales, %d saltados (ya existen), %d migrados.", totalObjects, skipped, totalObjects-skipped) -} - -func formatSize(bytes int64) string { - if bytes < 1024 { - return fmt.Sprintf("%d B", bytes) - } else if bytes < 1024*1024 { - return fmt.Sprintf("%.1f KB", float64(bytes)/1024) - } else if bytes < 1024*1024*1024 { - return fmt.Sprintf("%.1f MB", float64(bytes)/(1024*1024)) - } - return fmt.Sprintf("%.1f GB", float64(bytes)/(1024*1024*1024)) -} diff --git a/u_site.db b/u_site.db deleted file mode 100644 index e69de29..0000000