mirror of
https://gitlab.dit.htwk-leipzig.de/htwk-software/htwkalender.git
synced 2026-01-18 04:22:27 +01:00
feat:#7 extracted ical-service in own microservice
This commit is contained in:
70
backend-ical/service/connector/feedConnector.go
Normal file
70
backend-ical/service/connector/feedConnector.go
Normal file
@@ -0,0 +1,70 @@
|
||||
package connector
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"htwkalender-ical/model"
|
||||
"log/slog"
|
||||
)
|
||||
|
||||
func GetFeedByToken(token string) (model.FeedRecord, error) {
|
||||
var feed model.FeedRecord
|
||||
|
||||
// /api/collections/feeds/records/{id}
|
||||
|
||||
response, err := RequestApi("/api/collections/feeds/records/" + token)
|
||||
if err != nil {
|
||||
return model.FeedRecord{}, err
|
||||
}
|
||||
|
||||
// parse the response body json to FeedRecord struct
|
||||
feed, err = parseResponse(response.Body())
|
||||
if err != nil {
|
||||
slog.Error("Failed to read response body", "error", err)
|
||||
return model.FeedRecord{}, err
|
||||
}
|
||||
|
||||
return feed, nil
|
||||
|
||||
}
|
||||
|
||||
func parseResponse(response []byte) (model.FeedRecord, error) {
|
||||
var feedRecord model.FeedRecord
|
||||
|
||||
err := json.Unmarshal(response, &feedRecord)
|
||||
if err != nil {
|
||||
return model.FeedRecord{}, err
|
||||
}
|
||||
|
||||
return feedRecord, nil
|
||||
}
|
||||
|
||||
func GetModuleWithEvents(module model.FeedModule) (model.Module, error) {
|
||||
var modules model.Module
|
||||
|
||||
// /api/module?uuid=
|
||||
|
||||
response, err := RequestApi("/api/module?uuid=" + module.UUID)
|
||||
if err != nil {
|
||||
return model.Module{}, err
|
||||
}
|
||||
|
||||
// parse the response body json to Events struct
|
||||
modules, err = parseModuleResponse(response.Body())
|
||||
if err != nil {
|
||||
slog.Error("Failed to read response body", "error", err)
|
||||
return model.Module{}, err
|
||||
}
|
||||
|
||||
return modules, nil
|
||||
}
|
||||
|
||||
func parseModuleResponse(body []byte) (model.Module, error) {
|
||||
var module model.Module
|
||||
|
||||
err := json.Unmarshal(body, &module)
|
||||
if err != nil {
|
||||
return model.Module{}, err
|
||||
}
|
||||
|
||||
return module, nil
|
||||
}
|
||||
22
backend-ical/service/connector/restHandler.go
Normal file
22
backend-ical/service/connector/restHandler.go
Normal file
@@ -0,0 +1,22 @@
|
||||
package connector
|
||||
|
||||
import (
|
||||
"github.com/gofiber/fiber/v3/client"
|
||||
"time"
|
||||
)
|
||||
|
||||
func RequestApi(path string) (*client.Response, error) {
|
||||
|
||||
var host = "http://localhost"
|
||||
|
||||
cc := client.New()
|
||||
cc.SetTimeout(5 * time.Second)
|
||||
|
||||
// set retry to 0
|
||||
response, err := cc.Get(host + path)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return response, nil
|
||||
}
|
||||
Reference in New Issue
Block a user