♻️ refactor: updated codebase #9

Author: pnguyen215

example/govm_test.go

@@ -4,6 +4,8 @@ import (
 	"testing"
 
 	"github.com/sivaosorg/govm/bot/telegram"
+	"github.com/sivaosorg/govm/logger"
+	"github.com/sivaosorg/govm/query"
 	"github.com/sivaosorg/govm/timex"
 )
 
@@ -28,3 +30,10 @@ func TestCardNotification(t *testing.T) {
 	svc := createTelegramService()
 	svc.SendWarning("Kafka Stream", "Kafka Streams is a part of the Apache Kafka project that enables developers to build real-time processing applications, where data can be ingested, processed, and transformed in real-time as it flows through the Kafka cluster. Kafka Streams is a library for building scalable and fault-tolerant stream processing applications without the need for a separate processing cluster.")
 }
+
+func TestDecisionModify(t *testing.T) {
+	m := query.NewModify().
+		Add("username_column", *query.WithDecision(true).SetValue(1)).
+		Add("password_column", *query.NewDecision().SetEnabled(true).SetValue("123"))
+	logger.Infof("modifies: %v", m.Transform())
+}

query/query.go

@@ -172,6 +172,12 @@ func (i *decision) SetValue(value interface{}) *decision {
 	return i
 }
 
+func (i *decision) SetValueFunc(value interface{}, fnc func() bool) *decision {
+	i.SetEnabled(fnc())
+	i.SetValue(value)
+	return i
+}
+
 func (i *decision) SetOn(value time.Time) *decision {
 	i.on = value
 	return i
@@ -235,6 +241,10 @@ func (m Modify) Transform() map[string]interface{} {
 	return values.Build()
 }
 
+func (m Modify) Json() string {
+	return utils.ToJson(m)
+}
+
 func GetTotalPages(totalCount int, size int) int {
 	d := float64(totalCount) / float64(size)
 	return int(math.Ceil(d))