mirror of
https://gitlab.com/foxixus/neomovies-api.git
synced 2025-10-28 01:48:51 +05:00
Compare commits
5 Commits
47bcc6589d
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c988c762a9 | ||
|
|
f42d548105 | ||
|
|
04fe3f3925 | ||
|
|
53a405a743 | ||
|
|
71ea922528 |
15
README.md
15
README.md
@@ -278,18 +278,15 @@ curl -X POST https://api.neomovies.ru/api/v1/auth/login \
|
||||
}'
|
||||
```
|
||||
|
||||
### Поиск фильмов
|
||||
### Поиск (унифицированный)
|
||||
|
||||
```bash
|
||||
# Поиск фильмов
|
||||
curl "https://api.neomovies.ru/api/v1/movies/search?query=marvel&page=1"
|
||||
# Мультипоиск (источник обязателен)
|
||||
curl "https://api.neomovies.ru/api/v1/search?query=matrix&source=tmdb&page=1"
|
||||
|
||||
# Детали фильма
|
||||
curl "https://api.neomovies.ru/api/v1/movies/550"
|
||||
|
||||
# Добавить в избранное (с JWT токеном)
|
||||
curl -X POST https://api.neomovies.ru/api/v1/favorites/550 \
|
||||
-H "Authorization: Bearer YOUR_JWT_TOKEN"
|
||||
# Детали по униф. ID
|
||||
curl "https://api.neomovies.ru/api/v1/movie/tmdb_550"
|
||||
curl "https://api.neomovies.ru/api/v1/tv/kp_61365"
|
||||
```
|
||||
|
||||
### Поиск торрентов
|
||||
|
||||
@@ -69,7 +69,7 @@ func Handler(w http.ResponseWriter, r *http.Request) {
|
||||
docsHandler := handlersPkg.NewDocsHandler()
|
||||
searchHandler := handlersPkg.NewSearchHandler(tmdbService, kpService)
|
||||
unifiedHandler := handlersPkg.NewUnifiedHandler(tmdbService, kpService)
|
||||
categoriesHandler := handlersPkg.NewCategoriesHandler(tmdbService)
|
||||
categoriesHandler := handlersPkg.NewCategoriesHandler(tmdbService).WithKinopoisk(kpService)
|
||||
playersHandler := handlersPkg.NewPlayersHandler(globalCfg)
|
||||
torrentsHandler := handlersPkg.NewTorrentsHandler(torrentService, tmdbService)
|
||||
reactionsHandler := handlersPkg.NewReactionsHandler(reactionsService)
|
||||
@@ -97,6 +97,7 @@ func Handler(w http.ResponseWriter, r *http.Request) {
|
||||
api.HandleFunc("/categories/{id}/media", categoriesHandler.GetMediaByCategory).Methods("GET")
|
||||
|
||||
api.HandleFunc("/players/alloha/{id_type}/{id}", playersHandler.GetAllohaPlayer).Methods("GET")
|
||||
api.HandleFunc("/players/alloha/meta/kp/{kp_id}", playersHandler.GetAllohaMetaByKP).Methods("GET")
|
||||
api.HandleFunc("/players/lumex/{id_type}/{id}", playersHandler.GetLumexPlayer).Methods("GET")
|
||||
api.HandleFunc("/players/vibix/{id_type}/{id}", playersHandler.GetVibixPlayer).Methods("GET")
|
||||
api.HandleFunc("/players/hdvb/{id_type}/{id}", playersHandler.GetHDVBPlayer).Methods("GET")
|
||||
|
||||
2
main.go
2
main.go
@@ -49,7 +49,7 @@ func main() {
|
||||
docsHandler := appHandlers.NewDocsHandler()
|
||||
searchHandler := appHandlers.NewSearchHandler(tmdbService, kpService)
|
||||
unifiedHandler := appHandlers.NewUnifiedHandler(tmdbService, kpService)
|
||||
categoriesHandler := appHandlers.NewCategoriesHandler(tmdbService)
|
||||
categoriesHandler := appHandlers.NewCategoriesHandler(tmdbService).WithKinopoisk(kpService)
|
||||
playersHandler := appHandlers.NewPlayersHandler(cfg)
|
||||
torrentsHandler := appHandlers.NewTorrentsHandler(torrentService, tmdbService)
|
||||
reactionsHandler := appHandlers.NewReactionsHandler(reactionsService)
|
||||
|
||||
15
netlify.toml
Normal file
15
netlify.toml
Normal file
@@ -0,0 +1,15 @@
|
||||
[build]
|
||||
functions = "netlify/functions"
|
||||
|
||||
[build.environment]
|
||||
GO_VERSION = "1.22.6"
|
||||
|
||||
# Optional: include static assets used by handlers (placeholders, etc.)
|
||||
[functions]
|
||||
included_files = ["assets/**", "public/**", "static/**"]
|
||||
|
||||
# Route all API requests to the serverless function "api"
|
||||
[[redirects]]
|
||||
from = "/api/*"
|
||||
to = "/.netlify/functions/api/:splat"
|
||||
status = 200
|
||||
15
netlify/functions/api.go
Normal file
15
netlify/functions/api.go
Normal file
@@ -0,0 +1,15 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"net/http"
|
||||
|
||||
bridge "github.com/vercel/go-bridge/go/bridge"
|
||||
handler "neomovies-api/api"
|
||||
)
|
||||
|
||||
func main() {
|
||||
bridge.Start(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||
handler.Handler(w, r.WithContext(context.Background()))
|
||||
}))
|
||||
}
|
||||
@@ -13,12 +13,17 @@ import (
|
||||
|
||||
type CategoriesHandler struct {
|
||||
tmdbService *services.TMDBService
|
||||
kpService *services.KinopoiskService
|
||||
}
|
||||
|
||||
func NewCategoriesHandler(tmdbService *services.TMDBService) *CategoriesHandler {
|
||||
return &CategoriesHandler{
|
||||
tmdbService: tmdbService,
|
||||
// Для совместимости, kpService может быть добавлен позже через setter при инициализации в main.go/api/index.go
|
||||
return &CategoriesHandler{tmdbService: tmdbService}
|
||||
}
|
||||
|
||||
func (h *CategoriesHandler) WithKinopoisk(kp *services.KinopoiskService) *CategoriesHandler {
|
||||
h.kpService = kp
|
||||
return h
|
||||
}
|
||||
|
||||
type Category struct {
|
||||
@@ -35,7 +40,7 @@ func (h *CategoriesHandler) GetCategories(w http.ResponseWriter, r *http.Request
|
||||
return
|
||||
}
|
||||
|
||||
// Преобразуем жанры в категории
|
||||
// Преобразуем жанры в категории (пока TMDB). Для KP — можно замаппить фиксированный список
|
||||
var categories []Category
|
||||
for _, genre := range genresResponse.Genres {
|
||||
slug := generateSlug(genre.Name)
|
||||
@@ -77,16 +82,28 @@ func (h *CategoriesHandler) GetMediaByCategory(w http.ResponseWriter, r *http.Re
|
||||
return
|
||||
}
|
||||
|
||||
source := r.URL.Query().Get("source") // "kp" | "tmdb"
|
||||
var data interface{}
|
||||
var err2 error
|
||||
|
||||
if source == "kp" && h.kpService != nil {
|
||||
// KP не имеет прямого discover по genre id TMDB — здесь можно реализовать маппинг slug->поисковый запрос
|
||||
// Для простоты: используем keyword поиск по имени категории (slug как ключевое слово)
|
||||
// Получим человекочитаемое имя жанра из TMDB как приближение
|
||||
if mediaType == "movie" {
|
||||
// Поиском KP (keyword) эмулируем категорию
|
||||
data, err2 = h.kpService.SearchFilms(r.URL.Query().Get("name"), page)
|
||||
} else {
|
||||
// Для сериалов у KP: используем тот же поиск (KP выдаёт и сериалы в некоторых случаях)
|
||||
data, err2 = h.kpService.SearchFilms(r.URL.Query().Get("name"), page)
|
||||
}
|
||||
} else {
|
||||
if mediaType == "movie" {
|
||||
// Используем discover API для получения фильмов по жанру
|
||||
data, err2 = h.tmdbService.DiscoverMoviesByGenre(categoryID, page, language)
|
||||
} else {
|
||||
// Используем discover API для получения сериалов по жанру
|
||||
data, err2 = h.tmdbService.DiscoverTVByGenre(categoryID, page, language)
|
||||
}
|
||||
}
|
||||
|
||||
if err2 != nil {
|
||||
http.Error(w, err2.Error(), http.StatusInternalServerError)
|
||||
|
||||
@@ -5,6 +5,7 @@ import (
|
||||
"fmt"
|
||||
"io"
|
||||
"net/http"
|
||||
"time"
|
||||
|
||||
"github.com/gorilla/mux"
|
||||
|
||||
@@ -177,7 +178,8 @@ func (h *FavoritesHandler) fetchMediaInfoRussian(mediaID, mediaType string) (*mo
|
||||
url = fmt.Sprintf("https://api.themoviedb.org/3/tv/%s?api_key=%s&language=ru-RU", mediaID, h.config.TMDBAccessToken)
|
||||
}
|
||||
|
||||
resp, err := http.Get(url)
|
||||
client := &http.Client{Timeout: 6 * time.Second}
|
||||
resp, err := client.Get(url)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("failed to fetch from TMDB: %w", err)
|
||||
}
|
||||
|
||||
@@ -7,6 +7,7 @@ import (
|
||||
"log"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"sort"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -58,7 +59,8 @@ func (h *PlayersHandler) GetAllohaPlayer(w http.ResponseWriter, r *http.Request)
|
||||
apiURL := fmt.Sprintf("https://api.alloha.tv/?token=%s&%s", h.config.AllohaToken, idParam)
|
||||
log.Printf("Calling Alloha API: %s", apiURL)
|
||||
|
||||
resp, err := http.Get(apiURL)
|
||||
client := &http.Client{Timeout: 8 * time.Second}
|
||||
resp, err := client.Get(apiURL)
|
||||
if err != nil {
|
||||
log.Printf("Error calling Alloha API: %v", err)
|
||||
http.Error(w, "Failed to fetch from Alloha API", http.StatusInternalServerError)
|
||||
@@ -139,6 +141,120 @@ func (h *PlayersHandler) GetAllohaPlayer(w http.ResponseWriter, r *http.Request)
|
||||
log.Printf("Successfully served Alloha player for %s: %s", idType, id)
|
||||
}
|
||||
|
||||
// GetAllohaMetaByKP returns seasons/episodes meta for Alloha by kinopoisk_id
|
||||
func (h *PlayersHandler) GetAllohaMetaByKP(w http.ResponseWriter, r *http.Request) {
|
||||
vars := mux.Vars(r)
|
||||
kpID := vars["kp_id"]
|
||||
if strings.TrimSpace(kpID) == "" {
|
||||
http.Error(w, "kp_id is required", http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
if h.config.AllohaToken == "" {
|
||||
http.Error(w, "Server misconfiguration: ALLOHA_TOKEN missing", http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
apiURL := fmt.Sprintf("https://api.alloha.tv/?token=%s&kp=%s", url.QueryEscape(h.config.AllohaToken), url.QueryEscape(kpID))
|
||||
client := &http.Client{Timeout: 8 * time.Second}
|
||||
resp, err := client.Get(apiURL)
|
||||
if err != nil {
|
||||
http.Error(w, "Failed to fetch from Alloha API", http.StatusBadGateway)
|
||||
return
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
if resp.StatusCode != http.StatusOK {
|
||||
http.Error(w, fmt.Sprintf("Alloha API error: %d", resp.StatusCode), http.StatusBadGateway)
|
||||
return
|
||||
}
|
||||
body, err := io.ReadAll(resp.Body)
|
||||
if err != nil {
|
||||
http.Error(w, "Failed to read Alloha response", http.StatusBadGateway)
|
||||
return
|
||||
}
|
||||
|
||||
// Define only the parts we need (map-based structure as в примере)
|
||||
var raw struct {
|
||||
Status string `json:"status"`
|
||||
Data struct {
|
||||
SeasonsCount int `json:"seasons_count"`
|
||||
Seasons map[string]struct {
|
||||
Season int `json:"season"`
|
||||
Episodes map[string]struct {
|
||||
Episode int `json:"episode"`
|
||||
Translation map[string]struct {
|
||||
Translation string `json:"translation"`
|
||||
Name string `json:"name"`
|
||||
} `json:"translation"`
|
||||
} `json:"episodes"`
|
||||
} `json:"seasons"`
|
||||
} `json:"data"`
|
||||
}
|
||||
|
||||
if err := json.Unmarshal(body, &raw); err != nil {
|
||||
http.Error(w, "Invalid JSON from Alloha", http.StatusBadGateway)
|
||||
return
|
||||
}
|
||||
|
||||
type episodeMeta struct {
|
||||
Episode int `json:"episode"`
|
||||
Translations []string `json:"translations"`
|
||||
}
|
||||
type seasonMeta struct {
|
||||
Season int `json:"season"`
|
||||
Episodes []episodeMeta `json:"episodes"`
|
||||
}
|
||||
out := struct {
|
||||
Success bool `json:"success"`
|
||||
Seasons []seasonMeta `json:"seasons"`
|
||||
}{Success: true, Seasons: make([]seasonMeta, 0)}
|
||||
|
||||
if raw.Status == "success" && len(raw.Data.Seasons) > 0 {
|
||||
// sort seasons by numeric key
|
||||
seasonKeys := make([]int, 0, len(raw.Data.Seasons))
|
||||
for k := range raw.Data.Seasons {
|
||||
if n, err := strconv.Atoi(strings.TrimSpace(k)); err == nil {
|
||||
seasonKeys = append(seasonKeys, n)
|
||||
}
|
||||
}
|
||||
sort.Ints(seasonKeys)
|
||||
|
||||
for _, sn := range seasonKeys {
|
||||
s := raw.Data.Seasons[strconv.Itoa(sn)]
|
||||
sm := seasonMeta{Season: sn}
|
||||
|
||||
// sort episodes by numeric key
|
||||
epKeys := make([]int, 0, len(s.Episodes))
|
||||
for ek := range s.Episodes {
|
||||
if en, err := strconv.Atoi(strings.TrimSpace(ek)); err == nil {
|
||||
epKeys = append(epKeys, en)
|
||||
}
|
||||
}
|
||||
sort.Ints(epKeys)
|
||||
|
||||
for _, en := range epKeys {
|
||||
e := s.Episodes[strconv.Itoa(en)]
|
||||
em := episodeMeta{Episode: en}
|
||||
// collect translations
|
||||
for _, tr := range e.Translation {
|
||||
t := strings.TrimSpace(tr.Translation)
|
||||
if t == "" {
|
||||
t = strings.TrimSpace(tr.Name)
|
||||
}
|
||||
if t != "" {
|
||||
em.Translations = append(em.Translations, t)
|
||||
}
|
||||
}
|
||||
sm.Episodes = append(sm.Episodes, em)
|
||||
}
|
||||
|
||||
out.Seasons = append(out.Seasons, sm)
|
||||
}
|
||||
}
|
||||
|
||||
w.Header().Set("Content-Type", "application/json")
|
||||
_ = json.NewEncoder(w).Encode(out)
|
||||
}
|
||||
|
||||
func (h *PlayersHandler) GetLumexPlayer(w http.ResponseWriter, r *http.Request) {
|
||||
log.Printf("GetLumexPlayer called: %s %s", r.Method, r.URL.Path)
|
||||
|
||||
@@ -601,7 +717,8 @@ func (h *PlayersHandler) GetHDVBPlayer(w http.ResponseWriter, r *http.Request) {
|
||||
}
|
||||
log.Printf("HDVB API URL: %s", apiURL)
|
||||
|
||||
resp, err := http.Get(apiURL)
|
||||
client := &http.Client{Timeout: 8 * time.Second}
|
||||
resp, err := client.Get(apiURL)
|
||||
if err != nil {
|
||||
log.Printf("Error fetching HDVB data: %v", err)
|
||||
http.Error(w, "Failed to fetch player data", http.StatusInternalServerError)
|
||||
|
||||
@@ -75,6 +75,7 @@ type UnifiedSearchItem struct {
|
||||
SourceID string `json:"sourceId"`
|
||||
Title string `json:"title"`
|
||||
Type string `json:"type"`
|
||||
OriginalType string `json:"originalType,omitempty"`
|
||||
ReleaseDate string `json:"releaseDate"`
|
||||
PosterURL string `json:"posterUrl"`
|
||||
Rating float64 `json:"rating"`
|
||||
|
||||
@@ -220,8 +220,8 @@ func MapKPToUnified(kpFilm *KPFilm) *models.UnifiedContent {
|
||||
Type: mapKPTypeToUnified(kpFilm),
|
||||
Genres: genres,
|
||||
Rating: kpFilm.RatingKinopoisk,
|
||||
PosterURL: poster,
|
||||
BackdropURL: kpFilm.CoverUrl,
|
||||
PosterURL: BuildAPIImageProxyURL(poster, "w500"),
|
||||
BackdropURL: BuildAPIImageProxyURL(kpFilm.CoverUrl, "w1280"),
|
||||
Director: "",
|
||||
Cast: []models.UnifiedCastMember{},
|
||||
Duration: kpFilm.FilmLength,
|
||||
|
||||
@@ -6,6 +6,7 @@ import (
|
||||
"net/http"
|
||||
"net/url"
|
||||
"strconv"
|
||||
"time"
|
||||
|
||||
"neomovies-api/pkg/models"
|
||||
)
|
||||
@@ -17,10 +18,15 @@ type TMDBService struct {
|
||||
}
|
||||
|
||||
func NewTMDBService(accessToken string) *TMDBService {
|
||||
transport := &http.Transport{
|
||||
MaxIdleConns: 100,
|
||||
MaxIdleConnsPerHost: 10,
|
||||
IdleConnTimeout: 60 * time.Second,
|
||||
}
|
||||
return &TMDBService{
|
||||
accessToken: accessToken,
|
||||
baseURL: "https://api.themoviedb.org/3",
|
||||
client: &http.Client{},
|
||||
client: &http.Client{Timeout: 10 * time.Second, Transport: transport},
|
||||
}
|
||||
}
|
||||
|
||||
@@ -196,6 +202,8 @@ func (s *TMDBService) FindTMDBIdByIMDB(imdbID string, media string, language str
|
||||
var resp struct {
|
||||
MovieResults []struct{ ID int `json:"id"` } `json:"movie_results"`
|
||||
TVResults []struct{ ID int `json:"id"` } `json:"tv_results"`
|
||||
TVEpisodeResults []struct{ ShowID int `json:"show_id"` } `json:"tv_episode_results"`
|
||||
TVSeasonResults []struct{ ShowID int `json:"show_id"` } `json:"tv_season_results"`
|
||||
}
|
||||
if err := s.makeRequest(endpoint, &resp); err != nil {
|
||||
return 0, err
|
||||
@@ -217,6 +225,12 @@ func (s *TMDBService) FindTMDBIdByIMDB(imdbID string, media string, language str
|
||||
if len(resp.TVResults) > 0 {
|
||||
return resp.TVResults[0].ID, nil
|
||||
}
|
||||
if len(resp.TVSeasonResults) > 0 {
|
||||
return resp.TVSeasonResults[0].ShowID, nil
|
||||
}
|
||||
if len(resp.TVEpisodeResults) > 0 {
|
||||
return resp.TVEpisodeResults[0].ShowID, nil
|
||||
}
|
||||
}
|
||||
return 0, fmt.Errorf("tmdb id not found for imdb %s", imdbID)
|
||||
}
|
||||
|
||||
@@ -236,6 +236,7 @@ func MapKPSearchToUnifiedItems(kps *KPSearchResponse) []models.UnifiedSearchItem
|
||||
SourceID: "kp_" + strconv.Itoa(kpId),
|
||||
Title: title,
|
||||
Type: mapKPTypeToUnifiedShort(f.Type),
|
||||
OriginalType: strings.ToUpper(strings.TrimSpace(f.Type)),
|
||||
ReleaseDate: yearToDate(f.Year),
|
||||
PosterURL: poster,
|
||||
Rating: rating,
|
||||
|
||||
Reference in New Issue
Block a user