init commit

Author: erokhinms

.github/workflows/exchanger.yml

@@ -0,0 +1,31 @@
+name: Deploy to GitHub Pages
+
+on:
+  push:
+    branches:
+      - master
+
+jobs:
+  
+  build-and-deploy:
+    runs-on: ubuntu-latest
+    environment:
+      name: github-pages
+      
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Install Node.js
+        uses: actions/setup-node@v4
+        with:
+          node-version: 20
+      - name: Update libs and build
+        run: cd frontend && npm ci && npm run build
+
+      - name: Deploy
+        uses: peaceiris/actions-gh-pages@v4
+        with:
+          github_token: ${{ secrets.GITHUB_TOKEN }}
+          publish_dir: ./frontend/dist
+          user_name: github-actions[bot]
+          user_email: 41898282+github-actions[bot]@users.noreply.github.com

.gitignore

@@ -0,0 +1,2 @@
+node_modules/
+dist/

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "frontend"]
+	path = frontend
+	url = ./frontend

connectors/dex_connector.go

@@ -0,0 +1,33 @@
+package connectors
+
+import (
+	"encoding/json"
+	"log"
+)
+
+// DexConnector реализует работу с внешними DEX API
+
+type DexConnector struct{}
+
+func (d *DexConnector) GetFixedFloatCurrencies() ([]byte, error) {
+	resp, err := PostCurrencies()
+	if err != nil {
+		log.Println("Ошибка при запросе FixedFloat:", err)
+		return nil, err
+	}
+	return resp, nil
+}
+
+func (d *DexConnector) GetCurrencies() ([]byte, error) {
+	cryptoResp, err := d.GetFixedFloatCurrencies()
+	if err != nil {
+		return nil, err
+	}
+
+	var cryptoObj map[string]any
+	if err := json.Unmarshal(cryptoResp, &cryptoObj); err != nil {
+		return nil, err
+	}
+
+	return json.Marshal(cryptoObj)
+}

connectors/fixedfloat_api.go

@@ -0,0 +1,42 @@
+package connectors
+
+import (
+	"bytes"
+	"crypto/hmac"
+	"crypto/sha256"
+	"encoding/hex"
+	"io"
+	"net/http"
+	"os"
+)
+
+func PostCurrencies() ([]byte, error) {
+	url := "https://ff.io/api/v2/ccies"
+	client := &http.Client{}
+
+	apiKey := os.Getenv("FIXEDFLOAT_API_KEY")
+	apiSecret := os.Getenv("FIXEDFLOAT_API_SECRET")
+
+	jsonData := []byte("{}")
+
+	// HMAC SHA256 подпись
+	h := hmac.New(sha256.New, []byte(apiSecret))
+	h.Write(jsonData)
+	sign := hex.EncodeToString(h.Sum(nil))
+
+	request, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonData))
+	if err != nil {
+		return nil, err
+	}
+	request.Header.Set("Content-Type", "application/json; charset=UTF-8")
+	request.Header.Set("Accept", "application/json")
+	request.Header.Set("X-API-KEY", apiKey)
+	request.Header.Set("X-API-SIGN", sign)
+
+	resp, err := client.Do(request)
+	if err != nil {
+		return nil, err
+	}
+	defer resp.Body.Close()
+	return io.ReadAll(resp.Body)
+}

frontend

@@ -0,0 +1,5 @@
+module xmr_mixer
+
+go 1.24.3
+
+require github.com/gorilla/websocket v1.5.3

go.mod

@@ -0,0 +1,2 @@
+github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
+github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=

go.sum

@@ -0,0 +1,79 @@
+package main
+
+import (
+	"encoding/json"
+	"log"
+	"net/http"
+	"runtime"
+	"xmr_mixer/connectors"
+
+	"github.com/gorilla/websocket"
+)
+
+var upgrader = websocket.Upgrader{
+	CheckOrigin: func(r *http.Request) bool {
+		return true // Разрешить любые Origin (НЕ использовать в продакшене!)
+	},
+}
+
+// CurrencyProvider определяет интерфейс для получения списка валют
+type CurrencyProvider interface {
+	GetCurrencies() ([]byte, error)
+}
+
+func avoidCORS(h http.HandlerFunc) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Access-Control-Allow-Origin", "*")
+		h(w, r)
+	}
+}
+
+func main() {
+	http.HandleFunc("/api/test/", func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		json.NewEncoder(w).Encode(map[string]bool{"answer": true})
+	})
+	http.HandleFunc("/ws", wsHandler)
+
+	// DexConnector как CurrencyProvider
+	var provider CurrencyProvider = &connectors.DexConnector{}
+
+	http.HandleFunc("/api/v1/currencies", avoidCORS(func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		resp, err := provider.GetCurrencies()
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte(`[]`))
+			return
+		}
+		w.Write(resp)
+	}))
+
+	log.Println("Сервер запущен на :8080")
+	log.Fatal(http.ListenAndServe(":8080", nil))
+}
+
+func wsHandler(w http.ResponseWriter, r *http.Request) {
+	log.Printf("Origin: %s", r.Header.Get("Origin"))
+	conn, err := upgrader.Upgrade(w, r, nil)
+	if err != nil {
+		log.Println("Ошибка апгрейда:", err)
+		return
+	}
+	go handleWS(conn)
+}
+
+func handleWS(conn *websocket.Conn) {
+	defer conn.Close()
+	for {
+		_, msg, err := conn.ReadMessage()
+		if err != nil {
+			log.Println("Ошибка чтения:", err)
+			break
+		}
+		log.Printf("Получено сообщение: %s", msg)
+
+		conn.WriteMessage(websocket.TextMessage, []byte("pong"))
+		log.Printf("Текущее количество горутин: %d", runtime.NumGoroutine())
+	}
+}