Transaction.go

package main

import (
	"encoding/json"
	"fmt"
	"net/http"
	"strconv"
	"time"
)

// Configurations and Constants
const (
	TimestampErrorLimit = 300 // 예시 값, 실제 값으로 변경
	ResultFail          = "FAIL"
)

// Mocked configuration structure
var Config = struct {
	Database bool
}{
	Database: true, // 실제 설정에 맞게 변경
}

// Mocked utility functions and structures for demonstration purposes
func Utime() int64 {
	return time.Now().Unix()
}

func SignatureValidity(data int64, publicKey, signature string) bool {
	// 실제 서명 유효성 검사 로직 구현
	return true
}

func HashValidity(cid string) bool {
	// 실제 해시 유효성 검사 로직 구현
	return true
}

func AddressValidity(address string) bool {
	// 실제 주소 유효성 검사 로직 구현
	return true
}

func TimeHashValidity(timehash string) bool {
	// 실제 시간 해시 유효성 검사 로직 구현
	return true
}

// TransactionHandler handles the transactions.
type TransactionHandler struct{}

func (t *TransactionHandler) Fail(w http.ResponseWriter, result, errMsg string) {
	http.Error(w, fmt.Sprintf("%s: %s", result, errMsg), http.StatusBadRequest)
}

func (t *TransactionHandler) Main(w http.ResponseWriter, req *http.Request) {
	if !Config.Database {
		t.Fail(w, ResultFail, "The database usage setting is set to false.")
		return
	}

	now := Utime()
	timestampStr := req.FormValue("timestamp")
	timestamp, err := strconv.ParseInt(timestampStr, 10, 64)
	if err != nil {
		t.Fail(w, ResultFail, "Invalid timestamp.")
		return
	}
	publicKey := req.FormValue("public_key")
	signature := req.FormValue("signature")

	timeValidity := abs(now-timestamp) < TimestampErrorLimit
	signatureValidity := SignatureValidity(timestamp, publicKey, signature)

	if !timeValidity || !signatureValidity {
		t.Fail(w, ResultFail, "Invalid request.")
		return
	}

	data := req.FormValue("data")
	switch data {
	case "get":
		response := t.GetTransaction(req)
		json.NewEncoder(w).Encode(response)
	case "list":
		fallthrough
	default:
		response := t.ListTransaction(req, false)
		json.NewEncoder(w).Encode(response)
	case "fullList":
		response := t.ListTransaction(req, true)
		json.NewEncoder(w).Encode(response)
	}
}

func (t *TransactionHandler) ListTransaction(req *http.Request, full bool) []map[string]interface{} {
	pageStr := req.FormValue("page")
	page, _ := strconv.Atoi(pageStr)
	countStr := req.FormValue("count")
	count, _ := strconv.Atoi(countStr)

	cid := req.FormValue("cid")
	typ := req.FormValue("type")
	address := req.FormValue("address")
	from := req.FormValue("from")
	to := req.FormValue("to")
	timehash := req.FormValue("timehash")

	query := map[string]string{}

	if HashValidity(cid) {
		query["cid"] = cid
	}
	if match, _ := regexp.MatchString(`^[A-Za-z_0-9]+$`, typ); match {
		query["type"] = typ // 실제로는 SQL 인젝션 방지를 위해 proper escaping 필요
	}
	if AddressValidity(address) {
		query["address"] = address
	}
	if AddressValidity(from) {
		query["from"] = from
	}
	if AddressValidity(to) {
		query["to"] = to
	}
	if TimeHashValidity(timehash) {
		query["timehash"] = timehash
	}

	chainDB := ChainDB{}
	return chainDB.ListData(page, count, query, full)
}

func (t *TransactionHandler) GetTransaction(req *http.Request) map[string]interface{} {
	target := req.FormValue("target")
	if target == "" {
		target = "05df2656734c9e326b71a0d256e39c01054f89f83027c7179fd9fe942a0d6270875c2d16f41732"
	}

	mainChain := MainChainInstance()
	return mainChain.Transaction(target)
}

// ChainDB is a mocked structure for demonstration purposes
type ChainDB struct{}

func (db *ChainDB) ListData(page, count int, query map[string]string, full bool) []map[string]interface{} {
	// 실제 데이터베이스 쿼리 로직 구현
	return []map[string]interface{}{
		{"example_key": "example_value"},
	}
}

// MainChain is a mocked structure for demonstration purposes
type MainChain struct{}

func MainChainInstance() *MainChain {
	return &MainChain{}
}

func (mc *MainChain) Transaction(target string) map[string]interface{} {
	// 실제 트랜잭션 조회 로직 구현
	return map[string]interface{}{
		"transaction_key": "transaction_value",
	}
}

func abs(x int64) int64 {
	if x < 0 {
		return -x
	}
	return x
}

func main() {
	http.HandleFunc("/transaction", func(w http.ResponseWriter, req *http.Request) {
		handler := &TransactionHandler{}
		handler.Main(w, req)
	})

	http.ListenAndServe(":8080", nil)
}

주요 구성 요소와 함수

필요한 패키지 및 상수

패키지 임포트:
- encoding/json: JSON 데이터를 처리합니다.
- fmt: 포맷된 문자열을 처리합니다.
- net/http: HTTP 서버와 클라이언트를 처리합니다.
- strconv: 문자열을 숫자로 변환하는 기능을 제공합니다.
- time: 시간 관련 기능을 제공합니다.

상수 정의:

const (
    TimestampErrorLimit = 300 // 타임스탬프 허용 오차 범위
    ResultFail          = "FAIL" // 실패 결과를 나타내는 상수
)

모의 구성 및 함수

이 예제에서는 실제 구현 대신 모의(mocked) 함수를 사용합니다. 이러한 모의 함수는 실제 시스템에서 구현될 함수와 유사하게 동작합니다.

var Config = struct {
    Database bool
}{
    Database: true, // 실제 설정에 맞게 변경
}

func Utime() int64 {
    return time.Now().Unix() // 현재 시간을 Unix 타임스탬프로 반환
}

func SignatureValidity(data int64, publicKey, signature string) bool {
    // 실제 서명 유효성 검사 로직 구현
    return true
}

func HashValidity(cid string) bool {
    // 실제 해시 유효성 검사 로직 구현
    return true
}

func AddressValidity(address string) bool {
    // 실제 주소 유효성 검사 로직 구현
    return true
}

func TimeHashValidity(timehash string) bool {
    // 실제 시간 해시 유효성 검사 로직 구현
    return true
}

TransactionHandler 구조체와 관련 함수

이 부분은 HTTP 요청을 처리하는 핵심 로직입니다.

type TransactionHandler struct{}

func (t *TransactionHandler) Fail(w http.ResponseWriter, result, errMsg string) {
    http.Error(w, fmt.Sprintf("%s: %s", result, errMsg), http.StatusBadRequest)
}

Fail 함수: 이 함수는 요청이 실패했을 때 클라이언트에 실패 메시지를 반환합니다.
- w: 응답을 작성하는 데 사용되는 http.ResponseWriter 객체입니다.
- result: 결과 문자열입니다.
- errMsg: 오류 메시지입니다.

func (t *TransactionHandler) Main(w http.ResponseWriter, req *http.Request) {
    if !Config.Database {
        t.Fail(w, ResultFail, "The database usage setting is set to false.")
        return
    }

    now := Utime()
    timestampStr := req.FormValue("timestamp")
    timestamp, err := strconv.ParseInt(timestampStr, 10, 64)
    if err != nil {
        t.Fail(w, ResultFail, "Invalid timestamp.")
        return
    }
    publicKey := req.FormValue("public_key")
    signature := req.FormValue("signature")

    timeValidity := abs(now-timestamp) < TimestampErrorLimit
    signatureValidity := SignatureValidity(timestamp, publicKey, signature)

    if !timeValidity || !signatureValidity {
        t.Fail(w, ResultFail, "Invalid request.")
        return
    }

    data := req.FormValue("data")
    switch data {
    case "get":
        response := t.GetTransaction(req)
        json.NewEncoder(w).Encode(response)
    case "list":
        fallthrough
    default:
        response := t.ListTransaction(req, false)
        json.NewEncoder(w).Encode(response)
    case "fullList":
        response := t.ListTransaction(req, true)
        json.NewEncoder(w).Encode(response)
    }
}

Main 함수: 이 함수는 /transaction 경로로 들어오는 요청을 처리합니다.
- 데이터베이스 설정이 true인지 확인합니다. false인 경우 실패 응답을 반환합니다.
- 현재 시간을 now 변수에 저장합니다.
- 요청에서 timestamp, public_key, signature 값을 읽습니다.
- timestamp 값을 숫자로 변환합니다.
- 현재 시간과 타임스탬프의 차이가 허용 오차 범위 내에 있는지(timeValidity) 확인하고, 서명이 유효한지(signatureValidity) 확인합니다.
- 유효하지 않은 경우 실패 응답을 반환합니다.
- 요청의 data 값에 따라 트랜잭션 데이터를 반환하는 함수를 호출합니다.

func (t *TransactionHandler) ListTransaction(req *http.Request, full bool) []map[string]interface{} {
    pageStr := req.FormValue("page")
    page, _ := strconv.Atoi(pageStr)
    countStr := req.FormValue("count")
    count, _ := strconv.Atoi(countStr)

    cid := req.FormValue("cid")
    typ := req.FormValue("type")
    address := req.FormValue("address")
    from := req.FormValue("from")
    to := req.FormValue("to")
    timehash := req.FormValue("timehash")

    query := map[string]string{}

    if HashValidity(cid) {
        query["cid"] = cid
    }
    if match, _ := regexp.MatchString(`^[A-Za-z_0-9]+$`, typ); match {
        query["type"] = typ // 실제로는 SQL 인젝션 방지를 위해 proper escaping 필요
    }
    if AddressValidity(address) {
        query["address"] = address
    }
    if AddressValidity(from) {
        query["from"] = from
    }
    if AddressValidity(to) {
        query["to"] = to
    }
    if TimeHashValidity(timehash) {
        query["timehash"] = timehash
    }

    chainDB := ChainDB{}
    return chainDB.ListData(page, count, query, full)
}

ListTransaction 함수: 이 함수는 요청된 조건에 따라 트랜잭션 목록을 반환합니다.
- 요청에서 page, count, cid, type, address, from, to, timehash 값을 읽습니다.
- 각 값을 유효성 검사 함수로 확인하고, 유효한 경우 query 맵에 추가합니다.
- ChainDB의 ListData 메서드를 호출하여 트랜잭션 목록을 반환합니다.

func (t *TransactionHandler) GetTransaction(req *http.Request) map[string]interface{} {
    target := req.FormValue("target")
    if target == "" {
        target = "05df2656734c9e326b71a0d256e39c01054f89f83027c7179fd9fe942a0d6270875c2d16f41732"
    }

    mainChain := MainChainInstance()
    return mainChain.Transaction(target)
}

GetTransaction 함수: 이 함수는 특정 트랜잭션을 조회하여 반환합니다.
- 요청에서 target 값을 읽습니다. 값이 없으면 기본 값을 사용합니다.
- MainChain 인스턴스를 사용하여 target에 해당하는 트랜잭션을 조회하여 반환합니다.

모의 데이터베이스 및 메인 체인 구조체

type ChainDB struct{}

func (db *ChainDB) ListData(page, count int, query map[string]string, full bool) []map[string]interface{} {
    // 실제 데이터베이스 쿼리 로직 구현
    return []map[string]interface{}{
        {"example_key": "example_value"},
    }
}

type MainChain struct{}

func MainChainInstance() *MainChain {
    return &MainChain{}
}

func (mc *MainChain) Transaction(target string) map[string]interface{} {
    // 실제 트랜잭션 조회 로직 구현
    return map[string]interface{}{
        "transaction_key": "transaction_value",
    }
}

ChainDB: 트랜잭션 목록을 반환하는 함수가 포함된 모의 데이터베이스 구조체입니다.
MainChain: 특정 트랜잭션을 조회하는 함수가 포함된 모의 메인 체인 구조체입니다.

보조 함수

func abs(x int64) int64 {
    if x < 0 {
        return -x
    }
    return x
}

abs 함수: 주어진 숫자의 절대값을 반환합니다.

main 함수

func main() {
    http.HandleFunc("/transaction", func(w http.ResponseWriter, req *http.Request) {
        handler := &TransactionHandler{}
        handler.Main(w, req)
    })

    http.ListenAndServe(":8080", nil)
}

main 함수: HTTP 서버를 설정하고 시작하는 함수입니다.
- /transaction 경로로 들어오는 요청을 TransactionHandler 구조체의 Main 메서드로 처리하도록 설정합니다.
- 포트 8080에서 HTTP 서버를 시작합니다.

요약

이 코드는 HTTP 서버를 설정하여 /transaction 경로에서 들어오는 요청을 처리합니다. 요청 파라미터를 읽고, 유효성을 검사한 후, 트랜잭션 데이터를 반환합니다. 성공적인 처리 후에는 트랜잭션 데이터를 반환하고, 실패하면 오류 메시지를 반환합니다. 각 함수와 메서드는 특정 역할을 수행하며, 전체적으로 협력하여 요청을 처리하고 응답을 반환합니다.

PreviousSatatus.go NextWeight.go

Last updated 1 year ago

hashtag주요 구성 요소와 함수

hashtag요약

주요 구성 요소와 함수

요약