app.go 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. package dbstore
  2. import (
  3. "fmt"
  4. "git.linuxforward.com/byop/byop-engine/dbmanager"
  5. "git.linuxforward.com/byop/byop-engine/models"
  6. "github.com/google/uuid"
  7. "gorm.io/gorm"
  8. )
  9. // AppStore handles database operations for apps
  10. type AppStore struct {
  11. db *gorm.DB
  12. }
  13. // NewAppStore creates a new AppStore
  14. func NewAppStore(dbManager dbmanager.DbManager) *AppStore {
  15. return &AppStore{
  16. db: dbManager.GetDB(),
  17. }
  18. }
  19. // Create creates a new app
  20. func (as *AppStore) Create(app *models.App) error {
  21. // Generate ID if not provided
  22. if app.ID == "" {
  23. app.ID = uuid.New().String()
  24. }
  25. // GORM will handle created_at and updated_at automatically
  26. return as.db.Create(app).Error
  27. }
  28. // GetByID retrieves an app by ID
  29. func (as *AppStore) GetByID(id string) (*models.App, error) {
  30. var app models.App
  31. result := as.db.First(&app, "id = ?", id)
  32. if result.Error != nil {
  33. if result.Error == gorm.ErrRecordNotFound {
  34. return nil, nil // No app found
  35. }
  36. return nil, fmt.Errorf("failed to get app: %w", result.Error)
  37. }
  38. return &app, nil
  39. }
  40. // Update updates an existing app
  41. func (as *AppStore) Update(app *models.App) error {
  42. return as.db.Save(app).Error
  43. }
  44. // Delete deletes an app by ID
  45. func (as *AppStore) Delete(id string) error {
  46. return as.db.Delete(&models.App{}, "id = ?", id).Error
  47. }
  48. // List retrieves all apps with optional filtering
  49. func (as *AppStore) List(filter map[string]interface{}) ([]*models.App, error) {
  50. var apps []*models.App
  51. // Build query from filters
  52. query := as.db
  53. if filter != nil {
  54. for key, value := range filter {
  55. query = query.Where(key+" = ?", value)
  56. }
  57. }
  58. // Execute query
  59. if err := query.Find(&apps).Error; err != nil {
  60. return nil, fmt.Errorf("failed to list apps: %w", err)
  61. }
  62. return apps, nil
  63. }
  64. // GetAppWithDeployments retrieves an app by ID with associated deployments
  65. func (as *AppStore) GetAppWithDeployments(id string) (*models.App, error) {
  66. var app models.App
  67. result := as.db.Preload("Deployments").First(&app, "id = ?", id)
  68. if result.Error != nil {
  69. if result.Error == gorm.ErrRecordNotFound {
  70. return nil, nil // No app found
  71. }
  72. return nil, fmt.Errorf("failed to get app: %w", result.Error)
  73. }
  74. return &app, nil
  75. }