# This endpoint adds a post to the database.
# Also, using a third party api it will do semantic analysis for potential abuse.
class StoryPost(GenericAPIView):
    """ 
    This endpoint adds a post to the database.
    Also, using a third party api it will do semantic analysis for potential abuse.
    """
    queryset = Story.objects.all()
    serializer_class = StorySerializer
    def post(self, request, format=None):
        serializer = StorySerializer(data=request.data)
        if serializer.is_valid():
            lat, lng = find_coordinates(serializer.validated_data['location'])
            abuse = check_abuse(serializer.validated_data['story'], serializer)
            if abuse != True and abuse != False:
                return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
            serializer.save(notifyAdmin = abuse, latitude=lat, longitude=lng)
            return Response(serializer.data, status=200)
        return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
        

def check_abuse(story, serializer):
    #Using a third party api, check if there is possible abuse in text.
    #If runs correctly will return a boolean variable denoting abuse.
    #If exception occurs return a HttpResponse of 400.

    # Seting various request parameters.
    headers = {
        'Content-Type': 'application/json',
        'Ocp-Apim-Subscription-Key': tisane_key,
    }

    tisane_body = json.dumps({ "language":"en", "content": story, "settings":{} })

    try:
        conn = http.client.HTTPSConnection('api.tisane.ai')
        conn.request("POST", "/parse", tisane_body, headers)
        response = conn.getresponse()
        data = json.loads(response.read())
        conn.close()
        
        return 'abuse' in data
    except Exception as e:
        print(e)
        return HttpResponse(e.strerror, status = 400)


# Gets flagged stories (notifyAdmin == True) from the database.
# Only used with get.
@api_view(['GET'])
def flagged_stories(request):
    """ 
    Gets flagged stories (notifyAdmin == True) from the database.
    Only used with get.
    """
    if request.method != 'GET':
        return HttpResponse('Please use this end point with GET.', 400)
    query = Story.objects.filter(notifyAdmin = True)
    response = {'flagged_stories': []}
    for q in query:
        response['flagged_stories'].append({
            'id': q.id,
            'title': q.title,
            'story': q.story,
        })
    return JsonResponse(data = response)

from django.test import TestCase
from ..models import Story
import json

class PostStoryTestCase(TestCase):

    def setUp(self):
        
        Story.objects.create(id = 1, title = "Testing Story", story= "Once upon a time ...", name = "USER", longitude = 
        3.14, latitude = 4.13, location = "somewhere", tag =" ", notifyAdmin  = False)
        Story.objects.create(id = 2, title = "Testing Story2", story= "This notifies the admin.", name = "USER", longitude = 
        3.14, latitude = 4.13, location = "somewhere", tag =" ", notifyAdmin = True)

    def test_can_find_notify_admin(self):
        self.assertEqual(Story.objects.get(notifyAdmin = True).story, "This notifies the admin.")

    def test_creates_post(self): 
        dummy_body = json.dumps({'title':'TEST', 'story': 'STILL TESTING.', 'name':'USER',  
            'longitude':0, 'latitude': 0 ,'location' : 'somwhere', 'tag': 'TESTTAG'})
        response = self.client.post('/api/storypost/', data = dummy_body, content_type="application/json")
        self.assertEqual(response.status_code, 200)
    
    def test_creates_flagged_post(self):
        dummy_body = json.dumps({'title':'TEST', 'story': 'Just shut up!', 'name':'USER',
            'longitude':0, 'latitude': 0 ,'location' : 'somwhere', 'tag': 'TESTTAG'})
        response = self.client.post('/api/storypost/', data = dummy_body, content_type="application/json")
        self.assertEqual(response.status_code, 200)
        notify_flag = Story.objects.get(id = response.json()['id']).notifyAdmin
        self.assertEqual(notify_flag, True)
    
    def test_gets_flagged_post(self):
        response = self.client.get('/api/flagged_stories/')
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.content)['flagged_stories']
        found_flag = 2 in [story['id'] for story in data] # Post with id = 2 was flagged.
        self.assertEqual(found_flag, True)

    def test_post_no_data(self):
        response = self.client.post('/api/storypost/', data = {}, content_type="application/json")
        self.assertEqual(response.status_code, 400)