summaryrefslogtreecommitdiff
path: root/services/worker/internal/parser/parser.go
diff options
context:
space:
mode:
authorFuwn <[email protected]>2026-02-07 01:44:12 -0800
committerFuwn <[email protected]>2026-02-07 01:44:12 -0800
commit504a0c1bed5b2086fec1e3b89027d328f9c09604 (patch)
tree3e92560239227426daef6a7d549bd7ea0ca14805 /services/worker/internal/parser/parser.go
parentfeat: asa.news RSS reader with developer tier, REST API, and webhooks (diff)
downloadasa.news-504a0c1bed5b2086fec1e3b89027d328f9c09604.tar.xz
asa.news-504a0c1bed5b2086fec1e3b89027d328f9c09604.zip
style: format Go worker with iku
Diffstat (limited to 'services/worker/internal/parser/parser.go')
-rw-r--r--services/worker/internal/parser/parser.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/services/worker/internal/parser/parser.go b/services/worker/internal/parser/parser.go
index 1fb2f76..32611e7 100644
--- a/services/worker/internal/parser/parser.go
+++ b/services/worker/internal/parser/parser.go
@@ -36,18 +36,20 @@ func (feedParser *Parser) Parse(feedIdentifier string, ownerIdentifier *string,
}
feedEntries := make([]model.FeedEntry, 0, len(parsedFeed.Items))
-
audioEnclosureCount := 0
for _, feedItem := range parsedFeed.Items {
normalizedEntry := normalizeFeedItem(feedIdentifier, ownerIdentifier, feedItem)
+
if normalizedEntry.EnclosureURL != nil {
audioEnclosureCount++
}
+
feedEntries = append(feedEntries, normalizedEntry)
}
audioEnclosureRatio := 0.0
+
if len(feedEntries) > 0 {
audioEnclosureRatio = float64(audioEnclosureCount) / float64(len(feedEntries))
}
@@ -180,6 +182,7 @@ func resolveAudioEnclosure(feedItem *gofeed.Item) (*string, *string, *int64) {
enclosureType := enclosure.Type
var enclosureLength *int64
+
if enclosure.Length != "" {
if parsedLength, parseError := strconv.ParseInt(enclosure.Length, 10, 64); parseError == nil {
enclosureLength = &parsedLength