diff options
| author | Xe Iaso <me@xeiaso.net> | 2024-05-24 11:21:08 -0400 |
|---|---|---|
| committer | Xe Iaso <me@xeiaso.net> | 2024-05-24 11:21:08 -0400 |
| commit | 5d37f3b5cca204d822348a845c1d9dbe8909c66a (patch) | |
| tree | 7f1e372ac725315512fb2e24f750ea7df1873df7 /internal | |
| parent | f1118cbd7ddea56c165f2643f938aee0248e23a3 (diff) | |
| download | xesite-5d37f3b5cca204d822348a845c1d9dbe8909c66a.tar.xz xesite-5d37f3b5cca204d822348a845c1d9dbe8909c66a.zip | |
cmd/xesite: rip out legacy mi integration
Signed-off-by: Xe Iaso <me@xeiaso.net>
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/lume/lume.go | 22 | ||||
| -rw-r--r-- | internal/mi/mi.go | 53 |
2 files changed, 0 insertions, 75 deletions
diff --git a/internal/lume/lume.go b/internal/lume/lume.go index 891e895..2dc5b74 100644 --- a/internal/lume/lume.go +++ b/internal/lume/lume.go @@ -26,7 +26,6 @@ import ( "tailscale.com/metrics" "xeiaso.net/v4/internal/config" "xeiaso.net/v4/internal/jsonfeed" - "xeiaso.net/v4/internal/mi" "xeiaso.net/v4/pb/external/mimi/announce" "xeiaso.net/v4/pb/external/protofeed" ) @@ -71,7 +70,6 @@ type FS struct { opt *Options conf *config.Config - miClient *mi.Client mimiClient announce.Announce fs fs.FS @@ -131,7 +129,6 @@ type Options struct { URL string PatreonClient *patreon.Client DataDir string - MiToken string MimiAnnounceURL string } @@ -209,11 +206,6 @@ func New(ctx context.Context, o *Options) (*FS, error) { siteCommit = ref.Hash().String() } - if o.MiToken != "" { - fs.miClient = mi.New(o.MiToken, "xeiaso.net/v4/internal/lume "+os.Args[0]) - slog.Debug("mi integration enabled") - } - if o.MimiAnnounceURL != "" { mimiClient := announce.NewAnnounceProtobufClient(o.MimiAnnounceURL, &http.Client{}) fs.mimiClient = mimiClient @@ -231,13 +223,6 @@ func New(ctx context.Context, o *Options) (*FS, error) { return nil, err } - if fs.miClient != nil { - go func() { - if err := fs.miClient.Refresh(); err != nil { - slog.Error("failed to refresh mi", "err", err) - } - }() - } go fs.mimiRefresh() fs.lastBuildTime = time.Now() @@ -303,13 +288,6 @@ func (f *FS) Update(ctx context.Context) error { return err } - if f.miClient != nil { - go func() { - if err := f.miClient.Refresh(); err != nil { - slog.Error("failed to refresh mi", "err", err) - } - }() - } go f.mimiRefresh() return nil diff --git a/internal/mi/mi.go b/internal/mi/mi.go deleted file mode 100644 index 67134fd..0000000 --- a/internal/mi/mi.go +++ /dev/null @@ -1,53 +0,0 @@ -package mi - -import ( - "errors" - "net/http" -) - -type Client struct { - cli *http.Client - baseURL string - headers http.Header -} - -func New(token string, userAgent string) *Client { - headers := http.Header{} - headers.Set("Authorization", token) - headers.Set("User-Agent", userAgent) - - cli := &http.Client{} - - return &Client{ - cli: cli, - baseURL: "https://mi.within.website", - headers: headers, - } -} - -func (c *Client) Refresh() error { - if c == nil { - return nil - } - - req, err := http.NewRequest("POST", c.baseURL+"/api/blog/refresh", nil) - if err != nil { - return err - } - - for k, v := range c.headers { - req.Header[k] = v - } - - resp, err := c.cli.Do(req) - if err != nil { - return err - } - defer resp.Body.Close() - - if resp.StatusCode != http.StatusOK { - return errors.New("non-200 status code") - } - - return nil -} |
