Add API to fetch charting datapoints for a chart inside a dashbaord

dashboard.go

@@ -47,6 +47,15 @@ type DashboardChart struct {
 	bun.BaseModel `json:"-"`
 }
 
+type DashboardChartPosition struct {
+	ID          uuid.UUID `bun:"type:uuid,default:uuid_generate_v4(),pk" json:"id,omitempty"`
+	DashboardID uuid.UUID `json:"dashboard_id,omitempty"`
+	ChartID     uuid.UUID `json:"chart_id,omitempty"`
+	OrderIndex  int64     `json:"order_index,omitempty"`
+
+	bun.BaseModel `json:"-"`
+}
+
 type ListDashboardOptions struct {
 	Paginator   Paginator
 	WorkspaceID uuid.UUID
@@ -68,4 +77,7 @@ type DashboardRepository interface {
 	AddChart(context.Context, *DashboardChart) error
 	List(context.Context, ListDashboardOptions) ([]Dashboard, int64, error)
 	GetCharts(context.Context, FetchDashboardChartsOption) ([]DashboardChart, error)
+
+	UpdateDashboardPositions(context.Context, uuid.UUID, []DashboardChartPosition) error
+	GetDashboardPositions(context.Context, uuid.UUID) ([]DashboardChartPosition, error)
 }

integration.go

@@ -130,9 +130,10 @@ type IntegrationDataValues struct {
 	// InternalName + ProviderID search in db
 	// We cannot use only InternalName becasue some integrations
 	// like mercury have the same InternalName twice ( each account has a savings and checkings which we track)
-	InternalName IntegrationChartInternalNameType
-	ProviderID   string
-	Data         IntegrationDataPoint
+	InternalName   IntegrationChartInternalNameType
+	UserFacingName string
+	ProviderID     string
+	Data           IntegrationDataPoint
 }
 
 type IntegrationChartValues struct {
@@ -188,4 +189,5 @@ type IntegrationRepository interface {
 	AddDataPoint(context.Context, *WorkspaceIntegration, []IntegrationDataValues) error
 	ListCharts(context.Context, uuid.UUID) ([]IntegrationChart, error)
 	GetChart(context.Context, FetchChartOptions) (IntegrationChart, error)
+	GetDataPoints(context.Context, IntegrationChart) ([]IntegrationDataPoint, error)
 }

internal/datastore/postgres/dashboard.go

@@ -7,6 +7,7 @@
 	"time"
 
 	"github.com/ayinke-llc/malak"
+	"github.com/google/uuid"
 	"github.com/uptrace/bun"
 )
 
@@ -26,6 +27,10 @@
 	ctx, cancelFn := withContext(ctx)
 	defer cancelFn()
 
+	if dashboard.Title == "" {
+		return errors.New("dashboard title is required")
+	}
+
 	return d.inner.RunInTx(ctx, &sql.TxOptions{},
 		func(ctx context.Context, tx bun.Tx) error {
 
@@ -128,3 +133,58 @@
 
 	return charts, err
 }
+
+func (d *dashboardRepo) GetDashboardPositions(ctx context.Context,
+	dashboardID uuid.UUID) ([]malak.DashboardChartPosition, error) {
+
+	ctx, cancelFn := withContext(ctx)
+	defer cancelFn()
+
+	positions := make([]malak.DashboardChartPosition, 0)
+
+	err := d.inner.NewSelect().
+		Model(&positions).
+		Where("dashboard_id = ?", dashboardID).
+		Scan(ctx)
+
+	return positions, err
+}
+
+func (d *dashboardRepo) UpdateDashboardPositions(ctx context.Context,
+	dashboardID uuid.UUID,
+	positions []malak.DashboardChartPosition) error {
+
+	ctx, cancelFn := withContext(ctx)
+	defer cancelFn()
+
+	return d.inner.RunInTx(ctx, &sql.TxOptions{},
+		func(ctx context.Context, tx bun.Tx) error {
+			// First check if dashboard exists
+			exists, err := tx.NewSelect().
+				Model((*malak.Dashboard)(nil)).
+				Where("id = ?", dashboardID).
+				Exists(ctx)
+			if err != nil {
+				return err
+			}
+			if !exists {
+				return malak.ErrDashboardNotFound
+			}
+
+			_, err = tx.NewDelete().
+				Model(new(malak.DashboardChartPosition)).
+				Where("dashboard_id = ?", dashboardID).
+				Exec(ctx)
+			if err != nil {
+				return err
+			}
+
+			if len(positions) > 0 {
+				_, err = tx.NewInsert().Model(&positions).
+					Exec(ctx)
+				return err
+			}
+
+			return nil
+		})
+}