1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
#-*- coding: utf-8 -*-
# Copyright (C) 1998-2012 by the Free Software Foundation, Inc.
#
# This file is part of HyperKitty.
#
# HyperKitty is free software: you can redistribute it and/or modify it under
# the terms of the GNU General Public License as published by the Free
# Software Foundation, either version 3 of the License, or (at your option)
# any later version.
#
# HyperKitty is distributed in the hope that it will be useful, but WITHOUT
# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
# FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
# more details.
#
# You should have received a copy of the GNU General Public License along with
# HyperKitty. If not, see <http://www.gnu.org/licenses/>.
#
from rest_framework.views import APIView
from rest_framework.response import Response
from rest_framework import serializers
from rest_framework.exceptions import ParseError
from hyperkitty.models import Tag
from hyperkitty.lib import get_store
from hyperkitty.lib.voting import get_votes
class ListSerializer(serializers.Serializer):
name = serializers.CharField()
display_name = serializers.CharField()
subject_prefix = serializers.CharField()
class EmailSerializer(serializers.Serializer):
list_name = serializers.EmailField()
message_id = serializers.CharField()
thread_id = serializers.CharField()
sender_name = serializers.CharField()
sender_email = serializers.EmailField()
subject = serializers.CharField()
in_reply_to = serializers.CharField()
date = serializers.DateTimeField()
likes = serializers.IntegerField()
dislikes = serializers.IntegerField()
class EmailLinkSerializer(serializers.Serializer):
list_name = serializers.EmailField()
message_id = serializers.CharField()
sender_name = serializers.CharField()
sender_email = serializers.EmailField()
date = serializers.DateTimeField()
class ThreadSerializer(serializers.Serializer):
thread_id = serializers.CharField()
list_name = serializers.EmailField()
date_active = serializers.DateTimeField()
subject = serializers.CharField()
starting_email = EmailLinkSerializer()
email_ids = serializers.CharField()
participants = serializers.CharField()
class TagSerializer(serializers.ModelSerializer):
class Meta:
model = Tag
fields = ("list_address", "threadid", "tag")
class ListResource(APIView):
""" Resource used to retrieve lists from the archives using the
REST API.
"""
def get(self, request):
store = get_store(request)
lists = store.get_lists()
if not lists:
return Response(status=404)
else:
return Response(ListSerializer(lists, many=True).data)
class EmailResource(APIView):
""" Resource used to retrieve emails from the archives using the
REST API.
"""
def get(self, request, mlist_fqdn, messageid):
store = get_store(request)
email = store.get_message_by_hash_from_list(mlist_fqdn, messageid)
if not email:
return Response(status=404)
else:
email.likes, email.dislikes, _ignore = get_votes(email.message_id_hash)
return Response(EmailSerializer(email).data)
class ThreadResource(APIView):
""" Resource used to retrieve threads from the archives using the
REST API.
"""
def get(self, request, mlist_fqdn, threadid):
store = get_store(request)
thread = store.get_thread(mlist_fqdn, threadid)
if not thread:
return Response(status=404)
else:
return Response(ThreadSerializer(thread).data)
class SearchResource(APIView):
""" Resource used to search the archives using the REST API.
"""
def get(self, request, mlist_fqdn, field, keyword):
fields = ['Subject', 'Content', 'SubjectContent', 'From']
if field not in fields:
raise ParseError(detail="Unknown field: " + field + ". Supported fields are " + ", ".join(fields))
store = get_store(request)
threads = None
if field == 'Subject':
threads = store.search_list_for_subject(mlist_fqdn, keyword)
elif field == 'Content':
threads = store.search_list_for_content(mlist_fqdn, keyword)
elif field == 'SubjectContent':
threads = store.search_list_for_content_subject(mlist_fqdn, keyword)
elif field == 'From':
threads = store.search_list_for_sender(mlist_fqdn, keyword)
if not threads:
return Response(status=404)
else:
return Response(EmailSerializer(threads, many=True).data)
class TagResource(APIView):
"""
Resource used to retrieve tags from the database using the REST API.
"""
def get(self, request):
tags = Tag.objects.all()
serializer = TagSerializer(tags, many=True)
return Response(serializer.data)
|
