mirror of
https://gitlab.dit.htwk-leipzig.de/htwk-software/htwkalender-pwa.git
synced 2025-07-16 09:38:51 +02:00
feat:#53 added merge events for ical feed
This commit is contained in:
@ -20,9 +20,12 @@ import (
|
||||
"database/sql"
|
||||
"github.com/pocketbase/dbx"
|
||||
"github.com/pocketbase/pocketbase/daos"
|
||||
"htwkalender/model"
|
||||
database "htwkalender/service/db"
|
||||
"htwkalender/service/functions"
|
||||
localTime "htwkalender/service/functions/time"
|
||||
"log/slog"
|
||||
"strings"
|
||||
)
|
||||
|
||||
func ClearFeeds(db *daos.Dao, months int, clock localTime.Clock) {
|
||||
@ -50,3 +53,89 @@ func ClearFeeds(db *daos.Dao, months int, clock localTime.Clock) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func CombineEventsInFeed(events model.Events) model.Events {
|
||||
// Combine events with the same Prof, Name, Start and End time into one event
|
||||
// if the note is empty then there is no room displayed in the new note
|
||||
// room listing isn't displayed if there is only one event.
|
||||
|
||||
combinedEvents := make(model.Events, 0)
|
||||
combinedEvents = append(combinedEvents, events[0])
|
||||
|
||||
for index1 := 1; index1 < len(events); index1++ {
|
||||
for index2 := 0; index2 < len(combinedEvents); index2++ {
|
||||
|
||||
if events[index1].Name == combinedEvents[index2].Name &&
|
||||
events[index1].Start == combinedEvents[index2].Start &&
|
||||
events[index1].End == combinedEvents[index2].End &&
|
||||
events[index1].Course == combinedEvents[index2].Course {
|
||||
|
||||
// if no notes are present skip
|
||||
if !functions.OnlyWhitespace(events[index1].Notes) {
|
||||
// if combinedEvents notes are empty, add the new notes
|
||||
if functions.OnlyWhitespace(combinedEvents[index2].Notes) {
|
||||
combinedEvents[index2].Notes = descriptionString(events[index1])
|
||||
} else {
|
||||
addNotesIfAlreadyRoomsAdded(events, combinedEvents, index2, index1)
|
||||
}
|
||||
}
|
||||
|
||||
combineRooms(events, index1, combinedEvents, index2)
|
||||
combineProfs(events, index1, combinedEvents, index2)
|
||||
|
||||
// remove the event from the events list
|
||||
events = append(events[:index1], events[index1+1:]...)
|
||||
|
||||
break
|
||||
|
||||
} else {
|
||||
// if the event is not in the combinedEvents list, add it
|
||||
if index2 == len(combinedEvents)-1 {
|
||||
combinedEvents = append(combinedEvents, events[index1])
|
||||
events = append(events[:index1], events[index1+1:]...)
|
||||
break
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return combinedEvents
|
||||
}
|
||||
|
||||
func addNotesIfAlreadyRoomsAdded(events model.Events, combinedEvents model.Events, index2 int, index1 int) {
|
||||
// check if combinedEvents[index2].Rooms string contains comma "," ,
|
||||
if !strings.Contains(combinedEvents[index2].Rooms, ",") {
|
||||
combinedEvents[index2].Notes = descriptionString(combinedEvents[index2]) + "\n" + descriptionString(events[index1])
|
||||
} else {
|
||||
combinedEvents[index2].Notes += "\n" + descriptionString(events[index1])
|
||||
}
|
||||
}
|
||||
|
||||
func combineProfs(events model.Events, index1 int, combinedEvents model.Events, index2 int) {
|
||||
// combine the profs
|
||||
if events[index1].Prof != "" {
|
||||
if combinedEvents[index2].Prof == "" {
|
||||
combinedEvents[index2].Prof = events[index1].Prof
|
||||
} else {
|
||||
if !strings.Contains(combinedEvents[index2].Prof, events[index1].Prof) {
|
||||
combinedEvents[index2].Prof += ", " + events[index1].Prof
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func descriptionString(event model.Event) string {
|
||||
return event.Rooms + " - " + event.Notes + " (" + event.Prof + ")"
|
||||
}
|
||||
|
||||
func combineRooms(events model.Events, index1 int, combinedEvents model.Events, index2 int) {
|
||||
// combine the rooms
|
||||
if events[index1].Rooms != "" {
|
||||
if combinedEvents[index2].Rooms == "" {
|
||||
combinedEvents[index2].Rooms = events[index1].Rooms
|
||||
} else {
|
||||
if !strings.Contains(combinedEvents[index2].Rooms, events[index1].Rooms) {
|
||||
combinedEvents[index2].Rooms += ", " + events[index1].Rooms
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@ -21,6 +21,7 @@ import (
|
||||
"github.com/pocketbase/pocketbase/tests"
|
||||
"htwkalender/model"
|
||||
mockTime "htwkalender/service/functions/time"
|
||||
"reflect"
|
||||
"testing"
|
||||
"time"
|
||||
)
|
||||
@ -97,3 +98,55 @@ func TestClearFeeds(t *testing.T) {
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
func TestCombineEventsInFeed(t *testing.T) {
|
||||
type args struct {
|
||||
events model.Events
|
||||
}
|
||||
testCases := []struct {
|
||||
name string
|
||||
args args
|
||||
want model.Events
|
||||
}{
|
||||
{
|
||||
name: "TestCombineEventsInFeed",
|
||||
args: args{
|
||||
events: model.Events{
|
||||
{
|
||||
Name: "Test",
|
||||
Start: mockTime.ParseAsTypesDatetime(time.Date(2023, 12, 1, 0, 0, 0, 0, time.UTC)),
|
||||
End: mockTime.ParseAsTypesDatetime(time.Date(2023, 12, 1, 4, 0, 0, 0, time.UTC)),
|
||||
Prof: "Test",
|
||||
Rooms: "Test",
|
||||
Notes: "Test",
|
||||
},
|
||||
{
|
||||
Name: "Test",
|
||||
Start: mockTime.ParseAsTypesDatetime(time.Date(2023, 12, 1, 0, 0, 0, 0, time.UTC)),
|
||||
End: mockTime.ParseAsTypesDatetime(time.Date(2023, 12, 1, 4, 0, 0, 0, time.UTC)),
|
||||
Prof: "Test",
|
||||
Rooms: "Test",
|
||||
Notes: "Test",
|
||||
},
|
||||
},
|
||||
},
|
||||
want: model.Events{
|
||||
{
|
||||
Name: "Test",
|
||||
Start: mockTime.ParseAsTypesDatetime(time.Date(2023, 12, 1, 0, 0, 0, 0, time.UTC)),
|
||||
End: mockTime.ParseAsTypesDatetime(time.Date(2023, 12, 1, 4, 0, 0, 0, time.UTC)),
|
||||
Prof: "Test",
|
||||
Rooms: "Test",
|
||||
Notes: "Test: Test\nTest: Test",
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
for _, tt := range testCases {
|
||||
t.Run(tt.name, func(t *testing.T) {
|
||||
if got := CombineEventsInFeed(tt.args.events); !reflect.DeepEqual(got, tt.want) {
|
||||
t.Errorf("CombineEventsInFeed() = %v, want %v", got, tt.want)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
@ -33,22 +33,22 @@ const expirationTime = 5 * time.Minute
|
||||
func Feed(app *pocketbase.PocketBase, token string) (string, error) {
|
||||
var result string
|
||||
|
||||
feed, err := db.FindFeedByToken(token, app)
|
||||
if feed == nil && err != nil {
|
||||
icalFeed, err := db.FindFeedByToken(token, app)
|
||||
if icalFeed == nil && err != nil {
|
||||
return "", err
|
||||
}
|
||||
|
||||
modules := make(map[string]model.FeedCollection)
|
||||
var modulesArray []model.FeedCollection
|
||||
_ = json.Unmarshal([]byte(feed.Modules), &modulesArray)
|
||||
_ = json.Unmarshal([]byte(icalFeed.Modules), &modulesArray)
|
||||
|
||||
for _, module := range modulesArray {
|
||||
modules[module.UUID] = module
|
||||
}
|
||||
|
||||
newFeed, err := createFeedForToken(app, modules)
|
||||
if err != nil {
|
||||
return "", err
|
||||
newFeed, createFeedErr := createFeedForToken(app, modules)
|
||||
if createFeedErr != nil {
|
||||
return "", createFeedErr
|
||||
}
|
||||
result = newFeed.Content
|
||||
|
||||
@ -56,16 +56,18 @@ func Feed(app *pocketbase.PocketBase, token string) (string, error) {
|
||||
}
|
||||
|
||||
func createFeedForToken(app *pocketbase.PocketBase, modules map[string]model.FeedCollection) (*model.FeedModel, error) {
|
||||
res, err := db.GetPlanForModules(app, modules)
|
||||
|
||||
events, err := db.GetPlanForModules(app, modules)
|
||||
if err != nil {
|
||||
return nil, apis.NewNotFoundError("Could not fetch events", err)
|
||||
}
|
||||
|
||||
// Combine Events
|
||||
//events = feed.CombineEventsInFeed(events)
|
||||
|
||||
b := bytes.Buffer{}
|
||||
goics.NewICalEncode(&b).Encode(IcalModel{Events: res, Mapping: modules})
|
||||
feed := &model.FeedModel{Content: b.String(), ExpiresAt: time.Now().Add(expirationTime)}
|
||||
return feed, nil
|
||||
goics.NewICalEncode(&b).Encode(IcalModel{Events: events, Mapping: modules})
|
||||
icalFeed := &model.FeedModel{Content: b.String(), ExpiresAt: time.Now().Add(expirationTime)}
|
||||
return icalFeed, nil
|
||||
}
|
||||
|
||||
func CreateIndividualFeed(requestBody []byte, app *pocketbase.PocketBase) (string, error) {
|
||||
@ -76,16 +78,16 @@ func CreateIndividualFeed(requestBody []byte, app *pocketbase.PocketBase) (strin
|
||||
return "", apis.NewNotFoundError("Could not parse request body", err)
|
||||
}
|
||||
|
||||
var feed model.Feed
|
||||
var icalFeed model.Feed
|
||||
jsonModules, _ := json.Marshal(modules)
|
||||
feed.Modules = string(jsonModules)
|
||||
icalFeed.Modules = string(jsonModules)
|
||||
|
||||
collection, dbError := db.FindCollection(app, "feeds")
|
||||
if dbError != nil {
|
||||
return "", apis.NewNotFoundError("Collection could not be found", dbError)
|
||||
}
|
||||
|
||||
record, err := db.SaveFeed(feed, collection, app)
|
||||
record, err := db.SaveFeed(icalFeed, collection, app)
|
||||
if err != nil {
|
||||
return "", apis.NewNotFoundError("Could not save feed", err)
|
||||
}
|
||||
|
@ -156,18 +156,18 @@ func addPropertyIfNotEmpty(component *goics.Component, key string, value string)
|
||||
func generateDescription(event model.Event) string {
|
||||
var description string
|
||||
|
||||
if !functions.OnlyWhitespace(event.Notes) {
|
||||
description += "Notizen: " + event.Notes + "\n"
|
||||
}
|
||||
if !functions.OnlyWhitespace(event.Prof) {
|
||||
description += "Prof: " + event.Prof + "\n"
|
||||
description += "Profs: " + event.Prof + "\n"
|
||||
}
|
||||
if !functions.OnlyWhitespace(event.Course) {
|
||||
description += "Gruppe: " + event.Course + "\n"
|
||||
description += "Gruppen: " + event.Course + "\n"
|
||||
}
|
||||
if !functions.OnlyWhitespace(event.EventType) {
|
||||
description += "Typ: " + event.EventType + event.Compulsory + "\n"
|
||||
}
|
||||
if !functions.OnlyWhitespace(event.Notes) {
|
||||
description += "Notizen: " + event.Notes + "\n"
|
||||
}
|
||||
|
||||
return description
|
||||
}
|
||||
|
Reference in New Issue
Block a user