mirror of https://github.com/gabehf/Koito.git
Compare commits
No commits in common. 'a4689bed2736e58e5d5c607dd9a2aee705a167b8' and '70f51987813bb85ac01db6f8b0b43804916ea2bc' have entirely different histories.
a4689bed27
...
70f5198781
@ -1,57 +0,0 @@
|
|||||||
import { useState } from "react";
|
|
||||||
import { Modal } from "./Modal";
|
|
||||||
import { AsyncButton } from "../AsyncButton";
|
|
||||||
import { submitListen } from "api/api";
|
|
||||||
import { useNavigate } from "react-router";
|
|
||||||
|
|
||||||
interface Props {
|
|
||||||
open: boolean
|
|
||||||
setOpen: Function
|
|
||||||
trackid: number
|
|
||||||
}
|
|
||||||
|
|
||||||
export default function AddListenModal({ open, setOpen, trackid }: Props) {
|
|
||||||
const [ts, setTS] = useState<Date>(new Date);
|
|
||||||
const [loading, setLoading] = useState(false)
|
|
||||||
const [error, setError] = useState('')
|
|
||||||
const navigate = useNavigate()
|
|
||||||
|
|
||||||
const close = () => {
|
|
||||||
setOpen(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
const submit = () => {
|
|
||||||
setLoading(true)
|
|
||||||
submitListen(trackid.toString(), ts)
|
|
||||||
.then(r => {
|
|
||||||
if(r.ok) {
|
|
||||||
setLoading(false)
|
|
||||||
navigate(0)
|
|
||||||
} else {
|
|
||||||
r.json().then(r => setError(r.error))
|
|
||||||
setLoading(false)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
const formatForDatetimeLocal = (d: Date) => {
|
|
||||||
const pad = (n: number) => n.toString().padStart(2, "0");
|
|
||||||
return `${d.getFullYear()}-${pad(d.getMonth() + 1)}-${pad(d.getDate())}T${pad(d.getHours())}:${pad(d.getMinutes())}`;
|
|
||||||
};
|
|
||||||
|
|
||||||
return (
|
|
||||||
<Modal isOpen={open} onClose={close}>
|
|
||||||
<h2>Add Listen</h2>
|
|
||||||
<div className="flex flex-col items-center gap-4">
|
|
||||||
<input
|
|
||||||
type="datetime-local"
|
|
||||||
className="w-full mx-auto fg bg rounded p-2"
|
|
||||||
value={formatForDatetimeLocal(ts)}
|
|
||||||
onChange={(e) => setTS(new Date(e.target.value))}
|
|
||||||
/>
|
|
||||||
<AsyncButton loading={loading} onClick={submit}>Submit</AsyncButton>
|
|
||||||
<p className="error">{error}</p>
|
|
||||||
</div>
|
|
||||||
</Modal>
|
|
||||||
)
|
|
||||||
}
|
|
||||||
@ -1,77 +0,0 @@
|
|||||||
package handlers
|
|
||||||
|
|
||||||
import (
|
|
||||||
"net/http"
|
|
||||||
"strconv"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/gabehf/koito/engine/middleware"
|
|
||||||
"github.com/gabehf/koito/internal/db"
|
|
||||||
"github.com/gabehf/koito/internal/logger"
|
|
||||||
"github.com/gabehf/koito/internal/utils"
|
|
||||||
)
|
|
||||||
|
|
||||||
func SubmitListenWithIDHandler(store db.DB) http.HandlerFunc {
|
|
||||||
|
|
||||||
var defaultClientStr = "Koito Web UI"
|
|
||||||
|
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
ctx := r.Context()
|
|
||||||
l := logger.FromContext(ctx)
|
|
||||||
|
|
||||||
l.Debug().Msg("SubmitListenWithIDHandler: Got request")
|
|
||||||
|
|
||||||
u := middleware.GetUserFromContext(ctx)
|
|
||||||
if u == nil {
|
|
||||||
l.Debug().Msg("SubmitListenWithIDHandler: Unauthorized request (user context is nil)")
|
|
||||||
utils.WriteError(w, "unauthorized", http.StatusUnauthorized)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
err := r.ParseForm()
|
|
||||||
if err != nil {
|
|
||||||
l.Debug().Msg("SubmitListenWithIDHandler: Failed to parse form")
|
|
||||||
utils.WriteError(w, "form is invalid", http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
trackIDStr := r.FormValue("track_id")
|
|
||||||
timestampStr := r.FormValue("unix")
|
|
||||||
client := r.FormValue("client")
|
|
||||||
if client == "" {
|
|
||||||
client = defaultClientStr
|
|
||||||
}
|
|
||||||
|
|
||||||
if trackIDStr == "" || timestampStr == "" {
|
|
||||||
l.Debug().Msg("SubmitListenWithIDHandler: Request is missing required parameters")
|
|
||||||
utils.WriteError(w, "track_id and unix (timestamp) must be provided", http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
trackID, err := strconv.Atoi(trackIDStr)
|
|
||||||
if err != nil {
|
|
||||||
l.Debug().AnErr("error", err).Msg("SubmitListenWithIDHandler: Invalid track id")
|
|
||||||
utils.WriteError(w, "invalid track_id", http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
unix, err := strconv.ParseInt(timestampStr, 10, 64)
|
|
||||||
if err != nil || time.Now().Unix() < unix {
|
|
||||||
l.Debug().AnErr("error", err).Msg("SubmitListenWithIDHandler: Invalid unix timestamp")
|
|
||||||
utils.WriteError(w, "invalid timestamp", http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
ts := time.Unix(unix, 0)
|
|
||||||
err = store.SaveListen(ctx, db.SaveListenOpts{
|
|
||||||
TrackID: int32(trackID),
|
|
||||||
Time: ts,
|
|
||||||
UserID: u.ID,
|
|
||||||
Client: client,
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
l.Err(err).Msg("SubmitListenWithIDHandler: Failed to submit listen")
|
|
||||||
utils.WriteError(w, "failed to submit listen", http.StatusInternalServerError)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
w.WriteHeader(http.StatusCreated)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,41 +0,0 @@
|
|||||||
package handlers
|
|
||||||
|
|
||||||
import (
|
|
||||||
"net/http"
|
|
||||||
|
|
||||||
"github.com/gabehf/koito/internal/db"
|
|
||||||
"github.com/gabehf/koito/internal/logger"
|
|
||||||
"github.com/gabehf/koito/internal/memkv"
|
|
||||||
"github.com/gabehf/koito/internal/models"
|
|
||||||
"github.com/gabehf/koito/internal/utils"
|
|
||||||
)
|
|
||||||
|
|
||||||
type NowPlayingResponse struct {
|
|
||||||
CurrentlyPlaying bool `json:"currently_playing"`
|
|
||||||
Track models.Track `json:"track"`
|
|
||||||
}
|
|
||||||
|
|
||||||
func NowPlayingHandler(store db.DB) http.HandlerFunc {
|
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
ctx := r.Context()
|
|
||||||
l := logger.FromContext(ctx)
|
|
||||||
|
|
||||||
l.Debug().Msg("NowPlayingHandler: Got request")
|
|
||||||
|
|
||||||
// Hardcoded user id as 1. Not great but it works until (if) multi-user is supported.
|
|
||||||
if trackIdI, ok := memkv.Store.Get("1"); !ok {
|
|
||||||
utils.WriteJSON(w, http.StatusOK, NowPlayingResponse{CurrentlyPlaying: false})
|
|
||||||
} else if trackId, ok := trackIdI.(int32); !ok {
|
|
||||||
l.Debug().Msg("NowPlayingHandler: Failed type assertion for trackIdI")
|
|
||||||
utils.WriteError(w, "internal server error", http.StatusInternalServerError)
|
|
||||||
} else {
|
|
||||||
track, err := store.GetTrack(ctx, db.GetTrackOpts{ID: trackId})
|
|
||||||
if err != nil {
|
|
||||||
l.Error().Err(err).Msg("NowPlayingHandler: Failed to get track from database")
|
|
||||||
utils.WriteError(w, "failed to fetch currently playing track from database", http.StatusInternalServerError)
|
|
||||||
} else {
|
|
||||||
utils.WriteJSON(w, http.StatusOK, NowPlayingResponse{CurrentlyPlaying: true, Track: *track})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,18 +0,0 @@
|
|||||||
package handlers
|
|
||||||
|
|
||||||
import (
|
|
||||||
"net/http"
|
|
||||||
|
|
||||||
"github.com/gabehf/koito/internal/cfg"
|
|
||||||
"github.com/gabehf/koito/internal/utils"
|
|
||||||
)
|
|
||||||
|
|
||||||
type ServerConfig struct {
|
|
||||||
DefaultTheme string `json:"default_theme"`
|
|
||||||
}
|
|
||||||
|
|
||||||
func GetCfgHandler() http.HandlerFunc {
|
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
utils.WriteJSON(w, http.StatusOK, ServerConfig{DefaultTheme: cfg.DefaultTheme()})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,110 +0,0 @@
|
|||||||
package memkv
|
|
||||||
|
|
||||||
import (
|
|
||||||
"sync"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
type item struct {
|
|
||||||
value interface{}
|
|
||||||
expiresAt time.Time
|
|
||||||
}
|
|
||||||
|
|
||||||
type InMemoryStore struct {
|
|
||||||
data map[string]item
|
|
||||||
defaultExpiration time.Duration
|
|
||||||
mu sync.RWMutex
|
|
||||||
stopJanitor chan struct{}
|
|
||||||
}
|
|
||||||
|
|
||||||
var Store *InMemoryStore
|
|
||||||
|
|
||||||
func init() {
|
|
||||||
Store = NewStore(10 * time.Minute)
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewStore(defaultExpiration time.Duration) *InMemoryStore {
|
|
||||||
s := &InMemoryStore{
|
|
||||||
data: make(map[string]item),
|
|
||||||
defaultExpiration: defaultExpiration,
|
|
||||||
stopJanitor: make(chan struct{}),
|
|
||||||
}
|
|
||||||
|
|
||||||
go s.janitor(1 * time.Minute)
|
|
||||||
|
|
||||||
return s
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *InMemoryStore) Set(key string, value interface{}, expiration ...time.Duration) {
|
|
||||||
s.mu.Lock()
|
|
||||||
defer s.mu.Unlock()
|
|
||||||
|
|
||||||
exp := s.defaultExpiration
|
|
||||||
if len(expiration) > 0 {
|
|
||||||
exp = expiration[0]
|
|
||||||
}
|
|
||||||
|
|
||||||
var expiresAt time.Time
|
|
||||||
if exp > 0 {
|
|
||||||
expiresAt = time.Now().Add(exp)
|
|
||||||
}
|
|
||||||
|
|
||||||
s.data[key] = item{
|
|
||||||
value: value,
|
|
||||||
expiresAt: expiresAt,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *InMemoryStore) Get(key string) (interface{}, bool) {
|
|
||||||
s.mu.RLock()
|
|
||||||
it, found := s.data[key]
|
|
||||||
s.mu.RUnlock()
|
|
||||||
|
|
||||||
if !found {
|
|
||||||
return nil, false
|
|
||||||
}
|
|
||||||
|
|
||||||
if !it.expiresAt.IsZero() && time.Now().After(it.expiresAt) {
|
|
||||||
s.Delete(key)
|
|
||||||
return nil, false
|
|
||||||
}
|
|
||||||
|
|
||||||
return it.value, true
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *InMemoryStore) Delete(key string) {
|
|
||||||
s.mu.Lock()
|
|
||||||
defer s.mu.Unlock()
|
|
||||||
delete(s.data, key)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *InMemoryStore) janitor(interval time.Duration) {
|
|
||||||
ticker := time.NewTicker(interval)
|
|
||||||
defer ticker.Stop()
|
|
||||||
|
|
||||||
for {
|
|
||||||
select {
|
|
||||||
case <-ticker.C:
|
|
||||||
s.cleanup()
|
|
||||||
case <-s.stopJanitor:
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *InMemoryStore) cleanup() {
|
|
||||||
now := time.Now()
|
|
||||||
|
|
||||||
s.mu.Lock()
|
|
||||||
defer s.mu.Unlock()
|
|
||||||
|
|
||||||
for k, it := range s.data {
|
|
||||||
if !it.expiresAt.IsZero() && now.After(it.expiresAt) {
|
|
||||||
delete(s.data, k)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *InMemoryStore) Close() {
|
|
||||||
close(s.stopJanitor)
|
|
||||||
}
|
|
||||||
Loading…
Reference in new issue