Fix: hasura metadata replace

Author: aopoltorzhicky

hasura/api.go

@@ -158,17 +158,13 @@ func (api *API) ExportMetadata(ctx context.Context) (Metadata, error) {
 func (api *API) ReplaceMetadata(ctx context.Context, data *Metadata) error {
 	req := versionedRequest{
 		Type:    "replace_metadata",
-		Version: 1,
-		Args:    data,
-	}
-	var resp replaceMetadataResponse
-	if err := api.post(ctx, "/v1/metadata", nil, req, &resp); err != nil {
-		return err
-	}
-	if resp.Message == "success" {
-		return nil
+		Version: 2,
+		Args: map[string]any{
+			"metadata":                    data,
+			"allow_inconsistent_metadata": true,
+		},
 	}
-	return errors.Errorf("Can't replace hasura's metadata: %s", resp.Message)
+	return api.post(ctx, "/v1/metadata", nil, req, nil)
 }
 
 // TrackTable -

hasura/hasura.go

@@ -25,7 +25,7 @@ func checkHealth(ctx context.Context, api *API) {
 	if err := api.Health(ctx); err != nil {
 		return
 	}
-	ticker := time.NewTicker(5 * time.Second)
+	ticker := time.NewTicker(time.Second)
 	for {
 		select {
 		case <-ctx.Done():

hasura/requests.go

@@ -49,7 +49,7 @@ type Configuration struct {
 type ConnectionInfo struct {
 	UsePreparedStatements bool        `json:"use_prepared_statements"`
 	IsolationLevel        string      `json:"isolation_level"`
-	DatabaseUrl           DatabaseUrl `json:"database_url,omitempty"`
+	DatabaseUrl           DatabaseUrl `json:"database_url"`
 }
 
 // DatabaseUrl -
@@ -73,11 +73,7 @@ func (d *DatabaseUrl) UnmarshalJSON(data []byte) error {
 		return err
 	}
 
-	fromEnvValue := os.Getenv(fromEnv.FromEnv)
-	if fromEnvValue == "" {
-		return errors.Errorf("you have to set '%s' environment variable due to hasura connection info", fromEnv.FromEnv)
-	}
-	*d = DatabaseUrl(fromEnvValue)
+	*d = DatabaseUrl(os.Getenv(fromEnv.FromEnv))
 	return nil
 }