summaryrefslogtreecommitdiffstats
path: root/services/f3/driver/topic.go
diff options
context:
space:
mode:
Diffstat (limited to 'services/f3/driver/topic.go')
-rw-r--r--services/f3/driver/topic.go111
1 files changed, 111 insertions, 0 deletions
diff --git a/services/f3/driver/topic.go b/services/f3/driver/topic.go
new file mode 100644
index 0000000..16b2eb3
--- /dev/null
+++ b/services/f3/driver/topic.go
@@ -0,0 +1,111 @@
+// Copyright Earl Warren <contact@earl-warren.org>
+// Copyright Loïc Dachary <loic@dachary.org>
+// SPDX-License-Identifier: MIT
+
+package driver
+
+import (
+ "context"
+ "fmt"
+
+ "code.gitea.io/gitea/models/db"
+ repo_model "code.gitea.io/gitea/models/repo"
+
+ "code.forgejo.org/f3/gof3/v3/f3"
+ f3_tree "code.forgejo.org/f3/gof3/v3/tree/f3"
+ "code.forgejo.org/f3/gof3/v3/tree/generic"
+ f3_util "code.forgejo.org/f3/gof3/v3/util"
+)
+
+var _ f3_tree.ForgeDriverInterface = &topic{}
+
+type topic struct {
+ common
+
+ forgejoTopic *repo_model.Topic
+}
+
+func (o *topic) SetNative(topic any) {
+ o.forgejoTopic = topic.(*repo_model.Topic)
+}
+
+func (o *topic) GetNativeID() string {
+ return fmt.Sprintf("%d", o.forgejoTopic.ID)
+}
+
+func (o *topic) NewFormat() f3.Interface {
+ node := o.GetNode()
+ return node.GetTree().(f3_tree.TreeInterface).NewFormat(node.GetKind())
+}
+
+func (o *topic) ToFormat() f3.Interface {
+ if o.forgejoTopic == nil {
+ return o.NewFormat()
+ }
+
+ return &f3.Topic{
+ Common: f3.NewCommon(o.GetNativeID()),
+ Name: o.forgejoTopic.Name,
+ }
+}
+
+func (o *topic) FromFormat(content f3.Interface) {
+ topic := content.(*f3.Topic)
+ o.forgejoTopic = &repo_model.Topic{
+ ID: f3_util.ParseInt(topic.GetID()),
+ Name: topic.Name,
+ }
+}
+
+func (o *topic) Get(ctx context.Context) bool {
+ node := o.GetNode()
+ o.Trace("%s", node.GetID())
+
+ id := node.GetID().Int64()
+
+ if has, err := db.GetEngine(ctx).Where("ID = ?", id).Get(o.forgejoTopic); err != nil {
+ panic(fmt.Errorf("topic %v %w", id, err))
+ } else if !has {
+ return false
+ }
+
+ return true
+}
+
+func (o *topic) Patch(ctx context.Context) {
+ o.Trace("%d", o.forgejoTopic.ID)
+ if _, err := db.GetEngine(ctx).ID(o.forgejoTopic.ID).Cols("name").Update(o.forgejoTopic); err != nil {
+ panic(fmt.Errorf("UpdateTopicCols: %v %v", o.forgejoTopic, err))
+ }
+}
+
+func (o *topic) Put(ctx context.Context) generic.NodeID {
+ sess := db.GetEngine(ctx)
+
+ if _, err := sess.Insert(o.forgejoTopic); err != nil {
+ panic(err)
+ }
+ o.Trace("topic created %d", o.forgejoTopic.ID)
+ return generic.NewNodeID(o.forgejoTopic.ID)
+}
+
+func (o *topic) Delete(ctx context.Context) {
+ node := o.GetNode()
+ o.Trace("%s", node.GetID())
+
+ sess := db.GetEngine(ctx)
+
+ if _, err := sess.Delete(&repo_model.RepoTopic{
+ TopicID: o.forgejoTopic.ID,
+ }); err != nil {
+ panic(fmt.Errorf("Delete RepoTopic for %v %v", o.forgejoTopic, err))
+ }
+
+ if _, err := sess.Delete(o.forgejoTopic); err != nil {
+ panic(fmt.Errorf("Delete Topic %v %v", o.forgejoTopic, err))
+ }
+}
+
+func newTopic() generic.NodeDriverInterface {
+ return &topic{}
+}