Feat/hasura config

build/metadata/Dockerfile

@@ -35,5 +35,6 @@ COPY ./cmd/metadata/mappings ./mappings
 COPY ./cmd/metadata/graphql ./graphql
 COPY ./build/*.yml ./
 COPY ./cmd/metadata/views/*.sql ./views/
+COPY ./cmd/metadata/custom_hasura_config ./custom_hasura_config
 
 ENTRYPOINT ["/go/bin/dipdup-metadata"]

cmd/metadata/config/config.go

@@ -23,6 +23,7 @@ func (c *Config) Substitute() error {
 			return err
 		}
 	}
+	c.Config.Hasura.SetSourceName()
 	return nil
 }
 

cmd/metadata/main.go

@@ -81,7 +81,13 @@ func main() {
 						return
 					}
 
-					if err := hasura.Create(ctx, cfg.Hasura, cfg.Database, views, new(models.TokenMetadata), new(models.ContractMetadata)); err != nil {
+					custom_configs, err := readCustomHasuraConfigs(ctx, cfg.Database)
+					if err != nil {
+						log.Err(err).Msg("readCustomHasuraConfigs")
+						return
+					}
+
+					if err := hasura.Create(ctx, cfg.Hasura, cfg.Database, views, custom_configs, new(models.TokenMetadata), new(models.ContractMetadata)); err != nil {
 						log.Err(err).Msg("hasura.Create")
 					}
 				})
@@ -109,7 +115,13 @@ func main() {
 								return
 							}
 
-							if err := hasura.Create(ctx, cfg.Hasura, cfg.Database, views, new(models.TokenMetadata), new(models.ContractMetadata)); err != nil {
+							custom_configs, err := readCustomHasuraConfigs(ctx, cfg.Database)
+							if err != nil {
+								log.Err(err).Msg("readCustomHasuraConfigs")
+								return
+							}
+
+							if err := hasura.Create(ctx, cfg.Hasura, cfg.Database, views, custom_configs, new(models.TokenMetadata), new(models.ContractMetadata)); err != nil {
 								log.Err(err).Msg("hasura.Create")
 							}
 						})
@@ -212,3 +224,33 @@ func createViews(ctx context.Context, database golibConfig.Database) ([]string,
 
 	return views, nil
 }
+
+func readCustomHasuraConfigs(ctx context.Context, database golibConfig.Database) ([]hasura.Request, error) {
+	files, err := ioutil.ReadDir("custom_hasura_config")
+	if err != nil {
+		return nil, err
+	}
+
+	custom_configs := make([]hasura.Request, 0)
+	for i := range files {
+		if files[i].IsDir() || strings.HasPrefix(files[i].Name(), ".") {
+			continue
+		}
+
+		path := fmt.Sprintf("custom_hasura_config/%s", files[i].Name())
+		raw, err := ioutil.ReadFile(path)
+		if err != nil {
+			return nil, err
+		}
+
+		conf := hasura.Request{}
+
+		err = json.Unmarshal([]byte(raw), &conf)
+		if err != nil {
+			return nil, err
+		}
+		custom_configs = append(custom_configs, conf)
+	}
+
+	return custom_configs, nil
+}