cfed4a69999708660c547ff32f668eda6f7c14c2
[audio.git] / apps / archive / views.py
1 # Create your views here.
2
3 from datetime import datetime
4 import os
5 import os.path
6
7 from archive import settings
8 from django.contrib.auth import logout
9 from django.contrib.auth.decorators import login_required
10 from django.core.urlresolvers import reverse
11 from django.db.models import Q, Max
12 from django.http import Http404
13 from django.shortcuts import render, redirect, get_object_or_404
14 from django.views.decorators.http import require_POST
15
16 import mutagen
17
18 from archive.constants import status
19 from archive import models
20 from archive.forms import AudiobookForm
21 from archive import tasks
22 from archive.utils import all_files
23
24
25 @login_required
26 def list_new(request):
27     division = 'new'
28
29     path = settings.NEW_PATH
30     objects = sorted(all_files(path))
31     return render(request, "archive/list_new.html", locals())
32
33
34 @login_required
35 def file_new(request, filename):
36     division = 'new'
37
38     filepath = filename.encode('utf-8')
39     root_filepath = os.path.join(settings.NEW_PATH, filename.encode('utf-8'))
40     if request.POST:
41         form = AudiobookForm(request.POST)
42         if form.is_valid():
43             try:
44                 form.save(path=filepath)
45             except IOError:
46                 raise Http404
47             return redirect(list_new)
48
49     try:
50         tags = mutagen.File(root_filepath)
51     except IOError:
52         raise Http404
53     d = {}
54     if tags:
55         for tag in tags:
56             value = tags[tag]
57             if isinstance(value, list):
58                 d[tag] = value[0]
59             else:
60                 d[tag] = value
61             if tag == 'project':
62                 try:
63                     d[tag] = models.Project.objects.get(name=d[tag]).pk
64                 except models.Project.DoesNotExist:
65                     d[tag] = None
66
67     if not request.POST:
68         form = AudiobookForm(d)
69     return render(request, "archive/file_new.html", locals())
70
71
72 @require_POST
73 @login_required
74 def move_to_archive(request, filename):
75     """ move a new file to the unmanaged files dir """
76
77     filename_str = filename.encode('utf-8')
78     old_path = os.path.join(settings.NEW_PATH, filename_str)
79     new_path = os.path.join(settings.UNMANAGED_PATH, filename_str)
80     new_dir = os.path.split(new_path)[0]
81     if not os.path.isdir(new_dir):
82         os.makedirs(new_dir)
83
84     if not os.path.isfile(old_path):
85         raise Http404
86
87     try:
88         os.link(old_path, new_path)
89         os.unlink(old_path)
90     except OSError:
91         # destination file exists, don't overwrite it
92         # TODO: this should probably be more informative
93         return redirect(file_new, filename)
94
95     return redirect(list_new)
96
97
98 @require_POST
99 @login_required
100 def move_to_new(request, filename):
101     """ move a unmanaged file to new files dir """
102
103     filename_str = filename.encode('utf-8')
104     old_path = os.path.join(settings.UNMANAGED_PATH, filename_str)
105     new_path = os.path.join(settings.NEW_PATH, filename_str)
106     new_dir = os.path.split(new_path)[0]
107     if not os.path.isdir(new_dir):
108         os.makedirs(new_dir)
109
110     if not os.path.isfile(old_path):
111         raise Http404
112
113     try:
114         os.link(old_path, new_path)
115         os.unlink(old_path)
116     except OSError:
117         # destination file exists, don't overwrite it
118         # TODO: this should probably be more informative
119         return redirect(reverse(file_unmanaged, args=[filename]) + "?exists=1")
120
121     return redirect(list_unmanaged)
122
123
124 @require_POST
125 @login_required
126 def publish(request, aid):
127     """ mark file for publishing """
128     audiobook = get_object_or_404(models.Audiobook, id=aid)
129     tags = {
130         'name': audiobook.title,
131         'url': audiobook.url,
132         'tags': audiobook.new_publish_tags(),
133         }
134     audiobook.mp3_tags = tags
135     audiobook.ogg_tags = tags
136     audiobook.mp3_status = audiobook.ogg_status = status.WAITING
137     audiobook.save()
138     # isn't there a race here?
139     audiobook.mp3_task = tasks.Mp3Task.delay(aid).task_id
140     audiobook.ogg_task = tasks.OggTask.delay(aid).task_id
141     audiobook.save()
142
143     return redirect(file_managed, aid)
144
145
146 @require_POST
147 @login_required
148 def cancel_publishing(request, aid):
149     """ cancel scheduled publishing """
150     audiobook = get_object_or_404(models.Audiobook, id=aid)
151     # TODO: cancel tasks
152     audiobook.mp3_status = None
153     audiobook.ogg_status = None
154     audiobook.save()
155     return redirect(file_managed, aid)
156
157
158 @login_required
159 def list_unpublished(request):
160     division = 'unpublished'
161
162     objects = models.Audiobook.objects.filter(Q(mp3_published=None) | Q(ogg_published=None))
163     return render(request, "archive/list_unpublished.html", locals())
164
165
166 @login_required
167 def list_publishing(request):
168     division = 'publishing'
169
170     objects = models.Audiobook.objects.exclude(mp3_status=None, ogg_status=None)
171     objects_by_status = {}
172     for o in objects:
173         if o.mp3_status:
174             k = o.mp3_status, o.get_mp3_status_display()
175             objects_by_status.setdefault(k, []).append(o)
176         if o.ogg_status and o.ogg_status != o.mp3_status:
177             k = o.ogg_status, o.get_ogg_status_display()
178             objects_by_status.setdefault(k, []).append(o)
179     status_objects = sorted(objects_by_status.items(), reverse=True)
180
181     return render(request, "archive/list_publishing.html", locals())
182
183
184 @login_required
185 def list_published(request):
186     division = 'published'
187
188     objects = models.Audiobook.objects.exclude(Q(mp3_published=None) | Q(ogg_published=None))
189     return render(request, "archive/list_published.html", locals())
190
191
192 @login_required
193 def file_managed(request, id):
194     audiobook = get_object_or_404(models.Audiobook, id=id)
195
196     if request.POST:
197         form = AudiobookForm(request.POST, instance=audiobook)
198         if form.is_valid():
199             try:
200                 form.save()
201             except IOError:
202                 raise Http404
203
204     division = 'published' if audiobook.published() else 'unpublished'
205     path = audiobook.source_file.path[len(settings.FILES_PATH):].lstrip('/')
206
207     # for tags update
208     tags = mutagen.File(audiobook.source_file.path)
209     if not tags:
210         tags = {}
211     form = AudiobookForm(instance=audiobook)
212
213     return render(request, "archive/file_managed.html", locals())
214
215
216 @login_required
217 def list_unmanaged(request):
218     division = 'unmanaged'
219
220     objects = sorted(all_files(settings.UNMANAGED_PATH))
221     return render(request, "archive/list_unmanaged.html", locals())
222
223
224 @login_required
225 def file_unmanaged(request, filename):
226     division = 'unmanaged'
227
228     tags = mutagen.File(os.path.join(settings.UNMANAGED_PATH, filename.encode('utf-8')))
229     if not tags:
230         tags = {}
231     
232     err_exists = request.GET.get('exists')
233     return render(request, "archive/file_unmanaged.html", locals())
234
235
236 @login_required
237 def logout_view(request):
238     logout(request)
239     return redirect(list_new)