113 lines
2.6 KiB
Go
113 lines
2.6 KiB
Go
package main
|
|
|
|
import (
|
|
"log"
|
|
"time"
|
|
)
|
|
|
|
const WEBSOCKET_SERVER = "ws://youtube-download-ws-server.site.quack-lab.dev/ws"
|
|
const WEBSOCKET_SERVER_ALT = "ws://localhost:8080/ws"
|
|
|
|
func init() {
|
|
// log.SetFlags(log.Lmicroseconds | log.Lshortfile)
|
|
log.SetFlags(log.Lmicroseconds)
|
|
}
|
|
|
|
// func instrument() {
|
|
// numGoroutines := runtime.NumGoroutine()
|
|
|
|
// var m runtime.MemStats
|
|
// runtime.ReadMemStats(&m)
|
|
|
|
// malloc := float64(m.Alloc)
|
|
// ramUsedMB := malloc / 1024 / 1024
|
|
// kbPerGoroutine := malloc / 1024 / float64(numGoroutines)
|
|
|
|
// log.Printf("Number of active goroutines: %d; RAM used: %.2f MB; KB per goroutine: %.2f", numGoroutines, ramUsedMB, kbPerGoroutine)
|
|
// }
|
|
|
|
func main() {
|
|
// go func() {
|
|
// for {
|
|
// instrument()
|
|
// time.Sleep(1 * time.Second)
|
|
// }
|
|
// }()
|
|
|
|
// res, err := http.Get(FULL_URL)
|
|
// if err != nil {
|
|
// log.Fatal(err)
|
|
// }
|
|
// defer res.Body.Close()
|
|
// body, err := io.ReadAll(res.Body)
|
|
// if err != nil {
|
|
// log.Printf("Error reading response body: %+v\n", err)
|
|
// return
|
|
// }
|
|
// if res.StatusCode != http.StatusOK {
|
|
// log.Printf("Non-OK HTTP status: %d\nResponse body: %s\n", res.StatusCode, body)
|
|
// return
|
|
// }
|
|
|
|
// var data APIResponse
|
|
// err = json.Unmarshal(body, &data)
|
|
// if err != nil {
|
|
// log.Printf("Error unmarshaling JSON: %+v\n", err)
|
|
// return
|
|
// }
|
|
// log.Printf("Data: %+v\n", data)
|
|
|
|
// listener := new(RealtimeListener)
|
|
// listener.Url = POCKETBASE_REALTIME
|
|
// listener.Collections = []string{COLLECTION_NAME}
|
|
// listener.initialize()
|
|
|
|
var ws WSConnection
|
|
read := make(chan string)
|
|
go func() {
|
|
for {
|
|
ws = WSConnection{
|
|
url: WEBSOCKET_SERVER,
|
|
}
|
|
ws.Open()
|
|
for {
|
|
msg, ok := <-ws.ReadChan
|
|
if !ok {
|
|
break
|
|
}
|
|
read <- msg
|
|
}
|
|
<-ws.Dead
|
|
log.Printf("Reconnecting in 5 seconds...")
|
|
time.Sleep(5 * time.Second)
|
|
}
|
|
}()
|
|
|
|
sem := make(chan struct{}, 4)
|
|
for {
|
|
select {
|
|
case event := <-read:
|
|
eventCopy := event
|
|
status := make(chan error)
|
|
sem <- struct{}{}
|
|
|
|
log.Printf("New event: %+v; semaphore at: %d", eventCopy, len(sem))
|
|
go func() {
|
|
defer func() {
|
|
<-sem
|
|
log.Printf("Semaphore at: %d", len(sem))
|
|
}()
|
|
// Download(eventCopy, status)
|
|
DownloadURL(eventCopy, status)
|
|
// go DownloadNative(event, status)
|
|
for status := range status {
|
|
log.Printf("Status: %s\n", status)
|
|
}
|
|
}()
|
|
case <-time.After(1 * time.Minute):
|
|
// Perform some action or simply continue to avoid deadlock
|
|
log.Println("Consumer is alive, but has no new events.")
|
|
}
|
|
}
|
|
}
|