diff --git a/reader/cmd/main.go b/reader/cmd/main.go index 15f3ff6..1ee46e7 100644 --- a/reader/cmd/main.go +++ b/reader/cmd/main.go @@ -1,13 +1,10 @@ package main import ( - "fmt" - "go.uber.org/zap" - "os" - "reader/internal/config" - logger "reader/internal/log" - "reader/internal/metrics" - "reader/internal/unpacker" + jwtware "github.com/gofiber/contrib/jwt" + "github.com/gofiber/fiber/v2" + "github.com/sirupsen/logrus" + "reader/internal/handlers" ) func main() { @@ -15,29 +12,54 @@ func main() { // //http.HandleFunc("GET /api/v1/download/", handlers.Download) // example request: {"date": "07-03-2025", "start_time": "16-43", "end_time": "16-44"} //http.HandleFunc("GET /api/v1/hls/", handlers.HLS) - //http.HandleFunc("GET /api/v1/vods/", handlers.ListVodsHandler) - //http.HandleFunc("GET /api/v1/vods/{id}/", handlers.ConfigVodsHandler) - //http.HandleFunc("DELETE /api/v1/vods/{id}/", handlers.DelVodsHandler) - //http.HandleFunc("GET /api/v1/vods/{id}/files/", handlers.ListFilesVodsHandler) - //http.HandleFunc("GET /api/v1/vods/{id}/{res}/{file}", handlers.SingleVodsHandler) - //http.HandleFunc("DELETE /api/v1/vods/{id}/{res}/{file}", handlers.DelSingleVodsHandler) - // + //log.Println("Starting server on:") //log.Printf("Serving on HTTP port: %d\n", port) // //log.Fatal(http.ListenAndServe(fmt.Sprintf(":%d", port), nil)) - go metrics.Metrics() - logger.StartMainLogger(config.Local, "reader") + //go metrics.Metrics() + //logger.StartMainLogger(config.Local, "reader") + // + //// Check if the data folder in the directory. + //homeDir, err := os.UserHomeDir() + //if err != nil { + //} + //config.DirData = fmt.Sprintf("%s/%s/vod", homeDir, config.Local) + // + //err = unpacker.CreateVideo() + //if err != nil { + // logger.Log.Error("failed to create flow", zap.Error(err)) + //} - // Check if the data folder in the directory. - homeDir, err := os.UserHomeDir() - if err != nil { - } - config.DirData = fmt.Sprintf("%s/%s/vod", homeDir, config.Local) + app := fiber.New() - err = unpacker.CreateVideo() - if err != nil { - logger.Log.Error("failed to create flow", zap.Error(err)) - } + authStorage := &handlers.AuthStorage{map[string]handlers.User{}} + authHandler := &handlers.AuthHandler{Storage: authStorage} + userHandler := &handlers.UserHandler{Storage: authStorage} + + // Группа обработчиков, которые доступны неавторизованным пользователям + publicGroup := app.Group("") + publicGroup.Post("/register", authHandler.Register) + publicGroup.Post("/login", authHandler.Login) + + // Группа обработчиков, которые требуют авторизации + authorizedGroup := app.Group("") + authorizedGroup.Use(jwtware.New(jwtware.Config{ + SigningKey: jwtware.SigningKey{ + Key: handlers.JwtSecretKey, + }, + ContextKey: handlers.ContextKeyUser, + })) + authorizedGroup.Get("/profile", userHandler.Profile) + + // API Flussonic Media Server adapted handlers. + authorizedGroup.Get("/vods/:id/:res/:file", handlers.SingleVodsHandler) + authorizedGroup.Delete("/vods/:id/:res/:file", handlers.DelSingleVodsHandler) + authorizedGroup.Get("/vods/:id/files", handlers.ListFilesVodsHandler) + authorizedGroup.Delete("/vods/:id", handlers.DelVodsHandler) + authorizedGroup.Get("/vods/:id", handlers.ConfigVodsHandler) + authorizedGroup.Get("/vods", handlers.ListVodsHandler) + + logrus.Fatal(app.Listen(":8100")) } diff --git a/reader/go.mod b/reader/go.mod index ce5d085..47328d2 100644 --- a/reader/go.mod +++ b/reader/go.mod @@ -9,11 +9,17 @@ require ( github.com/bluenviron/mediacommon v1.14.0 github.com/bluenviron/mediacommon/v2 v2.0.0 github.com/gen2brain/aac-go v0.0.0-20230119102159-ef1e76509d21 + github.com/gofiber/contrib/jwt v1.1.0 + github.com/gofiber/fiber/v2 v2.52.6 + github.com/golang-jwt/jwt/v5 v5.2.2 github.com/prometheus/client_golang v1.22.0 + github.com/sirupsen/logrus v1.9.3 go.uber.org/zap v1.27.0 ) require ( + github.com/MicahParks/keyfunc/v2 v2.1.0 // indirect + github.com/andybalholm/brotli v1.1.0 // indirect github.com/asticode/go-astikit v0.54.0 // indirect github.com/asticode/go-astits v1.13.0 // indirect github.com/beorn7/perks v1.0.1 // indirect @@ -22,6 +28,9 @@ require ( github.com/google/uuid v1.6.0 // indirect github.com/grafov/m3u8 v0.12.1 // indirect github.com/klauspost/compress v1.18.0 // indirect + github.com/mattn/go-colorable v0.1.13 // indirect + github.com/mattn/go-isatty v0.0.20 // indirect + github.com/mattn/go-runewidth v0.0.16 // indirect github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect github.com/pion/randutil v0.1.0 // indirect github.com/pion/rtcp v1.2.15 // indirect @@ -30,6 +39,10 @@ require ( github.com/prometheus/client_model v0.6.1 // indirect github.com/prometheus/common v0.63.0 // indirect github.com/prometheus/procfs v0.16.0 // indirect + github.com/rivo/uniseg v0.2.0 // indirect + github.com/valyala/bytebufferpool v1.0.0 // indirect + github.com/valyala/fasthttp v1.51.0 // indirect + github.com/valyala/tcplisten v1.0.0 // indirect go.uber.org/multierr v1.11.0 // indirect golang.org/x/net v0.39.0 // indirect golang.org/x/sys v0.32.0 // indirect diff --git a/reader/go.sum b/reader/go.sum index fdd359c..8c2199e 100644 --- a/reader/go.sum +++ b/reader/go.sum @@ -1,17 +1,11 @@ -git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250403101647-d3117763025c h1:XL0wdylLmMB3WK55l8X1dc/TmBIuVHO9/gUho79NsHw= -git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250403101647-d3117763025c/go.mod h1:dDCZejhHOcSrjFJi6iwB82bTIYEA6IX2CXFXHffrU30= -git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250409113019-60d315c6f613 h1:bFD/cmpO58rhun8q1vZFa31F+D/s5wiL7x+JEVXumsA= -git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250409113019-60d315c6f613/go.mod h1:dDCZejhHOcSrjFJi6iwB82bTIYEA6IX2CXFXHffrU30= -git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250409113444-ba39c3a9fd2f h1:uhHmn71zIKPPhWf4pNMQQFBd23GZt+TFrLTbEBHhaHM= -git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250409113444-ba39c3a9fd2f/go.mod h1:dDCZejhHOcSrjFJi6iwB82bTIYEA6IX2CXFXHffrU30= -git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250409113609-a11ba13ae8ad h1:+7jOhNFyIeLVmsyUQFAxXSKcNKM06Hj9OLxE3vCTYtA= -git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250409113609-a11ba13ae8ad/go.mod h1:dDCZejhHOcSrjFJi6iwB82bTIYEA6IX2CXFXHffrU30= git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250409123815-ca6ff10458e1 h1:od5GvRrFeiz7ko3Z+j4aj2RyULrI37JockSIvju0zNs= git.insit.tech/psa/rtsp_reader-writer/writer v0.0.0-20250409123815-ca6ff10458e1/go.mod h1:dDCZejhHOcSrjFJi6iwB82bTIYEA6IX2CXFXHffrU30= -git.insit.tech/sas/rtsp_proxy v0.0.0-20250403064958-d4446b880371 h1:rfv9H0aF9piFSfdh1ZPPMU+vb2ws/nZyanRJfZmteGI= -git.insit.tech/sas/rtsp_proxy v0.0.0-20250403064958-d4446b880371/go.mod h1:C8AfoW1Go9xoZz2VdGYKjK8h3ormC3zYb40h7OGL+rs= git.insit.tech/sas/rtsp_proxy v0.0.0-20250408124826-100d046486db h1:ED88DsYnxGxKNr8aARLuYOfgE2Dmj3fFlVR5PzdmrOE= git.insit.tech/sas/rtsp_proxy v0.0.0-20250408124826-100d046486db/go.mod h1:C8AfoW1Go9xoZz2VdGYKjK8h3ormC3zYb40h7OGL+rs= +github.com/MicahParks/keyfunc/v2 v2.1.0 h1:6ZXKb9Rp6qp1bDbJefnG7cTH8yMN1IC/4nf+GVjO99k= +github.com/MicahParks/keyfunc/v2 v2.1.0/go.mod h1:rW42fi+xgLJ2FRRXAfNx9ZA8WpD4OeE/yHVMteCkw9k= +github.com/andybalholm/brotli v1.1.0 h1:eLKJA0d02Lf0mVpIDgYnqXcUn0GqVmEFny3VuID1U3M= +github.com/andybalholm/brotli v1.1.0/go.mod h1:sms7XGricyQI9K10gOSf56VKKWS4oLer58Q+mhRPtnY= github.com/asticode/go-astikit v0.30.0/go.mod h1:h4ly7idim1tNhaVkdVBeXQZEE3L0xblP7fCWbgwipF0= github.com/asticode/go-astikit v0.54.0 h1:uq9eurgisdkYwJU9vSWIQaPH4MH0cac82sQH00kmSNQ= github.com/asticode/go-astikit v0.54.0/go.mod h1:fV43j20UZYfXzP9oBn33udkvCvDvCDhzjVqoLFuuYZE= @@ -28,10 +22,17 @@ github.com/bluenviron/mediacommon/v2 v2.0.0/go.mod h1:iHEz1SFIet6zBwAQoh1a92vTQ3 github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs= github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM= github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/gen2brain/aac-go v0.0.0-20230119102159-ef1e76509d21 h1:yfrARW/aVlqKORCdKrYdU0PZUKPqQvYEUQBKfVlNa9Q= github.com/gen2brain/aac-go v0.0.0-20230119102159-ef1e76509d21/go.mod h1:HZqGD/LXHB1VCGUGNzuyxSsD12f3KjbJbvImAmoK/mM= +github.com/gofiber/contrib/jwt v1.1.0 h1:ka5WjWsZ2cd0irvfpmH9hIKj+fflvVRzQxJ7Nv1H3tE= +github.com/gofiber/contrib/jwt v1.1.0/go.mod h1:CpIwrkUQ3Q6IP8y9n3f0wP9bOnSKx39EDp2fBVgMFVk= +github.com/gofiber/fiber/v2 v2.52.6 h1:Rfp+ILPiYSvvVuIPvxrBns+HJp8qGLDnLJawAu27XVI= +github.com/gofiber/fiber/v2 v2.52.6/go.mod h1:YEcBbO/FB+5M1IZNBP9FO3J9281zgPAreiI1oqg8nDw= +github.com/golang-jwt/jwt/v5 v5.2.2 h1:Rl4B7itRWVtYIHFrSNd7vhTiz9UpLdi6gZhZ3wEeDy8= +github.com/golang-jwt/jwt/v5 v5.2.2/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk= github.com/golang/snappy v1.0.0 h1:Oy607GVXHs7RtbggtPBnr2RmDArIsAefDwvrdWvRhGs= github.com/golang/snappy v1.0.0/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q= github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8= @@ -42,8 +43,19 @@ github.com/grafov/m3u8 v0.12.1 h1:DuP1uA1kvRRmGNAZ0m+ObLv1dvrfNO0TPx0c/enNk0s= github.com/grafov/m3u8 v0.12.1/go.mod h1:nqzOkfBiZJENr52zTVd/Dcl03yzphIMbJqkXGu+u080= github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo= github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ= +github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= +github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk= +github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= +github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc= github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw= +github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= +github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg= +github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= +github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= +github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= +github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc= +github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w= github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA= github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ= github.com/pion/randutil v0.1.0 h1:CFG1UdESneORglEsnimhUjf33Rwjubwj6xfiOXBa3mA= @@ -58,8 +70,6 @@ github.com/pkg/profile v1.4.0/go.mod h1:NWz/XGvpEW1FyYQ7fCx4dqYBLlfTcE+A9FLAkNKq github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U= github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= -github.com/prometheus/client_golang v1.21.1 h1:DOvXXTqVzvkIewV/CDPFdejpMCGeMcbGCQ8YOmu+Ibk= -github.com/prometheus/client_golang v1.21.1/go.mod h1:U9NM32ykUErtVBxdvD3zfi+EuFkkaBvMb09mIfe0Zgg= github.com/prometheus/client_golang v1.22.0 h1:rb93p9lokFEsctTys46VnV1kLCDpVZ0a/Y92Vm0Zc6Q= github.com/prometheus/client_golang v1.22.0/go.mod h1:R7ljNsLXhuQXYZYtw6GAE9AZg8Y7vEW5scdCXrWRXC0= github.com/prometheus/client_model v0.6.1 h1:ZKSh/rekM+n3CeS952MLRAdFwIKqeY8b62p8ais2e9E= @@ -68,10 +78,23 @@ github.com/prometheus/common v0.63.0 h1:YR/EIY1o3mEFP/kZCD7iDMnLPlGyuU2Gb3HIcXnA github.com/prometheus/common v0.63.0/go.mod h1:VVFF/fBIoToEnWRVkYoXEkq3R3paCoxG9PXP74SnV18= github.com/prometheus/procfs v0.16.0 h1:xh6oHhKwnOJKMYiYBDWmkHqQPyiY40sny36Cmx2bbsM= github.com/prometheus/procfs v0.16.0/go.mod h1:8veyXUu3nGP7oaCxhX6yeaM5u4stL2FeMXnCqhDthZg= +github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY= +github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc= +github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjRBZyWFQ= +github.com/rogpeppe/go-internal v1.10.0/go.mod h1:UQnix2H7Ngw/k4C5ijL5+65zddjncjaFoBhdsK/akog= +github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ= +github.com/sirupsen/logrus v1.9.3/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4= +github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA= github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= +github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw= +github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc= +github.com/valyala/fasthttp v1.51.0 h1:8b30A5JlZ6C7AS81RsWjYMQmrZG6feChmgAolCl1SqA= +github.com/valyala/fasthttp v1.51.0/go.mod h1:oI2XroL+lI7vdXyYoQk03bXBThfFl2cVdIA3Xl7cH8g= +github.com/valyala/tcplisten v1.0.0 h1:rBHj/Xf+E1tRGZyWIWwJDiRY0zc1Js+CV5DqwacVSA8= +github.com/valyala/tcplisten v1.0.0/go.mod h1:T0xQ8SeCZGxckz9qRXTfG43PvQ/mcWh7FwZEA7Ioqkc= github.com/youpy/go-riff v0.1.0 h1:vZO/37nI4tIET8tQI0Qn0Y79qQh99aEpponTPiPut7k= github.com/youpy/go-riff v0.1.0/go.mod h1:83nxdDV4Z9RzrTut9losK7ve4hUnxUR8ASSz4BsKXwQ= github.com/youpy/go-wav v0.3.2 h1:NLM8L/7yZ0Bntadw/0h95OyUsen+DQIVf9gay+SUsMU= @@ -84,19 +107,21 @@ go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0= go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y= go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8= go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E= -golang.org/x/net v0.38.0 h1:vRMAPTMaeGqVhG5QyLJHqNDwecKTomGeqbnfZyKlBI8= -golang.org/x/net v0.38.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8= golang.org/x/net v0.39.0 h1:ZCu7HMWDxpXpaiKdhzIfaltL9Lp31x/3fCP11bc6/fY= golang.org/x/net v0.39.0/go.mod h1:X7NRbYVEA+ewNkCNyJ513WmMdQ3BineSwVtN2zD/d+E= -golang.org/x/sys v0.31.0 h1:ioabZlmFYtWhL+TRYpcnNlLwhyxaM9kWTDEmfnprqik= -golang.org/x/sys v0.31.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k= +golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.32.0 h1:s77OFDvIQeibCmezSnk/q6iAfkdiQaJi4VzroCFrN20= golang.org/x/sys v0.32.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k= google.golang.org/protobuf v1.36.6 h1:z1NpPI8ku2WgiWnf+t9wTPsn6eP1L7ksHUlkfLvd9xY= google.golang.org/protobuf v1.36.6/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= gopkg.in/natefinch/lumberjack.v2 v2.2.1 h1:bBRl1b0OH9s/DuPhuXpNl+VtCaJXFZ5/uEFST95x9zc= gopkg.in/natefinch/lumberjack.v2 v2.2.1/go.mod h1:YD8tP3GAjkrDg1eZH7EGmyESg/lsYskCTPBJVb9jqSc= gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= +gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/reader/internal/auth/auth.go b/reader/internal/auth/auth.go new file mode 100644 index 0000000..c12c205 --- /dev/null +++ b/reader/internal/auth/auth.go @@ -0,0 +1,197 @@ +package auth + +import ( + "errors" + "fmt" + jwtware "github.com/gofiber/contrib/jwt" + "github.com/gofiber/fiber/v2" + "github.com/golang-jwt/jwt/v5" + "github.com/sirupsen/logrus" + "time" +) + +const ( + contextKeyUser = "user" +) + +func Auth() { + app := fiber.New() + + authStorage := &AuthStorage{map[string]User{}} + authHandler := &AuthHandler{storage: authStorage} + userHandler := &UserHandler{storage: authStorage} + + // Группа обработчиков, которые доступны неавторизованным пользователям + publicGroup := app.Group("") + publicGroup.Post("/register", authHandler.Register) + publicGroup.Post("/login", authHandler.Login) + + // Группа обработчиков, которые требуют авторизации + authorizedGroup := app.Group("") + authorizedGroup.Use(jwtware.New(jwtware.Config{ + SigningKey: jwtware.SigningKey{ + Key: jwtSecretKey, + }, + ContextKey: contextKeyUser, + })) + authorizedGroup.Get("/profile", userHandler.Profile) + + logrus.Fatal(app.Listen(":8000")) +} + +type ( + // Обработчик HTTP-запросов на регистрацию и аутентификацию пользователей + AuthHandler struct { + storage *AuthStorage + } + + // Хранилище зарегистрированных пользователей + // Данные хранятся в оперативной памяти + AuthStorage struct { + users map[string]User + } + + // Структура данных с информацией о пользователе + User struct { + Email string + Name string + password string + } +) + +// Структура HTTP-запроса на регистрацию пользователя +type RegisterRequest struct { + Email string `json:"email"` + Name string `json:"name"` + Password string `json:"password"` +} + +// Обработчик HTTP-запросов на регистрацию пользователя +func (h *AuthHandler) Register(c *fiber.Ctx) error { + regReq := RegisterRequest{} + if err := c.BodyParser(®Req); err != nil { + return fmt.Errorf("body parser: %w", err) + } + + // Проверяем, что пользователь с таким email еще не зарегистрирован + if _, exists := h.storage.users[regReq.Email]; exists { + return errors.New("the user already exists") + } + + // Сохраняем в память нового зарегистрированного пользователя + h.storage.users[regReq.Email] = User{ + Email: regReq.Email, + Name: regReq.Name, + password: regReq.Password, + } + + return c.SendStatus(fiber.StatusCreated) +} + +// Структура HTTP-запроса на вход в аккаунт +type LoginRequest struct { + Email string `json:"email"` + Password string `json:"password"` +} + +// Структура HTTP-ответа на вход в аккаунт +// В ответе содержится JWT-токен авторизованного пользователя +type LoginResponse struct { + AccessToken string `json:"access_token"` +} + +var ( + errBadCredentials = errors.New("email or password is incorrect") +) + +// Секретный ключ для подписи JWT-токена +// Необходимо хранить в безопасном месте +var jwtSecretKey = []byte("very-secret-key") + +// Обработчик HTTP-запросов на вход в аккаунт +func (h *AuthHandler) Login(c *fiber.Ctx) error { + regReq := LoginRequest{} + if err := c.BodyParser(®Req); err != nil { + return fmt.Errorf("body parser: %w", err) + } + + // Ищем пользователя в памяти приложения по электронной почте + user, exists := h.storage.users[regReq.Email] + // Если пользователь не найден, возвращаем ошибку + if !exists { + return errBadCredentials + } + // Если пользователь найден, но у него другой пароль, возвращаем ошибку + if user.password != regReq.Password { + return errBadCredentials + } + + // Генерируем JWT-токен для пользователя, + // который он будет использовать в будущих HTTP-запросах + + // Генерируем полезные данные, которые будут храниться в токене + payload := jwt.MapClaims{ + "sub": user.Email, + "exp": time.Now().Add(time.Hour * 72).Unix(), + } + + // Создаем новый JWT-токен и подписываем его по алгоритму HS256 + token := jwt.NewWithClaims(jwt.SigningMethodHS256, payload) + + t, err := token.SignedString(jwtSecretKey) + if err != nil { + logrus.WithError(err).Error("JWT token signing") + return c.SendStatus(fiber.StatusInternalServerError) + } + + return c.JSON(LoginResponse{AccessToken: t}) +} + +// Обработчик HTTP-запросов, которые связаны с пользователем +type UserHandler struct { + storage *AuthStorage +} + +// Структура HTTP-ответа с информацией о пользователе +type ProfileResponse struct { + Email string `json:"email"` + Name string `json:"name"` +} + +func jwtPayloadFromRequest(c *fiber.Ctx) (jwt.MapClaims, bool) { + jwtToken, ok := c.Context().Value(contextKeyUser).(*jwt.Token) + if !ok { + logrus.WithFields(logrus.Fields{ + "jwt_token_context_value": c.Context().Value(contextKeyUser), + }).Error("wrong type of JWT token in context") + return nil, false + } + + payload, ok := jwtToken.Claims.(jwt.MapClaims) + if !ok { + logrus.WithFields(logrus.Fields{ + "jwt_token_claims": jwtToken.Claims, + }).Error("wrong type of JWT token claims") + return nil, false + } + + return payload, true +} + +// Обработчик HTTP-запросов на получение информации о пользователе +func (h *UserHandler) Profile(c *fiber.Ctx) error { + jwtPayload, ok := jwtPayloadFromRequest(c) + if !ok { + return c.SendStatus(fiber.StatusUnauthorized) + } + + userInfo, ok := h.storage.users[jwtPayload["sub"].(string)] + if !ok { + return errors.New("user not found") + } + + return c.JSON(ProfileResponse{ + Email: userInfo.Email, + Name: userInfo.Name, + }) +} diff --git a/reader/internal/handlers/handlers.go b/reader/internal/handlers/handlers.go index df9fa25..e5e1cda 100644 --- a/reader/internal/handlers/handlers.go +++ b/reader/internal/handlers/handlers.go @@ -4,6 +4,7 @@ import ( "encoding/json" "errors" "fmt" + jwtware "github.com/gofiber/contrib/jwt" "log" "net/http" "os" @@ -12,9 +13,10 @@ import ( "time" "git.insit.tech/psa/rtsp_reader-writer/writer/pkg/storage" - "go.uber.org/zap" + "github.com/gofiber/fiber/v2" + "github.com/golang-jwt/jwt/v5" + "github.com/sirupsen/logrus" "reader/internal/config" - logger "reader/internal/log" "reader/internal/processor" ) @@ -162,13 +164,11 @@ func HLS(w http.ResponseWriter, r *http.Request) { // // This method allows to get the list of all VOD locations. VOD location is a virtual filepath used to place files for // VOD (Video on Demand) broadcasting. -func ListVodsHandler(w http.ResponseWriter, r *http.Request) { +func ListVodsHandler(c *fiber.Ctx) error { // Read directory. entries, err := os.ReadDir(config.DirData) if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("failed to read dir", zap.Error(err)) - return + return c.SendStatus(fiber.StatusInternalServerError) } // Filter only folders. @@ -186,27 +186,20 @@ func ListVodsHandler(w http.ResponseWriter, r *http.Request) { } // Write header and code response. - w.Header().Set("Content-Type", "application/json") - if err := json.NewEncoder(w).Encode(VodsRes); err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("failed to encode dir", zap.Error(err)) - return - } + return c.JSON(VodsRes) } // ConfigVodsHandler returns configuration of the requested VOD location. // // This method allows to get a single VOD location. -func ConfigVodsHandler(w http.ResponseWriter, r *http.Request) { +func ConfigVodsHandler(c *fiber.Ctx) error { // Read camera id. - id := r.PathValue("id") + id := c.Params("id") // Get resolutions. resolutions, err := storage.GetResolutions(id) if err != nil { - http.Error(w, err.Error(), http.StatusBadRequest) - logger.Log.Error("camera does not exist", zap.Error(err)) - return + return c.SendStatus(fiber.StatusBadRequest) } // Calculate response fields. @@ -217,20 +210,19 @@ func ConfigVodsHandler(w http.ResponseWriter, r *http.Request) { // Read directory. entries, err := os.ReadDir(resDir) if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("resolution does not exist", zap.Error(err)) - return + return c.SendStatus(fiber.StatusInternalServerError) } // Check if a folder has files that was not created or modified for last 5 minutes. disabled, err := Inactive5Minutes(entries) if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) + return c.SendStatus(fiber.StatusInternalServerError) } + // Calculate the difference between first existing rec file and the last one in milliseconds. segmentDuration, err := recDurationMilliseconds(entries) if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) + return c.SendStatus(fiber.StatusInternalServerError) } // Prepare the Response. @@ -244,39 +236,30 @@ func ConfigVodsHandler(w http.ResponseWriter, r *http.Request) { } // Write header and code response. - w.Header().Set("Content-Type", "application/json") - if err := json.NewEncoder(w).Encode(VodsRes); err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("failed to encode dir", zap.Error(err)) - return - } - w.Write([]byte("Whole VOD location configuration")) + return c.JSON(VodsRes) } // DelVodsHandler delete archive of the requested VOD location. // // This method delete a single VOD location by its prefix. -func DelVodsHandler(w http.ResponseWriter, r *http.Request) { +func DelVodsHandler(c *fiber.Ctx) error { // Read camera id. - id := r.PathValue("id") + id := c.Params("id") err := os.Remove(fmt.Sprintf("%s/%s", config.DirData, id)) if err != nil { - http.Error(w, err.Error(), http.StatusBadRequest) - logger.Log.Error("camera does not exist", zap.Error(err)) - return + return c.SendStatus(fiber.StatusBadRequest) } - w.WriteHeader(http.StatusNoContent) - w.Write([]byte("Deleted")) + return c.SendStatus(fiber.StatusNoContent) } // ListFilesVodsHandler returns the list of all files and folders in archive for a specific VOD location. // // This method allows to get the list of all files and folders for a specific VOD location. -func ListFilesVodsHandler(w http.ResponseWriter, r *http.Request) { +func ListFilesVodsHandler(c *fiber.Ctx) error { // Read camera id. - id := r.PathValue("id") + id := c.Params("id") // Create map for response. files := make(map[string][]string) @@ -284,9 +267,7 @@ func ListFilesVodsHandler(w http.ResponseWriter, r *http.Request) { // Get resolutions. resolutions, err := storage.GetResolutions(id) if err != nil { - http.Error(w, err.Error(), http.StatusBadRequest) - logger.Log.Error("camera does not exist", zap.Error(err)) - return + return c.SendStatus(fiber.StatusBadRequest) } for _, resolution := range resolutions { @@ -296,9 +277,7 @@ func ListFilesVodsHandler(w http.ResponseWriter, r *http.Request) { // Read directory. entries, err := os.ReadDir(resDir) if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("resolution does not exist", zap.Error(err)) - return + return c.SendStatus(fiber.StatusInternalServerError) } // Create slice for files in folders. @@ -320,37 +299,27 @@ func ListFilesVodsHandler(w http.ResponseWriter, r *http.Request) { } // Write header and code response. - w.Header().Set("Content-Type", "application/json") - w.Write([]byte("List of files in the VOD storage")) - if err := json.NewEncoder(w).Encode(vodsRes); err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("failed to encode dir", zap.Error(err)) - return - } + return c.JSON(vodsRes) } // SingleVodsHandler returns a specific file in archive for a specific resolution and VOD location. // // This method allows to get a single VOD file. -func SingleVodsHandler(w http.ResponseWriter, r *http.Request) { +func SingleVodsHandler(c *fiber.Ctx) error { // Read camera id, res, filename. - id := r.PathValue("id") - res := r.PathValue("res") - file := r.PathValue("file") + id := c.Params("id") + res := c.Params("res") + file := c.Params("file") // Calculate file size in bytes. FileBytes, err := storage.FileBytes(id, res, file) if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("file not found", zap.Error(err)) - return + return c.SendStatus(fiber.StatusBadRequest) } dur, tracks, err := storage.GetDurAndTracks(id, res, file) if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("file not found", zap.Error(err)) - return + return c.SendStatus(fiber.StatusInternalServerError) } media := MediaSingleVodsResponse{ @@ -364,37 +333,216 @@ func SingleVodsHandler(w http.ResponseWriter, r *http.Request) { vodsRes := SingleVodsResponse{ Name: file, Prefix: id, - Url: r.URL.String(), + Url: c.OriginalURL(), Folder: res, Bytes: FileBytes, MediaInfo: media, } // Write header and code response. - w.Header().Set("Content-Type", "application/json") - w.Write([]byte("Whole VOD file configuration")) - if err := json.NewEncoder(w).Encode(vodsRes); err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - logger.Log.Error("failed to encode dir", zap.Error(err)) - return - } + return c.JSON(vodsRes) } // DelSingleVodsHandler deletes a VOD file by its name. // // This method deletes a VOD file by its name. -func DelSingleVodsHandler(w http.ResponseWriter, r *http.Request) { +func DelSingleVodsHandler(c *fiber.Ctx) error { // Read camera id, res, filename. - id := r.PathValue("id") - res := r.PathValue("res") - file := r.PathValue("file") + id := c.Params("id") + res := c.Params("res") + file := c.Params("file") if err := os.Remove(fmt.Sprintf("%s/%s/%s/%s", config.DirData, id, res, file)); err != nil { - http.Error(w, err.Error(), http.StatusNotFound) - logger.Log.Error("file does not exist", zap.Error(err)) - return + return c.SendStatus(fiber.StatusNotFound) } - w.WriteHeader(http.StatusNoContent) - w.Write([]byte("Deleted")) + return c.SendStatus(fiber.StatusNoContent) +} + +// ////////////////////////////////////////////////////////////////////////// +// ////////////////////////////////////////////////////////////////////////// +const ( + ContextKeyUser = "user" +) + +func Auth() { + app := fiber.New() + + authStorage := &AuthStorage{map[string]User{}} + authHandler := &AuthHandler{Storage: authStorage} + userHandler := &UserHandler{Storage: authStorage} + + // Группа обработчиков, которые доступны неавторизованным пользователям + publicGroup := app.Group("") + publicGroup.Post("/register", authHandler.Register) + publicGroup.Post("/login", authHandler.Login) + + // Группа обработчиков, которые требуют авторизации + authorizedGroup := app.Group("") + authorizedGroup.Use(jwtware.New(jwtware.Config{ + SigningKey: jwtware.SigningKey{ + Key: JwtSecretKey, + }, + ContextKey: ContextKeyUser, + })) + authorizedGroup.Get("/profile", userHandler.Profile) + + logrus.Fatal(app.Listen(":8100")) +} + +type ( + // Обработчик HTTP-запросов на регистрацию и аутентификацию пользователей + AuthHandler struct { + Storage *AuthStorage + } + + // Хранилище зарегистрированных пользователей + // Данные хранятся в оперативной памяти + AuthStorage struct { + Users map[string]User + } + + // Структура данных с информацией о пользователе + User struct { + Email string + Name string + password string + } +) + +// Структура HTTP-запроса на регистрацию пользователя +type RegisterRequest struct { + Email string `json:"email"` + Name string `json:"name"` + Password string `json:"password"` +} + +// Обработчик HTTP-запросов на регистрацию пользователя +func (h *AuthHandler) Register(c *fiber.Ctx) error { + regReq := RegisterRequest{} + if err := c.BodyParser(®Req); err != nil { + return fmt.Errorf("body parser: %w", err) + } + + // Проверяем, что пользователь с таким email еще не зарегистрирован + if _, exists := h.Storage.Users[regReq.Email]; exists { + return errors.New("the user already exists") + } + + // Сохраняем в память нового зарегистрированного пользователя + h.Storage.Users[regReq.Email] = User{ + Email: regReq.Email, + Name: regReq.Name, + password: regReq.Password, + } + + return c.SendStatus(fiber.StatusCreated) +} + +// Структура HTTP-запроса на вход в аккаунт +type LoginRequest struct { + Email string `json:"email"` + Password string `json:"password"` +} + +// Структура HTTP-ответа на вход в аккаунт +// В ответе содержится JWT-токен авторизованного пользователя +type LoginResponse struct { + AccessToken string `json:"access_token"` +} + +var ( + errBadCredentials = errors.New("email or password is incorrect") +) + +// Секретный ключ для подписи JWT-токена +// Необходимо хранить в безопасном месте +var JwtSecretKey = []byte("very-secret-key") + +// Обработчик HTTP-запросов на вход в аккаунт +func (h *AuthHandler) Login(c *fiber.Ctx) error { + regReq := LoginRequest{} + if err := c.BodyParser(®Req); err != nil { + return fmt.Errorf("body parser: %w", err) + } + + // Ищем пользователя в памяти приложения по электронной почте + user, exists := h.Storage.Users[regReq.Email] + // Если пользователь не найден, возвращаем ошибку + if !exists { + return errBadCredentials + } + // Если пользователь найден, но у него другой пароль, возвращаем ошибку + if user.password != regReq.Password { + return errBadCredentials + } + + // Генерируем JWT-токен для пользователя, + // который он будет использовать в будущих HTTP-запросах + + // Генерируем полезные данные, которые будут храниться в токене + payload := jwt.MapClaims{ + "sub": user.Email, + "exp": time.Now().Add(time.Hour * 72).Unix(), + } + + // Создаем новый JWT-токен и подписываем его по алгоритму HS256 + token := jwt.NewWithClaims(jwt.SigningMethodHS256, payload) + + t, err := token.SignedString(JwtSecretKey) + if err != nil { + logrus.WithError(err).Error("JWT token signing") + return c.SendStatus(fiber.StatusInternalServerError) + } + + return c.JSON(LoginResponse{AccessToken: t}) +} + +// Обработчик HTTP-запросов, которые связаны с пользователем +type UserHandler struct { + Storage *AuthStorage +} + +// Структура HTTP-ответа с информацией о пользователе +type ProfileResponse struct { + Email string `json:"email"` + Name string `json:"name"` +} + +func jwtPayloadFromRequest(c *fiber.Ctx) (jwt.MapClaims, bool) { + jwtToken, ok := c.Context().Value(ContextKeyUser).(*jwt.Token) + if !ok { + logrus.WithFields(logrus.Fields{ + "jwt_token_context_value": c.Context().Value(ContextKeyUser), + }).Error("wrong type of JWT token in context") + return nil, false + } + + payload, ok := jwtToken.Claims.(jwt.MapClaims) + if !ok { + logrus.WithFields(logrus.Fields{ + "jwt_token_claims": jwtToken.Claims, + }).Error("wrong type of JWT token claims") + return nil, false + } + + return payload, true +} + +// Обработчик HTTP-запросов на получение информации о пользователе +func (h *UserHandler) Profile(c *fiber.Ctx) error { + jwtPayload, ok := jwtPayloadFromRequest(c) + if !ok { + return c.SendStatus(fiber.StatusUnauthorized) + } + + userInfo, ok := h.Storage.Users[jwtPayload["sub"].(string)] + if !ok { + return errors.New("user not found") + } + + return c.JSON(ProfileResponse{ + Email: userInfo.Email, + Name: userInfo.Name, + }) }