mail based rss feed aggregator
start senders before fetchers, add more logging and re-fetch the first feed after 5s for testing purposes
+13
-3
+13
-3
src/eater.gleam
+13
-3
src/eater.gleam
···
41
41
|> supervisor.add(sender.factory(sender_factory))
42
42
|> supervisor.start()
43
43
44
-
let assert Ok(_) =
45
-
fetcher.start_all_existing(fetcher_factory, registry, database)
46
-
as "Failed to start existing fetchers"
44
+
log(logging.Info, "Finished starting supervisor")
47
45
48
46
let assert Ok(_) =
49
47
sender.start_all_existing(
···
53
51
smtp_environment,
54
52
)
55
53
as "Failed to start existing senders"
54
+
55
+
log(logging.Info, "Finished starting senders")
56
+
57
+
let assert Ok(fetchers) =
58
+
fetcher.start_all_existing(fetcher_factory, registry, database)
59
+
as "Failed to start existing fetchers"
60
+
61
+
log(logging.Info, "Finished starting fetchers")
62
+
63
+
let assert [fetcher, ..] = fetchers
64
+
65
+
process.send_after(fetcher.data, 5000, fetcher.CheckFeeds)
56
66
57
67
process.sleep_forever()
58
68
}