Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[WIP] Resolver and Serialisation #21

Draft
wants to merge 6 commits into
base: main
Choose a base branch
from
Draft

[WIP] Resolver and Serialisation #21

Show file tree
Hide file tree
Changes from 5 commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
084c35c
Added context to most methods needing one, various code cleanups
Keitio Sep 23, 2022
9507ad9
Extended UserInfo & Token Data struct + tests
iDevelopThings Sep 25, 2022
395f66b
`SigninUser` & `SignupUser` method which returns a more typed respons…
iDevelopThings Sep 25, 2022
76e52b0
Test Suite setup in db_test(left old tests alone)
iDevelopThings Sep 25, 2022
e663267
[WIP]
iDevelopThings Sep 25, 2022
5267127
[WIP]
iDevelopThings Sep 26, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
220 changes: 130 additions & 90 deletions db.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package surrealdb

import (
"context"
"encoding/json"
"errors"
"fmt"
Expand All @@ -10,8 +11,9 @@ import (
const statusOK = "OK"

var (
InvalidResponse = errors.New("invalid SurrealDB response")
QueryError = errors.New("error occurred processing the SurrealDB query")
ErrInvalidResponse = errors.New("invalid SurrealDB response")
ErrQuery = errors.New("error occurred processing the SurrealDB query")
ErrInvalidLoginResponse = errors.New("invalid login response")
)

// DB is a client for the SurrealDB database that holds are websocket connection.
Expand All @@ -20,21 +22,24 @@ type DB struct {
}

// New Creates a new DB instance given a WebSocket URL.
func New(url string) (*DB, error) {
ws, err := NewWebsocket(url)
func New(ctx context.Context, url string) (*DB, error) {
ws, err := NewWebsocket(ctx, url)
if err != nil {
return nil, err
}
return &DB{ws}, nil
}

// Unmarshal loads a SurrealDB response into a struct.
func Unmarshal(data interface{}, v interface{}) error {
var ok bool
func Unmarshal(data any, v any) error {
// TODO: make this function obsolete
// currently, we get JSON bytes from the connection, unmarshall them to a *any, marshall them back into
// JSON and then unmarshall them into the target struct
// This is cumbersome to use and expensive to run

assertedData, ok := data.([]interface{})
assertedData, ok := data.([]any)
if !ok {
return InvalidResponse
return ErrInvalidResponse
}
sliceFlag := isSlice(v)

Expand All @@ -59,27 +64,27 @@ func Unmarshal(data interface{}, v interface{}) error {

// UnmarshalRaw loads a raw SurrealQL response returned by Query into a struct. Queries that return with results will
// return ok = true, and queries that return with no results will return ok = false.
func UnmarshalRaw(rawData interface{}, v interface{}) (ok bool, err error) {
var data []interface{}
if data, ok = rawData.([]interface{}); !ok {
return false, InvalidResponse
func UnmarshalRaw(rawData any, v any) (ok bool, err error) {
data, ok := rawData.([]any)
if !ok {
return false, ErrInvalidResponse
}

var responseObj map[string]interface{}
if responseObj, ok = data[0].(map[string]interface{}); !ok {
return false, InvalidResponse
responseObj, ok := data[0].(map[string]any)
if !ok {
return false, ErrInvalidResponse
}

var status string
if status, ok = responseObj["status"].(string); !ok {
return false, InvalidResponse
status, ok := responseObj["status"].(string)
if !ok {
return false, ErrInvalidResponse
}
if status != statusOK {
return false, QueryError
return false, ErrQuery
}

result := responseObj["result"]
if len(result.([]interface{})) == 0 {
if len(result.([]any)) == 0 {
return false, nil
}
err = Unmarshal(result, v)
Expand All @@ -95,141 +100,181 @@ func UnmarshalRaw(rawData interface{}, v interface{}) (ok bool, err error) {
// --------------------------------------------------

// Close closes the underlying WebSocket connection.
func (self *DB) Close() {
_ = self.ws.Close()
func (db *DB) Close() error {
return db.ws.Close()
}

// --------------------------------------------------

// Use is a method to select the namespace and table to use.
func (self *DB) Use(ns string, db string) (interface{}, error) {
return self.send("use", ns, db)
func (db *DB) Use(ctx context.Context, ns string, dbname string) (any, error) {
return db.send(ctx, "use", ns, dbname)
}

func (self *DB) Info() (interface{}, error) {
return self.send("info")
func (db *DB) Info(ctx context.Context) (any, error) {
return db.send(ctx, "info")
}

// Signup is a helper method for signing up a new user.
func (self *DB) Signup(vars interface{}) (interface{}, error) {
return self.send("signup", vars)
func (db *DB) Signup(ctx context.Context, vars any) (any, error) {
return db.send(ctx, "signup", vars)
}

// SignupUser is a helper method for signing in a user and returning a typed response
func (db *DB) SignupUser(ctx context.Context, vars UserInfo) (*AuthenticationResult, error) {
authResult := &AuthenticationResult{Success: false}
result, err := db.send(ctx, "signup", vars)
if err != nil {
return authResult, err
}

err = authResult.fromQuery(result)

return authResult, err
}

// Signin is a helper method for signing in a user.
func (self *DB) Signin(vars interface{}) (interface{}, error) {
return self.send("signin", vars)
func (db *DB) Signin(ctx context.Context, vars UserInfo) (any, error) {
return db.send(ctx, "signin", vars)
}

// SigninUser is a helper method for signing in a user and returning a typed response
// Note: This will probably fail when signing in as a root user, but for
// a regular user(via a scope for example) we get a JWT response
func (db *DB) SigninUser(ctx context.Context, vars UserInfo) (*AuthenticationResult, error) {
authResult := &AuthenticationResult{Success: false}
result, err := db.send(ctx, "signin", vars)
if err != nil {
return authResult, err
}
if err != nil {
return authResult, err
}

err = authResult.fromQuery(result)

return authResult, err
}

func (self *DB) Invalidate() (interface{}, error) {
return self.send("invalidate")
func (db *DB) Invalidate(ctx context.Context) (any, error) {
return db.send(ctx, "invalidate")
}

func (self *DB) Authenticate(token string) (interface{}, error) {
return self.send("authenticate", token)
func (db *DB) Authenticate(ctx context.Context, token string) (any, error) {
return db.send(ctx, "authenticate", token)
}

// --------------------------------------------------

func (self *DB) Live(table string) (interface{}, error) {
return self.send("live", table)
func (db *DB) Live(ctx context.Context, table string) (any, error) {
return db.send(ctx, "live", table)
}

func (self *DB) Kill(query string) (interface{}, error) {
return self.send("kill", query)
func (db *DB) Kill(ctx context.Context, query string) (any, error) {
return db.send(ctx, "kill", query)
}

func (self *DB) Let(key string, val interface{}) (interface{}, error) {
return self.send("let", key, val)
func (db *DB) Let(ctx context.Context, key string, val any) (any, error) {
return db.send(ctx, "let", key, val)
}

// Query is a convenient method for sending a query to the database.
func (self *DB) Query(sql string, vars interface{}) (interface{}, error) {
return self.send("query", sql, vars)
func (db *DB) Query(ctx context.Context, sql string, vars any) (any, error) {
return db.send(ctx, "query", sql, vars)
}
func (db *DB) QueryRaw(ctx context.Context, sql string, vars any) *RPCRawResponse {
response, err := db.send(ctx, "query", sql, vars)
if err != nil {
panic(err)
}
return response.(*RPCRawResponse)
}

// Select a table or record from the database.
func (self *DB) Select(what string) (interface{}, error) {
return self.send("select", what)
func (db *DB) Select(ctx context.Context, what string) (any, error) {
return db.send(ctx, "select", what)
}

// Creates a table or record in the database like a POST request.
func (self *DB) Create(thing string, data interface{}) (interface{}, error) {
return self.send("create", thing, data)
func (db *DB) Create(ctx context.Context, thing string, data any) (any, error) {
return db.send(ctx, "create", thing, data)
}

// Update a table or record in the database like a PUT request.
func (self *DB) Update(what string, data interface{}) (interface{}, error) {
return self.send("update", what, data)
func (db *DB) Update(ctx context.Context, what string, data any) (any, error) {
return db.send(ctx, "update", what, data)
}

// Change a table or record in the database like a PATCH request.
func (self *DB) Change(what string, data interface{}) (interface{}, error) {
return self.send("change", what, data)
func (db *DB) Change(ctx context.Context, what string, data any) (any, error) {
return db.send(ctx, "change", what, data)
}

// Modify applies a series of JSONPatches to a table or record.
func (self *DB) Modify(what string, data []Patch) (interface{}, error) {
return self.send("modify", what, data)
func (db *DB) Modify(ctx context.Context, what string, data []Patch) (any, error) {
return db.send(ctx, "modify", what, data)
}

// Delete a table or a row from the database like a DELETE request.
func (self *DB) Delete(what string) (interface{}, error) {
return self.send("delete", what)
func (db *DB) Delete(ctx context.Context, what string) (any, error) {
return db.send(ctx, "delete", what)
}

// --------------------------------------------------
// Private methods
// --------------------------------------------------

// send is a helper method for sending a query to the database.
func (self *DB) send(method string, params ...interface{}) (interface{}, error) {
func (db *DB) send(ctx context.Context, method string, params ...any) (any, error) {

// generate an id for the action, this is used to distinguish its response
id := xid(16)
id := xid()
// chn: the channel where the server response will arrive, err: the channel where errors will come
chn, err := self.ws.Once(id, method)
chn := db.ws.Once(id, method)
// here we send the args through our websocket connection
self.ws.Send(id, method, params)
db.ws.Send(id, method, params)

select {
case <-ctx.Done():
return nil, ctx.Err()

for {
select {
case r := <-chn:
if r.err != nil {
return nil, r.err
}
switch method {
case "delete":
return nil, nil
case "select":
return db.resp(method, params, r.value)
case "create":
return db.resp(method, params, r.value)
case "update":
return db.resp(method, params, r.value)
case "change":
return db.resp(method, params, r.value)
case "modify":
return db.resp(method, params, r.value)
default:
case e := <-err:
return nil, e
case r := <-chn:
switch method {
case "delete":
return nil, nil
case "select":
return self.resp(method, params, r)
case "create":
return self.resp(method, params, r)
case "update":
return self.resp(method, params, r)
case "change":
return self.resp(method, params, r)
case "modify":
return self.resp(method, params, r)
default:
return r, nil
}
return r.value, nil
}
}

}

// resp is a helper method for parsing the response from a query.
func (self *DB) resp(_ string, params []interface{}, res interface{}) (interface{}, error) {
func (db *DB) resp(_ string, params []any, res any) (any, error) {

arg, ok := params[0].(string)

if !ok {
return res, nil
}

// TODO: explian what that condition is for
if strings.Contains(arg, ":") {

arr, ok := res.([]interface{})
arr, ok := res.([]any)

if !ok {
return nil, PermissionError{what: arg}
Expand All @@ -248,15 +293,10 @@ func (self *DB) resp(_ string, params []interface{}, res interface{}) (interface
}

func isSlice(possibleSlice interface{}) bool {
slice := false

switch v := possibleSlice.(type) {
default:
res := fmt.Sprintf("%s", v)
if res == "[]" || res == "&[]" || res == "*[]" {
slice = true
}
res := fmt.Sprintf("%s", possibleSlice)
if res == "[]" || res == "&[]" || res == "*[]" {
return true
}

return slice
return false
}
Loading