Hasura: error parsing

Author: aopoltorzhicky

hasura/api.go

@@ -2,7 +2,6 @@ package hasura
 
 import (
 	"bytes"
-	"io/ioutil"
 	"net/http"
 	"net/url"
 	"path"
@@ -83,11 +82,11 @@ func (api *API) post(endpoint string, args map[string]string, body interface{},
 	defer resp.Body.Close()
 
 	if resp.StatusCode != http.StatusOK {
-		bodyBytes, err := ioutil.ReadAll(resp.Body)
-		if err != nil {
+		var apiError APIError
+		if err := json.NewDecoder(resp.Body).Decode(&apiError); err != nil {
 			return errors.Wrap(err, "Hasura's response decoding error")
 		}
-		return errors.Errorf("Invalid status code: %s %s", resp.Status, string(bodyBytes))
+		return apiError
 	}
 
 	if output == nil {
@@ -141,10 +140,10 @@ func (api *API) ReplaceMetadata(data *Metadata) error {
 // TrackTable -
 func (api *API) TrackTable(schema, name string) error {
 	req := request{
-		Type: "track_table",
+		Type: "pg_track_table",
 		Args: map[string]string{
-			"schema": schema,
-			"name":   name,
+			"source": schema,
+			"table":  name,
 		},
 	}
 	return api.post("/v1/query", nil, req, nil)

hasura/error.go

@@ -0,0 +1,34 @@
+package hasura
+
+import "strings"
+
+// APIError -
+type APIError struct {
+	Path string `json:"path"`
+	Text string `json:"error"`
+	Code string `json:"code"`
+}
+
+// Error -
+func (e APIError) Error() string {
+	var builder strings.Builder
+	builder.WriteString("hasura api error")
+	if e.Path != "" {
+		builder.WriteString(" path=")
+		builder.WriteString(e.Path)
+	}
+	if e.Text != "" {
+		builder.WriteString(" error=")
+		builder.WriteString(e.Text)
+	}
+	if e.Code != "" {
+		builder.WriteString(" code=")
+		builder.WriteString(e.Code)
+	}
+	return builder.String()
+}
+
+// AlreadyExists -
+func (e APIError) AlreadyExists() bool {
+	return e.Code == "already-exists"
+}

hasura/hasura.go

@@ -64,7 +64,9 @@ func Create(hasura config.Hasura, cfg config.Database, views []string, models ..
 		log.Info("Creating REST endpoints...")
 		for _, query := range metadata.QueryCollections[0].Definition.Queries {
 			if err := api.CreateRestEndpoint(query.Name, query.Name, query.Name, allowedQueries); err != nil {
-				return err
+				if e, ok := err.(APIError); !ok || !e.AlreadyExists() {
+					return err
+				}
 			}
 		}
 	}

state/db.go

@@ -44,6 +44,8 @@ func OpenConnection(cfg config.Database) (*gorm.DB, error) {
 	}
 
 	return gorm.Open(dialector, &gorm.Config{
+		SkipDefaultTransaction: true,
+		PrepareStmt:            true,
 		Logger: logger.New(
 			log.New(os.Stdout, "\r\n", log.LstdFlags),
 			logger.Config{