Add support for storing filters in dashboard entries

dashboard/convert/dashboardtag.go

@@ -0,0 +1,39 @@
+package convert
+
+import (
+	"github.com/traggo/server/generated/gqlmodel"
+	"github.com/traggo/server/model"
+)
+
+func tagFiltersToExternal(tags []model.DashboardTagFilter, include bool) []*gqlmodel.TimeSpanTag {
+	if len(tags) == 0 {
+		return nil
+	}
+
+	result := []*gqlmodel.TimeSpanTag{}
+	for _, tag := range tags {
+		if tag.Include == include {
+			result = append(result, &gqlmodel.TimeSpanTag{
+				Key:   tag.Key,
+				Value: tag.StringValue,
+			})
+		}
+	}
+	return result
+}
+
+func TagFiltersToInternal(gqls []*gqlmodel.InputTimeSpanTag, include bool) []model.DashboardTagFilter {
+	result := make([]model.DashboardTagFilter, 0)
+	for _, tag := range gqls {
+		result = append(result, tagFilterToInternal(*tag, include))
+	}
+	return result
+}
+
+func tagFilterToInternal(gqls gqlmodel.InputTimeSpanTag, include bool) model.DashboardTagFilter {
+	return model.DashboardTagFilter{
+		Key:         gqls.Key,
+		StringValue: gqls.Value,
+		Include:     include,
+	}
+}

dashboard/convert/entry.go

@@ -38,9 +38,11 @@ func ToExternalEntry(entry model.DashboardEntry) (*gqlmodel.DashboardEntry, erro
 		To:   entry.RangeTo,
 	}
 	stats := &gqlmodel.StatsSelection{
-		Interval: ExternalInterval(entry.Interval),
-		Tags:     strings.Split(entry.Keys, ","),
-		Range:    dateRange,
+		Interval:    ExternalInterval(entry.Interval),
+		Tags:        strings.Split(entry.Keys, ","),
+		Range:       dateRange,
+		ExcludeTags: tagFiltersToExternal(entry.TagFilters, false),
+		IncludeTags: tagFiltersToExternal(entry.TagFilters, true),
 	}
 	if entry.RangeID != model.NoRangeIDDefined {
 		stats.RangeID = &entry.RangeID

dashboard/entry/add.go

@@ -24,6 +24,13 @@ func (r *ResolverForEntry) AddDashboardEntry(ctx context.Context, dashboardID in
 		return nil, err
 	}
 
+	tagFilters := convert.TagFiltersToInternal(stats.ExcludeTags, false)
+	tagFilters = append(tagFilters, convert.TagFiltersToInternal(stats.IncludeTags, true)...)
+
+	if err := tagsDuplicates(tagFilters); err != nil {
+		return nil, err
+	}
+
 	entry := model.DashboardEntry{
 		Keys:            strings.Join(stats.Tags, ","),
 		Type:            convert.InternalEntryType(entryType),
@@ -34,6 +41,7 @@ func (r *ResolverForEntry) AddDashboardEntry(ctx context.Context, dashboardID in
 		MobilePosition:  convert.EmptyPos(),
 		DesktopPosition: convert.EmptyPos(),
 		RangeID:         -1,
+		TagFilters:      tagFilters,
 	}
 
 	if len(stats.Tags) == 0 {

dashboard/entry/tagcheck.go

@@ -0,0 +1,33 @@
+package entry
+
+import (
+	"fmt"
+
+	"github.com/traggo/server/model"
+)
+
+func tagsDuplicates(tags []model.DashboardTagFilter) error {
+	existingTags := make(map[model.DashboardTagFilter]struct{})
+
+	for _, tag := range tags {
+		if _, ok := existingTags[tag]; ok {
+			tagType := "exclude"
+			if tag.Include {
+				tagType = "include"
+			}
+
+			return fmt.Errorf("%s tags: tag '%s' is present multiple times", tagType, tag.Key+":"+tag.StringValue)
+		} else {
+			copyTag := tag
+			copyTag.Include = !copyTag.Include
+
+			if _, ok := existingTags[copyTag]; ok {
+				return fmt.Errorf("tag '%s' is present in both exclude tags and include tags", tag.Key+":"+tag.StringValue)
+			}
+		}
+
+		existingTags[tag] = struct{}{}
+	}
+
+	return nil
+}

dashboard/entry/update.go

@@ -36,9 +36,22 @@ func (r *ResolverForEntry) UpdateDashboardEntry(ctx context.Context, id int, ent
 		entry.Total = *total
 	}
 
+	tx := r.DB.Begin()
+	if err := tx.Error; err != nil {
+		return nil, err
+	}
+	defer func() {
+		if r := recover(); r != nil {
+			tx.Rollback()
+			panic(r)
+		} else if tx != nil {
+			tx.Rollback()
+		}
+	}()
+
 	if stats != nil {
 		if stats.RangeID != nil {
-			if _, err := util.FindDashboardRange(r.DB, *stats.RangeID); err != nil {
+			if _, err := util.FindDashboardRange(tx, *stats.RangeID); err != nil {
 				return nil, err
 			}
 			entry.RangeID = *stats.RangeID
@@ -53,6 +66,19 @@ func (r *ResolverForEntry) UpdateDashboardEntry(ctx context.Context, id int, ent
 			entry.RangeFrom = stats.Range.From
 			entry.RangeTo = stats.Range.To
 		}
+
+		tagFilters := convert.TagFiltersToInternal(stats.ExcludeTags, false)
+		tagFilters = append(tagFilters, convert.TagFiltersToInternal(stats.IncludeTags, true)...)
+
+		if err := tagsDuplicates(tagFilters); err != nil {
+			return nil, err
+		}
+
+		if err := tx.Where("dashboard_entry_id = ?", id).Delete(new(model.DashboardTagFilter)).Error; err != nil {
+			return nil, fmt.Errorf("failed to update tag filters: %s", err)
+		}
+
+		entry.TagFilters = tagFilters
 		entry.Keys = strings.Join(stats.Tags, ",")
 		entry.Interval = convert.InternalInterval(stats.Interval)
 	}
@@ -65,7 +91,14 @@ func (r *ResolverForEntry) UpdateDashboardEntry(ctx context.Context, id int, ent
 		return &gqlmodel.DashboardEntry{}, err
 	}
 
-	r.DB.Save(entry)
+	if err := tx.Save(entry).Error; err != nil {
+		return nil, err
+	}
+
+	if err := tx.Commit().Error; err != nil {
+		return nil, err
+	}
 
+	tx = nil
 	return convert.ToExternalEntry(entry)
 }

dashboard/get.go

@@ -15,7 +15,13 @@ func (r *ResolverForDashboard) Dashboards(ctx context.Context) ([]*gqlmodel.Dash
 	userID := auth.GetUser(ctx).ID
 
 	dashboards := []model.Dashboard{}
-	find := r.DB.Preload("Entries").Preload("Ranges").Where(&model.Dashboard{UserID: userID}).Find(&dashboards)
+
+	q := r.DB
+	q = q.Preload("Entries")
+	q = q.Preload("Entries.TagFilters")
+	q = q.Preload("Ranges")
+
+	find := q.Where(&model.Dashboard{UserID: userID}).Find(&dashboards)
 
 	if find.Error != nil {
 		return nil, find.Error

model/all.go

@@ -11,6 +11,7 @@ func All() []interface{} {
 		new(UserSetting),
 		new(Dashboard),
 		new(DashboardEntry),
+		new(DashboardTagFilter),
 		new(DashboardRange),
 	}
 }

model/dashboard.go

@@ -36,11 +36,20 @@ type DashboardEntry struct {
 	RangeID     int
 	RangeFrom   string
 	RangeTo     string
+	TagFilters  []DashboardTagFilter
 
 	MobilePosition  string
 	DesktopPosition string
 }
 
+// DashboardTagFilter a tag for filtering timespans
+type DashboardTagFilter struct {
+	DashboardEntryID int `gorm:"type:int REFERENCES dashboard_entries(id) ON DELETE CASCADE"`
+	Key              string
+	StringValue      string
+	Include          bool
+}
+
 // DashboardType the dashboard type
 type DashboardType string
 

ui/src/dashboard/Entry/AddPopup.tsx

@@ -10,6 +10,8 @@ import * as gqlDashboard from '../../gql/dashboard';
 import {Fade} from '../../common/Fade';
 import {DashboardEntryForm, isValidDashboardEntry} from './DashboardEntryForm';
 import {AddDashboardEntry, AddDashboardEntryVariables} from '../../gql/__generated__/AddDashboardEntry';
+import {handleError} from '../../utils/errors';
+import {useSnackbar} from 'notistack';
 
 interface EditPopupProps {
     dashboardId: number;
@@ -38,6 +40,9 @@ export const AddPopup: React.FC<EditPopupProps> = ({
         refetchQueries: [{query: gqlDashboard.Dashboards}],
     });
     const valid = isValidDashboardEntry(entry);
+
+    const {enqueueSnackbar} = useSnackbar();
+
     return (
         <Popper
             key="popup"
@@ -89,6 +94,8 @@ export const AddPopup: React.FC<EditPopupProps> = ({
                                                       }
                                                     : null,
                                                 rangeId: entry.statsSelection.rangeId,
+                                                excludeTags: entry.statsSelection.excludeTags,
+                                                includeTags: entry.statsSelection.includeTags,
                                             },
                                             pos: {
                                                 desktop: {
@@ -99,7 +106,9 @@ export const AddPopup: React.FC<EditPopupProps> = ({
                                                 },
                                             },
                                         },
-                                    }).then(finish);
+                                    })
+                                        .then(finish)
+                                        .catch(handleError('Add Dashboard Entry', enqueueSnackbar));
                                 }}>
                                 Add
                             </Button>

ui/src/dashboard/Entry/DashboardEntry.tsx

@@ -52,6 +52,8 @@ const SpecificDashboardEntry: React.FC<{entry: Dashboards_dashboards_items; rang
                 range,
                 interval,
                 tags: entry.statsSelection.tags,
+                excludeTags: entry.statsSelection.excludeTags,
+                includeTags: entry.statsSelection.includeTags,
             },
         },
     });

ui/src/dashboard/Entry/DashboardEntryForm.tsx

@@ -38,9 +38,13 @@ export const DashboardEntryForm: React.FC<EditPopupProps> = ({entry, onChange: s
     const tagsResult = useQuery<Tags>(gqlTags.Tags);
 
     let tagKeys;
+    let excludeTags;
+    let includeTags;
     if (!tagsResult.error && !tagsResult.loading && tagsResult.data && tagsResult.data.tags) {
         const keyInputTags = (entry.statsSelection.tags || []).map((key) => ({key, value: ''}));
         tagKeys = toTagSelectorEntry(tagsResult.data.tags, keyInputTags);
+        excludeTags = toTagSelectorEntry(tagsResult.data.tags, entry.statsSelection.excludeTags || []);
+        includeTags = toTagSelectorEntry(tagsResult.data.tags, entry.statsSelection.includeTags || []);
     }
 
     const range: Dashboards_dashboards_items_statsSelection_range = entry.statsSelection.range
@@ -204,6 +208,35 @@ export const DashboardEntryForm: React.FC<EditPopupProps> = ({entry, onChange: s
                 onlySelectKeys
                 removeWhenClicked
             />
+
+            <FormTagSelector
+                label="Exclude"
+                selectedEntries={excludeTags || []}
+                onSelectedEntriesChanged={(tags) => {
+                    entry.statsSelection.excludeTags = tags.map((tag) => ({
+                        key: tag.tag.key,
+                        value: tag.value,
+                        __typename: 'TimeSpanTag',
+                    }));
+                    setEntry(entry);
+                }}
+                allowDuplicateKeys
+                createTags={false}
+            />
+            <FormTagSelector
+                label="Include"
+                selectedEntries={includeTags || []}
+                onSelectedEntriesChanged={(tags) => {
+                    entry.statsSelection.includeTags = tags.map((tag) => ({
+                        key: tag.tag.key,
+                        value: tag.value,
+                        __typename: 'TimeSpanTag',
+                    }));
+                    setEntry(entry);
+                }}
+                allowDuplicateKeys
+                createTags={false}
+            />
         </>
     );
 };

ui/src/dashboard/Entry/EditPopup.tsx

@@ -10,6 +10,8 @@ import * as gqlDashboard from '../../gql/dashboard';
 import {UpdateDashboardEntry, UpdateDashboardEntryVariables} from '../../gql/__generated__/UpdateDashboardEntry';
 import {Fade} from '../../common/Fade';
 import {DashboardEntryForm, isValidDashboardEntry} from './DashboardEntryForm';
+import {handleError} from '../../utils/errors';
+import {useSnackbar} from 'notistack';
 
 interface EditPopupProps {
     entry: Dashboards_dashboards_items;
@@ -24,6 +26,9 @@ export const EditPopup: React.FC<EditPopupProps> = ({entry, anchorEl, onChange:
         refetchQueries: [{query: gqlDashboard.Dashboards}],
     });
     const valid = isValidDashboardEntry(entry);
+
+    const {enqueueSnackbar} = useSnackbar();
+
     return (
         <Popper
             key="popup"
@@ -75,9 +80,13 @@ export const EditPopup: React.FC<EditPopupProps> = ({entry, anchorEl, onChange:
                                                       }
                                                     : null,
                                                 rangeId: entry.statsSelection.rangeId,
+                                                excludeTags: entry.statsSelection.excludeTags,
+                                                includeTags: entry.statsSelection.includeTags,
                                             },
                                         },
-                                    }).then(() => setEdit(null));
+                                    })
+                                        .then(() => setEdit(null))
+                                        .catch(handleError('Edit Dashboard Entry', enqueueSnackbar));
                                 }}>
                                 Save
                             </Button>