Add support for query helpers

Author: Suven-p

src/SDK/Language/Go.php

@@ -93,6 +93,11 @@ public function getFiles(): array
                 'destination'   => '{{ spec.title | caseLower}}/inputFile.go',
                 'template'      => 'go/inputFile.go.twig',
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => '{{ spec.title | caseLower}}/query.go',
+                'template'      => 'go/query.go.twig',
+            ],
             [
                 'scope'         => 'service',
                 'destination'   => '{{ spec.title | caseLower}}/{{service.name | caseDash}}.go',

templates/go/query.go.twig

@@ -0,0 +1,119 @@
+package {{ spec.title | caseLower }}
+
+import (
+	"fmt"
+	"reflect"
+)
+
+type Query struct {}
+
+func NewQuery() *Query {
+	return &Query{}
+}
+
+func (q *Query) parseValue(value interface{}) string {
+	if val, ok := value.(string); ok {
+		return fmt.Sprintf("\"%s\"", val)
+	}
+	return toString(value)
+}
+
+func (q *Query) parseQuery(attribute string, method string, value interface{}) string {
+	stringValue := ""
+	switch reflect.TypeOf(value).Kind() {
+	case reflect.Array, reflect.Slice:
+		arr := reflect.Indirect(reflect.ValueOf(value))
+		for i := 0; i < arr.Len(); i++ {
+			stringValue += q.parseValue(arr.Index(i).Interface())
+			if i < arr.Len()-1 {
+				stringValue += ","
+			}
+		}
+	default:
+		stringValue = q.parseValue(value)
+	}
+	return fmt.Sprintf("%s(\"%s\", [%s])", method, attribute, stringValue)
+}
+
+func (q *Query) Equal(attribute string, value interface{}) string {
+	return q.parseQuery(attribute, "equal", value)
+}
+
+func (q *Query) NotEqual(attribute string, value interface{}) string {
+	return q.parseQuery(attribute, "notEqual", value)
+}
+
+func (q *Query) LessThan(attribute string, value interface{}) string {
+	return q.parseQuery(attribute, "lessThan", value)
+}
+
+func (q *Query) LessThanEqual(attribute string, value interface{}) string {
+	return q.parseQuery(attribute, "lessThanEqual", value)
+}
+
+func (q *Query) GreaterThan(attribute string, value interface{}) string {
+	return q.parseQuery(attribute, "greaterThan", value)
+}
+
+func (q *Query) GreaterThanEqual(attribute string, value interface{}) string {
+	return q.parseQuery(attribute, "greaterThanEqual", value)
+}
+
+func (q *Query) Search(attribute string, value string) string {
+	return q.parseQuery(attribute, "search", value)
+}
+
+func (q *Query) IsNull(attribute string) string {
+	return fmt.Sprintf("isNull(\"%s\")", attribute)
+}
+
+func (q *Query) IsNotNull(attribute string) string {
+	return fmt.Sprintf("isNotNull(\"%s\")", attribute)
+}
+
+func (q *Query) Between(attribute string, start, end interface{}) string {
+	return q.parseQuery(attribute, "between", []interface{}{start, end})
+}
+
+func (q *Query) StartsWith(attribute string, value interface{}) string {
+	return q.parseQuery(attribute, "startsWith", value)
+}
+
+func (q *Query) EndsWith(attribute string, value interface{}) string {
+	return q.parseQuery(attribute, "endsWith", value)
+}
+
+func (q *Query) Select(attributes []string) string {
+	stringValue := ""
+	for i, attribute := range attributes {
+		stringValue += fmt.Sprintf("\"%s\"", attribute)
+		if i < len(attributes)-1 {
+			stringValue += ","
+		}
+	}
+	return fmt.Sprintf("select([%s])", stringValue)
+}
+
+func (q *Query) OrderAsc(attribute string) string {
+	return fmt.Sprintf("orderAsc(\"%s\")", attribute)
+}
+
+func (q *Query) OrderDesc(attribute string) string {
+	return fmt.Sprintf("orderDesc(\"%s\")", attribute)
+}
+
+func (q *Query) CursorBefore(documentId string) string {
+	return fmt.Sprintf("cursorBefore(\"%s\")", documentId)
+}
+
+func (q *Query) CursorAfter(documentId string) string {
+	return fmt.Sprintf("cursorAfter(\"%s\")", documentId)
+}
+
+func (q *Query) Limit(limit int) string {
+	return fmt.Sprintf("limit(%d)", limit)
+}
+
+func (q *Query) Offset(offset int) string {
+	return fmt.Sprintf("offset(%d)", offset)
+}

tests/Go112Test.php

@@ -24,5 +24,6 @@ class Go112Test extends Base
         ...Base::EXTENDED_GENERAL_RESPONSES,
         ...Base::LARGE_FILE_RESPONSES,
         ...Base::EXCEPTION_RESPONSES,
+        ...Base::QUERY_HELPER_RESPONSES,
     ];
 }

tests/Go118Test.php

@@ -24,5 +24,6 @@ class Go118Test extends Base
         ...Base::EXTENDED_GENERAL_RESPONSES,
         ...Base::LARGE_FILE_RESPONSES,
         ...Base::EXCEPTION_RESPONSES,
+        ...Base::QUERY_HELPER_RESPONSES,
     ];
 }

tests/languages/go/tests.go

@@ -126,6 +126,9 @@ func testGeneralService(client appwrite.Client, stringInArray []interface{}) {
 
 	general.Empty()
 
+	// Test Queries
+	testQueries()
+
 	// Final test
 	response, err = general.Headers()
 	if err != nil {
@@ -166,3 +169,27 @@ func testLargeUpload(client appwrite.Client, stringInArray []interface{}) {
 	}
 	fmt.Printf("%s\n", response.Result.(map[string]interface{})["result"])
 }
+
+func testQueries() {
+	query := appwrite.NewQuery()
+	fmt.Println(query.Equal("released", []interface{}{true}))
+	fmt.Println(query.Equal("title", []string{"Spiderman", "Dr. Strange"}))
+	fmt.Println(query.NotEqual("title", "Spiderman"))
+	fmt.Println(query.LessThan("releasedYear", 1990))
+	fmt.Println(query.GreaterThan("releasedYear", 1990))
+	fmt.Println(query.Search("name", "john"))
+	fmt.Println(query.IsNull("name"))
+	fmt.Println(query.IsNotNull("name"))
+	fmt.Println(query.Between("age", 50, 100))
+	fmt.Println(query.Between("age", 50.5, 100.5))
+	fmt.Println(query.Between("name", "Anna", "Brad"))
+	fmt.Println(query.StartsWith("name", "Ann"))
+	fmt.Println(query.EndsWith("name", "nne"))
+	fmt.Println(query.Select([]string{"name", "age"}))
+	fmt.Println(query.OrderAsc("title"))
+	fmt.Println(query.OrderDesc("title"))
+	fmt.Println(query.CursorAfter("my_movie_id"))
+	fmt.Println(query.CursorBefore("my_movie_id"))
+	fmt.Println(query.Limit(50))
+	fmt.Println(query.Offset(20))
+}