aboutsummaryrefslogtreecommitdiff
path: root/internal/integration/rssbridge/rssbridge.go
blob: 672d36b68833fbe408e52bb9ca9ab3aee3926ea6 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
// SPDX-FileCopyrightText: Copyright The Miniflux Authors. All rights reserved.
// SPDX-License-Identifier: Apache-2.0

package rssbridge // import "miniflux.app/integration/rssbridge"

import (
	"encoding/json"
	"fmt"
	"net/http"
	"net/url"
)

type Bridge struct {
	URL        string     `json:"url"`
	BridgeMeta BridgeMeta `json:"bridgeMeta"`
}

type BridgeMeta struct {
	Name string `json:"name"`
}

func DetectBridges(rssbridgeURL, websiteURL string) (bridgeResponse []Bridge, err error) {
	u, err := url.Parse(rssbridgeURL)
	if err != nil {
		return nil, err
	}
	values := u.Query()
	values.Add("action", "findfeed")
	values.Add("format", "atom")
	values.Add("url", websiteURL)
	u.RawQuery = values.Encode()

	response, err := http.Get(u.String())
	if err != nil {
		return nil, fmt.Errorf("RSS-Bridge: unable to excute request: %w", err)
	}
	defer response.Body.Close()
	if response.StatusCode == http.StatusNotFound {
		return
	}
	if response.StatusCode > 400 {
		return nil, fmt.Errorf("RSS-Bridge: unexpected status code %d", response.StatusCode)
	}
	if err := json.NewDecoder(response.Body).Decode(&bridgeResponse); err != nil {
		return nil, fmt.Errorf("RSS-Bridge: unable to decode bridge response: %w", err)
	}
	return
}