-
Notifications
You must be signed in to change notification settings - Fork 20
/
topic.go
106 lines (92 loc) · 2.73 KB
/
topic.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
package slide
import (
"context"
"encoding/json"
"fmt"
"github.com/OpenSlides/openslides-autoupdate-service/internal/projector"
"github.com/OpenSlides/openslides-autoupdate-service/internal/projector/datastore"
)
type dbTopic struct {
ID int `json:"id"`
Title string `json:"title"`
Text string `json:"text"`
AgendaItemID int `json:"agenda_item_id"`
}
func topicFromMap(in map[string]json.RawMessage) (*dbTopic, error) {
bs, err := json.Marshal(in)
if err != nil {
return nil, fmt.Errorf("encoding topic data: %w", err)
}
var t dbTopic
if err := json.Unmarshal(bs, &t); err != nil {
return nil, fmt.Errorf("decoding topic data: %w", err)
}
return &t, nil
}
// Topic renders the topic slide.
func Topic(store *projector.SlideStore) {
store.RegisterSliderFunc("topic", func(ctx context.Context, fetch *datastore.Fetcher, p7on *projector.Projection) (encoded []byte, err error) {
data := fetch.Object(
ctx,
p7on.ContentObjectID,
"id",
"title",
"text",
"agenda_item_id",
)
topic, err := topicFromMap(data)
if err != nil {
return nil, fmt.Errorf("get topic: %w", err)
}
var itemNumber string
if topic.AgendaItemID > 0 {
itemNumber = datastore.String(ctx, fetch.FetchIfExist, "agenda_item/%d/item_number", topic.AgendaItemID)
}
if err := fetch.Err(); err != nil {
return nil, err
}
out := struct {
Title string `json:"title"`
Text string `json:"text"`
AgendaItemNumber string `json:"item_number"`
}{
Title: topic.Title,
Text: topic.Text,
AgendaItemNumber: itemNumber,
}
responseValue, err := json.Marshal(out)
if err != nil {
return nil, fmt.Errorf("encoding response slide topic: %w", err)
}
return responseValue, err
})
store.RegisterGetTitleInformationFunc("topic", func(ctx context.Context, fetch *datastore.Fetcher, fqid string, itemNumber string, meetingID int) (json.RawMessage, error) {
data := fetch.Object(ctx, fqid, "id", "title", "agenda_item_id")
topic, err := topicFromMap(data)
if err != nil {
return nil, fmt.Errorf("get topic from map: %w", err)
}
if itemNumber == "" && topic.AgendaItemID > 0 {
itemNumber = datastore.String(ctx, fetch.FetchIfExist, "agenda_item/%d/item_number", topic.AgendaItemID)
}
if err := fetch.Err(); err != nil {
return nil, err
}
title := struct {
Collection string `json:"collection"`
ContentObjectID string `json:"content_object_id"`
Title string `json:"title"`
AgendaItemNumber string `json:"agenda_item_number"`
}{
"topic",
fqid,
topic.Title,
itemNumber,
}
bs, err := json.Marshal(title)
if err != nil {
return nil, fmt.Errorf("encoding title: %w", err)
}
return bs, err
})
}