트랜잭션

class Tx: #트랜잭션의 구성요소 : 버전, 입력, 출력, 락타임, 테스트넷 여부 def __init__(self, version, tx_ins, tx_outs, locktime, testnet=False): self.version = version self.tx_ins = tx_ins self.tx_outs = tx_outs self.locktime = locktime self.testnet = testnet def __repr__(self): tx_ins = '' for tx_in in self.tx_ins: tx_ins += tx_in.__repr__() + '\n' tx_outs = '' for tx_out in self.tx_outs: tx_outs += tx_out.__repr__() + '\n' return 'tx: {}\nversion: {}\ntx_ins:\n{}tx_outs:\n{}locktime: {}'.format( self.id(), self.version, tx_ins, tx_outs, self.locktime, ) #트랜잭션 ID를 추출하여 16진수로 리턴한다. def id(self): return self.hash().hex() #트랜잭션을 직렬화하고 해시값을 만들어 리턴한다. def hash(self): return hash256(self.serialize())[::-1] #트랜잭션 파싱 @classmethod def parse(cls, s, testnet=False): #4바이트에서 버전을 추출한다. version = little_endian_to_int(s.read(4)) #read_varint() : 1바이트의 int를 가져오는 사용자 정의 함수 #입력의 갯수를 가져온다. num_inputs = read_varint(s) #입력을 배열에 넣는다 inputs = [] for _ in range(num_inputs): inputs.append(TxIn.parse(s)) #출력의 갯수를 가져온다. num_outputs = read_varint(s) #출력을 배열에 넣는다. outputs = [] for _ in range(num_outputs): outputs.append(TxOut.parse(s)) #록타임 4바이트를 가져온다. locktime = little_endian_to_int(s.read(4)) #인스턴스 생성 return cls(version, inputs, outputs, locktime, testnet=testnet) #트랜잭션을 직렬화해서 리턴하는 함수 def serialize(self): #버전 result = int_to_little_endian(self.version, 4) #입력의 갯수 result += encode_varint(len(self.tx_ins)) #입력 for tx_in in self.tx_ins: #입력값의 직렬화 result += tx_in.serialize() #출력의 갯수 result += encode_varint(len(self.tx_outs)) #출력 for tx_out in self.tx_outs: #출력값의 직렬화 result += tx_out.serialize() #리틀엔디언 형태의 록타임 4바이트 result += int_to_little_endian(self.locktime, 4) return result #트랜잭션의 수수료를 조회하는 함수 (사토시 단위로 리턴) def fee(self): input_sum, output_sum = 0, 0 #입력에서 값의 합을 구한다. for tx_in in self.tx_ins: input_sum += tx_in.value(self.testnet) #출력에서 값의 합을 구한다. for tx_out in self.tx_outs: output_sum += tx_out.amount return input_sum - output_sum #서명을 위한 메시지의 해시를 구하는 함수 def sig_hash(self, input_index, redeem_script=None): #트랜잭션을 직접 만들어 해시를 구한다. #버전 s = int_to_little_endian(self.version, 4) #입력의 수 s += encode_varint(len(self.tx_ins)) #입력 for i, tx_in in enumerate(self.tx_ins): #서명할 입력을 찾으면 if i == input_index: #전 트랜잭션에서 공개키 해시를 가져온다. 입력 코드를 참조하자. script_sig = tx_in.script_pubkey(self.testnet) # Otherwise, the ScriptSig is empty else: script_sig = None #입력 메시지 완성 s += TxIn( prev_tx=tx_in.prev_tx, prev_index=tx_in.prev_index, script_sig=script_sig, sequence=tx_in.sequence, ).serialize() #출력 포함 s += encode_varint(len(self.tx_outs)) for tx_out in self.tx_outs: s += tx_out.serialize() #록타임 s += int_to_little_endian(self.locktime, 4) #해시유형 s += int_to_little_endian(SIGHASH_ALL, 4) #hash256 해시 h256 = hash256(s) return int.from_bytes(h256, 'big') #해제 스크립트 검증 def verify_input(self, input_index): tx_in = self.tx_ins[input_index] #이전 트랜잭션에서 공개키의 해시를 가져온다. script_pubkey = tx_in.script_pubkey(testnet=self.testnet) #메시지 해시를 가져온다. z = self.sig_hash(input_index) #해제 스크립트와 잠금스크립트를 붙인다. combined = tx_in.script_sig + script_pubkey #스크립트를 검증한다. return combined.evaluate(z) #트랜잭션 검증 def verify(self): #수수료 검증 if self.fee() < 0: return False #입력 검증 for i in range(len(self.tx_ins)): if not self.verify_input(i): return False return True #해제스크립트에 서명값을 포함 def sign_input(self, input_index, private_key): #메시지 해시를 가져온다. z = self.sig_hash(input_index) #서명값 추출 후 직렬화 der = private_key.sign(z).der() #서명값에 해시 유형을 넣는다. sig = der + SIGHASH_ALL.to_bytes(1, 'big') #공개키를 추출한다. sec = private_key.point.sec() #스크립트를 만든다. script_sig = Script([sig, sec]) #입력에 스크립트를 포함한다. self.tx_ins[input_index].script_sig = script_sig # return whether sig is valid using self.verify_input return self.verify_input(input_index)