feat: crafting stock and national currency proxy

Makefile

@@ -18,6 +18,14 @@ traefik-test:
 		--api.dashboard=true \
 		--api.insecure=false
 
+stock-list-test:
+	curl -X GET $(ENDPOINT)/stock/lists
+
+stock-prediction-test:
+	curl -X POST $(ENDPOINT)/stock/prediction \
+		-H "Content-Type: application/json" \
+		-d "{\"days\": 2, \"currency\": \"BTC-USD\"}"
+
 crypto-list-test:
 	curl -X GET $(ENDPOINT)/crypto/lists
 
@@ -25,4 +33,12 @@ crypto-prediction-test:
 	curl -X POST $(ENDPOINT)/crypto/prediction \
 		-H "Content-Type: application/json" \
 		-d "{\"days\": 2, \"currency\": \"BTC-USD\"}"
+
+natcurr-list-test:
+	curl -X GET $(ENDPOINT)/national-currency/lists
+
+natcurr-prediction-test:
+	curl -X POST $(ENDPOINT)/national-currency/prediction \
+		-H "Content-Type: application/json" \
+		-d "{\"days\": 2, \"currency\": \"BTC-USD\"}"
 	

main.go

@@ -7,19 +7,41 @@ import (
 	"github.com/gofiber/fiber/v2"
 
 	proxy "tebakaja_lb_proxy/proxy"
+
+	stock_proxy "tebakaja_lb_proxy/proxy/stock"
 	crypto_proxy "tebakaja_lb_proxy/proxy/crypto"
+	national_currency_proxy "tebakaja_lb_proxy/proxy/national_currency"
 )
 
 func main() {
-	app := fiber.New()
+	proxyService := fiber.New()
+	proxyService.Use(proxy.LoggingMiddleware)
+	proxyService.Use(proxy.RateLimiterMiddleware())
+
+	stockGroup := proxyService.Group("/stock")
+	stockGroup.Get("/lists",
+		stock_proxy.StockListsHandler(
+			&stock_proxy.StockServiceImpl{}))
+	stockGroup.Post("/prediction",
+		stock_proxy.StockPredictionHandler(
+			&stock_proxy.StockServiceImpl{}))
 
-	app.Use(proxy.LoggingMiddleware)
-	app.Use(proxy.RateLimiter())
+	cryptoGroup := proxyService.Group("/crypto")
+	cryptoGroup.Get("/lists",
+		crypto_proxy.CryptoListsHandler(
+			&crypto_proxy.CryptoServiceImpl{}))
+	cryptoGroup.Post("/prediction",
+		crypto_proxy.CryptoPredictionHandler(
+			&crypto_proxy.CryptoServiceImpl{}))
 
-	cryptoGroup := app.Group("/crypto")
-	cryptoGroup.Get("/lists", crypto_proxy.CryptoListsHandler(&crypto_proxy.CryptoServiceImpl{}))
-	cryptoGroup.Post("/prediction", crypto_proxy.CryptoPredictionHandler(&crypto_proxy.CryptoServiceImpl{}))
+	nationalCurrencyGroup := proxyService.Group("/national-currency")
+	nationalCurrencyGroup.Get("/lists",
+		national_currency_proxy.NationalCurrencyListsHandler(
+			&national_currency_proxy.NationalCurrencyServiceImpl{}))
+	nationalCurrencyGroup.Post("/prediction",
+		national_currency_proxy.NationalCurrencyPredictionHandler(
+			&national_currency_proxy.NationalCurrencyServiceImpl{}))
 
 	port := 7860
-	log.Fatal(app.Listen(fmt.Sprintf("0.0.0.0:%d", port)))
+	log.Fatal(proxyService.Listen(fmt.Sprintf("0.0.0.0:%d", port)))
 }

proxy/crypto/constants.go

@@ -1,3 +0,0 @@
-package crypto
-
-const CRYPTO_ENDPOINT = "https://qywok-cryptocurrency-prediction.hf.space/crypto"

proxy/crypto/list_service.go

@@ -5,6 +5,7 @@ import (
 	"context"
 	"net/http"
 	"encoding/json"
+	proxy "tebakaja_lb_proxy/proxy"
 )
 
 
@@ -12,7 +13,7 @@ import (
  *  --- Cryptocurrency Prediction Model Lists Service ---
  */
 func (s *CryptoServiceImpl) CryptoListsService(ctx context.Context) (ApiResponse, error) {
-	endpoint := fmt.Sprintf("%s/lists", CRYPTO_ENDPOINT)
+	endpoint := fmt.Sprintf("%s/lists", proxy.GetEndpointByRestService("crypto"))
 	req, err := http.NewRequestWithContext(ctx, "GET", endpoint, nil)
 	if err != nil {
 		return ApiResponse{

proxy/crypto/prediction_service.go

@@ -6,6 +6,7 @@ import (
 	"context"
 	"net/http"
 	"encoding/json"
+	proxy "tebakaja_lb_proxy/proxy"
 )
 
 
@@ -21,7 +22,7 @@ func (s *CryptoServiceImpl) CryptoPredictionService(ctx context.Context, req Pre
 		}, err
 	}
 
-	endpoint := fmt.Sprintf("%s/prediction", CRYPTO_ENDPOINT)
+	endpoint := fmt.Sprintf("%s/prediction", proxy.GetEndpointByRestService("crypto"))
 	httpReq, err := http.NewRequestWithContext(ctx, "POST", endpoint, bytes.NewBuffer(reqBody))
 	if err != nil {
 		return ApiResponse{

proxy/loadbalancers.go

@@ -1 +0,0 @@
-package proxy

proxy/middlewares.go

@@ -9,22 +9,31 @@ import (
 	"github.com/gofiber/fiber/v2/middleware/limiter"
 )
 
-// Middleware untuk logging setiap request
+// Logging Middleware
 func LoggingMiddleware(c *fiber.Ctx) error {
 	start := time.Now()
-	err := c.Next()
-	log.Printf("[%s] %s %s - %d %s in %v", time.Now().Format("2006-01-02 15:04:05"), c.Method(), c.Path(), c.Response().StatusCode(), http.StatusText(c.Response().StatusCode()), time.Since(start))
+	err   := c.Next()
+
+	log.Printf("[%s] %s %s - %d %s in %v", time.Now().Format("2006-01-02 15:04:05"),
+		c.Method(), c.Path(), c.Response().StatusCode(),
+		http.StatusText(c.Response().StatusCode()), time.Since(start))
+
 	return err
 }
 
-// Middleware rate limiter: 200 requests per menit per IP
-func RateLimiter() func(*fiber.Ctx) error {
+
+/*
+ *  --- Rate Limiter Middleware ---
+*/
+func RateLimiterMiddleware() func(*fiber.Ctx) error {
 	return limiter.New(limiter.Config{
 		Max:        200,
 		Expiration: 1 * time.Minute,
+
 		KeyGenerator: func(c *fiber.Ctx) string {
 			return c.IP()
 		},
+
 		LimitReached: func(c *fiber.Ctx) error {
 			return c.Status(http.StatusTooManyRequests).JSON(fiber.Map{
 				"error": "Rate limit exceeded",

proxy/national_currency/constants.go

@@ -1,3 +0,0 @@
-package national_currency
-
-const CRYPTO_ENDPOINT = "https://qywok-cryptocurrency-prediction.hf.space/crypto"

proxy/national_currency/interfaces.go

@@ -2,9 +2,9 @@ package national_currency
 
 import "context"
 
-type CryptoService interface {
-	CryptoListsService(ctx context.Context) (ApiResponse, error)
-	CryptoPredictionService(ctx context.Context, req PredictionRequest) (ApiResponse, error)
+type NationalCurrencyService interface {
+	NationalCurrencyListsService(ctx context.Context) (ApiResponse, error)
+	NationalCurrencyPredictionService(ctx context.Context, req PredictionRequest) (ApiResponse, error)
 }
 
-type CryptoServiceImpl struct{}
+type NationalCurrencyServiceImpl struct{}

proxy/national_currency/list_handler.go

@@ -12,9 +12,9 @@ import (
 
 
 /*
- *  --- Cryptocurrency Prediction Model Lists Handler ---
+ *  --- National Currency Prediction Model Lists Handler ---
  */
-func CryptoListsHandler(service CryptoService) fiber.Handler {
+func NationalCurrencyListsHandler(service NationalCurrencyService) fiber.Handler {
 	return func(c *fiber.Ctx) error {
 		ctx, cancel := context.WithTimeout(c.Context(), 120*time.Second)
 		defer cancel()
@@ -26,7 +26,7 @@ func CryptoListsHandler(service CryptoService) fiber.Handler {
 		go func() {
 			defer wg.Done()
 
-			apiResponse, err := service.CryptoListsService(ctx)
+			apiResponse, err := service.NationalCurrencyListsService(ctx)
 			if err != nil {
 				log.Printf("[%s] %v", time.Now().Format("2006-01-02 15:04:05"), err)
 				ch <- apiResponse

proxy/national_currency/list_service.go

@@ -5,14 +5,15 @@ import (
 	"context"
 	"net/http"
 	"encoding/json"
+	proxy "tebakaja_lb_proxy/proxy"
 )
 
 
 /*
- *  --- Cryptocurrency Prediction Model Lists Service ---
+ *  --- National Currency Prediction Model Lists Service ---
  */
-func (s *CryptoServiceImpl) CryptoListsService(ctx context.Context) (ApiResponse, error) {
-	endpoint := fmt.Sprintf("%s/lists", CRYPTO_ENDPOINT)
+func (s *NationalCurrencyServiceImpl) NationalCurrencyListsService(ctx context.Context) (ApiResponse, error) {
+	endpoint := fmt.Sprintf("%s/lists", proxy.GetEndpointByRestService("national"))
 	req, err := http.NewRequestWithContext(ctx, "GET", endpoint, nil)
 	if err != nil {
 		return ApiResponse{
@@ -28,6 +29,7 @@ func (s *CryptoServiceImpl) CryptoListsService(ctx context.Context) (ApiResponse
 			StatusCode: http.StatusInternalServerError,
 		}, err
 	}
+	
 	defer resp.Body.Close()
 
 	if resp.StatusCode != http.StatusOK {

proxy/national_currency/prediction_handler.go

@@ -13,9 +13,9 @@ import (
 
 
 /*
- * --- Cryptocurrency Prediction Handler ---
+ * --- National Currency Prediction Handler ---
  */
-func CryptoPredictionHandler(service CryptoService) fiber.Handler {
+func NationalCurrencyPredictionHandler(service NationalCurrencyService) fiber.Handler {
 	return func(c *fiber.Ctx) error {
 		ctx, cancel := context.WithTimeout(c.Context(), 120*time.Second)
 		defer cancel()
@@ -39,7 +39,7 @@ func CryptoPredictionHandler(service CryptoService) fiber.Handler {
 				return
 			}
 
-			apiResponse, err := service.CryptoPredictionService(ctx, predictionReq)
+			apiResponse, err := service.NationalCurrencyPredictionService(ctx, predictionReq)
 			if err != nil {
 				log.Printf("[%s] %v", time.Now().Format("2006-01-02 15:04:05"), err)
 				ch <- apiResponse

proxy/national_currency/prediction_service.go

@@ -6,13 +6,14 @@ import (
 	"context"
 	"net/http"
 	"encoding/json"
-)
+	proxy "tebakaja_lb_proxy/proxy"
+) 
 
 
 /*
- * --- Cryptocurrency Prediction Service ---
+ * --- National Currency Prediction Service ---
  */
-func (s *CryptoServiceImpl) CryptoPredictionService(ctx context.Context, req PredictionRequest) (ApiResponse, error) {
+func (s *NationalCurrencyServiceImpl) NationalCurrencyPredictionService(ctx context.Context, req PredictionRequest) (ApiResponse, error) {
 	reqBody, err := json.Marshal(req)
 	if err != nil {
 		return ApiResponse{
@@ -21,7 +22,7 @@ func (s *CryptoServiceImpl) CryptoPredictionService(ctx context.Context, req Pre
 		}, err
 	}
 
-	endpoint := fmt.Sprintf("%s/prediction", CRYPTO_ENDPOINT)
+	endpoint := fmt.Sprintf("%s/prediction", proxy.GetEndpointByRestService("national"))
 	httpReq, err := http.NewRequestWithContext(ctx, "POST", endpoint, bytes.NewBuffer(reqBody))
 	if err != nil {
 		return ApiResponse{

proxy/stock/constants.go

@@ -1,3 +0,0 @@
-package stock
-
-const CRYPTO_ENDPOINT = "https://qywok-cryptocurrency-prediction.hf.space/crypto"

proxy/stock/interfaces.go

@@ -2,9 +2,9 @@ package stock
 
 import "context"
 
-type CryptoService interface {
-	CryptoListsService(ctx context.Context) (ApiResponse, error)
-	CryptoPredictionService(ctx context.Context, req PredictionRequest) (ApiResponse, error)
+type StockService interface {
+	StockListsService(ctx context.Context) (ApiResponse, error)
+	StockPredictionService(ctx context.Context, req PredictionRequest) (ApiResponse, error)
 }
 
-type CryptoServiceImpl struct{}
+type StockServiceImpl struct{}

proxy/stock/list_handler.go

@@ -12,9 +12,9 @@ import (
 
 
 /*
- *  --- Cryptocurrency Prediction Model Lists Handler ---
+ *  --- Stock Prediction Model Lists Handler ---
  */
-func CryptoListsHandler(service CryptoService) fiber.Handler {
+func StockListsHandler(service StockService) fiber.Handler {
 	return func(c *fiber.Ctx) error {
 		ctx, cancel := context.WithTimeout(c.Context(), 120*time.Second)
 		defer cancel()
@@ -26,7 +26,7 @@ func CryptoListsHandler(service CryptoService) fiber.Handler {
 		go func() {
 			defer wg.Done()
 
-			apiResponse, err := service.CryptoListsService(ctx)
+			apiResponse, err := service.StockListsService(ctx)
 			if err != nil {
 				log.Printf("[%s] %v", time.Now().Format("2006-01-02 15:04:05"), err)
 				ch <- apiResponse

proxy/stock/list_service.go

@@ -5,14 +5,15 @@ import (
 	"context"
 	"net/http"
 	"encoding/json"
+	proxy "tebakaja_lb_proxy/proxy"
 )
 
 
 /*
- *  --- Cryptocurrency Prediction Model Lists Service ---
+ *  --- Stock Prediction Model Lists Service ---
  */
-func (s *CryptoServiceImpl) CryptoListsService(ctx context.Context) (ApiResponse, error) {
-	endpoint := fmt.Sprintf("%s/lists", CRYPTO_ENDPOINT)
+func (s *StockServiceImpl) StockListsService(ctx context.Context) (ApiResponse, error) {
+	endpoint := fmt.Sprintf("%s/lists", proxy.GetEndpointByRestService("stock"))
 	req, err := http.NewRequestWithContext(ctx, "GET", endpoint, nil)
 	if err != nil {
 		return ApiResponse{

proxy/stock/prediction_handler.go

@@ -13,9 +13,9 @@ import (
 
 
 /*
- * --- Cryptocurrency Prediction Handler ---
+ * --- Stock Prediction Handler ---
  */
-func CryptoPredictionHandler(service CryptoService) fiber.Handler {
+func StockPredictionHandler(service StockService) fiber.Handler {
 	return func(c *fiber.Ctx) error {
 		ctx, cancel := context.WithTimeout(c.Context(), 120*time.Second)
 		defer cancel()
@@ -39,7 +39,7 @@ func CryptoPredictionHandler(service CryptoService) fiber.Handler {
 				return
 			}
 
-			apiResponse, err := service.CryptoPredictionService(ctx, predictionReq)
+			apiResponse, err := service.StockPredictionService(ctx, predictionReq)
 			if err != nil {
 				log.Printf("[%s] %v", time.Now().Format("2006-01-02 15:04:05"), err)
 				ch <- apiResponse

proxy/stock/prediction_service.go

@@ -6,13 +6,14 @@ import (
 	"context"
 	"net/http"
 	"encoding/json"
+	proxy "tebakaja_lb_proxy/proxy"
 )
 
 
 /*
- * --- Cryptocurrency Prediction Service ---
+ * --- Stock Prediction Service ---
  */
-func (s *CryptoServiceImpl) CryptoPredictionService(ctx context.Context, req PredictionRequest) (ApiResponse, error) {
+func (s *StockServiceImpl) StockPredictionService(ctx context.Context, req PredictionRequest) (ApiResponse, error) {
 	reqBody, err := json.Marshal(req)
 	if err != nil {
 		return ApiResponse{
@@ -21,7 +22,7 @@ func (s *CryptoServiceImpl) CryptoPredictionService(ctx context.Context, req Pre
 		}, err
 	}
 
-	endpoint := fmt.Sprintf("%s/prediction", CRYPTO_ENDPOINT)
+	endpoint := fmt.Sprintf("%s/prediction", proxy.GetEndpointByRestService("stock"))
 	httpReq, err := http.NewRequestWithContext(ctx, "POST", endpoint, bytes.NewBuffer(reqBody))
 	if err != nil {
 		return ApiResponse{

proxy/stock/structs.go

@@ -18,14 +18,17 @@ type PredictionResponse struct {
 	Data       struct {
 		Currency    string `json:"currency"`
 		Predictions struct {
+			
 			Actuals    []struct {
 				Date  string  `json:"date"`
 				Price float64 `json:"price"`
 			} `json:"actuals"`
+
 			Predictions []struct {
 				Date  string  `json:"date"`
 				Price float64 `json:"price"`
 			} `json:"predictions"`
+
 		} `json:"predictions"`
 	} `json:"data"`
 }

proxy/utils.go

@@ -0,0 +1,45 @@
+package proxy
+
+import "time"
+
+func GetEndpointByRestService(svc_name string) string {
+	second := time.Now().Second()
+
+	var divisorToString map[int]string
+	switch svc_name {
+		case "crypto":
+			divisorToString = map[int]string{
+				9: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				7: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				5: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				3: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				2: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+			}
+		case "national":
+			divisorToString = map[int]string{
+				9: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				7: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				5: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				3: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				2: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+			}
+		default:
+			divisorToString = map[int]string{
+				9: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				7: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				5: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				3: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+				2: "https://qywok-cryptocurrency-prediction.hf.space/crypto",
+			}
+	}
+
+	var result string
+	for divisor, str := range divisorToString {
+		if (second % divisor) == 0 {
+			result += str
+			break
+		}
+	}
+
+	return result
+}