1 # -*- coding: utf-8 -*-
3 from __future__ import division
10 from datetime import *
12 from time import time as get_timestamp, sleep
19 from StringIO import StringIO
20 from django.http import *
21 from django.template import loader, RequestContext
22 from django import forms
23 from django.shortcuts import render_to_response, get_object_or_404
24 from django.utils.safestring import mark_safe
26 from decoratedstr import remove_decoration
28 from ais.area import list_areas
29 from ais.djais.basicauth import http_authenticate
30 from ais.djais.models import *
31 from ais.show_targets_ships import format_fleet_lastpos, kml_to_kmz, KML_DISPLAYOPT_SHOWHIDDEN
32 from ais.common import COUNTRIES_MID, Nmea, NmeaFeeder, SHIP_TYPES, STATUS_CODES, AIS_STATUS_NOT_AVAILABLE, AIS_ROT_NOT_AVAILABLE, AIS_LATLON_SCALE, AIS_LON_NOT_AVAILABLE, AIS_LAT_NOT_AVAILABLE, AIS_COG_SCALE, AIS_COG_NOT_AVAILABLE, AIS_NO_HEADING, AIS_SOG_SCALE, AIS_SOG_NOT_AVAILABLE, AIS_SOG_MAX_SPEED, add_nmea1, add_nmea5_partial, load_fleet_to_uset
33 from ais.ntools import datetime_to_timestamp, strmmsi_to_mmsi, clean_ais_charset, clean_latitude, clean_longitude, LatLonFormatError
34 from ais.inputs.common import is_id4_active
35 from ais.inputs.stats import STATS_DIR
36 from ais.inputs.config import peers_get_config, get_hidden_mmsi
37 from ais import jobrunner
38 from ais.djais.widgets import *
40 def auth(username, raw_password):
42 user = User.objects.get(login=username)
43 except User.DoesNotExist:
45 if not user.check_password(raw_password):
47 user.update_access_datetime()
51 @http_authenticate(auth, 'ais')
53 news = News.objects.order_by('-created')[:5]
54 return render_to_response('index.html', {'news':news}, RequestContext(request))
57 class VesselSearchForm(forms.Form):
58 def country_choices():
60 for mid, countryname in COUNTRIES_MID.iteritems():
61 if choices.has_key(countryname):
62 choices[countryname] += u','+unicode(mid)
64 choices[countryname] = unicode(mid)
65 choices = [ (countryname, mids) for mids, countryname in choices.iteritems() ]
66 choices = sorted(choices, key=operator.itemgetter(1))
67 return [(u'', u'Any')] + choices
69 name = forms.CharField(max_length=20, required=False)
70 mmsi = forms.CharField(help_text=u'Maritime Mobile Service Identity', min_length=9, max_length=9, required=False)
71 imo = forms.IntegerField(help_text=u'International Maritime Organization identifier assigned by Llyod', required=False)
72 callsign = forms.CharField(max_length=7, required=False)
73 flag = forms.ChoiceField(choices=country_choices(), required=False)
74 destination = forms.CharField(max_length=20, required=False)
77 cleaned_data = self.cleaned_data
78 for value in cleaned_data.values():
81 raise forms.ValidationError("You must enter at least one criteria")
84 mmsi = self.cleaned_data['mmsi']
87 mmsi = strmmsi_to_mmsi(mmsi)
88 except AssertionError:
89 raise forms.ValidationError("Invalid MMSI")
93 @http_authenticate(auth, 'ais')
94 def vessel_search(request):
95 if request.method == 'POST' or request.META['QUERY_STRING']:
96 form = VesselSearchForm(request.REQUEST)
98 data = form.cleaned_data
99 vessels = Vessel.objects
101 vessels = vessels.filter(mmsi=data['mmsi'])
103 vessels = vessels.filter(name__contains=data['name'].upper())
105 vessels = vessels.filter(imo=data['imo'])
107 vessels = vessels.filter(callsign__contains=data['callsign'].upper())
108 if data['destination']:
109 vessels = vessels.filter(destination__contains=data['destination'].upper())
111 vessels = vessels.extra(where=['mmsi/1000000 IN (%s) ' % data['flag']])
112 return render_to_response('vessels.html', {'vessels': vessels}, RequestContext(request))
114 form = VesselSearchForm()
116 return render_to_response('vessel_index.html', {'form': form}, RequestContext(request))
118 class SecondsWidget(forms.MultiWidget):
120 A widget that splits period number and period type in a integer and a choice widgets
121 Does not work well for more than a week, as month lengthes do vary.
124 (u'1', u'second(s)'),
125 (u'60', u'minute(s)'),
126 (u'3600', u'hour(s)'),
127 (u'86400', u'day(s)'),
128 (u'604800', u'week(s)'),
129 (u'2592000', u'month(es)'))
131 def __init__(self, attrs=None):
132 textattrs = { 'size': 3 }
134 textattrs.update(attrs)
136 forms.TextInput(attrs=textattrs),
137 forms.Select(choices=self.__periods, attrs=attrs))
138 super(SecondsWidget, self).__init__(widgets, attrs)
140 def decompress(self, value):
142 for period_second in reversed([int(sec_txt[0]) for sec_txt in self.__periods]):
143 if value >= period_second and not value % period_second:
144 return [ unicode(value // period_second), unicode(period_second) ]
147 class SecondsField(forms.MultiValueField):
148 widget = SecondsWidget
150 def __init__(self, *args, **kargs):
152 forms.IntegerField(),
155 forms.MultiValueField.__init__(self, fields=fields, *args, **kargs)
157 def compress(self, data_list):
158 #print 'data_list=', data_list
159 if data_list and data_list[0] is not None and data_list[1] is not None:
161 return data_list[0] * int(data_list[1])
166 class HistoryForm(forms.Form):
167 format = forms.ChoiceField(choices=(('animation', 'Animation (Google Earth v5)'), ('track', 'Track line (Google Earth)'), ('csv', 'Coma separated values (SpreadSheet)')), widget=forms.Select(attrs={'onchange': mark_safe("if (this.value=='csv') $('#csvhint').show(); else $('#csvhint').hide();")}))
168 period_type = forms.ChoiceField(choices=(('duration', 'Duration until now'), ('date_date','Between two dates'), ('start_duration', 'Start date and duration')), widget=forms.RadioSelect(attrs={'onchange': mark_safe("show_hide_start_end_time(this.value);")}))
169 start_date = forms.DateTimeField(required=False, widget=AisCalendarWidget(attrs={'class':'vDateField'}))
170 duration = SecondsField(required=False, label='Period length', initial=7*86400)
171 end_date = forms.DateTimeField(required=False, widget=AisCalendarWidget(attrs={'class':'vDateField'}))
172 grain = SecondsField(label='One position every', initial=3600)
173 filter_area = forms.ChoiceField(required=False, label='Only in area',
174 choices=[ (u'', u'(Not filtered)') ] + [ (fn[1], fn[0]) for fn in list_areas() ] )
175 reference_latitude = forms.CharField(required=False)
176 reference_longitude = forms.CharField(required=False)
177 filter_close_to = forms.FloatField(required=False, label=u'Only if closer than n miles from reference point')
178 filter_far_from = forms.FloatField(required=False, label=u'Only if farther than n miles from reference point')
179 filter_sog_le = forms.FloatField(required=False, label=u'Only if speed ≤ (knots)')
180 filter_sog_ge = forms.FloatField(required=False, label=u'Only if speed ≥ (knots)')
181 filter_destination = forms.CharField(required=False, label=u'Only if destination starts with', max_length=20, help_text=u'Use AIS upper case letters')
183 def clean_start_date(self):
184 period_type = self.cleaned_data.get('period_type', None)
185 start_date = self.cleaned_data.get('start_date', None)
186 if period_type in (u'date_date', u'start_duration') and start_date is None:
187 raise forms.ValidationError('That is field is required.')
190 def clean_duration(self):
191 period_type = self.cleaned_data.get('period_type', None)
192 duration = self.cleaned_data.get('duration', None)
193 print 'duration=', duration
194 if period_type in (u'duration', u'start_duration') and duration is None:
195 raise forms.ValidationError('That is field is required.')
198 def clean_end_date(self):
199 period_type = self.cleaned_data.get('period_type', None)
200 end_date = self.cleaned_data.get('end_date', None)
201 if period_type in (u'date_date',) and end_date is None:
202 raise forms.ValidationError('That is field is required.')
205 def clean_reference_latitude(self):
206 lat = self.cleaned_data.get('reference_latitude', None)
210 clean_lat = clean_latitude(lat)
211 except LatLonFormatError, err:
212 if len(err.args) > 1:
213 raise forms.ValidationError(err.args[0] % err.args[1:])
215 raise forms.ValidationError(*err.args)
216 return lat # return the text
218 def clean_reference_longitude(self):
219 lon = self.cleaned_data.get('reference_longitude', None)
223 clean_lon = clean_longitude(lon)
224 except LatLonFormatError, err:
225 if len(err.args) > 1:
226 raise forms.ValidationError(err.args[0] % err.args[1:])
228 raise forms.ValidationError(*err.args)
229 return lon # return the text
232 cleaned_data = self.cleaned_data
233 period_type = self.cleaned_data.get('period_type', None)
234 start_date = self.cleaned_data.get('start_date', None)
235 end_date = self.cleaned_data.get('end_date', None)
236 if period_type == u'date_date' and start_date is not None and end_date is not None:
237 if start_date >= end_date:
238 self._errors["start_date"] = self.error_class(['Start date must be before end date.'])
239 reference_latitude = self.cleaned_data.get('reference_latitude', None)
240 reference_longitude = self.cleaned_data.get('reference_longitude', None)
241 filter_close_to = self.cleaned_data.get('filter_close_to', None)
242 filter_far_from = self.cleaned_data.get('filter_far_from', None)
243 if filter_close_to is not None:
244 if reference_latitude is None:
245 self._errors['reference_latitude'] = self.error_class([u'Field required when using close_to filter'])
246 if reference_longitude is None:
247 self._errors['reference_longitude'] = self.error_class([u'Field required when using close_to filter'])
248 if filter_far_from is not None:
249 if reference_latitude is None:
250 self._errors['reference_latitude'] = self.error_class([u'Field required when using far_from filter'])
251 if reference_longitude is None:
252 self._errors['reference_longitude'] = self.error_class([u'Field required when using far_from filter'])
255 def get_cmdext(self):
257 Must not be called unless is_valid
258 Returns (command, extension)
260 def escape_cmd_arg(txt):
264 if c.upper() not in '+-./0123456789=@^_ABCDEFGHIJKLMNOPQRSTUVWXYZ':
277 command.append(escape_cmd_arg(txt))
279 data = self.cleaned_data
280 format = data['format']
282 if format == u'track':
283 command = [ u'show_targets_ships' ]
284 addparam(u'--format=track')
287 elif format == u'animation':
288 command = [ u'show_targets_ships' ]
289 addparam(u'--format=animation')
292 elif format == u'csv':
293 command = [ u'common' ]
296 raise Http404(u'Invalid archive format')
298 date_start = data.get('start_date', None)
301 addparam(date_start.strftime('%Y%m%d'))
303 date_end = data.get('end_date', None)
306 addparam(date_end.strftime('%Y%m%d'))
308 duration = data.get('duration', None)
310 addparam(u'--duration')
313 grain = data['grain']
314 addparam(u'--granularity')
317 filter_area = data.get('filter_area', None)
319 addparam(u'--filter-area')
320 addparam(filter_area)
322 filter_sog_le = data.get('filter_sog_le', None)
324 addparam(u'--filter-sog-le')
325 addparam(filter_sog_le)
327 filter_sog_ge = data.get('filter_sog_ge', None)
329 addparam(u'--filter-sog-ge')
330 addparam(filter_sog_ge)
332 filter_destination = data.get('filter_destination', None)
333 if filter_destination:
334 addparam(u'--filter-destination')
335 addparam(filter_destination)
337 reference_latitude = self.cleaned_data.get('reference_latitude', None)
338 reference_longitude = self.cleaned_data.get('reference_longitude', None)
339 filter_close_to = self.cleaned_data.get('filter_close_to', None)
340 filter_far_from = self.cleaned_data.get('filter_far_from', None)
341 if filter_close_to and reference_latitude and reference_longitude:
342 addparam(u'--filter-closeto')
343 addparam(reference_latitude)
344 addparam(reference_longitude)
345 addparam(filter_close_to)
346 if filter_far_from and reference_latitude and reference_longitude:
347 addparam(u'--filter-farfrom')
348 addparam(reference_latitude)
349 addparam(reference_longitude)
350 addparam(filter_far_from)
351 return u' '.join(command), extension
354 @http_authenticate(auth, 'ais')
355 def vessel(request, strmmsi):
356 mmsi = strmmsi_to_mmsi(strmmsi)
357 vessel = get_object_or_404(Vessel, pk=mmsi)
358 nmea = Nmea.new_from_lastinfo(strmmsi)
359 #if not nmea.timestamp_1 and not nmea.timestamp_5:
361 is_hidden = mmsi in get_hidden_mmsi()
362 hide_ship = is_hidden and not request.user.flag_allowhidden
363 return render_to_response('vessel.html', {'nmea': nmea, 'is_hidden': is_hidden, 'hide_ship': hide_ship,'form': HistoryForm()}, RequestContext(request))
366 class VesselManualInputForm(forms.Form):
367 timestamp = forms.DateTimeField(label=u'When', help_text=u'When was the observation made in GMT. Use YYYY-MM-DD HH:MM:SS format')
368 imo = forms.IntegerField(required=False, min_value=1000000, max_value=9999999)
369 name = forms.CharField(max_length=20, required=False)
370 callsign = forms.CharField(max_length=7, required=False)
371 type = forms.TypedChoiceField(required=False, choices = [ kv for kv in SHIP_TYPES.iteritems() if 'reserved' not in kv[1].lower()], coerce=int, empty_value=0, initial=0)
372 status = forms.TypedChoiceField(required=False, choices = [ kv for kv in STATUS_CODES.iteritems() if 'reserved' not in kv[1].lower()], coerce=int, empty_value=AIS_STATUS_NOT_AVAILABLE, initial=AIS_STATUS_NOT_AVAILABLE)
373 sog = forms.FloatField(label='Speed', help_text='Over ground, in knots', required=False, min_value=0, max_value=AIS_SOG_MAX_SPEED/AIS_SOG_SCALE)
374 latitude = forms.CharField(required=False)
375 longitude = forms.CharField(required=False)
376 cog = forms.FloatField(label='Course', help_text='Over ground', required=False, min_value=0.0, max_value=359.9)
377 heading = forms.IntegerField(required=False, min_value=0, max_value=359)
380 def _clean_ais_charset(ustr):
381 ustr = remove_decoration(ustr) # benign cleaning, but can increase size (œ->oe)
382 ustr = ustr.upper() # benign cleaning
383 str = clean_ais_charset(ustr.encode('ascii', 'replace'))
384 if unicode(str) != ustr:
385 raise forms.ValidationError('Invalid character: AIS alphabet is @ABCDEFGHIJKLMNOPQRSTUVWXYZ[\\]^- !"#$%&\'()*+,-./0123456789:;<=>?')
388 def clean_timestamp(self):
389 data = self.cleaned_data['timestamp']
392 if data < datetime.utcnow() - timedelta(365):
393 raise forms.ValidationError('Date is too much is the past.')
394 if data > datetime.utcnow():
395 raise forms.ValidationError('Date is be in the future. This form is only for observed results.')
396 return datetime_to_timestamp(data)
399 data = self.cleaned_data['imo']
404 def clean_name(self):
405 name = self.cleaned_data['name']
408 name = VesselManualInputForm._clean_ais_charset(name)
410 raise forms.ValidationError('Ensure this value has at most 20 characters (it has %s).' % len(name))
413 def clean_callsign(self):
414 callsign = self.cleaned_data['callsign']
417 callsign = VesselManualInputForm._clean_ais_charset(callsign)
419 raise forms.ValidationError('Ensure this value has at most 7 characters (it has %s).' % len(callsign))
423 sog = self.cleaned_data['sog']
425 return AIS_SOG_NOT_AVAILABLE
426 return int(sog*AIS_SOG_SCALE)
428 def clean_latitude(self):
429 #TODO: use ntools.clean_latitude
430 data = self.cleaned_data['latitude']
431 data = data.replace(u"''", u'"') # common mistake
432 data = data.replace(u' ', u'') # remove spaces
435 return AIS_LAT_NOT_AVAILABLE
436 tmp, side = data[:-1], data[-1]
439 elif side == sides[1]:
442 raise forms.ValidationError(u'Last character must be either %s or %s.' % (sides[0], sides[1]))
443 spl = tmp.split(u'°')
445 raise forms.ValidationError(u'You need to use the ° character.')
450 raise forms.ValidationError(u'Degrees must be an number. It\'s %s.' % d)
451 spl = tmp.split(u"'", 1)
453 # no ' sign: ok only if there is nothing but the side after °
454 # we don't accept seconds if there is no minutes:
455 # It might be an entry mistake
460 raise forms.ValidationError(u'You must use the \' character between ° and %s.' % data[-1])
466 raise forms.ValidationError(u'Minutes must be an number. It\'s %s.' % m)
471 raise forms.ValidationError(u'You must use the " character between seconds and %s.' % data[-1])
476 raise forms.ValidationError(u'Seconds must be an number. It\'s %s.' % s)
477 data = side * ( d + m / 60 + s / 3600)
479 if data < -90 or data > 90:
480 raise forms.ValidationError(u'%s in not in -90..90 range' % data)
481 return int(data * AIS_LATLON_SCALE)
483 def clean_longitude(self):
484 #TODO: use ntools.clean_latitude
485 data = self.cleaned_data['longitude']
486 data = data.replace(u"''", u'"') # common mistake
487 data = data.replace(u' ', u'') # remove spaces
490 return AIS_LON_NOT_AVAILABLE
491 tmp, side = data[:-1], data[-1]
494 elif side == sides[1]:
497 raise forms.ValidationError(u'Last character must be either %s or %s.' % (sides[0], sides[1]))
498 spl = tmp.split(u'°')
500 raise forms.ValidationError(u'You need to use the ° character.')
505 raise forms.ValidationError(u'Degrees must be an number. It\'s %s.' % d)
506 spl = tmp.split(u"'", 1)
508 # no ' sign: ok only if there is nothing but the side after °
509 # we don't accept seconds if there is no minutes:
510 # It might be an entry mistake
515 raise forms.ValidationError(u'You must use the \' character between ° and %s.' % data[-1])
521 raise forms.ValidationError(u'Minutes must be an number. It\'s %s.' % m)
526 raise forms.ValidationError(u'You must use the " character between seconds and %s.' % data[-1])
531 raise forms.ValidationError(u'Seconds must be an number. It\'s %s.' % s)
532 data = side * ( d + m / 60 + s / 3600)
534 if data < -180 or data > 180:
535 raise forms.ValidationError(u'%s in not in -180..180 range' % data)
536 return int(data * AIS_LATLON_SCALE)
539 data = self.cleaned_data['cog']
541 return AIS_COG_NOT_AVAILABLE
542 return int(data * AIS_COG_SCALE)
544 def clean_heading(self):
545 #raise forms.ValidationError(u'clean_heading called')
546 data = self.cleaned_data['heading']
548 return AIS_NO_HEADING
552 cleaned_data = self.cleaned_data
553 if (cleaned_data.get('latitude', AIS_LAT_NOT_AVAILABLE) == AIS_LAT_NOT_AVAILABLE ) ^ ( cleaned_data.get('longitude', AIS_LON_NOT_AVAILABLE) == AIS_LON_NOT_AVAILABLE):
554 raise forms.ValidationError('It makes no sense to enter just a latitude or a longitude. Enter both or none.')
555 if cleaned_data.get('latitude', AIS_LAT_NOT_AVAILABLE) == AIS_LAT_NOT_AVAILABLE:
556 if cleaned_data.get('status', AIS_STATUS_NOT_AVAILABLE) != AIS_STATUS_NOT_AVAILABLE:
557 raise forms.ValidationError('It makes no sense to enter a status without coordinates. Please enter latitute and longitude too.')
558 if cleaned_data.get('sog', AIS_SOG_NOT_AVAILABLE) != AIS_SOG_NOT_AVAILABLE:
559 raise forms.ValidationError('It makes no sense to enter a speed without coordinates. Please enter latitute and longitude too.')
560 if cleaned_data.get('cog', AIS_COG_NOT_AVAILABLE) != AIS_COG_NOT_AVAILABLE:
561 raise forms.ValidationError('It makes no sense to enter a course without coordinates. Please enter latitute and longitude too.')
562 if cleaned_data.get('heading', AIS_NO_HEADING) != AIS_NO_HEADING:
563 raise forms.ValidationError('It makes no sense to enter a heading without coordinates. Please enter latitute and longitude too.')
565 if cleaned_data.get('timestamp', None) \
566 and cleaned_data.get('imo', 0) == 0 \
567 and cleaned_data.get('name', '') == '' \
568 and cleaned_data.get('callsign', '') == '' \
569 and cleaned_data.get('type', 0) == 0 \
570 and cleaned_data.get('status', AIS_STATUS_NOT_AVAILABLE) == AIS_STATUS_NOT_AVAILABLE \
571 and cleaned_data.get('sog', AIS_SOG_NOT_AVAILABLE) == AIS_SOG_NOT_AVAILABLE \
572 and cleaned_data.get('latitude', AIS_LAT_NOT_AVAILABLE) == AIS_LAT_NOT_AVAILABLE \
573 and cleaned_data.get('longitude', AIS_LON_NOT_AVAILABLE) == AIS_LON_NOT_AVAILABLE \
574 and cleaned_data.get('cog', AIS_COG_NOT_AVAILABLE) == AIS_COG_NOT_AVAILABLE \
575 and cleaned_data.get('heading', AIS_NO_HEADING) == AIS_NO_HEADING:
576 raise forms.ValidationError("You must enter some data, beside when.")
579 @http_authenticate(auth, 'ais')
580 def vessel_manual_input(request, strmmsi):
581 strmmsi = strmmsi.encode('utf-8')
582 nmea = Nmea.new_from_lastinfo(strmmsi)
583 if request.method == 'POST' or request.META['QUERY_STRING']:
584 form = VesselManualInputForm(request.REQUEST)
586 data = form.cleaned_data
587 source = 'U' + struct.pack('<I', request.user.id)[0:3]
589 if data['imo'] != 0 \
590 or data['name'] != '' \
591 or data['callsign'] != '' \
592 or data['type'] != 0:
593 toto = (strmmsi, data['timestamp'], data['imo'], data['name'], data['callsign'], data['type'], 0,0,0,0, 0,0,24,60, 0, '', source)
594 result += 'UPDATING NMEA 5: '+repr(toto)+'<br>'
595 add_nmea5_partial(*toto)
596 if data['status'] != AIS_STATUS_NOT_AVAILABLE \
597 or data['sog'] != AIS_SOG_NOT_AVAILABLE \
598 or data['latitude'] != AIS_LAT_NOT_AVAILABLE \
599 or data['longitude'] != AIS_LON_NOT_AVAILABLE \
600 or data['cog'] != AIS_COG_NOT_AVAILABLE \
601 or data['heading'] != AIS_NO_HEADING:
602 toto = (strmmsi, data['timestamp'], data['status'], AIS_ROT_NOT_AVAILABLE, data['sog'], data['latitude'], data['longitude'], data['cog'], data['heading'], source)
603 result += 'UPDATING NMEA 1: '+repr(toto)+'<br>'
605 return HttpResponse('Not fully implemented: '+repr(data) + '<br>' + result)
607 form = VesselManualInputForm()
608 return render_to_response('vessel_manual_input.html', {'form': form, 'nmea': nmea}, RequestContext(request))
611 @http_authenticate(auth, 'ais')
612 def vessel_lastpos(request, strmmsi):
614 if request.user.flag_allowhidden:
615 display_options = KML_DISPLAYOPT_SHOWHIDDEN
616 value = kml_to_kmz(format_fleet_lastpos([ strmmsi ], document_name=strmmsi, display_options=display_options).encode('utf-8'))
617 response = HttpResponse(value, mimetype="application/vnd.google-earth.kmz")
618 response['Content-Disposition'] = 'attachment; filename=%s.kmz' % strmmsi
621 @http_authenticate(auth, 'ais')
622 def vessel_history(request, strmmsi):
625 That view is called from Google Earth, so that it must support GET method.
628 if request.method == 'POST':
629 form = HistoryForm(request.POST, initial=initial)
631 command, extension = form.get_cmdext()
633 if request.user.flag_allowhidden:
634 command += u' --show-hidden-ships'
635 command += u' ' + strmmsi
638 job.queue_time = datetime.utcnow()
639 job.friendly_filename = u'%s.%s' % (strmmsi, extension)
640 job.user = request.user
641 job.command = command
643 if not jobrunner.wakeup_daemon():
644 return HttpResponseServerError(jobrunner.DAEMON_WAKEUP_ERROR)
645 return HttpResponseRedirect('/job/%s/download' % job.id)
647 form = HistoryForm(initial=initial)
648 strmmsi = strmmsi.encode('utf-8')
649 nmea = Nmea.new_from_lastinfo(strmmsi)
650 return render_to_response('vessel_history.html', {'nmea': nmea, 'form':form}, RequestContext(request))
653 @http_authenticate(auth, 'ais')
655 fleetusers = request.user.fleetuser_set.order_by('fleet')
656 return render_to_response('fleets.html', {'fleetusers':fleetusers}, RequestContext(request))
659 @http_authenticate(auth, 'ais')
660 def fleet(request, fleetname):
661 fleet = get_object_or_404(Fleet, name=fleetname)
662 if not FleetUser.objects.filter(fleet=fleet.id, user=request.user.id).all():
663 return HttpResponseForbidden('<h1>Forbidden</h1>')
664 return render_to_response('fleet.html', {'fleet':fleet}, RequestContext(request))
667 class FleetEditForm(forms.Form):
668 name = forms.CharField(max_length=50)
669 description = forms.CharField(widget=forms.Textarea)
671 def clean_name(self):
672 name = self.cleaned_data['name']
674 raise forms.ValidationError("Sorry that name is reserved. Try another one.")
675 if name != self.initial.get('name', None):
676 if Fleet.objects.filter(name=name).count():
677 raise forms.ValidationError("Sorry that fleet name is already in use. Try another one.")
678 return remove_decoration(name).replace(u' ', u'_')
681 @http_authenticate(auth, 'ais')
682 def fleet_edit(request, fleetname):
684 if fleetname is not None:
685 fleet = get_object_or_404(Fleet, name=fleetname)
686 if not FleetUser.objects.filter(fleet=fleet.id, user=request.user.id).all():
687 return HttpResponseForbidden('<h1>Forbidden</h1>')
689 initial['name'] = fleet.name
690 initial['description'] = fleet.description
694 if request.method == 'POST':
695 form = FleetEditForm(request.POST, initial=initial)
697 fleet.name = form.cleaned_data['name']
698 fleet.description = form.cleaned_data['description']
700 if not fleetname: # new one
703 fu.user = request.user
705 request.user.info('Fleet updated')
706 return HttpResponseRedirect('/fleet/%s/' % fleet.name)
708 form = FleetEditForm(initial=initial)
709 return render_to_response('fleet_edit.html', {'fleet':fleet, 'form':form}, RequestContext(request))
712 @http_authenticate(auth, 'ais')
713 def fleet_vessels(request, fleetname):
714 fleet = get_object_or_404(Fleet, name=fleetname)
715 if not FleetUser.objects.filter(fleet=fleet, user=request.user.id).all():
716 return HttpResponseForbidden('<h1>Forbidden</h1>')
717 vessels = fleet.vessel.all()
718 return render_to_response('fleet_vessels.html', {'fleet':fleet, 'vessels': vessels}, RequestContext(request))
721 @http_authenticate(auth, 'ais')
722 def fleet_vessel_add(request, fleetname):
723 fleet = get_object_or_404(Fleet, name=fleetname)
724 if not FleetUser.objects.filter(fleet=fleet.id, user=request.user.id).all():
725 return HttpResponseForbidden('<h1>Forbidden</h1>')
726 strmmsi = request.REQUEST['mmsi']
727 mmsi = strmmsi_to_mmsi(strmmsi)
729 vessel = Vessel.objects.get(pk=mmsi)
730 except Vessel.DoesNotExist:
731 request.user.error('No such vessel')
734 fv = FleetVessel.objects.get(fleet=fleet, vessel=vessel)
735 except FleetVessel.DoesNotExist:
736 FleetVessel(fleet=fleet, vessel=vessel).save()
737 request.user.info(u'Vessel %s added to fleet %s.' % (vessel.name, fleetname))
739 request.user.error('Vessel with MMSI %s is already in that fleet' % strmmsi)
740 return HttpResponseRedirect('/fleet/%s/list' % fleetname)
743 class FleetAddVessel(forms.Form):
744 mmsi = forms.CharField(help_text=u'Enter one MMSI per line', required=False, widget=forms.Textarea)
745 #name = forms.CharField(max_length=20, required=False)
746 #imo = forms.IntegerField(required=False)
747 #callsign = forms.CharField(max_length=7, required=False)
748 #destination = forms.CharField(max_length=20, required=False)
750 cleaned_data = self.cleaned_data
751 for value in cleaned_data.values():
754 raise forms.ValidationError("You must enter at least one criteria")
756 @http_authenticate(auth, 'ais')
757 def fleet_vessel_add2(request, fleetname):
758 fleet = get_object_or_404(Fleet, name=fleetname)
759 if not FleetUser.objects.filter(fleet=fleet.id, user=request.user.id).all():
760 return HttpResponseForbidden('<h1>Forbidden</h1>')
761 if request.method == 'POST' or request.META['QUERY_STRING']:
762 form = FleetAddVessel(request.REQUEST)
764 data = form.cleaned_data
766 a_strmmsi = request.REQUEST['mmsi']
768 for strmmsi in a_strmmsi.split('\n'):
769 strmmsi = strmmsi.strip('\r')
773 sqlmmsi = strmmsi_to_mmsi(strmmsi)
774 except AssertionError:
775 result.append('Invalid mmsi %s' % strmmsi)
778 vessel = Vessel.objects.get(pk=sqlmmsi)
779 except Vessel.DoesNotExist:
780 result.append('No vessel with MMSI '+strmmsi)
783 fv = FleetVessel.objects.get(fleet=fleet, vessel=vessel)
784 result.append('Vessel with MMSI %s is already in that fleet' % strmmsi)
785 except FleetVessel.DoesNotExist:
786 FleetVessel(fleet=fleet, vessel=vessel).save()
787 result.append('Vessel with MMSI %s added' % strmmsi)
789 return HttpResponse('<br>'.join(result))
791 form = FleetAddVessel()
793 return render_to_response('fleet_vessel_add.html', {'form': form, 'fleet': fleet}, RequestContext(request))
796 @http_authenticate(auth, 'ais')
797 def fleet_users(request, fleetname):
798 fleet = get_object_or_404(Fleet, name=fleetname)
799 if not FleetUser.objects.filter(fleet=fleet.id, user=request.user.id).all():
800 return HttpResponseForbidden('<h1>Forbidden</h1>')
802 if request.method == 'POST' or request.META['QUERY_STRING']:
803 action = request.REQUEST['action']
804 userlogin = request.REQUEST['user']
806 user = User.objects.get(login=userlogin)
807 except User.DoesNotExist:
808 request.user.error(u'User %s does not exist.' % userlogin)
812 fu = FleetUser.objects.get(fleet=fleet, user=user)
813 request.user.error(u'User %s already has access.' % user.login)
814 except FleetUser.DoesNotExist:
815 FleetUser(fleet=fleet, user=user).save()
817 request.user.info(u'Granted access to user %s.' % user.login)
818 elif action == u'revoke':
820 fu = FleetUser.objects.get(fleet=fleet, user=user)
823 request.user.info(u'Revoked access to user %s.' % user.login)
824 if FleetUser.objects.filter(fleet=fleet).count() == 0:
826 request.user.info(u"Deleted fleet %s (no more users)." % fleet.name)
827 return HttpResponseRedirect('/fleet/')
828 except FleetUser.DoesNotExist:
829 request.user.error(u'User %s didn\'t have access.' % user.login)
831 request.user.error(u'Unknown action %s' % action)
833 fleetusers = fleet.fleetuser_set.order_by('user__name')
834 otherusers = User.objects.exclude(id__in=[fu.user.id for fu in fleetusers]).order_by('name')
835 return render_to_response('fleet_users.html', {'fleet':fleet, 'fleetusers': fleetusers, 'otherusers': otherusers}, RequestContext(request))
838 @http_authenticate(auth, 'ais')
839 def fleet_lastpos(request, fleetname):
840 fleet = get_object_or_404(Fleet, name=fleetname)
841 if not FleetUser.objects.filter(fleet=fleet.id, user=request.user.id).all():
842 return HttpResponseForbidden('<h1>Forbidden</h1>')
844 if request.user.flag_allowhidden:
845 display_options = KML_DISPLAYOPT_SHOWHIDDEN
846 fleet_uset = load_fleet_to_uset(fleet.id)
847 value = kml_to_kmz(format_fleet_lastpos(fleet_uset, document_name=fleetname+' fleet', display_options=display_options).encode('utf-8'))
848 response = HttpResponse(value, mimetype="application/vnd.google-earth.kmz")
849 response['Content-Disposition'] = 'attachment; filename=%s.kmz' % fleetname
852 @http_authenticate(auth, 'ais')
853 def fleet_history(request, fleetname):
854 fleet = get_object_or_404(Fleet, name=fleetname)
855 if not FleetUser.objects.filter(fleet=fleet.id, user=request.user.id).all():
856 return HttpResponseForbidden('<h1>Forbidden</h1>')
858 if request.method == 'POST':
859 form = HistoryForm(request.POST, initial=initial)
861 command, extension = form.get_cmdext()
863 if request.user.flag_allowhidden:
864 command += u' --show-hidden-ships'
865 command += u' @' + fleetname
868 job.queue_time = datetime.utcnow()
869 job.friendly_filename = u'%s.%s' % (fleetname, extension)
870 job.user = request.user
871 job.command = command
873 if not jobrunner.wakeup_daemon():
874 return HttpResponseServerError(jobrunner.DAEMON_WAKEUP_ERROR)
875 return HttpResponseRedirect('/job/%s/download' % job.id)
877 form = HistoryForm(initial=initial)
878 return render_to_response('fleet_history.html', {'fleet': fleet, 'form':form}, RequestContext(request))
881 @http_authenticate(auth, 'ais')
882 def jobs_index(request):
883 show_archive = request.REQUEST.has_key('archive')
885 jobs = request.user.job_set.all()
887 jobs = request.user.job_set.filter(archive_time__isnull=True)
889 response = render_to_response('jobs.html', {'jobs': jobs, 'queue_size': Job.queue_size(), 'archive': show_archive }, RequestContext(request))
890 response['Refresh'] = 15
893 @http_authenticate(auth, 'ais')
894 def job_detail(request, jobid):
895 job = get_object_or_404(Job, id=jobid)
896 if job.user != request.user:
897 return HttpResponseForbidden('403 Forbidden')
898 response = render_to_response('job.html', {'job': job, 'queue_size': Job.queue_size()}, RequestContext(request))
899 if not job.finish_time:
900 response['Refresh'] = 5
901 elif not job.archive_time:
902 # finished but not archived:
903 response['Refresh'] = '0;url=https://' + request.get_host() + '/job/%s/download' % job.id
904 # careful not to modify other unschronized columns
905 Job.objects.filter(id=jobid).update(archive_time = datetime.utcnow())
908 @http_authenticate(auth, 'ais')
909 def job_get(request, jobid):
910 job = get_object_or_404(Job, id=jobid)
911 if job.user != request.user:
912 return HttpResponseForbidden('403 Forbidden')
914 while not job.finish_time:
918 request.user.info('Your query is slow. Please be patient.')
920 # careful not to modify other unschronized columns
921 Job.objects.filter(id=jobid).update(notify = 'W') # Web
922 return HttpResponseRedirect('/job/%s/' % job.id)
923 job = get_object_or_404(Job, id=jobid)
925 if not job.archive_time:
926 # careful not to modify other unschronized columns
927 Job.objects.filter(id=jobid).update(archive_time = datetime.utcnow())
931 return HttpResponseRedirect('/job/%s/' % job.id)
932 extension = os.path.splitext(job.friendly_filename)[-1]
933 return HttpResponseRedirect('/job_result/%s%s/%s' % (job.id, extension, job.friendly_filename))
936 @http_authenticate(auth, 'ais')
937 def job_log(request, jobid):
938 job = get_object_or_404(Job, id=jobid)
939 if job.user != request.user:
940 return HttpResponseForbidden('403 Forbidden')
943 log = file(jobrunner.RESULT_DIR+unicode(jobid)+'.log').read()
945 if err.errno != 2: # No such file
947 return render_to_response('job_log.html', {'job': job, 'log': log}, RequestContext(request))
950 @http_authenticate(auth, 'ais')
952 users = User.objects.order_by('name')
954 user.admin_ok = user.is_admin_by(request.user.id)
955 if request.REQUEST.has_key('showtree'):
959 local_users[user.id] = user
961 if user.father_id == None:
964 local_users[user.father_id].children.append(user)
966 return render_to_response('users_tree.html', {'root': root, 'auser': request.user.id}, RequestContext(request))
968 return render_to_response('users.html', {'users':users}, RequestContext(request))
970 phone_re = re.compile('^\\+.+')
972 class UserEditForm(forms.Form):
973 login = forms.RegexField(regex=r'^[a-zA-Z0-9_]+$', max_length=16,
974 error_message ='Login must only contain letters, numbers and underscores')
975 name = forms.CharField(max_length=50)
976 email = forms.EmailField()
977 phone = forms.RegexField(regex='\\+.+', max_length=20, required=False,
978 error_message ='Phones must start with a \'+\'')
979 def __init__(self, show_flag_showhidden, *args, **kargs):
980 forms.Form.__init__(self, *args, **kargs)
981 self.old_login = kargs['initial']['login']
982 if show_flag_showhidden:
983 self.fields['show_hidden_ships'] = forms.BooleanField(required=False)
985 def clean_login(self):
986 new_login = self.cleaned_data['login']
987 if new_login != self.old_login:
988 if User.objects.filter(login=new_login).count():
989 raise forms.ValidationError("Sorry that login is already in use. Try another one.")
990 if new_login == u'add':
991 raise forms.ValidationError("Sorry that login is reserved. Try another one.")
994 @http_authenticate(auth, 'ais')
995 def user_detail(request, login):
996 user = get_object_or_404(User, login=login)
997 user.admin_ok = user.is_admin_by(request.user.id)
998 return render_to_response('user_detail.html', {'auser': user}, RequestContext(request))
1000 @http_authenticate(auth, 'ais')
1001 def user_edit(request, login):
1004 user = get_object_or_404(User, login=login)
1005 if not user.is_admin_by(request.user.id):
1006 return HttpResponseForbidden('403 Forbidden')
1009 user.father_id = request.user.id;
1010 initial['login'] = user.login
1011 initial['name'] = user.name
1012 initial['email'] = user.email
1013 initial['phone'] = user.phone
1014 initial['show_hidden_ships'] = user.flag_allowhidden
1015 if request.method == 'POST':
1016 form = UserEditForm(request.user.flag_allowhidden, request.POST, initial=initial)
1018 user.login = form.cleaned_data['login']
1019 user.name = form.cleaned_data['name']
1020 user.email = form.cleaned_data['email']
1021 user.phone = form.cleaned_data['phone']
1022 if request.user.flag_allowhidden:
1023 user.flag_allowhidden = form.cleaned_data['show_hidden_ships']
1025 user.check_sandbox_access(request.user)
1026 return HttpResponseRedirect('/user/')
1028 form = UserEditForm(request.user.flag_allowhidden, initial=initial)
1030 return render_to_response('user_edit.html', {'form':form, 'auser': user}, RequestContext(request))
1033 class ChangePasswordForm(forms.Form):
1034 new_password = forms.CharField(max_length=16, widget=forms.PasswordInput())
1035 new_password_check = forms.CharField(max_length=16, widget=forms.PasswordInput())
1037 def clean_generic_password(self, field_name):
1038 password = self.cleaned_data[field_name]
1040 crack.FascistCheck(password)
1041 except ValueError, err:
1042 raise forms.ValidationError(err.message)
1045 def clean_new_password(self):
1046 return self.clean_generic_password('new_password')
1048 def clean_new_password_check(self):
1049 return self.clean_generic_password('new_password_check')
1052 cleaned_data = self.cleaned_data
1053 pass1 = cleaned_data.get('new_password')
1054 pass2 = cleaned_data.get('new_password_check')
1055 if pass1 != pass2 and pass2:
1056 self._errors['new_password_check'] = forms.util.ErrorList(['Passwords must match'])
1057 del cleaned_data['new_password_check'] # FIXME
1061 @http_authenticate(auth, 'ais')
1062 def user_change_password(request, login):
1063 user = get_object_or_404(User, login=login)
1064 if not user.is_admin_by(request.user.id):
1065 return HttpResponseForbidden('403 Forbidden')
1066 if request.method == 'POST':
1067 form = ChangePasswordForm(request.POST)
1069 user.set_password(form.cleaned_data['new_password'])
1071 return HttpResponseRedirect('/user/')
1073 form = ChangePasswordForm()
1074 return render_to_response('user_change_password.html', {'form':form, 'auser':user}, RequestContext(request))
1077 @http_authenticate(auth, 'ais')
1078 def user_delete(request, login):
1079 user = get_object_or_404(User, login=login)
1080 if not user.is_admin_by(request.user.id):
1081 return HttpResponseForbidden('403 Forbidden')
1082 if request.REQUEST.get('confirm', None):
1084 return HttpResponseRedirect('/user/')
1085 return render_to_response('user_delete.html', {'form':None, 'auser':user}, RequestContext(request))
1088 def logout(request):
1090 return HttpResponse('Not implemented')
1091 #response = render_to_response('logout.html', {}, RequestContext(request))
1096 'name_long': '2 hours',
1100 'name_long': '6 hours',
1105 'name_long': '2 days',
1106 'seconds': 2*24*60*60
1109 'name_long': '2 weeks',
1110 'seconds': 14*24*60*60
1113 'name_long': '3 monthes',
1114 'seconds': 90*24*60*60
1116 'name_tiny': '180d',
1117 'name_long': '6 monthes',
1118 'seconds': 180*24*60*60
1121 class StatsSelectorForm(forms.Form):
1122 peers = forms.ChoiceField(choices=[('', 'All')] + [(id4,source['name']) for id4,source in peers_get_config().iteritems()])
1123 types = forms.ChoiceField(choices=[('', 'All'), ('bytes', 'Bandwidth'), ('counts', "Packet'izer")], initial='counts')
1124 periods = forms.ChoiceField(choices=[(period['name_tiny'], period['name_long']) for period in periods] + [('', 'All')], initial='2d')
1126 @http_authenticate(auth, 'ais')
1127 def sources_index(request):
1129 peers_config = peers_get_config()
1131 for id4, peer in peers_config.iteritems():
1133 peer['id2'] = id4[2:]
1134 peer['active'] = is_id4_active(id4, 60*ACTIVE_MINUTES)
1135 peers_display.append(peer)
1137 peers_display = sorted(peers_display, key=lambda k: k['id4'])
1139 form = StatsSelectorForm()
1141 response = render_to_response('sources_index.html', {'sources':peers_display, 'active_minutes': ACTIVE_MINUTES, 'form': form}, RequestContext(request))
1142 response['Refresh'] = 60*ACTIVE_MINUTES
1146 @http_authenticate(auth, 'ais')
1147 def sources_stats(request):
1148 filter_peers = request.REQUEST.get('peers', None)
1150 filter_peers = filter_peers.split(u',')
1152 peers_config = peers_get_config()
1155 for id4, peer in peers_config.iteritems():
1157 if unicode(id4) not in filter_peers:
1160 peers_display.append(peer)
1162 peers_display = sorted(peers_display, key=lambda k: k['id4'])
1164 filter_types = request.REQUEST.get('types', None)
1166 filter_types = filter_types.split(u',')
1168 filter_types = [ 'bytes', 'counts' ]
1169 logging.error('filter_types=%s', filter_types)
1171 filter_periods = request.REQUEST.get('periods', None)
1173 display_periods = []
1174 for period_name in filter_periods.split(u','):
1175 for period in periods:
1176 if period['name_tiny'] == period_name:
1177 display_periods.append(period)
1179 display_periods = periods
1180 #logging.error('display_periods=%s', display_periods)
1183 now = int(get_timestamp())
1184 for config in peers_display:
1186 for period in periods:
1187 args = os.path.join(STATS_DIR, id4+'-'+period['name_tiny']+'-bytes.png'), \
1190 '--title', config['name'] + ' - Bandwidth usage - ' + period['name_long'], \
1191 '--start', '%d' % (now - period['seconds']), \
1192 '--end', '%d' % now, \
1193 '--vertical-label', 'bps', \
1194 'DEF:bytes=%s:bytes:AVERAGE' % os.path.join(STATS_DIR, id4+'.rrd'), \
1195 'DEF:rawbytes=%s:rawbytes:AVERAGE' % os.path.join(STATS_DIR, id4+'.rrd'), \
1196 'CDEF:bits=bytes,8,*', \
1197 'CDEF:rawbits=rawbytes,8,*', \
1198 'LINE:bits#00FF00:IP payload', \
1199 'LINE:rawbits#FF0000:IP with headers'
1200 rrdtool.graph(*args)
1201 args = os.path.join(STATS_DIR, id4+'-'+period['name_tiny']+'-counts.png'), \
1204 '--title', config['name'] + ' - Packet\'izer stats - ' + period['name_long'], \
1205 '--start', '%d' % (now-period['seconds']), \
1206 '--end', '%d' % now, \
1207 '--vertical-label', 'Hz', \
1208 'DEF:packets=%s:packets:AVERAGE' % os.path.join(STATS_DIR, id4+'.rrd'), \
1209 'DEF:lines=%s:lines:AVERAGE' % os.path.join(STATS_DIR, id4+'.rrd'), \
1210 'LINE:packets#FF0000:input packets', \
1211 'LINE:lines#00FF00:AIVDM lines'
1212 rrdtool.graph(*args)
1213 return render_to_response('sources.html', {'sources':peers_display, 'show_bytes': 'bytes' in filter_types, 'show_counts': 'counts' in filter_types, 'periods': display_periods}, RequestContext(request))
1216 @http_authenticate(auth, 'ais')
1217 def news(request, page):
1223 npages = int((News.objects.count() + NEWS_PER_PAGE - 1) // NEWS_PER_PAGE)
1224 news = News.objects.order_by('-created')[(page - 1) * NEWS_PER_PAGE : page * NEWS_PER_PAGE]
1225 return render_to_response('news.html', {'news':news, 'page': page, 'npages': npages}, RequestContext(request))
1227 @http_authenticate(auth, 'ais')
1228 def news_atom(request):
1229 from django.db import connection
1231 news = News.objects.order_by('-created')
1233 cursor = connection.cursor()
1234 cursor.execute("SELECT MAX(updated) FROM news")
1235 row = cursor.fetchone()
1236 last_update = row[0]
1238 return render_to_response('news.atom', {'news':news, 'last_update':last_update}, RequestContext(request), mimetype='application/atom+xml')