“Naeel”
f878c4cc6f
- seed.go: CreateFixed с хардкод credentials для demo-service AccessKey=SSAK-demo-shared-sqs (постоянные, README всегда актуален) - tenant_store: добавлен CreateFixed для задания произвольных credentials - deployment.yaml: v0.1.9 - doc/byoc-credentials.md: полная документация BYOC фичи (TODO для API+UI)
116 lines
3.9 KiB
Go
116 lines
3.9 KiB
Go
// app/cmd/seed.go
|
|
// Created: 2026-04-09
|
|
// Updated: 2026-04-09 — фиксированные credentials для demo-tenant (BYOC)
|
|
// Автосид демо-данных при старте через SHARED_SQS_SEED_DEMO=true.
|
|
// Создаёт тенанта demo-service с 5 очередями и демо-сообщениями.
|
|
//
|
|
// DEMO CREDENTIALS — только для тестового стенда.
|
|
// Тенант demo-service изолирован: видит только свои очереди, не имеет доступа к
|
|
// admin API и к очередям других тенантов. Credentials открыты намеренно — стенд публичный.
|
|
package main
|
|
|
|
import (
|
|
"crypto/md5" //nolint:gosec — MD5 используется для SQS-совместимости, не для безопасности
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/google/uuid"
|
|
log "github.com/sirupsen/logrus"
|
|
|
|
"shared-sqs/app/models"
|
|
"shared-sqs/app/tenant"
|
|
)
|
|
|
|
// Фиксированные credentials демо-тенанта.
|
|
// Открыты намеренно — тестовый стенд.
|
|
// Тенант ограничен 10 очередями и не имеет прав admin API.
|
|
const (
|
|
demoTenantID = "t-demo-shared-sqs-ngcloud"
|
|
demoAccessKey = "SSAK-demo-shared-sqs"
|
|
demoSecretKey = "demo-secret-key-shared-sqs-ngcloud-2026"
|
|
demoTenantName = "demo-service"
|
|
demoMaxQueues = 10
|
|
)
|
|
|
|
// seedDemoData создаёт тенанта demo-service с очередями и сообщениями.
|
|
// Вызывается при SHARED_SQS_SEED_DEMO=true при старте сервера.
|
|
func seedDemoData(store *tenant.TenantStore) {
|
|
t, err := store.CreateFixed(demoTenantName, demoMaxQueues, demoTenantID, demoAccessKey, demoSecretKey)
|
|
if err != nil {
|
|
log.Warnf("seed: не удалось создать demo-tenant: %v", err)
|
|
return
|
|
}
|
|
log.Infof("seed: создан тенант %s (AccessKey=%s)", t.ID, t.AccessKey)
|
|
|
|
// Демо-очереди с набором сообщений
|
|
queues := []struct {
|
|
name string
|
|
msgs []string
|
|
}{
|
|
{
|
|
"orders",
|
|
[]string{
|
|
`{"order_id":"1001","amount":99.99,"status":"pending"}`,
|
|
`{"order_id":"1002","amount":14.50,"status":"completed"}`,
|
|
`{"order_id":"1003","amount":299.00,"status":"processing"}`,
|
|
},
|
|
},
|
|
{
|
|
"notifications",
|
|
[]string{
|
|
`{"to":"user@example.com","text":"Welcome to the service!"}`,
|
|
`{"to":"admin@example.com","text":"New user signed up"}`,
|
|
},
|
|
},
|
|
{
|
|
"emails",
|
|
[]string{
|
|
`{"subject":"Invoice #42","body":"See attachment","to":"billing@example.com"}`,
|
|
},
|
|
},
|
|
{
|
|
"uploads",
|
|
nil,
|
|
},
|
|
{
|
|
"user-events",
|
|
[]string{
|
|
`{"event":"login","user_id":"u-123","ts":1744000000}`,
|
|
`{"event":"logout","user_id":"u-123","ts":1744003600}`,
|
|
`{"event":"purchase","user_id":"u-456","item_id":"prod-7","ts":1744005000}`,
|
|
},
|
|
},
|
|
}
|
|
|
|
for _, q := range queues {
|
|
key := t.AccessKey + ":" + q.name
|
|
|
|
msgs := make([]models.SqsMessage, 0, len(q.msgs))
|
|
for _, body := range q.msgs {
|
|
//nolint:gosec — MD5 здесь для совместимости с AWS SQS протоколом
|
|
sum := md5.Sum([]byte(body)) //nolint:gosec
|
|
msgs = append(msgs, models.SqsMessage{
|
|
MessageBody: body,
|
|
Uuid: uuid.NewString(),
|
|
MD5OfMessageBody: fmt.Sprintf("%x", sum),
|
|
SentTime: time.Now(),
|
|
})
|
|
}
|
|
|
|
models.SyncQueues.Lock()
|
|
models.SyncQueues.Queues[key] = &models.Queue{
|
|
Name: q.name,
|
|
VisibilityTimeout: 30,
|
|
MaximumMessageSize: 262144,
|
|
MessageRetentionPeriod: 345600,
|
|
Messages: msgs,
|
|
Duplicates: make(map[string]time.Time),
|
|
}
|
|
models.SyncQueues.Unlock()
|
|
|
|
log.Infof("seed: очередь %s (%d сообщений)", q.name, len(q.msgs))
|
|
}
|
|
|
|
log.Infof("seed: демо-данные готовы — тенант %s, 5 очередей", t.Name)
|
|
}
|