mirror of
https://github.com/TeamPiped/instances-api.git
synced 2024-12-12 21:30:38 +05:30
461 lines
10 KiB
Go
461 lines
10 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
"github.com/InfluxCommunity/influxdb3-go/influxdb3"
|
|
"io"
|
|
"log"
|
|
"net/http"
|
|
"os"
|
|
"regexp"
|
|
"strconv"
|
|
"strings"
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/gofiber/fiber/v2"
|
|
|
|
"github.com/gofiber/fiber/v2/middleware/cors"
|
|
"github.com/gofiber/fiber/v2/middleware/etag"
|
|
"github.com/google/go-github/v60/github"
|
|
)
|
|
|
|
var monitored_instances = []Instance{}
|
|
|
|
var number_re = regexp.MustCompile(`(?m)(\d+)`)
|
|
|
|
type Instance struct {
|
|
Name string `json:"name"`
|
|
ApiUrl string `json:"api_url"`
|
|
Locations string `json:"locations"`
|
|
Version string `json:"version"`
|
|
UpToDate bool `json:"up_to_date"`
|
|
Cdn bool `json:"cdn"`
|
|
Registered int `json:"registered"`
|
|
LastChecked int64 `json:"last_checked"`
|
|
Cache bool `json:"cache"`
|
|
S3Enabled bool `json:"s3_enabled"`
|
|
ImageProxyUrl string `json:"image_proxy_url"`
|
|
RegistrationDisabled bool `json:"registration_disabled"`
|
|
Uptime24h float32 `json:"uptime_24h"`
|
|
Uptime7d float32 `json:"uptime_7d"`
|
|
Uptime30d float32 `json:"uptime_30d"`
|
|
}
|
|
|
|
type FrontendConfig struct {
|
|
S3Enabled bool `json:"s3Enabled"`
|
|
ImageProxyUrl string `json:"imageProxyUrl"`
|
|
RegistrationDisabled bool `json:"registrationDisabled"`
|
|
}
|
|
|
|
type PipedStreams struct {
|
|
Url string `json:"url"`
|
|
}
|
|
|
|
type Streams struct {
|
|
VideoStreams []PipedStreams `json:"videoStreams"`
|
|
}
|
|
|
|
var client = http.Client{
|
|
Timeout: 10 * time.Second,
|
|
}
|
|
|
|
var influxdbClient *influxdb3.Client
|
|
|
|
func testUrl(url string) (*http.Response, error) {
|
|
req, err := http.NewRequest("GET", url, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
req.Header.Set("User-Agent", "Piped-Instances-API/(https://github.com/TeamPiped/instances-api)")
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
return resp, err
|
|
}
|
|
if resp.StatusCode != 200 {
|
|
return resp, errors.New(fmt.Sprintf("Invalid response code at %s: %d", url, resp.StatusCode))
|
|
}
|
|
return resp, err
|
|
}
|
|
|
|
func testCaching(ApiUrl string) (bool, error) {
|
|
resp, err := testUrl(ApiUrl + "/trending?region=US")
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
oldTiming := resp.Header.Get("Server-Timing")
|
|
resp, err = testUrl(ApiUrl + "/trending?region=US")
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
newTiming := resp.Header.Get("Server-Timing")
|
|
cacheWorking := oldTiming == newTiming
|
|
return cacheWorking, nil
|
|
}
|
|
|
|
func getConfig(ApiUrl string) (FrontendConfig, error) {
|
|
resp, err := testUrl(ApiUrl + "/config")
|
|
if err != nil {
|
|
return FrontendConfig{}, err
|
|
}
|
|
bytes, err := io.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return FrontendConfig{}, err
|
|
}
|
|
var config FrontendConfig
|
|
err = json.Unmarshal(bytes, &config)
|
|
if err != nil {
|
|
return FrontendConfig{}, err
|
|
}
|
|
return config, nil
|
|
}
|
|
|
|
func getStreams(ApiUrl string, VideoId string) (Streams, error) {
|
|
resp, err := testUrl(ApiUrl + "/streams/" + VideoId)
|
|
if err != nil {
|
|
return Streams{}, err
|
|
}
|
|
bytes, err := io.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return Streams{}, err
|
|
}
|
|
var streams Streams
|
|
err = json.Unmarshal(bytes, &streams)
|
|
if err != nil {
|
|
return Streams{}, err
|
|
}
|
|
return streams, nil
|
|
}
|
|
|
|
func storeUptimeHistory(apiUrl string, uptimeStatus bool) {
|
|
// Create a new point
|
|
p := influxdb3.NewPointWithMeasurement("uptime").
|
|
SetTag("apiUrl", apiUrl).
|
|
SetField("status", uptimeStatus).
|
|
SetTimestamp(time.Now())
|
|
|
|
points := []*influxdb3.Point{p}
|
|
|
|
// Write the point
|
|
err := influxdbClient.WritePoints(context.Background(), points)
|
|
if err != nil {
|
|
log.Print(err)
|
|
}
|
|
}
|
|
|
|
func getUptimePercentage(apiUrl string, hours int) (float32, error) {
|
|
// Fetch uptime history from InfluxDB for the given period
|
|
query := fmt.Sprintf(`SELECT "status" FROM "uptime" WHERE "apiUrl" = '%s' AND time >= now() - interval '%d hours'`, apiUrl, hours)
|
|
result, err := influxdbClient.Query(context.Background(), query)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
|
|
// Calculate uptime percentage
|
|
successCount, failureCount := 0, 0
|
|
for result.Next() {
|
|
uptimeStatus := result.Value()["status"].(bool)
|
|
if uptimeStatus {
|
|
successCount++
|
|
} else {
|
|
failureCount++
|
|
}
|
|
}
|
|
uptimePercentage := float32(successCount) / float32(successCount+failureCount) * 100
|
|
|
|
return uptimePercentage, nil
|
|
}
|
|
|
|
func getInstanceDetails(split []string, latest string) (Instance, error) {
|
|
ApiUrl := strings.TrimSpace(split[1])
|
|
|
|
wg := sync.WaitGroup{}
|
|
errorChannel := make(chan error)
|
|
// the amount of tests to do
|
|
wg.Add(6)
|
|
// Add 3 more for uptime history
|
|
wg.Add(3)
|
|
|
|
var lastChecked int64
|
|
var registered int64
|
|
var config FrontendConfig
|
|
var hash string
|
|
var version string
|
|
var cacheWorking bool
|
|
|
|
go func() {
|
|
wg.Wait()
|
|
close(errorChannel)
|
|
}()
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
if _, err := testUrl(ApiUrl + "/healthcheck"); err != nil {
|
|
errorChannel <- err
|
|
return
|
|
}
|
|
lastChecked = time.Now().Unix()
|
|
}()
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
resp, err := testUrl(ApiUrl + "/registered/badge")
|
|
if err != nil {
|
|
errorChannel <- err
|
|
return
|
|
}
|
|
registered, err = strconv.ParseInt(number_re.FindString(resp.Request.URL.Path), 10, 32)
|
|
if err != nil {
|
|
errorChannel <- err
|
|
}
|
|
}()
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
resp, err := testUrl(ApiUrl + "/version")
|
|
if err != nil {
|
|
errorChannel <- err
|
|
return
|
|
}
|
|
buf := new(strings.Builder)
|
|
_, err = io.Copy(buf, resp.Body)
|
|
if err != nil {
|
|
errorChannel <- err
|
|
return
|
|
}
|
|
version = strings.TrimSpace(buf.String())
|
|
version_split := strings.Split(version, "-")
|
|
hash = version_split[len(version_split)-1]
|
|
}()
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
var err error
|
|
config, err = getConfig(ApiUrl)
|
|
if err != nil {
|
|
errorChannel <- err
|
|
}
|
|
}()
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
var err error
|
|
cacheWorking, err = testCaching(ApiUrl)
|
|
if err != nil {
|
|
errorChannel <- err
|
|
}
|
|
}()
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
// check if instance can fetch videos
|
|
streams, err := getStreams(ApiUrl, "jNQXAC9IVRw")
|
|
if err != nil {
|
|
errorChannel <- err
|
|
return
|
|
}
|
|
if len(streams.VideoStreams) == 0 {
|
|
errorChannel <- errors.New("no streams")
|
|
}
|
|
// head request to check first stream
|
|
if _, err := testUrl(streams.VideoStreams[0].Url); err != nil {
|
|
errorChannel <- err
|
|
}
|
|
}()
|
|
|
|
var uptime24h, uptime7d, uptime30d float32
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
var err error
|
|
uptime24h, err = getUptimePercentage(ApiUrl, 24)
|
|
if err != nil {
|
|
errorChannel <- err
|
|
}
|
|
}()
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
var err error
|
|
uptime7d, err = getUptimePercentage(ApiUrl, 24*7)
|
|
if err != nil {
|
|
errorChannel <- err
|
|
}
|
|
}()
|
|
|
|
go func() {
|
|
defer wg.Done()
|
|
var err error
|
|
uptime30d, err = getUptimePercentage(ApiUrl, 24*30)
|
|
if err != nil {
|
|
errorChannel <- err
|
|
}
|
|
}()
|
|
|
|
for err := range errorChannel {
|
|
go func() {
|
|
// Store the uptime history
|
|
storeUptimeHistory(ApiUrl, err == nil)
|
|
}()
|
|
return Instance{}, err
|
|
}
|
|
|
|
go func() {
|
|
// Store the uptime history
|
|
storeUptimeHistory(ApiUrl, true)
|
|
}()
|
|
|
|
return Instance{
|
|
Name: strings.TrimSpace(split[0]),
|
|
ApiUrl: ApiUrl,
|
|
Locations: strings.TrimSpace(split[2]),
|
|
Cdn: strings.TrimSpace(split[3]) == "Yes",
|
|
Registered: int(registered),
|
|
LastChecked: lastChecked,
|
|
Version: version,
|
|
UpToDate: strings.Contains(latest, hash),
|
|
Cache: cacheWorking,
|
|
S3Enabled: config.S3Enabled,
|
|
ImageProxyUrl: config.ImageProxyUrl,
|
|
RegistrationDisabled: config.RegistrationDisabled,
|
|
Uptime24h: uptime24h,
|
|
Uptime7d: uptime7d,
|
|
Uptime30d: uptime30d,
|
|
}, nil
|
|
}
|
|
|
|
func monitorInstances() {
|
|
ctx := context.Background()
|
|
ghClient := github.NewClient(nil)
|
|
|
|
if os.Getenv("GITHUB_TOKEN") != "" {
|
|
ghClient = ghClient.WithAuthToken(os.Getenv("GITHUB_TOKEN"))
|
|
}
|
|
|
|
// do forever
|
|
for {
|
|
// send a request to get markdown from GitHub
|
|
req, err := http.NewRequest("GET", "https://raw.githubusercontent.com/wiki/TeamPiped/Piped-Frontend/Instances.md", nil)
|
|
if err != nil {
|
|
log.Print(err)
|
|
continue
|
|
}
|
|
req.Header.Set("User-Agent", "Piped-Instances-API/(https://github.com/TeamPiped/instances-api)")
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
log.Print(err)
|
|
continue
|
|
}
|
|
|
|
// Find Latest Commit from GitHub
|
|
var latest string
|
|
{
|
|
commits, _, err := ghClient.Repositories.ListCommits(ctx, "TeamPiped", "Piped-Backend", &github.CommitsListOptions{
|
|
ListOptions: github.ListOptions{
|
|
PerPage: 1,
|
|
},
|
|
})
|
|
if err != nil {
|
|
log.Print(err)
|
|
time.Sleep(time.Second * 5)
|
|
continue
|
|
}
|
|
latest = commits[0].GetSHA()
|
|
}
|
|
|
|
if resp.StatusCode == 200 {
|
|
// parse the response
|
|
buf := new(strings.Builder)
|
|
_, err := io.Copy(buf, resp.Body)
|
|
|
|
if err != nil {
|
|
log.Print(err)
|
|
continue
|
|
}
|
|
|
|
lines := strings.Split(buf.String(), "\n")
|
|
|
|
instancesMap := make(map[int]Instance)
|
|
|
|
wg := sync.WaitGroup{}
|
|
|
|
skipped := 0
|
|
checking := 0
|
|
for _, line := range lines {
|
|
split := strings.Split(line, "|")
|
|
|
|
if len(split) < 5 {
|
|
continue
|
|
}
|
|
|
|
// skip first two table lines
|
|
if skipped < 2 {
|
|
skipped++
|
|
continue
|
|
}
|
|
|
|
wg.Add(1)
|
|
go func(i int, split []string) {
|
|
defer wg.Done()
|
|
instance, err := getInstanceDetails(split, latest)
|
|
if err == nil {
|
|
instancesMap[i] = instance
|
|
} else {
|
|
log.Print(err)
|
|
}
|
|
}(checking, split)
|
|
checking++
|
|
}
|
|
wg.Wait()
|
|
|
|
// Map to ordered array
|
|
var instances []Instance
|
|
for i := 0; i < checking; i++ {
|
|
instance, ok := instancesMap[i]
|
|
if ok {
|
|
instances = append(instances, instance)
|
|
}
|
|
}
|
|
|
|
// update the global instances variable
|
|
monitored_instances = instances
|
|
}
|
|
_ = resp.Body.Close()
|
|
time.Sleep(time.Minute)
|
|
}
|
|
}
|
|
|
|
func main() {
|
|
// create influxdb client
|
|
{
|
|
client, err := influxdb3.New(influxdb3.ClientConfig{
|
|
Host: os.Getenv("INFLUXDB_URL"),
|
|
Token: os.Getenv("INFLUXDB_TOKEN"),
|
|
Database: os.Getenv("INFLUXDB_DATABASE"),
|
|
})
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
influxdbClient = client
|
|
}
|
|
|
|
go monitorInstances()
|
|
|
|
app := fiber.New()
|
|
app.Use(cors.New())
|
|
app.Use(etag.New())
|
|
|
|
app.Get("/", func(c *fiber.Ctx) error {
|
|
return c.JSON(monitored_instances)
|
|
})
|
|
|
|
err := app.Listen(":3000")
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
}
|