Satatus.go

package main

import (
	"crypto/sha256"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"net/http"
)

// 필요한 패키지 및 구조체 정의
type Status struct{}

type SignedQuery struct {
	Query     map[string]interface{} `json:"query"`
	PublicKey string                 `json:"public_key"`
	Signature string                 `json:"signature"`
}

type Receipt struct {
	PreviousBlockhash string                 `json:"previous_blockhash"`
	Beneficiary       string                 `json:"beneficiary"`
	SignedQuery       map[string]interface{} `json:"signed_query"`
	PublicKey         string                 `json:"public_key"`
	Signature         string                 `json:"signature"`
}

// MainChain, Env, Bunch, Signer, Hasher 구조체 및 관련 메소드 정의 필요
// 이 부분은 실제 구현에 맞게 수정 필요

// Mocked functions and structs for demonstration purposes
var lastBlockHash = "mocked_last_block_hash"

type MainChain struct{}

func (mc *MainChain) LastBlock() *Block {
	return &Block{BlockHash: lastBlockHash}
}

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

type Block struct {
	BlockHash string
}

type Env struct{}

func (e *Env) Owner() string {
	return "mocked_owner"
}

func (e *Env) Peer() *Peer {
	return &Peer{PublicKey: "mocked_public_key", PrivateKey: "mocked_private_key"}
}

func EnvInstance() *Env {
	return &Env{}
}

type Peer struct {
	PublicKey  string
	PrivateKey string
}

type Bunch struct{}

func (b *Bunch) AddReceipt(receipt *Receipt) {
	// 실제 영수증 추가 로직 구현
	fmt.Println("Receipt added:", receipt)
}

func BunchInstance() *Bunch {
	return &Bunch{}
}

type Signer struct{}

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

func (s *Signer) Signature(hash, privateKey string) string {
	// 실제 서명 생성 로직 구현
	return "mocked_signature"
}

func SignerInstance() *Signer {
	return &Signer{}
}

type Hasher struct{}

func (h *Hasher) Hash(data interface{}) string {
	jsonData, _ := json.Marshal(data)
	hash := sha256.Sum256(jsonData)
	return fmt.Sprintf("%x", hash)
}

func HasherInstance() *Hasher {
	return &Hasher{}
}

// main 핸들러 함수
func (s *Status) Main(w http.ResponseWriter, req *http.Request) {
	signedQueryStr := req.FormValue("signed_query")
	if signedQueryStr == "" {
		signedQueryStr = "{}"
	}

	var signedQuery SignedQuery
	if err := json.Unmarshal([]byte(signedQueryStr), &signedQuery); err != nil {
		http.Error(w, "Invalid JSON format", http.StatusBadRequest)
		return
	}

	query := signedQuery.Query
	publicKey := signedQuery.PublicKey
	signature := signedQuery.Signature
	roundKey, _ := query["previous_blockhash"].(string)

	mainChain := MainChainInstance()
	if mainChain.LastBlock().BlockHash != roundKey || !SignerInstance().SignatureValidity(HasherInstance().Hash(query), publicKey, signature) {
		return
	}

	receiptHeader := map[string]interface{}{
		"previous_blockhash": roundKey,
		"beneficiary":        EnvInstance().Owner(),
		"signed_query":       signedQuery,
	}

	receipt := &Receipt{
		PreviousBlockhash: roundKey,
		Beneficiary:       EnvInstance().Owner(),
		SignedQuery:       signedQuery.Query,
		PublicKey:         EnvInstance().Peer().PublicKey,
		Signature:         SignerInstance().Signature(HasherInstance().Hash(receiptHeader), EnvInstance().Peer().PrivateKey),
	}

	BunchInstance().AddReceipt(receipt)

	// 응답이 필요하지 않은 경우, 단순히 반환
	return
}

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

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

주요 구성 요소와 함수

필요한 패키지 및 구조체 정의

패키지 임포트:
- crypto/sha256: SHA-256 해시 함수를 사용합니다.
- encoding/json: JSON 데이터를 처리합니다.
- fmt: 포맷된 문자열을 처리합니다.
- io/ioutil: 입출력 유틸리티를 사용합니다.
- net/http: HTTP 서버와 클라이언트를 처리합니다.
구조체 정의:
- SignedQuery: 서명된 쿼리를 나타내는 구조체입니다. Query, PublicKey, Signature 필드를 포함합니다.
- Receipt: 영수증을 나타내는 구조체입니다. PreviousBlockhash, Beneficiary, SignedQuery, PublicKey, Signature 필드를 포함합니다.

모의 함수와 구조체 정의

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

var lastBlockHash = "mocked_last_block_hash"

// MainChain 관련 모의 구조체 및 함수
type MainChain struct{}

func (mc *MainChain) LastBlock() *Block {
	return &Block{BlockHash: lastBlockHash}
}

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

type Block struct {
	BlockHash string
}

// Env 관련 모의 구조체 및 함수
type Env struct{}

func (e *Env) Owner() string {
	return "mocked_owner"
}

func (e *Env) Peer() *Peer {
	return &Peer{PublicKey: "mocked_public_key", PrivateKey: "mocked_private_key"}
}

func EnvInstance() *Env {
	return &Env{}
}

type Peer struct {
	PublicKey  string
	PrivateKey string
}

// Bunch 관련 모의 구조체 및 함수
type Bunch struct{}

func (b *Bunch) AddReceipt(receipt *Receipt) {
	fmt.Println("Receipt added:", receipt)
}

func BunchInstance() *Bunch {
	return &Bunch{}
}

// Signer 관련 모의 구조체 및 함수
type Signer struct{}

func (s *Signer) SignatureValidity(hash, publicKey, signature string) bool {
	return true
}

func (s *Signer) Signature(hash, privateKey string) string {
	return "mocked_signature"
}

func SignerInstance() *Signer {
	return &Signer{}
}

// Hasher 관련 모의 구조체 및 함수
type Hasher struct{}

func (h *Hasher) Hash(data interface{}) string {
	jsonData, _ := json.Marshal(data)
	hash := sha256.Sum256(jsonData)
	return fmt.Sprintf("%x", hash)
}

func HasherInstance() *Hasher {
	return &Hasher{}
}

Status 구조체와 Main 함수

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

type Status struct{}

// Main 함수는 /status 경로로 들어오는 요청을 처리합니다.
func (s *Status) Main(w http.ResponseWriter, req *http.Request) {
	signedQueryStr := req.FormValue("signed_query")
	if signedQueryStr == "" {
		signedQueryStr = "{}"
	}

	var signedQuery SignedQuery
	if err := json.Unmarshal([]byte(signedQueryStr), &signedQuery); err != nil {
		http.Error(w, "Invalid JSON format", http.StatusBadRequest)
		return
	}

	query := signedQuery.Query
	publicKey := signedQuery.PublicKey
	signature := signedQuery.Signature
	roundKey, _ := query["previous_blockhash"].(string)

	mainChain := MainChainInstance()
	if mainChain.LastBlock().BlockHash != roundKey || !SignerInstance().SignatureValidity(HasherInstance().Hash(query), publicKey, signature) {
		return
	}

	receiptHeader := map[string]interface{}{
		"previous_blockhash": roundKey,
		"beneficiary":        EnvInstance().Owner(),
		"signed_query":       signedQuery,
	}

	receipt := &Receipt{
		PreviousBlockhash: roundKey,
		Beneficiary:       EnvInstance().Owner(),
		SignedQuery:       signedQuery.Query,
		PublicKey:         EnvInstance().Peer().PublicKey,
		Signature:         SignerInstance().Signature(HasherInstance().Hash(receiptHeader), EnvInstance().Peer().PrivateKey),
	}

	BunchInstance().AddReceipt(receipt)
	return
}

signedQueryStr: 요청에서 signed_query 값을 읽습니다. 값이 없으면 빈 JSON 객체로 초기화합니다.
signedQuery: signedQueryStr를 JSON으로 파싱하여 SignedQuery 구조체로 변환합니다.
query, publicKey, signature: signedQuery에서 각각 쿼리, 공개 키, 서명 값을 추출합니다.
roundKey: 쿼리에서 previous_blockhash 값을 읽습니다.
mainChain: MainChainInstance를 호출하여 메인 체인의 인스턴스를 가져옵니다.
유효성 검사:
- 메인 체인의 마지막 블록 해시가 roundKey와 일치하는지 확인합니다.
- 쿼리의 해시 값과 서명이 유효한지 확인합니다.
receiptHeader: 영수증 헤더를 구성합니다.
receipt: Receipt 구조체를 생성합니다.
BunchInstance: BunchInstance를 호출하여 트랜잭션 묶음의 인스턴스를 가져오고, 영수증을 추가합니다.

main 함수

이 함수는 HTTP 서버를 설정하고 시작합니다.

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

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

/status 경로로 들어오는 요청을 Status 구조체의 Main 메서드로 처리하도록 설정합니다.
포트 8080에서 HTTP 서버를 시작합니다.

요약

이 코드는 HTTP 서버를 설정하여 /status 경로에서 들어오는 요청을 처리합니다. 요청에서 signed_query 값을 읽고, 서명된 쿼리의 유효성을 검사한 후, 영수증을 생성하여 추가합니다. 성공적인 처리 후에는 아무 응답도 반환하지 않습니다. 각 함수와 메서드는 특정 역할을 수행하며, 전체적으로 협력하여 요청을 처리하고 응답을 반환합니다.

PreviousSendTransaction.go NextTransaction.go

Last updated 1 year ago

hashtag주요 구성 요소와 함수

hashtag요약

주요 구성 요소와 함수

요약