![](https://cdn.steemitimages.com/DQmVr5PmAw3krYQAJN1BsyCdWy94BjUjm47x3ZuDky2619a/image.png)

> 참조 : [[steem-engine] 거래 정보 추출 - 작업 진행 내용 기록용](https://steemit.com/zzan/@wonsama/ofmmm-steem-engine) 내용이 잘못된 부분이 많이 존재하기 때문에 본 내용을 참조 바랍니다.

# 조회 방법 

* 거래 정보 : 토큰명 + 계정명으로 조회 
* 상세 정보 : txid 기준으로 조회 

# 데이터 구성

> STEEMP 에서 정보를 조회하는 것은 정보량이 많기 떄문에 개별 토큰에서 조회한다. (상세정보 조회 시 시간이 너무 많이 걸림)

* 구매등록, 구매등록취소, 구매완료, 판매완료 ( STEEMP )
* 판매등록, 판매등록취소, 구매완료, 판매완료 ( 각토큰 )
* 기타정보 : 유저간 토큰 발송, 토큰발행(issue)


# 구분

* action : buy, flag : buy      - 내가 사는 것, idx가 1이상만 존재
* action : buy, flag : sell     - N/A
* action : sell, flag : buy     - 남이 파는 것을 산 경우, idx가 1이상만 존재
* action : sell, flag : sell    - 내가 파는 것, idx가 0만 존재하며 내가 실제 판매에 성공한 정보(`하위 인덱스 모두를 탐색해야 됨``)를 로딩해야 됨에 유의

# from_type, to_type

* from_type, to_type - user:user, contract:user, user:contract
* from_type, to_type - contract 인 경우 from 또는 to 값이 tokens 또는 market
* tokens : 토큰 발행 issue 등의 정보가 담겨짐
* market : 스팀엔진 마켓 거래 정보가 담겨짐 -> 해당 정보를 필터링 하여 정리

# 유의사항

* 조회 시간이 많이 걸리므로 timeout 시간을 충분하게 늘려준다.
* 위 사항이 힘든 경우 limit 값을 줄여 상세 정보 조회 시간을 줄여준다.
* 버그인지 가끔 데이터 누락본이 있는데 이는 STEEMP에서 크로스 체크를 하면 되나 그러면 시간이 너무 많이 걸리므로 비추천함.(STEEMP에는 모든 토큰에 대한 정보를 포함하기 때문)   

# 관련 소스코드 (발췌본)

> 대상 마켓 이력정보를 조회하기 위한 관련 소스코드를 발췌하여 게시 합니다.

```javascript
/// market 이력 정보를 조회한다
async function init(author, symbol){

    // 전역 설정 값
    let datas;

    wlog.info(`STEP 0 (0/5) : start program ::: ${author}'s ${symbol} steem-engine market history.`);

    // 전체 목록정보 조회 
    wse
        .token_history(author, symbol)   // 토큰 거래 정보 조회
        .then(res=>{

            wlog.info(`STEP 1 (1/5) : token_history is loaded. (${res.length})`);

            // 매수, 매도 처리 정보의 txid 만 발췌하여 로딩
            let buy = res
                .filter(x=>x.from=='market'&&x.txid.indexOf('-')>0)
                .map(_market_data_update);  // buy 는 idx 가 다양하게 존재하는듯, 0은 없는 듯 ?!

            let sell = res
                .filter(x=>x.to=='market'&&x.txid.indexOf('-')>0)
                .map(_market_data_update);  // sell 은 idx 가 0 만 존재하는듯

            // 전송 데이터 
            datas = buy.concat(sell);

            // 유니크한 거래 TXID 정보 
            let txids = quique_strs(datas.map(x=>x.txid));

            wlog.info(`STEP 2 (2/5) : filtered search txids. (${txids.length})`);

            // 거래 정보 기준으로 전송
            let sends = [];
            for(let txid of txids){
                sends.push(wse.getTransactionInfo(txid));
            }

            return Promise.all(sends);
        })
        .then(res=>{

            wlog.info(`STEP 3 (3/5) : get detail transaction informations. (${res.length})`);

            let trans = [];
            for(let r of res){

                if(r.action == 'buy' && r.sender==author){          // flag : buy - 내가 사는 것
                    
                    _set_trans_data(trans, r, datas, author, symbol);

                }else if(r.action == 'buy' && r.sender!=author){    // flag : sell - N/A
                    
                    // 존재 불가의 데이터
                    wlog.error('sell - N/A', r);

                }else if(r.action == 'sell' && r.sender==author){   // flag : sell - 내가 파는 것
                    
                    _set_trans_data(trans, r, datas, author, 'STEEMP');

                }else if(r.action == 'sell' && r.sender!=author){   // flag : buy - 남이 파는것을 산 경우
                    
                    _set_trans_data(trans, r, datas, author, symbol);

                }else {
                    
                    // 존재 불가의 데이터 2
                    wlog.error('unknown data', r);
                }

            }// for(let r of res)

            wlog.info(`STEP 4 (4/5) : filtered detail transaction informations. (${trans.length})`);

            // 최신 순서로 정렬
            trans.sort((a,b)=>b.time-a.time);
            return Promise.resolve(trans);
        })
        .then(res=>{
            wlog.info(`STEP 5 (5/5) : prints results (${res.length})`);

            // 결과 출력 
            for(let r of res){
                let color = r.flag=='buy'?'red':'blue';

                // 로그 작성
                wlog[color](`[${r.flag.padEnd(4,' ')}][${r.timestamp}] ${r.who.padEnd(16,' ')} ${r.quantity.toString().padStart(10,' ')} ${symbol} x ${r.price.toString().padEnd(8,' ')} = ${r.sum.toString().padStart(12,' ')} STEEMP ( ${r.txid} )`);
            }
        });
}
init('wonsama', 'sct'.toUpperCase());
```