# Echo server program
import socket
from .loader import *

import pickle
temp_res_b = pickle.load(open('temp_resg.pkl', 'rb'), encoding="utf8")

import json

def api_call(claim, use_cache=False):
    """
    use_cache: arg for query_g
    """
    res_b, error = query_b(claim, use_cache)
    (sources, df, vera, stances, rep, clf_vera_coef, clf_vera_intc, urls, crowd_stance_lab, hh) = answer_loader(claim, res_b, True)
    articles = []
    n = len(sources)
    for i in range(n):
        a = {"sources": sources[i], "reputation": rep[i], "headlines": df.articleHeadline[i], "stance": stances[i].tolist() }
        articles.append(a)

    res = {"claim": claim,\
            "articles": articles, \
            "veracity": vera[0].tolist(), \
            "clf_vera_coef": clf_vera_coef, \
            "clf_vera_intc": clf_vera_intc, \
            "urls": urls, \
            'crowd_stance': crowd_stance_lab, \
            'hh': hh, \
            'error': error
    }
    return res
    #return json.dumps(res)

def answer(data):
    # extract data
    a = data.split("\n")
    if a[0] == 'claim':
        uid = -1
        claim = a[1]
    elif a[0] == 'uc':
        uid = a[1]
        claim = a[2]
    elif a[0] == 'api':
        claim = a[1]
        return api_call(claim)
    # load db file
    db = pickle.load(open('/u/atn/public_html/cgi-bin/factdb.pkl'), encoding="utf8")
    try:
        print('claim: ', claim)
        res_b = query_b(claim)
        print('got res_b')

        (sources, df, vera) = answer(claim, res_b)
        print('got (s, df, vera)')

        #save to db
        headlines = df.articleHeadline.values.tolist()
        db.update({uid: (sources, headlines, vera)})
        pickle.dump(db, open('/u/atn/public_html/cgi-bin/factdb.pkl','w') )

        ans_str = gen_res_str(sources, df, vera)
        ans_str = ans_str.encode('ascii', 'ignore')
        return ans_str
    except:
        return ""

if False:
    HOST = ''                 # Symbolic name meaning all available interfaces
    PORT = 50007              # Arbitrary non-privileged port


    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    s.bind((HOST, PORT))
    s.listen(1)

    print('ready')

    while True:
        conn, addr = s.accept()
        print('Connected by', addr)

        while True:
            data = conn.recv(pow(2,20))
            if not data: break
            print("received data:", data)
            conn.sendall(answer(data))
        conn.close()

# Echo server program
import socket
from .loader import *

import pickle
temp_res_b = pickle.load(open('temp_resg.pkl', 'rb'), encoding="utf8")

import json

def api_call(claim, use_cache=False):
    """
    use_cache: arg for query_g
    """
    res_b, error = query_b(claim, use_cache)
    (sources, df, vera, stances, rep, clf_vera_coef, clf_vera_intc, urls, crowd_stance_lab, hh) = answer_loader(claim, res_b, True)
    articles = []
    n = len(sources)
    for i in range(n):
        a = {"sources": sources[i], "reputation": rep[i], "headlines": df.articleHeadline[i], "stance": stances[i].tolist() }
        articles.append(a)

    res = {"claim": claim,\
            "articles": articles, \
            "veracity": vera[0].tolist(), \
            "clf_vera_coef": clf_vera_coef, \
            "clf_vera_intc": clf_vera_intc, \
            "urls": urls, \
            'crowd_stance': crowd_stance_lab, \
            'hh': hh, \
            'error': error
    }
    return res
    #return json.dumps(res)

def answer(data):
    # extract data
    a = data.split("\n")
    if a[0] == 'claim':
        uid = -1
        claim = a[1]
    elif a[0] == 'uc':
        uid = a[1]
        claim = a[2]
    elif a[0] == 'api':
        claim = a[1]
        return api_call(claim)
    # load db file
    db = pickle.load(open('/u/atn/public_html/cgi-bin/factdb.pkl'), encoding="utf8")
    try:
        print('claim: ', claim)
        res_b = query_b(claim)
        print('got res_b')

        (sources, df, vera) = answer(claim, res_b)
        print('got (s, df, vera)')

        #save to db
        headlines = df.articleHeadline.values.tolist()
        db.update({uid: (sources, headlines, vera)})
        pickle.dump(db, open('/u/atn/public_html/cgi-bin/factdb.pkl','w') )

        ans_str = gen_res_str(sources, df, vera)
        ans_str = ans_str.encode('ascii', 'ignore')
        return ans_str
    except:
        return ""

if False:
    HOST = ''                 # Symbolic name meaning all available interfaces
    PORT = 50007              # Arbitrary non-privileged port


    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    s.bind((HOST, PORT))
    s.listen(1)

    print('ready')

    while True:
        conn, addr = s.accept()
        print('Connected by', addr)

        while True:
            data = conn.recv(pow(2,20))
            if not data: break
            print("received data:", data)
            conn.sendall(answer(data))
        conn.close()

# Echo server program use_cache: arg for query_g #return json.dumps(res) # extract data # load db file #save to db # Symbolic name meaning all available interfaces # Arbitrary non-privileged port