repEs.js

import axios from "axios";


class RepEs {

    constructor(config) {
        this.config = config
        this.index_url = config.index_url
        this.index_name = config.index_name
        this.token = process.env?.INSCODE_API_KEY??'default'
    }

    query (keyword) {

        const url = this.index_url + '?user_token=' + this.token + '&index_name=' + this.index_name
        return new Promise(function(resolve,rejcet){
            axios.get(url,{
                params: {
                    keyword: encodeURI(keyword),
                }
            }).then(res => {

                if (res?.status === 200 && res?.data?.code === 200) {
                    const result = []
                    res?.data?.data?.hits.forEach(element => {
                        result.push({
                            page_content: element?._source?.content
                        })
                    });
                    resolve(result)

                }
                console.info(res)


            }).catch((err) => {
                console.error(err)
                rejcet()
            })
        })
        
    }

    add (content) {
        debugger
        const url = this.index_url + '/' + this.index_name
        return new Promise(function(resolve,rejcet){
            axios.put(url,{
                data: {
                    content: content,
                }
            }).then(res => {

                if (res?.status === 200 && res?.data?.code === 200) {
                    const result = []
                    res?.data?.data?.hits.forEach(element => {
                        result.push({
                            page_content: element?._source?.content
                        })
                    });
                    resolve(result)

                }
                console.info(res)


            }).catch((err) => {
                console.error(err)
                rejcet()
            })
        })

    }

}

export default RepEs