diff options
| -rw-r--r-- | config/config.go | 40 | ||||
| -rw-r--r-- | feed/feed.go | 55 |
2 files changed, 60 insertions, 35 deletions
diff --git a/config/config.go b/config/config.go index 3a5920c..5f0e1fd 100644 --- a/config/config.go +++ b/config/config.go @@ -10,19 +10,14 @@ import ( "path" "strings" + "ricketyspace.net/fern/feed" "ricketyspace.net/fern/file" ) -type Feed struct { - Id string `json:"id"` - Source string `json:"source"` - Schema string `json:"schema"` -} - type FernConfig struct { - YDLPath string `json:"ydl-path"` - DumpDir string `json:"dump-dir"` - Feeds []Feed `json:"feeds"` + YDLPath string `json:"ydl-path"` + DumpDir string `json:"dump-dir"` + Feeds []feed.Feed `json:"feeds"` } func Read() (*FernConfig, error) { @@ -92,7 +87,7 @@ func (config *FernConfig) validate() error { return fmt.Errorf("'feeds' not set in config") } for _, feed := range config.Feeds { - err = feed.validate() + err = feed.Validate(config.DumpDir) if err != nil { return err } @@ -100,28 +95,3 @@ func (config *FernConfig) validate() error { return nil } - -func (feed *Feed) validate() error { - // Check 'id' - if len(feed.Id) == 0 { - return fmt.Errorf("'id' not set in a feed") - } - - // Check 'source' - if len(feed.Source) == 0 { - return fmt.Errorf("'source' not set in a feed '%s'", feed.Id) - } - - // Check 'schema' - schemaOK := false - for _, schema := range []string{"npr", "youtube"} { - if feed.Schema == schema { - schemaOK = true - } - } - if !schemaOK { - return fmt.Errorf("schema '%s' for feed '%s' is not valid", - feed.Schema, feed.Id) - } - return nil -} diff --git a/feed/feed.go b/feed/feed.go new file mode 100644 index 0000000..13de66d --- /dev/null +++ b/feed/feed.go @@ -0,0 +1,55 @@ +// SPDX-License-Identifier: ISC +// Copyright © 2021 siddharth <s@ricketyspace.net> + +package feed + +import ( + "fmt" + "os" + "path" +) + +type Feed struct { + Id string `json:"id"` + Source string `json:"source"` + Schema string `json:"schema"` + DumpDir string +} + +func (feed *Feed) Validate(baseDumpDir string) error { + _, err := os.Stat(baseDumpDir) + if err != nil { + return err + } + + // Check 'id' + if len(feed.Id) == 0 { + return fmt.Errorf("'id' not set in a feed") + } + + // Check 'source' + if len(feed.Source) == 0 { + return fmt.Errorf("'source' not set in a feed '%s'", feed.Id) + } + + // Check 'schema' + schemaOK := false + for _, schema := range []string{"npr", "youtube"} { + if feed.Schema == schema { + schemaOK = true + } + } + if !schemaOK { + return fmt.Errorf("schema '%s' for feed '%s' is not valid", + feed.Schema, feed.Id) + } + + // Set dump directory for feed and ensure it exists. + feed.DumpDir = path.Join(baseDumpDir, feed.Id) + err = os.MkdirAll(feed.DumpDir, 0755) + if err != nil { + return err + } + + return nil +} |