What if you could see everything at a...
+Glance
+Install • Configuration • Themes
+ + + +### Features +#### Various widgets +* RSS feeds +* Subreddit posts +* Weather +* Bookmarks +* Latest YouTube videos from specific channels +* Calendar +* Stocks +* iframe +* Twitch channels & top games +* GitHub releases +* Site monitor + +#### Themeable + + +#### Optimized for mobile devices + + +#### Fast and lightweight +* Minimal JS, no bloated frameworks +* Very few dependencies +* Single, easily distributed <15mb binary and just as small docker container +* All requests are parallelized, uncached pages usually load within ~1s (depending on internet speed and number of widgets) + +### Configuration +Checkout the [configuration docs](docs/configuration.md) to learn more. A [preconfigured page](docs/configuration.md#preconfigured-page) is also available to get you started quickly. + +### Installation +> [!CAUTION] +> +> The project is under active development, expect things to break every once in a while. + +#### Manual +Checkout the [releases page](https://github.com/glanceapp/glance/releases) for available binaries. You can place the binary inside `/opt/glance/` and have it start with your server via a [systemd service](https://linuxhandbook.com/create-systemd-services/). To specify a different path for the config file use the `--config` option: + +``` +/opt/glance/glance --config /etc/glance.yml +``` + +#### Docker +> [!IMPORTANT] +> +> Make sure you have a valid `glance.yml` file before running the container. + +```console +docker run -d -p 8080:8080 \ + -v ./glance.yml:/app/glance.yml \ + -v /etc/timezone:/etc/timezone:ro \ + -v /etc/localtime:/etc/localtime:ro \ + glanceapp/glance +``` + +Or if you prefer docker compose: + +```yaml +services: + glance: + image: glanceapp/glance + volumes: + - ./glance.yml:/app/glance.yml + - /etc/timezone:/etc/timezone:ro + - /etc/localtime:/etc/localtime:ro + ports: + - 8080:8080 + restart: unless-stopped +``` + +### Building from source + +Requirements: [Go](https://go.dev/dl/) >= v1.22 + +To build: + +``` +go build . +``` + +To run: + +``` +go run . +``` diff --git a/docs/configuration.md b/docs/configuration.md new file mode 100644 index 0000000..1f7052a --- /dev/null +++ b/docs/configuration.md @@ -0,0 +1,873 @@ +# Configuration + +- [Intro](#intro) +- [Preconfigured page](#preconfigured-page) +- [Server](#server) +- [Theme](#theme) + - [Themes](#themes) +- [Pages & Columns](#pages--columns) +- [Widgets](#widgets) + - [RSS](#rss) + - [Videos](#videos) + - [Hacker News](#hacker-news) + - [Reddit](#reddit) + - [Weather](#weather) + - [Monitor](#monitor) + - [Releases](#releases) + - [Bookmarks](#bookmarks) + - [Calendar](#calendar) + - [Stocks](#stocks) + - [Twitch Channels](#twitch-channels) + - [Twitch Top Games](#twitch-top-games) + - [iframe](#iframe) + +## Intro +Configuration is done via a single YAML file and a server restart is required in order for any changes to take effect. Trying to start the server with an invalid config file will result in an error. + +## Preconfigured page +If you don't want to spend time reading through all the available configuration options and just want something to get you going quickly you can use the following `glance.yml` and make changes as you see fit: + +```yaml +pages: + - name: Home + columns: + - size: small + widgets: + - type: calendar + + - type: rss + limit: 10 + collapse-after: 3 + cache: 3h + feeds: + - url: https://ciechanow.ski/atom.xml + - url: https://www.joshwcomeau.com/rss.xml + title: Josh Comeau + - url: https://samwho.dev/rss.xml + - url: https://awesomekling.github.io/feed.xml + - url: https://ishadeed.com/feed.xml + title: Ahmad Shadeed + + - type: twitch-channels + channels: + - theprimeagen + - cohhcarnage + - christitustech + - blurbs + - asmongold + - jembawls + + - size: full + widgets: + - type: hacker-news + + - type: videos + channels: + - UCR-DXc1voovS8nhAvccRZhg # Jeff Geerling + - UCv6J_jJa8GJqFwQNgNrMuww # ServeTheHome + - UCOk-gHyjcWZNj3Br4oxwh0A # Techno Tim + + - type: reddit + subreddit: selfhosted + + - size: small + widgets: + - type: weather + location: London, United Kingdom + + - type: stocks + stocks: + - symbol: SPY + name: S&P 500 + - symbol: BTC-USD + name: Bitcoin + - symbol: NVDA + name: NVIDIA + - symbol: AAPL + name: Apple + - symbol: MSFT + name: Microsoft + - symbol: GOOGL + name: Google + - symbol: AMD + name: AMD + - symbol: RDDT + name: Reddit +``` + +This will give you a page that looks like the following: + + + +Configure the widgets, add more of them, add extra pages, etc. Make it your own! + +## Server +Server configuration is done through a top level `server` property. Example: + +```yaml +server: + port: 8080 + assets-path: /home/user/glance-assets +``` + +### Properties + +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| host | string | no | | +| port | number | no | 8080 | +| assets-path | string | no | | + +#### `host` +The address which the server will listen on. Setting it to `localhost` means that only the machine that the server is running on will be able to access the dashboard. By default it will listen on all interfaces. + +#### `port` +A number between 1 and 65,535, so long as that port isn't already used by anything else. + +#### `assets-path` +The path to a directory that will be served by the server under the `/assets/` path. This is handy for widgets like the Monitor where you have to specify an icon URL and you want to self host all the icons rather than pointing to an external source. + +> [!IMPORTANT] +> +> When installing through docker the path will point to the files inside the container. Don't forget to mount your assets path to the same path inside the container. +> Example: +> +> If your assets are in: +> ``` +> /home/user/glance-assets +> ``` +> +> You should mount: +> ``` +> /home/user/glance-assets:/app/assets +> ``` +> +> And your config should contain: +> ``` +> assets-path: /app/assets +> ``` + +##### Examples + +Say you have a directory `glance-assets` with a file `gitea-icon.png` in it and you specify your assets path like: + +```yaml +assets-path: /home/user/glance-assets +``` + +To be able to point to an asset from your assets path, use the the `/assets/` path like such: + +```yaml +icon: /assets/gitea-icon.png +``` + +## Theme +Theming is done through a top level `theme` property. Values for the colors are in [HSL](https://giggster.com/guide/basics/hue-saturation-lightness/) (hue, saturation, lightness) format. You can use a color picker [like this one](https://hslpicker.com/) to convert colors from other formats to HSL. The values are separated by a space and `%` is not required for any of the numbers. + +Example: + +```yaml +theme: + background-color: 100 20 10 + primary-color: 40 90 40 + contrast-multiplier: 1.1 +``` + +### Themes +If you don't want to spend time configuring your own theme, there are [several available themes](preconfigured-themes.md) which you can simply copy the values for. + +### Properties +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| light | bool | no | false | +| background-color | HSL | no | 240 8 9 | +| primary-color | HSL | no | 43 50 70 | +| positive-color | HSL | no | same as `primary-color` | +| negative-color | HSL | no | 0 70 70 | +| contrast-multiplier | number | no | 1 | +| text-saturation-multiplier | number | no | 1 | + +#### `light` +Whether the scheme is light or dark. This does not change the background color, it inverts the text colors so that they look appropriately on a light background. + +#### `background-color` +Color of the page and widgets. + +#### `primary-color` +Color used across the page, largely to indicate unvisited links. + +#### `positive-color` +Used to indicate that something is positive, such as stock price being up, twitch channel being live or a monitored site being online. If not set, the value of `primary-color` will be used. + +#### `negative-color` +Oppposite of `positive-color`. + +#### `contrast-multiplier` +Used to increase or decrease the contrast (in other words visibility) of the text. A value of `1.3` means that the text will be 30% lighter/darker depending on the scheme. Use this if you think that some of the text on the page is too dark and hard to read. Example: + + + +#### `text-saturation-multiplier` +Used to increase or decrease the saturation of text, useful when using a custom background color with a high amount of saturation and needing the text to have a more neutral color. `0.5` means that the saturation will be 50% lower and `1.5` means that it'll be 50% higher. + + +## Pages & Columns + + +Using pages and columns is how widgets are organized. Each page contains up to 3 columns and each column can have any number of widgets. + +### Pages +Pages are defined through a top level `pages` property. The page defined first becomes the home page and all pages get automatically added to the navigation bar in the order that they were defined. Example: + +```yaml +pages: + - name: Home + columns: ... + + - name: Videos + columns: ... + + - name: Homelab + columns: ... +``` + +### Properties +| Name | Type | Required | +| ---- | ---- | -------- | +| title | string | yes | +| slug | string | no | +| columns | array | yes | + +#### `title` +The name of the page which gets shown in the navigation bar. + +#### `slug` +The URL friendly version of the title which is used to access the page. For example if the title of the page is "RSS Feeds" you can make the page accessible via `localhost:8080/feeds` by setting the slug to `feeds`. If not defined, it will automatically be generated from the title. + +### Columns +Columns are defined for each page using a `columns` property. There are two types of columns - `full` and `small`, which refers to their width. A small column takes up a fixed amount of width (300px) and a full column takes up the all of the remaining width. You can have up to 3 columns per page and you must have either 1 or 2 full columns. Example: + +```yaml +pages: + - name: Home + columns: + - size: small + widgets: ... + - size: full + widgets: ... + - size: small + widgets: ... +``` + +### Properties +| Name | Type | Required | +| ---- | ---- | -------- | +| size | string | yes | +| widgets | array | no | + +Here are some of the possible column configurations: + + + +```yaml +columns: + - size: small + widgets: ... + - size: full + widgets: ... + - size: small + widgets: ... +``` + + + +```yaml +columns: + - size: full + widgets: ... + - size: small + widgets: ... +``` + + + +```yaml +columns: + - size: full + widgets: ... + - size: full + widgets: ... +``` + +## Widgets +Widgets are defined for each column using a `widgets` property. Example: + +```yaml +pages: + - name: Home + columns: + - size: small + widgets: + - type: weather + location: London, United Kingdom +``` + +> [!NOTE] +> +> Currently not all widgets are designed to fit every column size, however some widgets offer different "styles" that help alleviate this limitation. + +### Shared Properties +| Name | Type | Required | +| ---- | ---- | -------- | +| type | string | yes | +| title | string | no | +| cache | string | no | + +#### `type` +Used to specify the widget. + +#### `title` +The title of the widget. If left blank it will be defined by the widget. + +#### `cache` +How long to keep the fetched data in memory. The value is a string and must be a number followed by one of s, m, h, d. Examples: + +```yaml +cache: 30s # 30 seconds +cache: 5m # 5 minutes +cache: 2h # 2 hours +cache: 1d # 1 day +``` + +> [!NOTE] +> +> Not all widgets can have their cache duration modified. The calendar and weather widgets update on the hour and this cannot be changed. + +### RSS +Display a list of articles from multiple RSS feeds. + +Example: + +```yaml +- type: rss + title: News + style: horizontal-cards + feeds: + - url: https://feeds.bloomberg.com/markets/news.rss + title: Bloomberg + - url: https://moxie.foxbusiness.com/google-publisher/markets.xml + title: Fox Business + - url: https://moxie.foxbusiness.com/google-publisher/technology.xml + title: Fox Business +``` + +#### Properties +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| style | string | no | vertical-list | +| feeds | array | yes | +| limit | integer | no | 25 | +| collapse-after | integer | no | 5 | + +##### `style` +Used to change the appearance of the widget. Possible values are `vertical-list` and `horizontal-cards` where the former is intended to be used within a small column and the latter a full column. Below are previews of each style. + +`vertical-list` + + + +`horizontal-cards` + + + +##### `feeds` +An array of RSS/atom feeds. The title can optionally be changed. + +###### Properties for each feed +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| url | string | yes | | +| title | string | no | the title provided by the feed | + +##### `limit` +The maximum number of articles to show. + +##### `collapse-after` +How many articles are visible before the "SHOW MORE" button appears. Set to `-1` to never collapse. + +### Videos +Display a list of the latest videos from specific YouTube channels. + +Example: + +```yaml +- type: videos + channels: + - UCXuqSBlHAE6Xw-yeJA0Tunw + - UCBJycsmduvYEL83R_U4JriQ + - UCHnyfMqiRRG1u-2MsSQLbXA +``` + +Preview: + + +#### Properties +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| channels | array | yes | | +| limit | integer | no | 25 | + +##### `channels` +A list of channel IDs. One way of getting the ID of a channel is going to the channel's page and clicking on its description: + + + +Then scroll down and click on "Share channel", then "Copy channel ID": + + + +##### `limit` +The maximum number of videos to show. + +### Hacker News +Display a list of posts from [Hacker News](https://news.ycombinator.com/). + +Example: + +```yaml +- type: hacker-news + limit: 15 + collapse-after: 5 +``` + +Preview: + + +#### Properties +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| limit | integer | no | 15 | +| collapse-after | integer | no | 5 | + +### Reddit +Display a list of posts from a specific subreddit. + +Example: + +```yaml +- type: reddit + subreddit: technology +``` + +#### Properties +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| subreddit | string | yes | | +| style | string | no | vertical-list | +| limit | integer | no | 15 | +| collapse-after | integer | no | 5 | + +##### `subreddit` +The subreddit for which to fetch the posts from. + +##### `style` +Used to change the appearance of the widget. Possible values are `vertical-list`, `horizontal-cards` and `vertical-cards`. The first two were designed for full columns and the last for small columns. + +`vertical-list` + + + +`horizontal-cards` + + + +`vertical-cards` + + + +##### `limit` +The maximum number of posts to show. + +##### `collapse-after` +How many posts are visible before the "SHOW MORE" button appears. Set to `-1` to never collapse. Not available when using the `vertical-cards` and `horizontal-cards` styles. + +### Weather +Display weather information for a specific location. The data is provided by https://open-meteo.com/. + +Example: + +```yaml +- type: weather + location: London, United Kingdom +``` + +Preview: + + + +Each bar represents a 2 hour interval. The yellow background represents sunrise and sunset. The blue dots represent the times of the day where there is a high chance for precipitation. You can hover over the bars to view the exact temperature for that time. + +#### Properties + +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| location | string | yes | | +| hide-location | boolean | no | false | + +##### `location` +The name of the city and country to fetch weather information for. Attempting to launch the applcation with an invalid location will result in an error. You can use the [gecoding API page](https://open-meteo.com/en/docs/geocoding-api) to search for your specific location. Glance will use the first result from the list if there are multiple. + +##### `hide-location` +Optionally don't display the location name on the widget. + +### Monitor +Display a list of sites and whether they are reachable (online) or not. This is determined by sending a HEAD request to the specified URL, if the response is 200 then the site is OK. The time it took to receive a response is also shown in milliseconds. + +Example: + +```yaml +- type: monitor + cache: 1m + title: Services + sites: + - title: Jellyfin + url: https://jellyfin.yourdomain.com + icon: /assets/jellyfin-logo.png + - title: Gitea + url: https://gitea.yourdomain.com + icon: /assets/gitea-logo.png + - title: Immich + url: https://immich.yourdomain.com + icon: /assets/immich-logo.png + - title: AdGuard Home + url: https://adguard.yourdomain.com + icon: /assets/adguard-logo.png + - title: Vaultwarden + url: https://vault.yourdomain.com + icon: /assets/vaultwarden-logo.png + +``` + +Preview: + + + +You can hover over the "ERROR" text to view more information. + +#### Properties + +| Name | Type | Required | +| ---- | ---- | -------- | +| sites | array | yes | | + +##### `sites` + +Properties for each site: + +| Name | Type | Required | +| ---- | ---- | -------- | +| title | string | yes | +| url | string | yes | +| icon | string | no | + +`title` + +The title used to indicate the site. + +`url` + +The URL which will be requested and its response will determine the status of the site. + +`icon` + +Optional URL to an image which will be used as the icon for the site. Can be an external URL or internal via [server configured assets](#assets-path). + +### Releases +Display a list of releases for specific repositories on Github. Draft releases and prereleases will not be shown. + +Example: + +```yaml +- type: releases + repositories: + - immich-app/immich + - go-gitea/gitea + - dani-garcia/vaultwarden + - jellyfin/jellyfin +``` + +Preview: + + + +#### Properties + +| Name | Type | Required | Default | +| ---- | ---- | -------- | ------- | +| repositories | array | yes | | +| token | string | no | | +| limit | integer | no | 10 | +| collapse-after | integer | no | 5 | + +##### `repositories` +A list of repositores for which to fetch the latest release for. Only the name/repo is required, not the full URL. + +##### `token` +Without authentication Github allows for up to 60 requests per hour. You can easily exceed this limit and start seeing errors if you're tracking lots of repositories or your cache time is low. To circumvent this you can [create a read only token from your Github account](https://github.com/settings/personal-access-tokens/new) and provide it here. + +You can also specify the value for this token through an ENV variable using the syntax `${GITHUB_TOKEN}` where `GITHUB_TOKEN` is the name of the variable that holds the token. If you've installed Glance through docker you can specify the token in your docker-compose: + +```yaml +services: + glance: + image: glanceapp/glance + environment: + - GITHUB_TOKEN:-
+ {{ range .Groups }}
+
-
+ {{ if ne .Title "" }}{{ .Title }}{{ end }} +
-
+ {{ range .Links }}
+
- {{ .Title }} + {{ end }} +
+ {{ end }}
+
+
+
+{{ .Calendar.CurrentMonthName }}
+ -
+
- Week {{ .Calendar.CurrentWeekNumber }} +
- {{ .Calendar.CurrentYear }} +
+
+
+Mo
+ Tu
+ We
+ Th
+ Fr
+ Sa
+ Su
+
+ {{ range .Calendar.Days }}
+
+{{ end }}
diff --git a/internal/assets/templates/content.html b/internal/assets/templates/content.html
new file mode 100644
index 0000000..845507f
--- /dev/null
+++ b/internal/assets/templates/content.html
@@ -0,0 +1,9 @@
+{{ . }}
+ {{ end }}
+
+{{ range .Page.Columns }}
+
diff --git a/internal/assets/templates/document.html b/internal/assets/templates/document.html
new file mode 100644
index 0000000..04984f8
--- /dev/null
+++ b/internal/assets/templates/document.html
@@ -0,0 +1,17 @@
+
+
+
+ {{ block "document-head-before" . }}{{ end }}
+
+ {{ range .Widgets }}
+ {{ .Render }}
+ {{ end }}
+
+{{ end }}
+-
+ {{ range $i, $post := .Posts }}
+
-
+ {{ .Title }}
+
-
+
- {{ $post.TimePosted | relativeTime }} +
- {{ $post.Score | formatNumber }} points +
- {{ $post.CommentCount | formatNumber }} comments + {{ if $post.HasTargetUrl }} +
- {{ $post.TargetUrlDomain }} + {{ end }} +
+ {{ end }}
+
-
+ {{ range .Sites }}
+
-
+ {{ if .IconUrl }}
+
+ {{ end }} +
+ {{ .Title }} ++ {{ if eq .StatusStyle "good" }} + + {{ else }} + + {{ end }} +-
+ {{ if not .Status.Error }}
+
- {{ .StatusText }} +
- {{ .Status.ResponseTime.Milliseconds | formatNumber }}ms + {{ else if .Status.TimedOut }} +
- Timed Out + {{ else }} +
- ERROR + {{ end }} +
+ {{ end }}
+
+
+
+
+
+
+
+
+
+
+{{ end }}
diff --git a/internal/assets/templates/reddit-horizontal-cards.html b/internal/assets/templates/reddit-horizontal-cards.html
new file mode 100644
index 0000000..5744cea
--- /dev/null
+++ b/internal/assets/templates/reddit-horizontal-cards.html
@@ -0,0 +1,31 @@
+{{ template "widget-base.html" . }}
+
+{{ define "widget-content-classes" }}widget-content-frameless{{ end }}
+
+{{ define "widget-content" }}
+
+
+
+
+
+
+
+
+{{ end }}
diff --git a/internal/assets/templates/reddit-vertical-cards.html b/internal/assets/templates/reddit-vertical-cards.html
new file mode 100644
index 0000000..1ca0996
--- /dev/null
+++ b/internal/assets/templates/reddit-vertical-cards.html
@@ -0,0 +1,29 @@
+{{ template "widget-base.html" . }}
+
+{{ define "widget-content-classes" }}widget-content-frameless{{ end }}
+
+{{ define "widget-content" }}
+
+ {{ range .Posts }}
+
+
+ {{ if ne "" .ThumbnailUrl }}
+
+ {{ end }}
+
+ 
+
+ {{ end }}
+
+
+ {{ range .Posts }}
+
+{{ end }}
diff --git a/internal/assets/templates/releases.html b/internal/assets/templates/releases.html
new file mode 100644
index 0000000..2600dc2
--- /dev/null
+++ b/internal/assets/templates/releases.html
@@ -0,0 +1,21 @@
+{{ template "widget-base.html" . }}
+
+{{ define "widget-content" }}
+
+ {{ if ne "" .ThumbnailUrl }}
+
+ {{ end }}
+
+
+
+ {{ end }}
+
+ -
+ {{ range $i, $release := .Releases }}
+
-
+ {{ .Name }}
+
-
+
- {{ $release.TimeReleased | relativeTime }} +
- {{ $release.Version }} + {{ if gt $release.Downvotes 3 }} +
- {{ $release.Downvotes | formatNumber }} ⚠ + {{ end }} +
+ {{ end }}
+
+
+{{ end }}
diff --git a/internal/assets/templates/rss-list.html b/internal/assets/templates/rss-list.html
new file mode 100644
index 0000000..69bab75
--- /dev/null
+++ b/internal/assets/templates/rss-list.html
@@ -0,0 +1,20 @@
+{{ template "widget-base.html" . }}
+
+{{ define "widget-content" }}
+
+ {{ range .Items }}
+
+
+ {{ if ne "" .ImageURL }}
+ 
+ {{ else }}
+
+ {{ end }}
+
+
+ {{ end }}
+ -
+ {{ range $i, $item := .Items }}
+
-
+ {{ .Title }}
+
-
+
- {{ .PublishedAt | relativeTime }} + {{ if gt (len $.FeedRequests) 1 }} +
- {{ .ChannelName }} + {{ end }} +
+ {{ end }}
+
-
+ {{ range .Stocks }}
+
-
+ ++ + + +{{ .Symbol }}+{{ .Name }}+++{{ printf "%+.2f" .PercentChange }}%+${{ .Price | formatPrice }}+
+ {{ end }}
+
-
+ {{ range $i, $channel := .Channels }}
+
-
+ +++ {{ if $channel.Exists }} ++
+ {{ else }} + + {{ end }} +
+ {{ $channel.Name }} + {{ if $channel.Exists }} + {{ if $channel.IsLive }} + {{ $channel.Category }} ++-
+
- {{ $channel.LiveSince | relativeTime }} +
- {{ $channel.ViewersCount | formatViewerCount }} viewers +
Offline+ {{ end }} + {{ else }} +Not found+ {{ end }} +
+ {{ end }}
+
-
+ {{ range $i, $category := .Categories }}
+ {{ $shouldCollapseItem := shouldCollapse $i $.CollapseAfter }}
+
-
+ ++
+
+ {{ $category.Name }} ++-
+
- {{ $category.ViewersCount | formatViewerCount }} viewers + {{ if $category.IsNew }} +
- NEW + {{ end }} +
-
+ {{ range $i, $tag := $category.Tags }}
+ {{ if eq $i 0 }}
+
- {{ $tag.Name }} + {{ else }} +
- {{ $tag.Name }} + {{ end }} + {{ end }} +
+ {{ end }}
+
+
+{{ end }}
diff --git a/internal/assets/templates/weather.html b/internal/assets/templates/weather.html
new file mode 100644
index 0000000..1cccdc0
--- /dev/null
+++ b/internal/assets/templates/weather.html
@@ -0,0 +1,29 @@
+{{ template "widget-base.html" . }}
+
+{{ define "widget-content" }}
+
+ {{ range .Videos }}
+
+
+
+
+
+ {{ end }}
+ {{ .Weather.WeatherCodeAsString }}
+Feels like {{ .Weather.ApparentTemperature }}°C
+
+
+ {{ range $i, $column := .Weather.Columns }}
+
+
+{{ if not .HideLocation }}
+
+ {{ if $column.HasPrecipitation }}
+
+ {{ end }}
+ {{ if and (ge $i $.Weather.SunriseColumn) (le $i $.Weather.SunsetColumn ) }}
+
+ {{ end }}
+
+ {{ end }}
+{{ $column.Temperature | absInt }}
+
+ {{ index $.TimeLabels $i }}
+
+
+
+{{ end }}
+{{ end }}
diff --git a/internal/assets/templates/widget-base.html b/internal/assets/templates/widget-base.html
new file mode 100644
index 0000000..e37d53f
--- /dev/null
+++ b/internal/assets/templates/widget-base.html
@@ -0,0 +1,21 @@
+
diff --git a/internal/feed/calendar.go b/internal/feed/calendar.go
new file mode 100644
index 0000000..f7ec5d4
--- /dev/null
+++ b/internal/feed/calendar.go
@@ -0,0 +1,53 @@
+package feed
+
+import "time"
+
+// TODO: very inflexible, refactor to allow more customizability
+// TODO: allow changing first day of week
+// TODO: allow changing between showing the previous and next week and the entire month
+func NewCalendar(now time.Time) *Calendar {
+ year, week := now.ISOWeek()
+ weekday := now.Weekday()
+
+ if weekday == 0 {
+ weekday = 7
+ }
+
+ currentMonthDays := daysInMonth(now.Month(), year)
+
+ var previousMonthDays int
+
+ if previousMonthNumber := now.Month() - 1; previousMonthNumber < 1 {
+ previousMonthDays = daysInMonth(12, year-1)
+ } else {
+ previousMonthDays = daysInMonth(previousMonthNumber, year)
+ }
+
+ startDaysFrom := now.Day() - int(weekday+6)
+
+ days := make([]int, 21)
+
+ for i := 0; i < 21; i++ {
+ day := startDaysFrom + i
+
+ if day < 1 {
+ day = previousMonthDays + day
+ } else if day > currentMonthDays {
+ day = day - currentMonthDays
+ }
+
+ days[i] = day
+ }
+
+ return &Calendar{
+ CurrentDay: now.Day(),
+ CurrentWeekNumber: week,
+ CurrentMonthName: now.Month().String(),
+ CurrentYear: year,
+ Days: days,
+ }
+}
+
+func daysInMonth(m time.Month, year int) int {
+ return time.Date(year, m+1, 0, 0, 0, 0, 0, time.UTC).Day()
+}
diff --git a/internal/feed/github.go b/internal/feed/github.go
new file mode 100644
index 0000000..4a34182
--- /dev/null
+++ b/internal/feed/github.go
@@ -0,0 +1,117 @@
+package feed
+
+import (
+ "fmt"
+ "log/slog"
+ "net/http"
+ "time"
+)
+
+type githubReleaseResponseJson struct {
+ TagName string `json:"tag_name"`
+ PublishedAt string `json:"published_at"`
+ HtmlUrl string `json:"html_url"`
+ Draft bool `json:"draft"`
+ PreRelease bool `json:"prerelease"`
+ Reactions struct {
+ Downvotes int `json:"-1"`
+ } `json:"reactions"`
+}
+
+func parseGithubTime(t string) time.Time {
+ parsedTime, err := time.Parse("2006-01-02T15:04:05Z", t)
+
+ if err != nil {
+ return time.Now()
+ }
+
+ return parsedTime
+}
+
+func FetchLatestReleasesFromGithub(repositories []string, token string) (AppReleases, error) {
+ appReleases := make(AppReleases, 0, len(repositories))
+
+ if len(repositories) == 0 {
+ return appReleases, nil
+ }
+
+ requests := make([]*http.Request, len(repositories))
+
+ for i, repository := range repositories {
+ request, _ := http.NewRequest("GET", fmt.Sprintf("https://api.github.com/repos/%s/releases?per_page=10", repository), nil)
+
+ if token != "" {
+ request.Header.Add("Authorization", fmt.Sprintf("Bearer %s", token))
+ }
+
+ requests[i] = request
+ }
+
+ task := decodeJsonFromRequestTask[[]githubReleaseResponseJson](defaultClient)
+ job := newJob(task, requests).withWorkers(15)
+ responses, errs, err := workerPoolDo(job)
+
+ if err != nil {
+ return nil, err
+ }
+
+ var failed int
+
+ for i := range responses {
+ if errs[i] != nil {
+ failed++
+ slog.Error("Failed to fetch or parse github release", "error", errs[i], "url", requests[i].URL)
+ continue
+ }
+
+ releases := responses[i]
+
+ if len(releases) < 1 {
+ failed++
+ slog.Error("No releases found", "repository", repositories[i], "url", requests[i].URL)
+ continue
+ }
+
+ var liveRelease *githubReleaseResponseJson
+
+ for i := range releases {
+ release := &releases[i]
+
+ if !release.Draft && !release.PreRelease {
+ liveRelease = release
+ break
+ }
+ }
+
+ if liveRelease == nil {
+ slog.Error("No live release found", "repository", repositories[i], "url", requests[i].URL)
+ continue
+ }
+
+ version := liveRelease.TagName
+
+ if version[0] != 'v' {
+ version = "v" + version
+ }
+
+ appReleases = append(appReleases, AppRelease{
+ Name: repositories[i],
+ Version: version,
+ NotesUrl: liveRelease.HtmlUrl,
+ TimeReleased: parseGithubTime(liveRelease.PublishedAt),
+ Downvotes: liveRelease.Reactions.Downvotes,
+ })
+ }
+
+ if len(appReleases) == 0 {
+ return nil, ErrNoContent
+ }
+
+ appReleases.SortByNewest()
+
+ if failed > 0 {
+ return appReleases, fmt.Errorf("%w: could not get %d releases", ErrPartialContent, failed)
+ }
+
+ return appReleases, nil
+}
diff --git a/internal/feed/hacker-news.go b/internal/feed/hacker-news.go
new file mode 100644
index 0000000..8e7ad73
--- /dev/null
+++ b/internal/feed/hacker-news.go
@@ -0,0 +1,89 @@
+package feed
+
+import (
+ "fmt"
+ "log/slog"
+ "net/http"
+ "strconv"
+ "time"
+)
+
+type hackerNewsPostResponseJson struct {
+ Id int `json:"id"`
+ Score int `json:"score"`
+ Title string `json:"title"`
+ TargetUrl string `json:"url,omitempty"`
+ CommentCount int `json:"descendants"`
+ TimePosted int64 `json:"time"`
+}
+
+func getHackerNewsTopPostIds() ([]int, error) {
+ request, _ := http.NewRequest("GET", "https://hacker-news.firebaseio.com/v0/topstories.json", nil)
+ response, err := decodeJsonFromRequest[[]int](defaultClient, request)
+
+ if err != nil {
+ return nil, fmt.Errorf("%w: could not fetch list of post IDs", ErrNoContent)
+ }
+
+ return response, nil
+}
+
+func getHackerNewsPostsFromIds(postIds []int) (ForumPosts, error) {
+ requests := make([]*http.Request, len(postIds))
+
+ for i, id := range postIds {
+ request, _ := http.NewRequest("GET", fmt.Sprintf("https://hacker-news.firebaseio.com/v0/item/%d.json", id), nil)
+ requests[i] = request
+ }
+
+ task := decodeJsonFromRequestTask[hackerNewsPostResponseJson](defaultClient)
+ job := newJob(task, requests).withWorkers(30)
+ results, errs, err := workerPoolDo(job)
+
+ if err != nil {
+ return nil, err
+ }
+
+ posts := make(ForumPosts, 0, len(postIds))
+
+ for i := range results {
+ if errs[i] != nil {
+ slog.Error("Failed to fetch or parse hacker news post", "error", errs[i], "url", requests[i].URL)
+ continue
+ }
+
+ posts = append(posts, ForumPost{
+ Title: results[i].Title,
+ DiscussionUrl: "https://news.ycombinator.com/item?id=" + strconv.Itoa(results[i].Id),
+ TargetUrl: results[i].TargetUrl,
+ TargetUrlDomain: extractDomainFromUrl(results[i].TargetUrl),
+ CommentCount: results[i].CommentCount,
+ Score: results[i].Score,
+ TimePosted: time.Unix(results[i].TimePosted, 0),
+ })
+ }
+
+ if len(posts) == 0 {
+ return nil, ErrNoContent
+ }
+
+ if len(posts) != len(postIds) {
+ return posts, fmt.Errorf("%w could not fetch some hacker news posts", ErrPartialContent)
+ }
+
+ return posts, nil
+}
+
+func FetchHackerNewsTopPosts(limit int) (ForumPosts, error) {
+ postIds, err := getHackerNewsTopPostIds()
+
+ if err != nil {
+ return nil, err
+ }
+
+ if len(postIds) > limit {
+ postIds = postIds[:limit]
+ }
+
+ return getHackerNewsPostsFromIds(postIds)
+}
diff --git a/internal/feed/monitor.go b/internal/feed/monitor.go
new file mode 100644
index 0000000..e08964f
--- /dev/null
+++ b/internal/feed/monitor.go
@@ -0,0 +1,51 @@
+package feed
+
+import (
+ "context"
+ "errors"
+ "net/http"
+ "time"
+)
+
+type SiteStatus struct {
+ Code int
+ TimedOut bool
+ ResponseTime time.Duration
+ Error error
+}
+
+func getSiteStatusTask(request *http.Request) (SiteStatus, error) {
+ ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
+ defer cancel()
+ request = request.WithContext(ctx)
+ start := time.Now()
+ response, err := http.DefaultClient.Do(request)
+ took := time.Since(start)
+ status := SiteStatus{ResponseTime: took}
+
+ if err != nil {
+ if errors.Is(err, context.DeadlineExceeded) {
+ status.TimedOut = true
+ }
+
+ status.Error = err
+ return status, err
+ }
+
+ defer response.Body.Close()
+
+ status.Code = response.StatusCode
+
+ return status, nil
+}
+
+func FetchStatusesForRequests(requests []*http.Request) ([]SiteStatus, error) {
+ job := newJob(getSiteStatusTask, requests).withWorkers(20)
+ results, _, err := workerPoolDo(job)
+
+ if err != nil {
+ return nil, err
+ }
+
+ return results, nil
+}
diff --git a/internal/feed/openmeteo.go b/internal/feed/openmeteo.go
new file mode 100644
index 0000000..604ac05
--- /dev/null
+++ b/internal/feed/openmeteo.go
@@ -0,0 +1,151 @@
+package feed
+
+import (
+ "fmt"
+ "math"
+ "net/http"
+ "net/url"
+ "slices"
+ "time"
+
+ _ "time/tzdata"
+)
+
+type PlacesResponseJson struct {
+ Results []PlaceJson
+}
+
+type PlaceJson struct {
+ Name string
+ Latitude float64
+ Longitude float64
+ Timezone string
+ Country string
+ location *time.Location
+}
+
+type WeatherResponseJson struct {
+ Daily struct {
+ Sunrise []int64 `json:"sunrise"`
+ Sunset []int64 `json:"sunset"`
+ } `json:"daily"`
+
+ Hourly struct {
+ Temperature []float64 `json:"temperature_2m"`
+ PrecipitationProbability []int `json:"precipitation_probability"`
+ } `json:"hourly"`
+
+ Current struct {
+ Temperature float64 `json:"temperature_2m"`
+ ApparentTemperature float64 `json:"apparent_temperature"`
+ WeatherCode int `json:"weather_code"`
+ } `json:"current"`
+}
+
+type weatherColumn struct {
+ Temperature int
+ Scale float64
+ HasPrecipitation bool
+}
+
+func FetchPlaceFromName(location string) (*PlaceJson, error) {
+ requestUrl := fmt.Sprintf("https://geocoding-api.open-meteo.com/v1/search?name=%s&count=1&language=en&format=json", url.QueryEscape(location))
+ request, _ := http.NewRequest("GET", requestUrl, nil)
+ responseJson, err := decodeJsonFromRequest[PlacesResponseJson](defaultClient, request)
+
+ if err != nil {
+ return nil, fmt.Errorf("could not fetch places data: %v", err)
+ }
+
+ if len(responseJson.Results) == 0 {
+ return nil, fmt.Errorf("no places found for %s", location)
+ }
+
+ place := &responseJson.Results[0]
+
+ loc, err := time.LoadLocation(place.Timezone)
+
+ if err != nil {
+ return nil, fmt.Errorf("could not load location: %v", err)
+ }
+
+ place.location = loc
+
+ return place, nil
+}
+
+func barIndexFromHour(h int) int {
+ return h / 2
+}
+
+// TODO: bunch of spaget, refactor
+// TODO: allow changing between C and F
+func FetchWeatherForPlace(place *PlaceJson) (*Weather, error) {
+ query := url.Values{}
+
+ query.Add("latitude", fmt.Sprintf("%f", place.Latitude))
+ query.Add("longitude", fmt.Sprintf("%f", place.Longitude))
+ query.Add("timeformat", "unixtime")
+ query.Add("timezone", place.Timezone)
+ query.Add("forecast_days", "1")
+ query.Add("current", "temperature_2m,apparent_temperature,weather_code,wind_speed_10m")
+ query.Add("hourly", "temperature_2m,precipitation_probability")
+ query.Add("daily", "sunrise,sunset")
+
+ requestUrl := "https://api.open-meteo.com/v1/forecast?" + query.Encode()
+ request, _ := http.NewRequest("GET", requestUrl, nil)
+ responseJson, err := decodeJsonFromRequest[WeatherResponseJson](defaultClient, request)
+
+ if err != nil {
+ return nil, fmt.Errorf("%w: %v", ErrNoContent, err)
+ }
+
+ now := time.Now().In(place.location)
+ bars := make([]weatherColumn, 0, 24)
+ currentBar := barIndexFromHour(now.Hour())
+ sunriseBar := barIndexFromHour(time.Unix(int64(responseJson.Daily.Sunrise[0]), 0).In(place.location).Hour())
+ sunsetBar := barIndexFromHour(time.Unix(int64(responseJson.Daily.Sunset[0]), 0).In(place.location).Hour()) - 1
+
+ if sunsetBar < 0 {
+ sunsetBar = 0
+ }
+
+ if len(responseJson.Hourly.Temperature) == 24 {
+ temperatures := make([]int, 12)
+ precipitations := make([]bool, 12)
+
+ t := responseJson.Hourly.Temperature
+ p := responseJson.Hourly.PrecipitationProbability
+
+ for i := 0; i < 24; i += 2 {
+ if i/2 == currentBar {
+ temperatures[i/2] = int(responseJson.Current.Temperature)
+ } else {
+ temperatures[i/2] = int(math.Round((t[i] + t[i+1]) / 2))
+ }
+
+ precipitations[i/2] = (p[i]+p[i+1])/2 > 75
+ }
+
+ minT := slices.Min(temperatures)
+ maxT := slices.Max(temperatures)
+
+ for i := 0; i < 12; i++ {
+ bars = append(bars, weatherColumn{
+ Temperature: temperatures[i],
+ Scale: float64(temperatures[i]-minT) / float64(maxT-minT),
+ HasPrecipitation: precipitations[i],
+ })
+ }
+ }
+
+ return &Weather{
+ Temperature: int(responseJson.Current.Temperature),
+ ApparentTemperature: int(responseJson.Current.ApparentTemperature),
+ WeatherCode: responseJson.Current.WeatherCode,
+ CurrentColumn: currentBar,
+ SunriseColumn: sunriseBar,
+ SunsetColumn: sunsetBar,
+ Columns: bars,
+ }, nil
+}
diff --git a/internal/feed/primitives.go b/internal/feed/primitives.go
new file mode 100644
index 0000000..7f4f464
--- /dev/null
+++ b/internal/feed/primitives.go
@@ -0,0 +1,183 @@
+package feed
+
+import (
+ "math"
+ "sort"
+ "time"
+)
+
+type ForumPost struct {
+ Title string
+ DiscussionUrl string
+ TargetUrl string
+ TargetUrlDomain string
+ ThumbnailUrl string
+ CommentCount int
+ Score int
+ Engagement float64
+ TimePosted time.Time
+}
+
+type ForumPosts []ForumPost
+
+type Calendar struct {
+ CurrentDay int
+ CurrentWeekNumber int
+ CurrentMonthName string
+ CurrentYear int
+ Days []int
+}
+
+type Weather struct {
+ Temperature int
+ ApparentTemperature int
+ WeatherCode int
+ CurrentColumn int
+ SunriseColumn int
+ SunsetColumn int
+ Columns []weatherColumn
+}
+
+type AppRelease struct {
+ Name string
+ Version string
+ NotesUrl string
+ TimeReleased time.Time
+ Downvotes int
+}
+
+type AppReleases []AppRelease
+
+type Video struct {
+ ThumbnailUrl string
+ Title string
+ Url string
+ Author string
+ AuthorUrl string
+ TimePosted time.Time
+}
+
+type Videos []Video
+
+type Stock struct {
+ Name string
+ Symbol string
+ Price float64
+ PercentChange float64
+ SvgChartPoints string
+}
+
+type Stocks []Stock
+
+func (t Stocks) SortByAbsChange() {
+ sort.Slice(t, func(i, j int) bool {
+ return math.Abs(t[i].PercentChange) > math.Abs(t[j].PercentChange)
+ })
+}
+
+var weatherCodeTable = map[int]string{
+ 0: "Clear Sky",
+ 1: "Mainly Clear",
+ 2: "Partly Cloudy",
+ 3: "Overcast",
+ 45: "Fog",
+ 48: "Rime Fog",
+ 51: "Drizzle",
+ 53: "Drizzle",
+ 55: "Drizzle",
+ 56: "Drizzle",
+ 57: "Drizzle",
+ 61: "Rain",
+ 63: "Moderate Rain",
+ 65: "Heavy Rain",
+ 66: "Freezing Rain",
+ 67: "Freezing Rain",
+ 71: "Snow",
+ 73: "Moderate Snow",
+ 75: "Heavy Snow",
+ 77: "Snow Grains",
+ 80: "Rain",
+ 81: "Moderate Rain",
+ 82: "Heavy Rain",
+ 85: "Snow",
+ 86: "Snow",
+ 95: "Thunderstorm",
+ 96: "Thunderstorm",
+ 99: "Thunderstorm",
+}
+
+func (w *Weather) WeatherCodeAsString() string {
+ if weatherCode, ok := weatherCodeTable[w.WeatherCode]; ok {
+ return weatherCode
+ }
+
+ return ""
+}
+
+const depreciatePostsOlderThanHours = 7
+const maxDepreciation = 0.9
+const maxDepreciationAfterHours = 24
+
+func (p ForumPosts) CalculateEngagement() {
+ var totalComments int
+ var totalScore int
+
+ for i := range p {
+ totalComments += p[i].CommentCount
+ totalScore += p[i].Score
+ }
+
+ numberOfPosts := float64(len(p))
+ averageComments := float64(totalComments) / numberOfPosts
+ averageScore := float64(totalScore) / numberOfPosts
+
+ for i := range p {
+ p[i].Engagement = (float64(p[i].CommentCount)/averageComments + float64(p[i].Score)/averageScore) / 2
+
+ elapsed := time.Since(p[i].TimePosted)
+
+ if elapsed < time.Hour*depreciatePostsOlderThanHours {
+ continue
+ }
+
+ p[i].Engagement *= 1.0 - (math.Max(elapsed.Hours()-depreciatePostsOlderThanHours, maxDepreciationAfterHours)/maxDepreciationAfterHours)*maxDepreciation
+ }
+}
+
+func (p ForumPosts) SortByEngagement() {
+ sort.Slice(p, func(i, j int) bool {
+ return p[i].Engagement > p[j].Engagement
+ })
+}
+
+func (s *ForumPost) HasTargetUrl() bool {
+ return s.TargetUrl != ""
+}
+
+func (p ForumPosts) FilterPostedBefore(postedBefore time.Duration) []ForumPost {
+ recent := make([]ForumPost, 0, len(p))
+
+ for i := range p {
+ if time.Since(p[i].TimePosted) < postedBefore {
+ recent = append(recent, p[i])
+ }
+ }
+
+ return recent
+}
+
+func (r AppReleases) SortByNewest() AppReleases {
+ sort.Slice(r, func(i, j int) bool {
+ return r[i].TimeReleased.After(r[j].TimeReleased)
+ })
+
+ return r
+}
+
+func (v Videos) SortByNewest() Videos {
+ sort.Slice(v, func(i, j int) bool {
+ return v[i].TimePosted.After(v[j].TimePosted)
+ })
+
+ return v
+}
diff --git a/internal/feed/reddit.go b/internal/feed/reddit.go
new file mode 100644
index 0000000..b8449f9
--- /dev/null
+++ b/internal/feed/reddit.go
@@ -0,0 +1,83 @@
+package feed
+
+import (
+ "fmt"
+ "html"
+ "net/http"
+ "net/url"
+ "time"
+)
+
+type subredditResponseJson struct {
+ Data struct {
+ Children []struct {
+ Data struct {
+ Title string `json:"title"`
+ Upvotes int `json:"ups"`
+ Url string `json:"url"`
+ Time float64 `json:"created"`
+ CommentsCount int `json:"num_comments"`
+ Domain string `json:"domain"`
+ Permalink string `json:"permalink"`
+ Stickied bool `json:"stickied"`
+ Pinned bool `json:"pinned"`
+ IsSelf bool `json:"is_self"`
+ Thumbnail string `json:"thumbnail"`
+ } `json:"data"`
+ } `json:"children"`
+ } `json:"data"`
+}
+
+func FetchSubredditPosts(subreddit string) (ForumPosts, error) {
+ requestUrl := fmt.Sprintf("https://www.reddit.com/r/%s/hot.json", url.QueryEscape(subreddit))
+ request, err := http.NewRequest("GET", requestUrl, nil)
+
+ if err != nil {
+ return nil, err
+ }
+
+ // Required to increase rate limit, otherwise Reddit randomly returns 429 even after just 2 requests
+ addBrowserUserAgentHeader(request)
+ responseJson, err := decodeJsonFromRequest[subredditResponseJson](defaultClient, request)
+
+ if err != nil {
+ return nil, err
+ }
+
+ if len(responseJson.Data.Children) == 0 {
+ return nil, fmt.Errorf("no posts found")
+ }
+
+ posts := make(ForumPosts, 0, len(responseJson.Data.Children))
+
+ for i := range responseJson.Data.Children {
+ post := &responseJson.Data.Children[i].Data
+
+ if post.Stickied || post.Pinned {
+ continue
+ }
+
+ forumPost := ForumPost{
+ Title: html.UnescapeString(post.Title),
+ DiscussionUrl: "https://www.reddit.com" + post.Permalink,
+ TargetUrlDomain: post.Domain,
+ CommentCount: post.CommentsCount,
+ Score: post.Upvotes,
+ TimePosted: time.Unix(int64(post.Time), 0),
+ }
+
+ if post.Thumbnail != "" && post.Thumbnail != "self" && post.Thumbnail != "default" {
+ forumPost.ThumbnailUrl = post.Thumbnail
+ }
+
+ if !post.IsSelf {
+ forumPost.TargetUrl = post.Url
+ }
+
+ posts = append(posts, forumPost)
+ }
+
+ posts.CalculateEngagement()
+
+ return posts, nil
+}
diff --git a/internal/feed/requests.go b/internal/feed/requests.go
new file mode 100644
index 0000000..2181b75
--- /dev/null
+++ b/internal/feed/requests.go
@@ -0,0 +1,195 @@
+package feed
+
+import (
+ "context"
+ "encoding/json"
+ "encoding/xml"
+ "fmt"
+ "io"
+ "net/http"
+ "sync"
+ "time"
+)
+
+var defaultClient = &http.Client{
+ Timeout: 5 * time.Second,
+}
+
+type RequestDoer interface {
+ Do(*http.Request) (*http.Response, error)
+}
+
+func addBrowserUserAgentHeader(request *http.Request) {
+ request.Header.Set("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:123.0) Gecko/20100101 Firefox/123.0")
+}
+
+func decodeJsonFromRequest[T any](client RequestDoer, request *http.Request) (T, error) {
+ response, err := client.Do(request)
+ var result T
+
+ if err != nil {
+ return result, err
+ }
+
+ defer response.Body.Close()
+
+ body, err := io.ReadAll(response.Body)
+
+ if err != nil {
+ return result, err
+ }
+
+ if response.StatusCode != http.StatusOK {
+ return result, fmt.Errorf("unexpected status code %d for %s, response: %s", response.StatusCode, request.URL, string(body))
+ }
+
+ err = json.Unmarshal(body, &result)
+
+ if err != nil {
+ return result, err
+ }
+
+ return result, nil
+}
+
+func decodeJsonFromRequestTask[T any](client RequestDoer) func(*http.Request) (T, error) {
+ return func(request *http.Request) (T, error) {
+ return decodeJsonFromRequest[T](client, request)
+ }
+}
+
+// TODO: tidy up, these are a copy of the above but with a line changed
+func decodeXmlFromRequest[T any](client RequestDoer, request *http.Request) (T, error) {
+ response, err := client.Do(request)
+ var result T
+
+ if err != nil {
+ return result, err
+ }
+
+ defer response.Body.Close()
+
+ body, err := io.ReadAll(response.Body)
+
+ if err != nil {
+ return result, err
+ }
+
+ if response.StatusCode != http.StatusOK {
+ return result, fmt.Errorf("unexpected status code %d for %s, response: %s", response.StatusCode, request.URL, string(body))
+ }
+
+ err = xml.Unmarshal(body, &result)
+
+ if err != nil {
+ return result, err
+ }
+
+ return result, nil
+}
+
+func decodeXmlFromRequestTask[T any](client RequestDoer) func(*http.Request) (T, error) {
+ return func(request *http.Request) (T, error) {
+ return decodeXmlFromRequest[T](client, request)
+ }
+}
+
+type workerPoolTask[I any, O any] struct {
+ index int
+ input I
+ output O
+ err error
+}
+
+type workerPoolJob[I any, O any] struct {
+ data []I
+ workers int
+ task func(I) (O, error)
+ ctx context.Context
+}
+
+const defaultNumWorkers = 10
+
+func (job *workerPoolJob[I, O]) withWorkers(workers int) *workerPoolJob[I, O] {
+ if workers == 0 {
+ job.workers = defaultNumWorkers
+ } else if workers > len(job.data) {
+ job.workers = len(job.data)
+ } else {
+ job.workers = workers
+ }
+
+ return job
+}
+
+// func (job *workerPoolJob[I, O]) withContext(ctx context.Context) *workerPoolJob[I, O] {
+// if ctx != nil {
+// job.ctx = ctx
+// }
+
+// return job
+// }
+
+func newJob[I any, O any](task func(I) (O, error), data []I) *workerPoolJob[I, O] {
+ return &workerPoolJob[I, O]{
+ workers: defaultNumWorkers,
+ task: task,
+ data: data,
+ ctx: context.Background(),
+ }
+}
+
+func workerPoolDo[I any, O any](job *workerPoolJob[I, O]) ([]O, []error, error) {
+ results := make([]O, len(job.data))
+ errs := make([]error, len(job.data))
+
+ if len(job.data) == 0 {
+ return results, errs, nil
+ }
+
+ tasksQueue := make(chan *workerPoolTask[I, O])
+ resultsQueue := make(chan *workerPoolTask[I, O])
+
+ var wg sync.WaitGroup
+
+ for range job.workers {
+ wg.Add(1)
+ go func() {
+ defer wg.Done()
+
+ for t := range tasksQueue {
+ t.output, t.err = job.task(t.input)
+ resultsQueue <- t
+ }
+ }()
+ }
+
+ var err error
+
+ go func() {
+ loop:
+ for i := range job.data {
+ select {
+ default:
+ tasksQueue <- &workerPoolTask[I, O]{
+ index: i,
+ input: job.data[i],
+ }
+ case <-job.ctx.Done():
+ err = job.ctx.Err()
+ break loop
+ }
+ }
+
+ close(tasksQueue)
+ wg.Wait()
+ close(resultsQueue)
+ }()
+
+ for task := range resultsQueue {
+ errs[task.index] = task.err
+ results[task.index] = task.output
+ }
+
+ return results, errs, err
+}
diff --git a/internal/feed/rss.go b/internal/feed/rss.go
new file mode 100644
index 0000000..533bb11
--- /dev/null
+++ b/internal/feed/rss.go
@@ -0,0 +1,117 @@
+package feed
+
+import (
+ "context"
+ "fmt"
+ "log/slog"
+ "sort"
+ "time"
+
+ "github.com/mmcdole/gofeed"
+)
+
+type RSSFeedItem struct {
+ ChannelName string
+ ChannelURL string
+ Title string
+ Link string
+ ImageURL string
+ PublishedAt time.Time
+}
+
+type RSSFeedRequest struct {
+ Url string `yaml:"url"`
+ Title string `yaml:"title"`
+}
+
+type RSSFeedItems []RSSFeedItem
+
+func (f RSSFeedItems) SortByNewest() RSSFeedItems {
+ sort.Slice(f, func(i, j int) bool {
+ return f[i].PublishedAt.After(f[j].PublishedAt)
+ })
+
+ return f
+}
+
+var feedParser = gofeed.NewParser()
+
+func getItemsFromRSSFeedTask(request RSSFeedRequest) ([]RSSFeedItem, error) {
+ ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
+ defer cancel()
+
+ feed, err := feedParser.ParseURLWithContext(request.Url, ctx)
+
+ if err != nil {
+ return nil, err
+ }
+
+ items := make(RSSFeedItems, 0, len(feed.Items))
+
+ for i := range feed.Items {
+ item := feed.Items[i]
+
+ rssItem := RSSFeedItem{
+ ChannelURL: feed.Link,
+ Title: item.Title,
+ Link: item.Link,
+ }
+
+ if request.Title != "" {
+ rssItem.ChannelName = request.Title
+ } else {
+ rssItem.ChannelName = feed.Title
+ }
+
+ if item.Image != nil {
+ rssItem.ImageURL = item.Image.URL
+ } else if feed.Image != nil {
+ rssItem.ImageURL = feed.Image.URL
+ }
+
+ if item.PublishedParsed != nil {
+ rssItem.PublishedAt = *item.PublishedParsed
+ } else {
+ rssItem.PublishedAt = time.Now()
+ }
+
+ items = append(items, rssItem)
+ }
+
+ return items, nil
+}
+
+func GetItemsFromRSSFeeds(requests []RSSFeedRequest) (RSSFeedItems, error) {
+ job := newJob(getItemsFromRSSFeedTask, requests).withWorkers(10)
+ feeds, errs, err := workerPoolDo(job)
+
+ if err != nil {
+ return nil, fmt.Errorf("%w: %v", ErrNoContent, err)
+ }
+
+ failed := 0
+
+ entries := make(RSSFeedItems, 0, len(feeds)*10)
+
+ for i := range feeds {
+ if errs[i] != nil {
+ failed++
+ slog.Error("failed to get rss feed", "error", errs[i], "url", requests[i].Url)
+ continue
+ }
+
+ entries = append(entries, feeds[i]...)
+ }
+
+ if len(entries) == 0 {
+ return nil, ErrNoContent
+ }
+
+ entries.SortByNewest()
+
+ if failed > 0 {
+ return entries, fmt.Errorf("%w: missing %d RSS feeds", ErrPartialContent, failed)
+ }
+
+ return entries, nil
+}
diff --git a/internal/feed/twitch.go b/internal/feed/twitch.go
new file mode 100644
index 0000000..1ff82ee
--- /dev/null
+++ b/internal/feed/twitch.go
@@ -0,0 +1,248 @@
+package feed
+
+import (
+ "encoding/json"
+ "errors"
+ "fmt"
+ "log/slog"
+ "net/http"
+ "slices"
+ "sort"
+ "strings"
+ "time"
+)
+
+type TwitchCategory struct {
+ Slug string `json:"slug"`
+ Name string `json:"name"`
+ AvatarUrl string `json:"avatarURL"`
+ ViewersCount int `json:"viewersCount"`
+ Tags []struct {
+ Name string `json:"tagName"`
+ } `json:"tags"`
+ GameReleaseDate string `json:"originalReleaseDate"`
+ IsNew bool `json:"-"`
+}
+
+type TwitchChannel struct {
+ Login string
+ Exists bool
+ Name string
+ AvatarUrl string
+ IsLive bool
+ LiveSince time.Time
+ Category string
+ CategorySlug string
+ ViewersCount int
+}
+
+type TwitchChannels []TwitchChannel
+
+func (channels TwitchChannels) SortByViewers() {
+ sort.Slice(channels, func(i, j int) bool {
+ return channels[i].ViewersCount > channels[j].ViewersCount
+ })
+}
+
+type twitchOperationResponse struct {
+ Data json.RawMessage
+ Extensions struct {
+ OperationName string `json:"operationName"`
+ }
+}
+
+type twitchChannelShellOperationResponse struct {
+ UserOrError struct {
+ Type string `json:"__typename"`
+ DisplayName string `json:"displayName"`
+ ProfileImageUrl string `json:"profileImageURL"`
+ Stream *struct {
+ ViewersCount int `json:"viewersCount"`
+ }
+ } `json:"userOrError"`
+}
+
+type twitchStreamMetadataOperationResponse struct {
+ UserOrNull *struct {
+ Stream *struct {
+ StartedAt string `json:"createdAt"`
+ Game *struct {
+ Slug string `json:"slug"`
+ Name string `json:"name"`
+ } `json:"game"`
+ } `json:"stream"`
+ } `json:"user"`
+}
+
+type twitchDirectoriesOperationResponse struct {
+ Data struct {
+ DirectoriesWithTags struct {
+ Edges []struct {
+ Node TwitchCategory `json:"node"`
+ } `json:"edges"`
+ } `json:"directoriesWithTags"`
+ } `json:"data"`
+}
+
+const twitchGqlEndpoint = "https://gql.twitch.tv/gql"
+const twitchGqlClientId = "kimne78kx3ncx6brgo4mv6wki5h1ko"
+
+const twitchDirectoriesOperationRequestBody = `[{"operationName": "BrowsePage_AllDirectories","variables": {"limit": %d,"options": {"sort": "VIEWER_COUNT","tags": []}},"extensions": {"persistedQuery": {"version": 1,"sha256Hash": "2f67f71ba89f3c0ed26a141ec00da1defecb2303595f5cda4298169549783d9e"}}}]`
+
+func FetchTopGamesFromTwitch(exclude []string, limit int) ([]TwitchCategory, error) {
+ reader := strings.NewReader(fmt.Sprintf(twitchDirectoriesOperationRequestBody, len(exclude)+limit))
+ request, _ := http.NewRequest("POST", twitchGqlEndpoint, reader)
+ request.Header.Add("Client-ID", twitchGqlClientId)
+ response, err := decodeJsonFromRequest[[]twitchDirectoriesOperationResponse](defaultClient, request)
+
+ if err != nil {
+ return nil, err
+ }
+
+ if len(response) == 0 {
+ return nil, errors.New("no categories could be retrieved")
+ }
+
+ edges := (response)[0].Data.DirectoriesWithTags.Edges
+ categories := make([]TwitchCategory, 0, len(edges))
+
+ for i := range edges {
+ if slices.Contains(exclude, edges[i].Node.Slug) {
+ continue
+ }
+
+ category := &edges[i].Node
+ category.AvatarUrl = strings.Replace(category.AvatarUrl, "285x380", "144x192", 1)
+
+ if len(category.Tags) > 2 {
+ category.Tags = category.Tags[:2]
+ }
+
+ gameReleasedDate, err := time.Parse("2006-01-02T15:04:05Z", category.GameReleaseDate)
+
+ if err == nil {
+ if time.Since(gameReleasedDate) < 14*24*time.Hour {
+ category.IsNew = true
+ }
+ }
+
+ categories = append(categories, *category)
+ }
+
+ if len(categories) > limit {
+ categories = categories[:limit]
+ }
+
+ return categories, nil
+}
+
+const twitchChannelStatusOperationRequestBody = `[{"operationName":"ChannelShell","variables":{"login":"%s"},"extensions":{"persistedQuery":{"version":1,"sha256Hash":"580ab410bcd0c1ad194224957ae2241e5d252b2c5173d8e0cce9d32d5bb14efe"}}},{"operationName":"StreamMetadata","variables":{"channelLogin":"%s"},"extensions":{"persistedQuery":{"version":1,"sha256Hash":"676ee2f834ede42eb4514cdb432b3134fefc12590080c9a2c9bb44a2a4a63266"}}}]`
+
+// TODO: rework
+// The operations for multiple channels can all be sent in a single request
+// rather than sending a separate request for each channel. Need to figure out
+// what the limit is for max operations per request and batch operations in
+// multiple requests if number of channels exceeds allowed limit.
+
+func fetchChannelFromTwitchTask(channel string) (TwitchChannel, error) {
+ result := TwitchChannel{
+ Login: strings.ToLower(channel),
+ }
+
+ reader := strings.NewReader(fmt.Sprintf(twitchChannelStatusOperationRequestBody, channel, channel))
+ request, _ := http.NewRequest("POST", twitchGqlEndpoint, reader)
+ request.Header.Add("Client-ID", twitchGqlClientId)
+
+ response, err := decodeJsonFromRequest[[]twitchOperationResponse](defaultClient, request)
+
+ if err != nil {
+ return result, err
+ }
+
+ if len(response) != 2 {
+ return result, fmt.Errorf("expected 2 operation responses, got %d", len(response))
+ }
+
+ var channelShell twitchChannelShellOperationResponse
+ var streamMetadata twitchStreamMetadataOperationResponse
+
+ for i := range response {
+ switch response[i].Extensions.OperationName {
+ case "ChannelShell":
+ err = json.Unmarshal(response[i].Data, &channelShell)
+
+ if err != nil {
+ return result, fmt.Errorf("failed to unmarshal channel shell: %w", err)
+ }
+ case "StreamMetadata":
+ err = json.Unmarshal(response[i].Data, &streamMetadata)
+
+ if err != nil {
+ return result, fmt.Errorf("failed to unmarshal stream metadata: %w", err)
+ }
+ default:
+ return result, fmt.Errorf("unknown operation name: %s", response[i].Extensions.OperationName)
+ }
+ }
+
+ if channelShell.UserOrError.Type != "User" {
+ result.Name = result.Login
+ return result, nil
+ }
+
+ result.Exists = true
+ result.Name = channelShell.UserOrError.DisplayName
+ result.AvatarUrl = channelShell.UserOrError.ProfileImageUrl
+
+ if channelShell.UserOrError.Stream != nil {
+ result.IsLive = true
+ result.ViewersCount = channelShell.UserOrError.Stream.ViewersCount
+
+ if streamMetadata.UserOrNull != nil && streamMetadata.UserOrNull.Stream != nil && streamMetadata.UserOrNull.Stream.Game != nil {
+ result.Category = streamMetadata.UserOrNull.Stream.Game.Name
+ result.CategorySlug = streamMetadata.UserOrNull.Stream.Game.Slug
+ startedAt, err := time.Parse("2006-01-02T15:04:05Z", streamMetadata.UserOrNull.Stream.StartedAt)
+
+ if err == nil {
+ result.LiveSince = startedAt
+ } else {
+ slog.Warn("failed to parse twitch stream started at", "error", err, "started_at", streamMetadata.UserOrNull.Stream.StartedAt)
+ }
+ }
+ }
+
+ return result, nil
+}
+
+func FetchChannelsFromTwitch(channelLogins []string) (TwitchChannels, error) {
+ result := make(TwitchChannels, 0, len(channelLogins))
+
+ job := newJob(fetchChannelFromTwitchTask, channelLogins).withWorkers(10)
+ channels, errs, err := workerPoolDo(job)
+
+ if err != nil {
+ return result, err
+ }
+
+ var failed int
+
+ for i := range channels {
+ if errs[i] != nil {
+ failed++
+ slog.Warn("failed to fetch twitch channel", "channel", channelLogins[i], "error", errs[i])
+ continue
+ }
+
+ result = append(result, channels[i])
+ }
+
+ if failed == len(channelLogins) {
+ return result, ErrNoContent
+ }
+
+ if failed > 0 {
+ return result, fmt.Errorf("%w: failed to fetch %d channels", ErrPartialContent, failed)
+ }
+
+ return result, nil
+}
diff --git a/internal/feed/utils.go b/internal/feed/utils.go
new file mode 100644
index 0000000..a861e8a
--- /dev/null
+++ b/internal/feed/utils.go
@@ -0,0 +1,79 @@
+package feed
+
+import (
+ "errors"
+ "fmt"
+ "net/url"
+ "slices"
+ "strings"
+)
+
+var (
+ ErrNoContent = errors.New("failed to retrieve any content")
+ ErrPartialContent = errors.New("failed to retrieve some of the content")
+)
+
+func percentChange(current, previous float64) float64 {
+ return (current/previous - 1) * 100
+}
+
+func extractDomainFromUrl(u string) string {
+ if u == "" {
+ return ""
+ }
+
+ parsed, err := url.Parse(u)
+
+ if err != nil {
+ return ""
+ }
+
+ return strings.TrimPrefix(parsed.Host, "www.")
+}
+
+func SvgPolylineCoordsFromYValues(width float64, height float64, values []float64) string {
+ if len(values) < 2 {
+ return ""
+ }
+
+ verticalPadding := height * 0.02
+ height -= verticalPadding * 2
+ coordinates := make([]string, len(values))
+ distanceBetweenPoints := width / float64(len(values)-1)
+ min := slices.Min(values)
+ max := slices.Max(values)
+
+ for i := range values {
+ coordinates[i] = fmt.Sprintf(
+ "%.2f,%.2f",
+ float64(i)*distanceBetweenPoints,
+ ((max-values[i])/(max-min))*height+verticalPadding,
+ )
+ }
+
+ return strings.Join(coordinates, " ")
+}
+
+func maybeCopySliceWithoutZeroValues[T int | float64](values []T) []T {
+ if len(values) == 0 {
+ return values
+ }
+
+ for i := range values {
+ if values[i] != 0 {
+ continue
+ }
+
+ c := make([]T, 0, len(values)-1)
+
+ for i := range values {
+ if values[i] != 0 {
+ c = append(c, values[i])
+ }
+ }
+
+ return c
+ }
+
+ return values
+}
diff --git a/internal/feed/yahoo.go b/internal/feed/yahoo.go
new file mode 100644
index 0000000..9412665
--- /dev/null
+++ b/internal/feed/yahoo.go
@@ -0,0 +1,102 @@
+package feed
+
+import (
+ "fmt"
+ "log/slog"
+ "net/http"
+)
+
+type stockResponseJson struct {
+ Chart struct {
+ Result []struct {
+ Meta struct {
+ Symbol string `json:"symbol"`
+ RegularMarketPrice float64 `json:"regularMarketPrice"`
+ ChartPreviousClose float64 `json:"chartPreviousClose"`
+ } `json:"meta"`
+ Indicators struct {
+ Quote []struct {
+ Close []float64 `json:"close,omitempty"`
+ } `json:"quote"`
+ } `json:"indicators"`
+ } `json:"result"`
+ } `json:"chart"`
+}
+
+type StockRequest struct {
+ Symbol string
+ Name string
+}
+
+// TODO: allow changing chart time frame
+const stockChartDays = 21
+
+func FetchStocksDataFromYahoo(stockRequests []StockRequest) (Stocks, error) {
+ requests := make([]*http.Request, 0, len(stockRequests))
+
+ for i := range stockRequests {
+ request, _ := http.NewRequest("GET", fmt.Sprintf("https://query1.finance.yahoo.com/v8/finance/chart/%s?range=1mo&interval=1d", stockRequests[i].Symbol), nil)
+ requests = append(requests, request)
+ }
+
+ job := newJob(decodeJsonFromRequestTask[stockResponseJson](defaultClient), requests)
+ responses, errs, err := workerPoolDo(job)
+
+ if err != nil {
+ return nil, fmt.Errorf("%w: %v", ErrNoContent, err)
+ }
+
+ stocks := make(Stocks, 0, len(responses))
+ var failed int
+
+ for i := range responses {
+ if errs[i] != nil {
+ failed++
+ slog.Error("Failed to fetch stock data", "symbol", stockRequests[i].Symbol, "error", errs[i])
+ continue
+ }
+
+ response := responses[i]
+
+ if len(response.Chart.Result) == 0 {
+ failed++
+ slog.Error("Stock response contains no data", "symbol", stockRequests[i].Symbol)
+ continue
+ }
+
+ prices := response.Chart.Result[0].Indicators.Quote[0].Close
+
+ if len(prices) > stockChartDays {
+ prices = prices[len(prices)-stockChartDays:]
+ }
+
+ previous := response.Chart.Result[0].Meta.RegularMarketPrice
+
+ if len(prices) >= 2 && prices[len(prices)-2] != 0 {
+ previous = prices[len(prices)-2]
+ }
+
+ points := SvgPolylineCoordsFromYValues(100, 50, maybeCopySliceWithoutZeroValues(prices))
+
+ stocks = append(stocks, Stock{
+ Name: stockRequests[i].Name,
+ Symbol: response.Chart.Result[0].Meta.Symbol,
+ Price: response.Chart.Result[0].Meta.RegularMarketPrice,
+ PercentChange: percentChange(
+ response.Chart.Result[0].Meta.RegularMarketPrice,
+ previous,
+ ),
+ SvgChartPoints: points,
+ })
+ }
+
+ if len(stocks) == 0 {
+ return nil, ErrNoContent
+ }
+
+ if failed > 0 {
+ return stocks, fmt.Errorf("%w: could not fetch data for %d stock(s)", ErrPartialContent, failed)
+ }
+
+ return stocks, nil
+}
diff --git a/internal/feed/youtube.go b/internal/feed/youtube.go
new file mode 100644
index 0000000..e22b8bb
--- /dev/null
+++ b/internal/feed/youtube.go
@@ -0,0 +1,100 @@
+package feed
+
+import (
+ "fmt"
+ "log/slog"
+ "net/http"
+ "strings"
+ "time"
+)
+
+type youtubeFeedResponseXml struct {
+ Channel string `xml:"title"`
+ ChannelLink struct {
+ Href string `xml:"href,attr"`
+ } `xml:"link"`
+ Videos []struct {
+ Title string `xml:"title"`
+ Published string `xml:"published"`
+ Link struct {
+ Href string `xml:"href,attr"`
+ } `xml:"link"`
+
+ Group struct {
+ Thumbnail struct {
+ Url string `xml:"url,attr"`
+ } `xml:"http://search.yahoo.com/mrss/ thumbnail"`
+ } `xml:"http://search.yahoo.com/mrss/ group"`
+ } `xml:"entry"`
+}
+
+func parseYoutubeFeedTime(t string) time.Time {
+ parsedTime, err := time.Parse("2006-01-02T15:04:05-07:00", t)
+
+ if err != nil {
+ return time.Now()
+ }
+
+ return parsedTime
+}
+
+func FetchYoutubeChannelUploads(channelIds []string) (Videos, error) {
+ requests := make([]*http.Request, 0, len(channelIds))
+
+ for i := range channelIds {
+ request, _ := http.NewRequest("GET", "https://www.youtube.com/feeds/videos.xml?channel_id="+channelIds[i], nil)
+ requests = append(requests, request)
+ }
+
+ job := newJob(decodeXmlFromRequestTask[youtubeFeedResponseXml](defaultClient), requests).withWorkers(30)
+
+ responses, errs, err := workerPoolDo(job)
+
+ if err != nil {
+ return nil, fmt.Errorf("%w: %v", ErrNoContent, err)
+ }
+
+ videos := make(Videos, 0, len(channelIds)*15)
+
+ var failed int
+
+ for i := range responses {
+ if errs[i] != nil {
+ failed++
+ slog.Error("Failed to fetch youtube feed", "channel", channelIds[i], "error", errs[i])
+ continue
+ }
+
+ response := responses[i]
+
+ for j := range response.Videos {
+ video := &response.Videos[j]
+
+ // TODO: figure out a better way of skipping shorts
+ if strings.Contains(video.Title, "#shorts") {
+ continue
+ }
+
+ videos = append(videos, Video{
+ ThumbnailUrl: video.Group.Thumbnail.Url,
+ Title: video.Title,
+ Url: video.Link.Href,
+ Author: response.Channel,
+ AuthorUrl: response.ChannelLink.Href + "/videos",
+ TimePosted: parseYoutubeFeedTime(video.Published),
+ })
+ }
+ }
+
+ if len(videos) == 0 {
+ return nil, ErrNoContent
+ }
+
+ videos.SortByNewest()
+
+ if failed > 0 {
+ return videos, fmt.Errorf("%w: missing videos from %d channels", ErrPartialContent, failed)
+ }
+
+ return videos, nil
+}
diff --git a/internal/glance/cli.go b/internal/glance/cli.go
new file mode 100644
index 0000000..5987368
--- /dev/null
+++ b/internal/glance/cli.go
@@ -0,0 +1,42 @@
+package glance
+
+import (
+ "flag"
+ "os"
+)
+
+type CliIntent uint8
+
+const (
+ CliIntentServe CliIntent = iota
+ CliIntentCheckConfig = iota
+)
+
+type CliOptions struct {
+ Intent CliIntent
+ ConfigPath string
+}
+
+func ParseCliOptions() (*CliOptions, error) {
+ flags := flag.NewFlagSet("", flag.ExitOnError)
+
+ checkConfig := flags.Bool("check-config", false, "Check whether the config is valid")
+ configPath := flags.String("config", "glance.yml", "Set config path")
+
+ err := flags.Parse(os.Args[1:])
+
+ if err != nil {
+ return nil, err
+ }
+
+ intent := CliIntentServe
+
+ if *checkConfig {
+ intent = CliIntentCheckConfig
+ }
+
+ return &CliOptions{
+ Intent: intent,
+ ConfigPath: *configPath,
+ }, nil
+}
diff --git a/internal/glance/config.go b/internal/glance/config.go
new file mode 100644
index 0000000..9acc3be
--- /dev/null
+++ b/internal/glance/config.go
@@ -0,0 +1,79 @@
+package glance
+
+import (
+ "fmt"
+ "io"
+
+ "gopkg.in/yaml.v3"
+)
+
+type Config struct {
+ Server Server `yaml:"server"`
+ Theme Theme `yaml:"theme"`
+ Pages []Page `yaml:"pages"`
+}
+
+func NewConfigFromYml(contents io.Reader) (*Config, error) {
+ config := NewConfig()
+
+ contentBytes, err := io.ReadAll(contents)
+
+ if err != nil {
+ return nil, err
+ }
+
+ err = yaml.Unmarshal(contentBytes, config)
+
+ if err != nil {
+ return nil, err
+ }
+
+ if err = configIsValid(config); err != nil {
+ return nil, err
+ }
+
+ return config, nil
+}
+
+func NewConfig() *Config {
+ config := &Config{}
+
+ config.Server.Host = ""
+ config.Server.Port = 8080
+
+ return config
+}
+
+func configIsValid(config *Config) error {
+ for i := range config.Pages {
+ if config.Pages[i].Title == "" {
+ return fmt.Errorf("Page %d has no title", i+1)
+ }
+
+ if len(config.Pages[i].Columns) == 0 {
+ return fmt.Errorf("Page %d has no columns", i+1)
+ }
+
+ if len(config.Pages[i].Columns) > 3 {
+ return fmt.Errorf("Page %d has more than 3 columns: %d", i+1, len(config.Pages[i].Columns))
+ }
+
+ columnSizesCount := make(map[string]int)
+
+ for j := range config.Pages[i].Columns {
+ if config.Pages[i].Columns[j].Size != "small" && config.Pages[i].Columns[j].Size != "full" {
+ return fmt.Errorf("Column %d of page %d: size can only be either small or full", j+1, i+1)
+ }
+
+ columnSizesCount[config.Pages[i].Columns[j].Size]++
+ }
+
+ full := columnSizesCount["full"]
+
+ if full > 2 || full == 0 {
+ return fmt.Errorf("Page %d must have either 1 or 2 full width columns", i+1)
+ }
+ }
+
+ return nil
+}
diff --git a/internal/glance/glance.go b/internal/glance/glance.go
new file mode 100644
index 0000000..0c4001d
--- /dev/null
+++ b/internal/glance/glance.go
@@ -0,0 +1,221 @@
+package glance
+
+import (
+ "bytes"
+ "context"
+ "fmt"
+ "log/slog"
+ "net/http"
+ "path/filepath"
+ "regexp"
+ "strings"
+ "sync"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/widget"
+)
+
+var buildVersion = "dev"
+
+var sequentialWhitespacePattern = regexp.MustCompile(`\s+`)
+
+type Application struct {
+ Version string
+ Config Config
+ slugToPage map[string]*Page
+}
+
+type Theme struct {
+ BackgroundColor *widget.HSLColorField `yaml:"background-color"`
+ PrimaryColor *widget.HSLColorField `yaml:"primary-color"`
+ PositiveColor *widget.HSLColorField `yaml:"positive-color"`
+ NegativeColor *widget.HSLColorField `yaml:"negative-color"`
+ Light bool `yaml:"light"`
+ ContrastMultiplier float32 `yaml:"contrast-multiplier"`
+ TextSaturationMultiplier float32 `yaml:"text-saturation-multiplier"`
+}
+
+type Server struct {
+ Host string `yaml:"host"`
+ Port uint16 `yaml:"port"`
+ AssetsPath string `yaml:"assets-path"`
+ StartedAt time.Time `yaml:"-"`
+}
+
+type Column struct {
+ Size string `yaml:"size"`
+ Widgets widget.Widgets `yaml:"widgets"`
+}
+
+type templateData struct {
+ App *Application
+ Page *Page
+}
+
+type Page struct {
+ Title string `yaml:"name"`
+ Slug string `yaml:"slug"`
+ Columns []Column `yaml:"columns"`
+ mu sync.Mutex
+}
+
+func (p *Page) UpdateOutdatedWidgets() {
+ now := time.Now()
+
+ var wg sync.WaitGroup
+ context := context.Background()
+
+ for c := range p.Columns {
+ for w := range p.Columns[c].Widgets {
+ widget := p.Columns[c].Widgets[w]
+
+ if !widget.RequiresUpdate(&now) {
+ continue
+ }
+
+ wg.Add(1)
+ go func() {
+ defer wg.Done()
+ widget.Update(context)
+ }()
+ }
+ }
+
+ wg.Wait()
+}
+
+// TODO: fix, currently very simple, lots of uncovered edge cases
+func titleToSlug(s string) string {
+ s = strings.ToLower(s)
+ s = sequentialWhitespacePattern.ReplaceAllString(s, "-")
+ s = strings.Trim(s, "-")
+
+ return s
+}
+
+func NewApplication(config *Config) (*Application, error) {
+ if len(config.Pages) == 0 {
+ return nil, fmt.Errorf("no pages configured")
+ }
+
+ app := &Application{
+ Version: buildVersion,
+ Config: *config,
+ slugToPage: make(map[string]*Page),
+ }
+
+ app.slugToPage[""] = &config.Pages[0]
+
+ for i := range config.Pages {
+ if config.Pages[i].Slug == "" {
+ config.Pages[i].Slug = titleToSlug(config.Pages[i].Title)
+ }
+
+ app.slugToPage[config.Pages[i].Slug] = &config.Pages[i]
+ }
+
+ return app, nil
+}
+
+func (a *Application) HandlePageRequest(w http.ResponseWriter, r *http.Request) {
+ page, exists := a.slugToPage[r.PathValue("page")]
+
+ if !exists {
+ a.HandleNotFound(w, r)
+ return
+ }
+
+ pageData := templateData{
+ Page: page,
+ App: a,
+ }
+
+ var responseBytes bytes.Buffer
+ err := assets.PageTemplate.Execute(&responseBytes, pageData)
+
+ if err != nil {
+ w.WriteHeader(http.StatusInternalServerError)
+ w.Write([]byte(err.Error()))
+ return
+ }
+
+ w.Write(responseBytes.Bytes())
+}
+
+func (a *Application) HandlePageContentRequest(w http.ResponseWriter, r *http.Request) {
+ page, exists := a.slugToPage[r.PathValue("page")]
+
+ if !exists {
+ a.HandleNotFound(w, r)
+ return
+ }
+
+ pageData := templateData{
+ Page: page,
+ }
+
+ page.mu.Lock()
+ defer page.mu.Unlock()
+ page.UpdateOutdatedWidgets()
+
+ var responseBytes bytes.Buffer
+ err := assets.PageContentTemplate.Execute(&responseBytes, pageData)
+
+ if err != nil {
+ w.WriteHeader(http.StatusInternalServerError)
+ w.Write([]byte(err.Error()))
+ return
+ }
+
+ w.Write(responseBytes.Bytes())
+}
+
+func (a *Application) HandleNotFound(w http.ResponseWriter, r *http.Request) {
+ // TODO: add proper not found page
+ w.WriteHeader(http.StatusNotFound)
+ w.Write([]byte("Page not found"))
+}
+
+func FileServerWithCache(fs http.FileSystem, cacheDuration time.Duration) http.Handler {
+ server := http.FileServer(fs)
+
+ return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+ // TODO: fix always setting cache control even if the file doesn't exist
+ w.Header().Set("Cache-Control", fmt.Sprintf("public, max-age=%d", int(cacheDuration.Seconds())))
+ server.ServeHTTP(w, r)
+ })
+}
+
+func (a *Application) Serve() error {
+ // TODO: add gzip support, static files must have their gzipped contents cached
+ // TODO: add HTTPS support
+ mux := http.NewServeMux()
+
+ mux.HandleFunc("GET /{$}", a.HandlePageRequest)
+ mux.HandleFunc("GET /{page}", a.HandlePageRequest)
+ mux.HandleFunc("GET /api/pages/{page}/content/{$}", a.HandlePageContentRequest)
+ mux.Handle("GET /static/{path...}", http.StripPrefix("/static/", FileServerWithCache(http.FS(assets.PublicFS), 2*time.Hour)))
+
+ if a.Config.Server.AssetsPath != "" {
+ absAssetsPath, err := filepath.Abs(a.Config.Server.AssetsPath)
+
+ if err != nil {
+ return fmt.Errorf("invalid assets path: %s", a.Config.Server.AssetsPath)
+ }
+
+ slog.Info("Serving assets", "path", absAssetsPath)
+ assetsFS := FileServerWithCache(http.Dir(a.Config.Server.AssetsPath), 2*time.Hour)
+ mux.Handle("/assets/{path...}", http.StripPrefix("/assets/", assetsFS))
+ }
+
+ server := http.Server{
+ Addr: fmt.Sprintf("%s:%d", a.Config.Server.Host, a.Config.Server.Port),
+ Handler: mux,
+ }
+
+ a.Config.Server.StartedAt = time.Now()
+
+ slog.Info("Starting server", "host", a.Config.Server.Host, "port", a.Config.Server.Port)
+ return server.ListenAndServe()
+}
diff --git a/internal/glance/main.go b/internal/glance/main.go
new file mode 100644
index 0000000..5eee962
--- /dev/null
+++ b/internal/glance/main.go
@@ -0,0 +1,46 @@
+package glance
+
+import (
+ "fmt"
+ "os"
+)
+
+func Main() int {
+ options, err := ParseCliOptions()
+
+ if err != nil {
+ fmt.Println(err)
+ return 1
+ }
+
+ configFile, err := os.Open(options.ConfigPath)
+
+ if err != nil {
+ fmt.Printf("failed opening config file: %v\n", err)
+ return 1
+ }
+
+ config, err := NewConfigFromYml(configFile)
+ configFile.Close()
+
+ if err != nil {
+ fmt.Printf("failed parsing config file: %v\n", err)
+ return 1
+ }
+
+ if options.Intent == CliIntentServe {
+ app, err := NewApplication(config)
+
+ if err != nil {
+ fmt.Printf("failed creating application: %v\n", err)
+ return 1
+ }
+
+ if app.Serve() != nil {
+ fmt.Printf("http server error: %v\n", err)
+ return 1
+ }
+ }
+
+ return 0
+}
diff --git a/internal/widget/bookmarks.go b/internal/widget/bookmarks.go
new file mode 100644
index 0000000..a3e3d28
--- /dev/null
+++ b/internal/widget/bookmarks.go
@@ -0,0 +1,31 @@
+package widget
+
+import (
+ "html/template"
+
+ "github.com/glanceapp/glance/internal/assets"
+)
+
+type Bookmarks struct {
+ widgetBase `yaml:",inline"`
+ cachedHTML template.HTML `yaml:"-"`
+ Groups []struct {
+ Title string `yaml:"title"`
+ Color *HSLColorField `yaml:"color"`
+ Links []struct {
+ Title string `yaml:"title"`
+ URL string `yaml:"url"`
+ } `yaml:"links"`
+ } `yaml:"groups"`
+}
+
+func (widget *Bookmarks) Initialize() error {
+ widget.withTitle("Bookmarks").withError(nil)
+ widget.cachedHTML = widget.render(widget, assets.BookmarksTemplate)
+
+ return nil
+}
+
+func (widget *Bookmarks) Render() template.HTML {
+ return widget.cachedHTML
+}
diff --git a/internal/widget/calendar.go b/internal/widget/calendar.go
new file mode 100644
index 0000000..a126353
--- /dev/null
+++ b/internal/widget/calendar.go
@@ -0,0 +1,30 @@
+package widget
+
+import (
+ "context"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type Calendar struct {
+ widgetBase `yaml:",inline"`
+ Calendar *feed.Calendar
+}
+
+func (widget *Calendar) Initialize() error {
+ widget.withTitle("Calendar").withCacheOnTheHour()
+
+ return nil
+}
+
+func (widget *Calendar) Update(ctx context.Context) {
+ widget.Calendar = feed.NewCalendar(time.Now())
+ widget.withError(nil).scheduleNextUpdate()
+}
+
+func (widget *Calendar) Render() template.HTML {
+ return widget.render(widget, assets.CalendarTemplate)
+}
diff --git a/internal/widget/fields.go b/internal/widget/fields.go
new file mode 100644
index 0000000..eecb916
--- /dev/null
+++ b/internal/widget/fields.go
@@ -0,0 +1,152 @@
+package widget
+
+import (
+ "fmt"
+ "html/template"
+ "os"
+ "regexp"
+ "strconv"
+ "time"
+
+ "gopkg.in/yaml.v3"
+)
+
+var HSLColorPattern = regexp.MustCompile(`^(?:hsla?\()?(\d{1,3})(?: |,)+(\d{1,3})%?(?: |,)+(\d{1,3})%?\)?$`)
+var EnvFieldPattern = regexp.MustCompile(`^\${([A-Z_]+)}$`)
+
+const (
+ HSLHueMax = 360
+ HSLSaturationMax = 100
+ HSLLightnessMax = 100
+)
+
+type HSLColorField struct {
+ Hue uint16
+ Saturation uint8
+ Lightness uint8
+}
+
+func (c *HSLColorField) String() string {
+ return fmt.Sprintf("hsl(%d, %d%%, %d%%)", c.Hue, c.Saturation, c.Lightness)
+}
+
+func (c *HSLColorField) AsCSSValue() template.CSS {
+ return template.CSS(c.String())
+}
+
+func (c *HSLColorField) UnmarshalYAML(node *yaml.Node) error {
+ var value string
+
+ if err := node.Decode(&value); err != nil {
+ return err
+ }
+
+ matches := HSLColorPattern.FindStringSubmatch(value)
+
+ if len(matches) != 4 {
+ return fmt.Errorf("invalid HSL color format: %s", value)
+ }
+
+ hue, err := strconv.ParseUint(matches[1], 10, 16)
+
+ if err != nil {
+ return err
+ }
+
+ if hue > HSLHueMax {
+ return fmt.Errorf("HSL hue must be between 0 and %d", HSLHueMax)
+ }
+
+ saturation, err := strconv.ParseUint(matches[2], 10, 8)
+
+ if err != nil {
+ return err
+ }
+
+ if saturation > HSLSaturationMax {
+ return fmt.Errorf("HSL saturation must be between 0 and %d", HSLSaturationMax)
+ }
+
+ lightness, err := strconv.ParseUint(matches[3], 10, 8)
+
+ if err != nil {
+ return err
+ }
+
+ if lightness > HSLLightnessMax {
+ return fmt.Errorf("HSL lightness must be between 0 and %d", HSLLightnessMax)
+ }
+
+ c.Hue = uint16(hue)
+ c.Saturation = uint8(saturation)
+ c.Lightness = uint8(lightness)
+
+ return nil
+}
+
+var DurationPattern = regexp.MustCompile(`^(\d+)(s|m|h|d)$`)
+
+type DurationField time.Duration
+
+func (d *DurationField) UnmarshalYAML(node *yaml.Node) error {
+ var value string
+
+ if err := node.Decode(&value); err != nil {
+ return err
+ }
+
+ matches := DurationPattern.FindStringSubmatch(value)
+
+ if len(matches) != 3 {
+ return fmt.Errorf("invalid duration format: %s", value)
+ }
+
+ duration, err := strconv.Atoi(matches[1])
+
+ if err != nil {
+ return err
+ }
+
+ switch matches[2] {
+ case "s":
+ *d = DurationField(time.Duration(duration) * time.Second)
+ case "m":
+ *d = DurationField(time.Duration(duration) * time.Minute)
+ case "h":
+ *d = DurationField(time.Duration(duration) * time.Hour)
+ case "d":
+ *d = DurationField(time.Duration(duration) * 24 * time.Hour)
+ }
+
+ return nil
+}
+
+type OptionalEnvString string
+
+func (f *OptionalEnvString) UnmarshalYAML(node *yaml.Node) error {
+ var value string
+
+ err := node.Decode(&value)
+
+ if err != nil {
+ return err
+ }
+
+ matches := EnvFieldPattern.FindStringSubmatch(value)
+
+ if len(matches) != 2 {
+ *f = OptionalEnvString(value)
+
+ return nil
+ }
+
+ value, found := os.LookupEnv(matches[1])
+
+ if !found {
+ return fmt.Errorf("environment variable %s not found", matches[1])
+ }
+
+ *f = OptionalEnvString(value)
+
+ return nil
+}
diff --git a/internal/widget/hacker-news.go b/internal/widget/hacker-news.go
new file mode 100644
index 0000000..9870e74
--- /dev/null
+++ b/internal/widget/hacker-news.go
@@ -0,0 +1,52 @@
+package widget
+
+import (
+ "context"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type HackerNews struct {
+ widgetBase `yaml:",inline"`
+ Posts feed.ForumPosts `yaml:"-"`
+ Limit int `yaml:"limit"`
+ CollapseAfter int `yaml:"collapse-after"`
+}
+
+func (widget *HackerNews) Initialize() error {
+ widget.withTitle("Hacker News").withCacheDuration(30 * time.Minute)
+
+ if widget.Limit <= 0 {
+ widget.Limit = 15
+ }
+
+ if widget.CollapseAfter == 0 || widget.CollapseAfter < -1 {
+ widget.CollapseAfter = 5
+ }
+
+ return nil
+}
+
+func (widget *HackerNews) Update(ctx context.Context) {
+ posts, err := feed.FetchHackerNewsTopPosts(40)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ posts.CalculateEngagement()
+ posts.SortByEngagement()
+
+ if widget.Limit < len(posts) {
+ posts = posts[:widget.Limit]
+ }
+
+ widget.Posts = posts
+}
+
+func (widget *HackerNews) Render() template.HTML {
+ return widget.render(widget, assets.ForumPostsTemplate)
+}
diff --git a/internal/widget/iframe.go b/internal/widget/iframe.go
new file mode 100644
index 0000000..44d0822
--- /dev/null
+++ b/internal/widget/iframe.go
@@ -0,0 +1,45 @@
+package widget
+
+import (
+ "errors"
+ "fmt"
+ "html/template"
+ "net/url"
+
+ "github.com/glanceapp/glance/internal/assets"
+)
+
+type IFrame struct {
+ widgetBase `yaml:",inline"`
+ cachedHTML template.HTML `yaml:"-"`
+ Source string `yaml:"source"`
+ Height int `yaml:"height"`
+}
+
+func (widget *IFrame) Initialize() error {
+ widget.withTitle("IFrame").withError(nil)
+
+ if widget.Source == "" {
+ return errors.New("missing source for iframe")
+ }
+
+ _, err := url.Parse(widget.Source)
+
+ if err != nil {
+ return fmt.Errorf("invalid source for iframe: %v", err)
+ }
+
+ if widget.Height == 50 {
+ widget.Height = 300
+ } else if widget.Height < 50 {
+ widget.Height = 50
+ }
+
+ widget.cachedHTML = widget.render(widget, assets.IFrameTemplate)
+
+ return nil
+}
+
+func (widget *IFrame) Render() template.HTML {
+ return widget.cachedHTML
+}
diff --git a/internal/widget/monitor.go b/internal/widget/monitor.go
new file mode 100644
index 0000000..639e7f4
--- /dev/null
+++ b/internal/widget/monitor.go
@@ -0,0 +1,100 @@
+package widget
+
+import (
+ "context"
+ "fmt"
+ "html/template"
+ "net/http"
+ "strconv"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+func statusCodeToText(status int) string {
+ if status == 200 {
+ return "OK"
+ }
+ if status == 404 {
+ return "Not Found"
+ }
+ if status == 403 {
+ return "Forbidden"
+ }
+ if status == 401 {
+ return "Unauthorized"
+ }
+ if status >= 400 {
+ return "Client Error"
+ }
+ if status >= 500 {
+ return "Server Error"
+ }
+
+ return strconv.Itoa(status)
+}
+
+func statusCodeToStyle(status int) string {
+ if status == 200 {
+ return "good"
+ }
+
+ return "bad"
+}
+
+type Monitor struct {
+ widgetBase `yaml:",inline"`
+ Sites []struct {
+ Title string `yaml:"title"`
+ Url string `yaml:"url"`
+ IconUrl string `yaml:"icon"`
+ Status *feed.SiteStatus `yaml:"-"`
+ StatusText string `yaml:"-"`
+ StatusStyle string `yaml:"-"`
+ } `yaml:"sites"`
+}
+
+func (widget *Monitor) Initialize() error {
+ widget.withTitle("Monitor").withCacheDuration(5 * time.Minute)
+
+ return nil
+}
+
+func (widget *Monitor) Update(ctx context.Context) {
+ requests := make([]*http.Request, len(widget.Sites))
+
+ for i := range widget.Sites {
+ request, err := http.NewRequest("HEAD", widget.Sites[i].Url, nil)
+
+ if err != nil {
+ message := fmt.Errorf("failed to create http request for %s: %s", widget.Sites[i].Url, err)
+ widget.withNotice(message)
+ continue
+ }
+
+ requests[i] = request
+ }
+
+ statuses, err := feed.FetchStatusesForRequests(requests)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ for i := range widget.Sites {
+ site := &widget.Sites[i]
+ status := &statuses[i]
+
+ site.Status = status
+
+ if !status.TimedOut {
+ site.StatusText = statusCodeToText(status.Code)
+ site.StatusStyle = statusCodeToStyle(status.Code)
+ }
+ }
+}
+
+func (widget *Monitor) Render() template.HTML {
+ return widget.render(widget, assets.MonitorTemplate)
+}
diff --git a/internal/widget/reddit.go b/internal/widget/reddit.go
new file mode 100644
index 0000000..3287fcf
--- /dev/null
+++ b/internal/widget/reddit.go
@@ -0,0 +1,66 @@
+package widget
+
+import (
+ "context"
+ "errors"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type Reddit struct {
+ widgetBase `yaml:",inline"`
+ Posts feed.ForumPosts `yaml:"-"`
+ Subreddit string `yaml:"subreddit"`
+ Style string `yaml:"style"`
+ Limit int `yaml:"limit"`
+ CollapseAfter int `yaml:"collapse-after"`
+}
+
+func (widget *Reddit) Initialize() error {
+ if widget.Subreddit == "" {
+ return errors.New("no subreddit specified")
+ }
+
+ if widget.Limit <= 0 {
+ widget.Limit = 15
+ }
+
+ if widget.CollapseAfter == 0 || widget.CollapseAfter < -1 {
+ widget.CollapseAfter = 5
+ }
+
+ widget.withTitle("/r/" + widget.Subreddit).withCacheDuration(30 * time.Minute)
+
+ return nil
+}
+
+func (widget *Reddit) Update(ctx context.Context) {
+ posts, err := feed.FetchSubredditPosts(widget.Subreddit)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ if len(posts) > widget.Limit {
+ posts = posts[:widget.Limit]
+ }
+
+ posts.SortByEngagement()
+ widget.Posts = posts
+}
+
+func (widget *Reddit) Render() template.HTML {
+ if widget.Style == "horizontal-cards" {
+ return widget.render(widget, assets.RedditCardsHorizontalTemplate)
+ }
+
+ if widget.Style == "vertical-cards" {
+ return widget.render(widget, assets.RedditCardsVerticalTemplate)
+ }
+
+ return widget.render(widget, assets.ForumPostsTemplate)
+
+}
diff --git a/internal/widget/releases.go b/internal/widget/releases.go
new file mode 100644
index 0000000..77fe103
--- /dev/null
+++ b/internal/widget/releases.go
@@ -0,0 +1,51 @@
+package widget
+
+import (
+ "context"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type Releases struct {
+ widgetBase `yaml:",inline"`
+ Releases feed.AppReleases `yaml:"-"`
+ Repositories []string `yaml:"repositories"`
+ Token OptionalEnvString `yaml:"token"`
+ Limit int `yaml:"limit"`
+ CollapseAfter int `yaml:"collapse-after"`
+}
+
+func (widget *Releases) Initialize() error {
+ widget.withTitle("Releases").withCacheDuration(2 * time.Hour)
+
+ if widget.Limit <= 0 {
+ widget.Limit = 10
+ }
+
+ if widget.CollapseAfter == 0 || widget.CollapseAfter < -1 {
+ widget.CollapseAfter = 5
+ }
+
+ return nil
+}
+
+func (widget *Releases) Update(ctx context.Context) {
+ releases, err := feed.FetchLatestReleasesFromGithub(widget.Repositories, string(widget.Token))
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ if len(releases) > widget.Limit {
+ releases = releases[:widget.Limit]
+ }
+
+ widget.Releases = releases
+}
+
+func (widget *Releases) Render() template.HTML {
+ return widget.render(widget, assets.ReleasesTemplate)
+}
diff --git a/internal/widget/rss.go b/internal/widget/rss.go
new file mode 100644
index 0000000..81bd3ae
--- /dev/null
+++ b/internal/widget/rss.go
@@ -0,0 +1,55 @@
+package widget
+
+import (
+ "context"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type RSS struct {
+ widgetBase `yaml:",inline"`
+ FeedRequests []feed.RSSFeedRequest `yaml:"feeds"`
+ Style string `yaml:"style"`
+ Items feed.RSSFeedItems `yaml:"-"`
+ Limit int `yaml:"limit"`
+ CollapseAfter int `yaml:"collapse-after"`
+}
+
+func (widget *RSS) Initialize() error {
+ widget.withTitle("RSS Feed").withCacheDuration(1 * time.Hour)
+
+ if widget.Limit <= 0 {
+ widget.Limit = 25
+ }
+
+ if widget.CollapseAfter == 0 || widget.CollapseAfter < -1 {
+ widget.CollapseAfter = 5
+ }
+
+ return nil
+}
+
+func (widget *RSS) Update(ctx context.Context) {
+ items, err := feed.GetItemsFromRSSFeeds(widget.FeedRequests)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ if len(items) > widget.Limit {
+ items = items[:widget.Limit]
+ }
+
+ widget.Items = items
+}
+
+func (widget *RSS) Render() template.HTML {
+ if widget.Style == "horizontal-cards" {
+ return widget.render(widget, assets.RSSCardsTemplate)
+ }
+
+ return widget.render(widget, assets.RSSListTemplate)
+}
diff --git a/internal/widget/stocks.go b/internal/widget/stocks.go
new file mode 100644
index 0000000..afba0e4
--- /dev/null
+++ b/internal/widget/stocks.go
@@ -0,0 +1,37 @@
+package widget
+
+import (
+ "context"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type Stocks struct {
+ widgetBase `yaml:",inline"`
+ Stocks feed.Stocks `yaml:"-"`
+ Tickers []feed.StockRequest `yaml:"stocks"`
+}
+
+func (widget *Stocks) Initialize() error {
+ widget.withTitle("Stocks").withCacheDuration(time.Hour)
+
+ return nil
+}
+
+func (widget *Stocks) Update(ctx context.Context) {
+ stocks, err := feed.FetchStocksDataFromYahoo(widget.Tickers)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ stocks.SortByAbsChange()
+ widget.Stocks = stocks
+}
+
+func (widget *Stocks) Render() template.HTML {
+ return widget.render(widget, assets.StocksTemplate)
+}
diff --git a/internal/widget/twitch-channels.go b/internal/widget/twitch-channels.go
new file mode 100644
index 0000000..3f36669
--- /dev/null
+++ b/internal/widget/twitch-channels.go
@@ -0,0 +1,42 @@
+package widget
+
+import (
+ "context"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type TwitchChannels struct {
+ widgetBase `yaml:",inline"`
+ ChannelsRequest []string `yaml:"channels"`
+ Channels []feed.TwitchChannel `yaml:"-"`
+ CollapseAfter int `yaml:"collapse-after"`
+}
+
+func (widget *TwitchChannels) Initialize() error {
+ widget.withTitle("Twitch Channels").withCacheDuration(time.Minute * 10)
+
+ if widget.CollapseAfter == 0 || widget.CollapseAfter < -1 {
+ widget.CollapseAfter = 5
+ }
+
+ return nil
+}
+
+func (widget *TwitchChannels) Update(ctx context.Context) {
+ channels, err := feed.FetchChannelsFromTwitch(widget.ChannelsRequest)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ channels.SortByViewers()
+ widget.Channels = channels
+}
+
+func (widget *TwitchChannels) Render() template.HTML {
+ return widget.render(widget, assets.TwitchChannelsTemplate)
+}
diff --git a/internal/widget/twitch-top-games.go b/internal/widget/twitch-top-games.go
new file mode 100644
index 0000000..812c3c6
--- /dev/null
+++ b/internal/widget/twitch-top-games.go
@@ -0,0 +1,46 @@
+package widget
+
+import (
+ "context"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type TwitchGames struct {
+ widgetBase `yaml:",inline"`
+ Categories []feed.TwitchCategory `yaml:"-"`
+ Exclude []string `yaml:"exclude"`
+ Limit int `yaml:"limit"`
+ CollapseAfter int `yaml:"collapse-after"`
+}
+
+func (widget *TwitchGames) Initialize() error {
+ widget.withTitle("Top games on Twitch").withCacheDuration(time.Minute * 10)
+
+ if widget.Limit <= 0 {
+ widget.Limit = 10
+ }
+
+ if widget.CollapseAfter == 0 || widget.CollapseAfter < -1 {
+ widget.CollapseAfter = 5
+ }
+
+ return nil
+}
+
+func (widget *TwitchGames) Update(ctx context.Context) {
+ categories, err := feed.FetchTopGamesFromTwitch(widget.Exclude, widget.Limit)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ widget.Categories = categories
+}
+
+func (widget *TwitchGames) Render() template.HTML {
+ return widget.render(widget, assets.TwitchGamesListTemplate)
+}
diff --git a/internal/widget/videos.go b/internal/widget/videos.go
new file mode 100644
index 0000000..2652768
--- /dev/null
+++ b/internal/widget/videos.go
@@ -0,0 +1,45 @@
+package widget
+
+import (
+ "context"
+ "html/template"
+ "time"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type Videos struct {
+ widgetBase `yaml:",inline"`
+ Videos feed.Videos `yaml:"-"`
+ Channels []string `yaml:"channels"`
+ Limit int `yaml:"limit"`
+}
+
+func (widget *Videos) Initialize() error {
+ widget.withTitle("Videos").withCacheDuration(time.Hour)
+
+ if widget.Limit <= 0 {
+ widget.Limit = 25
+ }
+
+ return nil
+}
+
+func (widget *Videos) Update(ctx context.Context) {
+ videos, err := feed.FetchYoutubeChannelUploads(widget.Channels)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ if len(videos) > widget.Limit {
+ videos = videos[:widget.Limit]
+ }
+
+ widget.Videos = videos
+}
+
+func (widget *Videos) Render() template.HTML {
+ return widget.render(widget, assets.VideosTemplate)
+}
diff --git a/internal/widget/weather.go b/internal/widget/weather.go
new file mode 100644
index 0000000..390f9d7
--- /dev/null
+++ b/internal/widget/weather.go
@@ -0,0 +1,50 @@
+package widget
+
+import (
+ "context"
+ "fmt"
+ "html/template"
+
+ "github.com/glanceapp/glance/internal/assets"
+ "github.com/glanceapp/glance/internal/feed"
+)
+
+type Weather struct {
+ widgetBase `yaml:",inline"`
+ Location string `yaml:"location"`
+ HideLocation bool `yaml:"hide-location"`
+ Place *feed.PlaceJson `yaml:"-"`
+ Weather *feed.Weather `yaml:"-"`
+ TimeLabels [12]string `yaml:"-"`
+}
+
+var timeLabels = [12]string{"2am", "4am", "6am", "8am", "10am", "12pm", "2pm", "4pm", "6pm", "8pm", "10pm", "12am"}
+
+func (widget *Weather) Initialize() error {
+ widget.withTitle("Weather").withCacheOnTheHour()
+ widget.TimeLabels = timeLabels
+
+ place, err := feed.FetchPlaceFromName(widget.Location)
+
+ if err != nil {
+ return fmt.Errorf("failed fetching data for %s: %v", widget.Location, err)
+ }
+
+ widget.Place = place
+
+ return nil
+}
+
+func (widget *Weather) Update(ctx context.Context) {
+ weather, err := feed.FetchWeatherForPlace(widget.Place)
+
+ if !widget.canContinueUpdateAfterHandlingErr(err) {
+ return
+ }
+
+ widget.Weather = weather
+}
+
+func (widget *Weather) Render() template.HTML {
+ return widget.render(widget, assets.WeatherTemplate)
+}
diff --git a/internal/widget/widget.go b/internal/widget/widget.go
new file mode 100644
index 0000000..367d822
--- /dev/null
+++ b/internal/widget/widget.go
@@ -0,0 +1,282 @@
+package widget
+
+import (
+ "bytes"
+ "context"
+ "errors"
+ "fmt"
+ "html/template"
+ "log/slog"
+ "math"
+ "time"
+
+ "github.com/glanceapp/glance/internal/feed"
+
+ "gopkg.in/yaml.v3"
+)
+
+func New(widgetType string) (Widget, error) {
+ switch widgetType {
+ case "calendar":
+ return &Calendar{}, nil
+ case "weather":
+ return &Weather{}, nil
+ case "bookmarks":
+ return &Bookmarks{}, nil
+ case "iframe":
+ return &IFrame{}, nil
+ case "hacker-news":
+ return &HackerNews{}, nil
+ case "releases":
+ return &Releases{}, nil
+ case "videos":
+ return &Videos{}, nil
+ case "stocks":
+ return &Stocks{}, nil
+ case "reddit":
+ return &Reddit{}, nil
+ case "rss":
+ return &RSS{}, nil
+ case "monitor":
+ return &Monitor{}, nil
+ case "twitch-top-games":
+ return &TwitchGames{}, nil
+ case "twitch-channels":
+ return &TwitchChannels{}, nil
+ default:
+ return nil, fmt.Errorf("unknown widget type: %s", widgetType)
+ }
+}
+
+type Widgets []Widget
+
+func (w *Widgets) UnmarshalYAML(node *yaml.Node) error {
+ var nodes []yaml.Node
+
+ if err := node.Decode(&nodes); err != nil {
+ return err
+ }
+
+ for _, node := range nodes {
+ meta := struct {
+ Type string `yaml:"type"`
+ }{}
+
+ if err := node.Decode(&meta); err != nil {
+ return err
+ }
+
+ widget, err := New(meta.Type)
+
+ if err != nil {
+ return err
+ }
+
+ if err = node.Decode(widget); err != nil {
+ return err
+ }
+
+ if err = widget.Initialize(); err != nil {
+ return err
+ }
+
+ *w = append(*w, widget)
+ }
+
+ return nil
+}
+
+type Widget interface {
+ Initialize() error
+ RequiresUpdate(*time.Time) bool
+ Update(context.Context)
+ Render() template.HTML
+ GetType() string
+}
+
+type cacheType int
+
+const (
+ cacheTypeInfinite cacheType = iota
+ cacheTypeDuration
+ cacheTypeOnTheHour
+)
+
+type widgetBase struct {
+ Type string `yaml:"type"`
+ Title string `yaml:"title"`
+ CustomCacheDuration DurationField `yaml:"cache"`
+ ContentAvailable bool `yaml:"-"`
+ Error error `yaml:"-"`
+ Notice error `yaml:"-"`
+ templateBuffer bytes.Buffer `yaml:"-"`
+ cacheDuration time.Duration `yaml:"-"`
+ cacheType cacheType `yaml:"-"`
+ nextUpdate time.Time `yaml:"-"`
+ updateRetriedTimes int `yaml:"-"`
+}
+
+func (w *widgetBase) RequiresUpdate(now *time.Time) bool {
+ if w.cacheType == cacheTypeInfinite {
+ return false
+ }
+
+ if w.nextUpdate.IsZero() {
+ return true
+ }
+
+ return now.After(w.nextUpdate)
+}
+
+func (w *widgetBase) Update(ctx context.Context) {
+
+}
+
+func (w *widgetBase) GetType() string {
+ return w.Type
+}
+
+func (w *widgetBase) render(data any, t *template.Template) template.HTML {
+ w.templateBuffer.Reset()
+ err := t.Execute(&w.templateBuffer, data)
+
+ if err != nil {
+ w.ContentAvailable = false
+ w.Error = err
+
+ slog.Error("failed to render template", "error", err)
+
+ // need to immediately re-render with the error,
+ // otherwise risk breaking the page since the widget
+ // will likely be partially rendered with tags not closed.
+ w.templateBuffer.Reset()
+ err2 := t.Execute(&w.templateBuffer, data)
+
+ if err2 != nil {
+ slog.Error("failed to render error within widget", "error", err2, "initial_error", err)
+ w.templateBuffer.Reset()
+ // TODO: add some kind of a generic widget error template when the widget
+ // failed to render, and we also failed to re-render the widget with the error
+ }
+ }
+
+ return template.HTML(w.templateBuffer.String())
+}
+
+func (w *widgetBase) withTitle(title string) *widgetBase {
+ if w.Title == "" {
+ w.Title = title
+ }
+
+ return w
+}
+
+func (w *widgetBase) withCacheDuration(duration time.Duration) *widgetBase {
+ w.cacheType = cacheTypeDuration
+
+ if duration == -1 || w.CustomCacheDuration == 0 {
+ w.cacheDuration = duration
+ } else {
+ w.cacheDuration = time.Duration(w.CustomCacheDuration)
+ }
+
+ return w
+}
+
+func (w *widgetBase) withCacheOnTheHour() *widgetBase {
+ w.cacheType = cacheTypeOnTheHour
+
+ return w
+}
+
+func (w *widgetBase) withNotice(err error) *widgetBase {
+ w.Notice = err
+
+ return w
+}
+
+func (w *widgetBase) withError(err error) *widgetBase {
+ if err == nil && !w.ContentAvailable {
+ w.ContentAvailable = true
+ }
+
+ w.Error = err
+
+ return w
+}
+
+func (w *widgetBase) canContinueUpdateAfterHandlingErr(err error) bool {
+ // TODO: needs covering more edge cases.
+ // if there's partial content and we update early there's a chance
+ // the early update returns even less content than the initial update.
+ // need some kind of mechanism that tells us whether we should update early
+ // or not depending on the number of things that failed during the initial
+ // and subsequent update and how they failed - ie whether it was server
+ // error (like gateway timeout, do retry early) or client error (like
+ // hitting a rate limit, don't retry early). will require reworking a
+ // good amount of code in the feed package and probably having a custom
+ // error type that holds more information because screw wrapping errors.
+ // alternatively have a resource cache and only refetch the failed resources,
+ // then rebuild the widget.
+
+ if err != nil {
+ w.scheduleEarlyUpdate()
+
+ if !errors.Is(err, feed.ErrPartialContent) {
+ w.withError(err)
+ w.withNotice(nil)
+ return false
+ }
+
+ w.withError(nil)
+ w.withNotice(err)
+ return true
+ }
+
+ w.withNotice(nil)
+ w.withError(nil)
+ w.scheduleNextUpdate()
+ return true
+}
+
+func (w *widgetBase) getNextUpdateTime() time.Time {
+ now := time.Now()
+
+ if w.cacheType == cacheTypeDuration {
+ return now.Add(w.cacheDuration)
+ }
+
+ if w.cacheType == cacheTypeOnTheHour {
+ return now.Add(time.Duration(
+ ((60-now.Minute())*60)-now.Second(),
+ ) * time.Second)
+ }
+
+ return time.Time{}
+}
+
+func (w *widgetBase) scheduleNextUpdate() *widgetBase {
+ w.nextUpdate = w.getNextUpdateTime()
+ w.updateRetriedTimes = 0
+
+ return w
+}
+
+func (w *widgetBase) scheduleEarlyUpdate() *widgetBase {
+ w.updateRetriedTimes++
+
+ if w.updateRetriedTimes > 5 {
+ w.updateRetriedTimes = 5
+ }
+
+ nextEarlyUpdate := time.Now().Add(time.Duration(math.Pow(float64(w.updateRetriedTimes), 2)) * time.Minute)
+ nextUsualUpdate := w.getNextUpdateTime()
+
+ if nextEarlyUpdate.After(nextUsualUpdate) {
+ w.nextUpdate = nextUsualUpdate
+ } else {
+ w.nextUpdate = nextEarlyUpdate
+ }
+
+ return w
+}
diff --git a/main.go b/main.go
new file mode 100644
index 0000000..fa1d7f2
--- /dev/null
+++ b/main.go
@@ -0,0 +1,11 @@
+package main
+
+import (
+ "os"
+
+ "github.com/glanceapp/glance/internal/glance"
+)
+
+func main() {
+ os.Exit(glance.Main())
+}
diff --git a/scripts/build-and-ship/main.go b/scripts/build-and-ship/main.go
new file mode 100644
index 0000000..2349947
--- /dev/null
+++ b/scripts/build-and-ship/main.go
@@ -0,0 +1,237 @@
+package main
+
+import (
+ "fmt"
+ "os"
+ "os/exec"
+ "path"
+ "strings"
+)
+
+// bunch of spaget but it does the job for now
+// TODO: tidy up and add a proper build system with CI
+
+const buildPath = "./build"
+const archivesPath = "./build/archives"
+const executableName = "glance"
+const ownerAndRepo = "glanceapp/glance"
+const moduleName = "github.com/" + ownerAndRepo
+
+type archiveType int
+
+const (
+ archiveTypeTarGz archiveType = iota
+ archiveTypeZip
+)
+
+type buildInfo struct {
+ version string
+}
+
+type buildTarget struct {
+ os string
+ arch string
+ armV int
+ extension string
+ archive archiveType
+}
+
+var buildTargets = []buildTarget{
+ {
+ os: "windows",
+ arch: "amd64",
+ extension: ".exe",
+ archive: archiveTypeZip,
+ },
+ {
+ os: "windows",
+ arch: "arm64",
+ extension: ".exe",
+ archive: archiveTypeZip,
+ },
+ {
+ os: "linux",
+ arch: "amd64",
+ },
+ {
+ os: "linux",
+ arch: "arm64",
+ },
+ {
+ os: "linux",
+ arch: "arm",
+ armV: 6,
+ },
+ {
+ os: "linux",
+ arch: "arm",
+ armV: 7,
+ },
+}
+
+func main() {
+ cwd, err := os.Getwd()
+
+ if err != nil {
+ fmt.Println(err)
+ os.Exit(1)
+ }
+
+ _, err = os.Stat(buildPath)
+
+ if err == nil {
+ fmt.Println("Cleaning up build path")
+ os.RemoveAll(buildPath)
+ }
+
+ os.Mkdir(buildPath, 0755)
+ os.Mkdir(archivesPath, 0755)
+
+ version, err := getVersionFromGit()
+
+ if err != nil {
+ fmt.Println(version, err)
+ os.Exit(1)
+ }
+
+ info := buildInfo{
+ version: version,
+ }
+
+ for _, target := range buildTargets {
+ fmt.Printf("Building for %s/%s\n", target.os, target.arch)
+ if err := build(cwd, info, target); err != nil {
+ fmt.Println(err)
+ os.Exit(1)
+ }
+ }
+
+ versionTag := fmt.Sprintf("%s:%s", ownerAndRepo, version)
+ latestTag := fmt.Sprintf("%s:latest", ownerAndRepo)
+
+ fmt.Println("Building docker image")
+
+ output, err := exec.Command(
+ "sudo", "docker", "build",
+ "--platform=linux/arm64,linux/amd64",
+ "-t", versionTag,
+ "-t", latestTag,
+ ".",
+ ).CombinedOutput()
+
+ if err != nil {
+ fmt.Println(string(output))
+ fmt.Println(err)
+ os.Exit(1)
+ }
+
+ var input string
+ fmt.Print("Push docker image? [y/n]: ")
+ fmt.Scanln(&input)
+
+ if input != "y" {
+ os.Exit(0)
+ }
+
+ output, err = exec.Command(
+ "sudo", "docker", "push", versionTag,
+ ).CombinedOutput()
+
+ if err != nil {
+ fmt.Printf("Failed pushing %s:\n", versionTag)
+ fmt.Println(string(output))
+ fmt.Println(err)
+ os.Exit(1)
+ }
+
+ output, err = exec.Command(
+ "sudo", "docker", "push", latestTag,
+ ).CombinedOutput()
+
+ if err != nil {
+ fmt.Printf("Failed pushing %s:\n", latestTag)
+ fmt.Println(string(output))
+ fmt.Println(err)
+ os.Exit(1)
+ }
+}
+
+func getVersionFromGit() (string, error) {
+ output, err := exec.Command("git", "describe", "--tags", "--abbrev=0").CombinedOutput()
+
+ if err == nil {
+ return strings.TrimSpace(string(output)), err
+ }
+
+ return string(output), err
+}
+
+func archiveFile(name string, target string, t archiveType) error {
+ var output []byte
+ var err error
+
+ if t == archiveTypeZip {
+ output, err = exec.Command("zip", "-j", path.Join(archivesPath, name+".zip"), target).CombinedOutput()
+ } else if t == archiveTypeTarGz {
+ output, err = exec.Command("tar", "-C", buildPath, "-czf", path.Join(archivesPath, name+".tar.gz"), name).CombinedOutput()
+ }
+
+ if err != nil {
+ fmt.Println(string(output))
+ return err
+ }
+
+ return nil
+}
+
+func build(workingDir string, info buildInfo, target buildTarget) error {
+ var name string
+
+ if target.arch != "arm" {
+ name = fmt.Sprintf("%s-%s-%s%s", executableName, target.os, target.arch, target.extension)
+ } else {
+ name = fmt.Sprintf("%s-%s-%sv%d", executableName, target.os, target.arch, target.armV)
+ }
+
+ binaryPath := path.Join(buildPath, name)
+
+ glancePackage := moduleName + "/internal/glance"
+
+ flags := "-s -w"
+ flags += fmt.Sprintf(" -X %s.buildVersion=%s", glancePackage, info.version)
+
+ cmd := exec.Command(
+ "go",
+ "build",
+ "--trimpath",
+ "--ldflags",
+ flags,
+ "-o",
+ binaryPath,
+ )
+
+ cmd.Dir = workingDir
+ env := append(os.Environ(), "GOOS="+target.os, "GOARCH="+target.arch, "CGO_ENABLED=0")
+
+ if target.arch == "arm" {
+ env = append(env, fmt.Sprintf("GOARM=%d", target.armV))
+ }
+
+ cmd.Env = env
+ output, err := cmd.CombinedOutput()
+
+ if err != nil {
+ fmt.Println(err)
+ fmt.Println(string(output))
+ return err
+ }
+
+ os.Chmod(binaryPath, 0755)
+
+ fmt.Println("Creating archive")
+ if err := archiveFile(name, binaryPath, target.archive); err != nil {
+ return err
+ }
+
+ return nil
+}
{{ .Place.Name }}, {{ .Place.Country }}
+