Skip to content

Commit

Permalink
refactor: move metadata to metadata folder
Browse files Browse the repository at this point in the history
  • Loading branch information
immdipu committed Feb 28, 2025
1 parent b4027d9 commit 40d8aab
Show file tree
Hide file tree
Showing 6 changed files with 25 additions and 18 deletions.
16 changes: 2 additions & 14 deletions providers/brevo/connector.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,20 +6,8 @@ import (
"github.com/amp-labs/connectors/common"
"github.com/amp-labs/connectors/internal/components"
"github.com/amp-labs/connectors/internal/components/schema"
"github.com/amp-labs/connectors/internal/staticschema"
"github.com/amp-labs/connectors/providers"
"github.com/amp-labs/connectors/tools/fileconv"
"github.com/amp-labs/connectors/tools/scrapper"
)

// nolint:gochecknoglobals
var (
//go:embed schemas.json
schemaContent []byte
FileManager = scrapper.NewMetadataFileManager[staticschema.FieldMetadataMapV2](
schemaContent, fileconv.NewSiblingFileLocator())

schemas = FileManager.MustLoadSchemas()
"github.com/amp-labs/connectors/providers/brevo/metadata"
)

type Connector struct {
Expand All @@ -46,7 +34,7 @@ func constructor(base *components.Connector) (*Connector, error) {
connector := &Connector{Connector: base}

// Set the metadata provider for the connector
connector.SchemaProvider = schema.NewOpenAPISchemaProvider(connector.ProviderContext.Module(), schemas)
connector.SchemaProvider = schema.NewOpenAPISchemaProvider(connector.ProviderContext.Module(), metadata.Schemas)

return connector, nil
}
File renamed without changes.
File renamed without changes.
File renamed without changes.
19 changes: 19 additions & 0 deletions providers/brevo/metadata/scraping.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
package metadata

import (
_ "embed"

"github.com/amp-labs/connectors/internal/staticschema"
"github.com/amp-labs/connectors/tools/fileconv"
"github.com/amp-labs/connectors/tools/scrapper"
)

// nolint:gochecknoglobals
var (
//go:embed schemas.json
schemaContent []byte
FileManager = scrapper.NewMetadataFileManager[staticschema.FieldMetadataMapV2](
schemaContent, fileconv.NewSiblingFileLocator())

Schemas = FileManager.MustLoadSchemas()
)
8 changes: 4 additions & 4 deletions scripts/openapi/brevo/metadata/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@ import (
"github.com/amp-labs/connectors/internal/datautils"
"github.com/amp-labs/connectors/internal/goutils"
"github.com/amp-labs/connectors/internal/staticschema"
"github.com/amp-labs/connectors/providers/brevo"
"github.com/amp-labs/connectors/providers/brevo/openapi"
"github.com/amp-labs/connectors/providers/brevo/metadata"
"github.com/amp-labs/connectors/providers/brevo/metadata/openapi"
utilsopenapi "github.com/amp-labs/connectors/scripts/openapi/utils"
"github.com/amp-labs/connectors/tools/fileconv/api3"
"github.com/amp-labs/connectors/tools/scrapper"
Expand Down Expand Up @@ -113,8 +113,8 @@ func main() {
}
}

goutils.MustBeNil(brevo.FileManager.SaveSchemas(schemas))
goutils.MustBeNil(brevo.FileManager.SaveQueryParamStats(scrapper.CalculateQueryParamStats(registry)))
goutils.MustBeNil(metadata.FileManager.SaveSchemas(schemas))
goutils.MustBeNil(metadata.FileManager.SaveQueryParamStats(scrapper.CalculateQueryParamStats(registry)))

slog.Info("Completed.")
}

0 comments on commit 40d8aab

Please sign in to comment.