#! /usr/bin/env racket
; vim: filetype=racket
+; TODO write
+; TODO caching (use cache by default, unless explicitly asked for update)
+; TODO timeline limits
+; TODO user-defined feed sets (a la twitter lists)
+; TODO feed set operations
+; TODO timeline as a result of a query (feed set op + filter expressions)
+; TODO named timelines
+; TODO CLI params
+; TODO config files
+; TODO parse mentions:
+; - @<source.nick source.url> | @<source.url>
+; TODO highlight mentions
+; TODO filter on mentions
+; TODO highlight hashtags
+; TODO filter on hashtags
+; TODO hashtags as channels? initial hashtag special?
+; TODO query language
+; TODO concurrency
+; TODO console logger colors by level ('error)
+; TODO file logger ('debug)
+; TODO commands:
+; - r | read
+; - see timeline ops above
+; - w | write
+; - arg or stdin
+; - nick expand to URI
+; - q | query
+; - see timeline ops above
+; - see hashtag and channels above
+; - d | download
+; - u | upload
+; - calls user-configured command to upload user's own feed file to their server
+; TODO user-agent format: <client>/<version> (+<source.url>; @<source.nick>)
+; - requires configurability
+; - ref: https://twtxt.readthedocs.io/en/latest/user/discoverability.html
+
#lang racket
(require racket/date)
[i (in-naturals)])
(msg-print (odd? i) msg)))
+(define (feed->msgs feed)
+ (log-info "downloading feed nick:~a uri:~a"
+ (feed-nick feed)
+ (feed-uri feed))
+ (with-handlers
+ ([exn:fail:network?
+ (λ (e)
+ (log-error "network error nick:~a uri:~a exn:~a"
+ (feed-nick feed)
+ (feed-uri feed)
+ e)
+ #f)]
+ [integer?
+ (λ (status)
+ (log-error "http error nick:~a uri:~a status:~a"
+ (feed-nick feed)
+ (feed-uri feed)
+ status)
+ #f)])
+ (str->msgs [feed-nick feed] [uri-fetch (feed-uri feed)])))
+
+; TODO timeline contract : time-sorted list of messages
(define (timeline feeds)
- (let* ([timelines
- (filter-map
- (λ (feed)
- (log-info "processing feed nick:~a uri:~a"
- (feed-nick feed)
- (feed-uri feed))
- (with-handlers
- ([exn:fail:network?
- (λ (e)
- (log-error "network error nick:~a uri:~a exn:~a"
- (feed-nick feed)
- (feed-uri feed)
- e)
- #f)]
- [integer?
- (λ (status)
- (log-error "http error nick:~a uri:~a status:~a"
- (feed-nick feed)
- (feed-uri feed)
- status)
- #f)])
- (str->msgs [feed-nick feed] [uri-fetch (feed-uri feed)])))
- feeds)]
- [timeline
- (append* timelines)]
- [timeline
- (sort timeline (λ (a b) [< (msg-tm_epoch a) (msg-tm_epoch b)]))])
- timeline))
+ (sort (append* (filter-map feed->msgs feeds))
+ (λ (a b) [< (msg-tm_epoch a) (msg-tm_epoch b)])))
(define (we-are-twtxt)
(let* ([uri
(str->lines payload)]
[feeds
(map (λ (line)
+ ; TODO validation
(define toks (string-split line))
(feed
[list-ref toks 0]