package kr.wisestone.owl.search;

import kr.wisestone.owl.constant.ElasticSearchConstants;
import kr.wisestone.owl.util.ElasticSearchUtil;
import kr.wisestone.owl.vo.UserVo;
import org.elasticsearch.action.ActionListener;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.support.WriteRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;

@Component
public class ElasticSearch {
    private static final Logger log = LoggerFactory.getLogger(ElasticSearch.class);

    @Autowired
    private RestHighLevelClient restHighLevelClient;

    /*//  사용자 시스템 사용 기록을 저장한다.
    public void updateUserActiveHistory(HttpServletRequest httpServletRequest, UserVo userVo) {
        IndexRequest request = new IndexRequest(ElasticSearchConstants.USER_SESSION_HISTORY_INDEX);

        request.source(ElasticSearchUtil.makeUserActiveHistoryDocument(httpServletRequest, userVo), XContentType.JSON);
        request.timeout("5s");
        request.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);

        try {
            this.restHighLevelClient.indexAsync(request, RequestOptions.DEFAULT, new ActionListener<IndexResponse>() {
                @Override
                public void onResponse(IndexResponse indexResponse) {
                    log.debug("사용자 시스템 사용 기록 인덱스 업데이트 성공");
                }

                @Override
                public void onFailure(Exception ex) {
                    log.error("사용자 시스템 사용 기록 인덱스 업데이트 오류 : " + ex.getMessage());
                }
            });
        } catch (Exception ex) {
            log.error("사용자 시스템 사용 기록 인덱스 업데이트 오류 : " + ex.getMessage());
        }
    }*/
}