diff --git a/cloud/endagaweb/forms/dashboard_forms.py b/cloud/endagaweb/forms/dashboard_forms.py index 2f9a6ddc..f4fceea5 100644 --- a/cloud/endagaweb/forms/dashboard_forms.py +++ b/cloud/endagaweb/forms/dashboard_forms.py @@ -10,15 +10,16 @@ import datetime +import pytz +from crispy_forms.bootstrap import StrictButton, FieldWithButtons +from crispy_forms.helper import FormHelper +from crispy_forms.layout import Layout, Submit, Field from django import forms +from django.contrib.auth.forms import PasswordChangeForm, PasswordResetForm +from django.contrib.auth.models import User +from django.core import urlresolvers from django.db.models import Value from django.db.models.functions import Coalesce -from django.core import urlresolvers -from crispy_forms.helper import FormHelper -from crispy_forms.layout import Layout, Submit, Field -from crispy_forms.bootstrap import StrictButton, FieldWithButtons -from django.contrib.auth.forms import PasswordChangeForm -import pytz from ccm.common.currency import CURRENCIES from endagaweb import models @@ -190,7 +191,7 @@ def __init__(self, *args, **kwargs): self.helper.form_class = 'profile-form' update_button = StrictButton('Update', css_class='btn-default', type='submit') - self.helper.layout = Layout(FieldWithButtons('notify_numbers', update_button)) + self.helper.layout = Layout(FieldWithButtons('notify_numbers', update_button)) class SubVacuumForm(forms.Form): @@ -368,3 +369,30 @@ def __init__(self, *args, **kwargs): self.helper.form_action = '/dashboard/staff/tower-monitoring' self.helper.add_input(Submit('submit', 'Select')) self.helper.layout = Layout('tower') + + +class UserSearchForm(forms.Form): + """Crispy search form on /dashboard/subscribers.""" + query = forms.CharField(required=False, label="Search Username") + + def __init__(self, sender, *args, **kwargs): + self.helper = FormHelper() + self.helper.form_id = 'id-SearchForm' + self.helper.form_method = 'get' + if 'blocking' is sender: + self.helper.form_action = '/dashboard/user/management/blocking' + else: + self.helper.form_action = '/dashboard/user/management/delete' + # self.helper.form_class = 'form-vertical' + search_button = StrictButton('Find', css_class='btn-default', + type='submit') + self.helper.layout = Layout(FieldWithButtons('query', search_button)) + super(UserSearchForm, self).__init__(*args, **kwargs) + + + +class PasswordResetRequestForm(PasswordResetForm): + email = forms.CharField(label=("Email"), max_length=254) + class Meta: + model = User + fields = ("email") diff --git a/cloud/endagaweb/models.py b/cloud/endagaweb/models.py index d2429f9d..5f19c557 100644 --- a/cloud/endagaweb/models.py +++ b/cloud/endagaweb/models.py @@ -15,6 +15,7 @@ import calendar import datetime +import decimal import json import logging import time @@ -35,6 +36,7 @@ import django.utils.timezone import itsdangerous import pytz +import requests import stripe from ccm.common import crdt, logger @@ -43,10 +45,11 @@ from endagaweb.celery import app as celery_app from endagaweb.notifications import bts_up from endagaweb.util import currency as util_currency +from endagaweb.util.parse_destination import parse_destination from endagaweb.util import dbutils as dbutils -stripe.api_key = settings.STRIPE_API_KEY +stripe.api_key = settings.STRIPE_API_KEY # These UsageEvent kinds do not count towards subscriber activity. NON_ACTIVITIES = ( @@ -71,13 +74,14 @@ class UserProfile(models.Model): timezone_choices = [(v, v) for v in pytz.common_timezones] timezone = models.CharField(max_length=50, default='UTC', choices=timezone_choices) - + role = models.CharField(max_length=20, default='cloud_admin') # A UI kludge indicate which network a user is currently viewing # Important: This is not the only network a User is associated with # because a user may have permissions on other Network instances. # For example to get a list of networks the user can view: # >>> get_objects_for_user(user_profile.user, 'view_network', klass=Network) - network = models.ForeignKey('Network', null=True, on_delete=models.SET_NULL) + network = models.ForeignKey('Network', null=True, + on_delete=models.SET_NULL) def __str__(self): return "%s's profile" % self.user @@ -93,7 +97,7 @@ def alerts(self): TODO(matt): implement """ - #return [{'link': "#", 'title': "lookout!", 'label': "Danger"}] + # return [{'link': "#", 'title': "lookout!", 'label': "Danger"}] @staticmethod def new_user_hook(sender, instance, created, **kwargs): @@ -103,15 +107,20 @@ def new_user_hook(sender, instance, created, **kwargs): """ if created and instance.username != settings.ANONYMOUS_USER_NAME: profile = UserProfile.objects.create(user=instance) - network = Network.objects.create() + + # Add explicit name to avoid duplicate names when + # running setup_test_db + network = Network.objects.create(name='Network_%s' % (instance.pk,)) network.auth_group.user_set.add(instance) network.save() # Make this the users currently selected network profile.network = network profile.save() + post_save.connect(UserProfile.new_user_hook, sender=User) + class Ledger(models.Model): """A ledger represents a list of transactions and a balance. @@ -164,6 +173,7 @@ def transaction_save_handler(sender, instance, created, **kwargs): ledger.balance = F('balance') + instance.amount ledger.save() + class Transaction(models.Model): """ The transaction object represents a single line item in an account ledger. It needs to be applied to a ledger for it to take affect. In @@ -198,7 +208,6 @@ class Transaction(models.Model): ('local_sms', 'local_sms'), ('local_call', 'local_call'), ('local_recv_call', 'local_recv_call'), - ('local_recv_sms', 'local_recv_sms'), ('number.nexmo.monthly', 'number.nexmo.monthly'), ) kind = models.CharField(max_length=100, choices=transaction_kinds) @@ -216,7 +225,7 @@ def pretty_amount(self): def new(cls, kind, **kwargs): """ Create a new Transaction, save it. """ if kind not in [k for k, _ in cls.transaction_kinds]: - raise ValueError("invalid transaction kind: '%s'" % (kind, )) + raise ValueError("invalid transaction kind: '%s'" % (kind,)) return Transaction(kind=kind, **kwargs) @@ -268,41 +277,50 @@ class BTS(models.Model): package_versions = models.TextField(null=True) # Towers report their uptime in seconds during checkins. uptime = models.IntegerField(null=True) - #location of the tower, default is campanile - #can't use point object for some reason + # location of the tower, default is campanile + # can't use point object for some reason location = geomodels.GeometryField(geography=True, default='POINT(-122.260931 37.871783)') - #power level of the tower + # power level of the tower power_level = models.IntegerField(default=100) - #band used - eventually can add more - #authoritative place for range as well - #name, dbname, acceptable ranges - #maybe should be in config somewhere - #null means no band set - #only odd for GSM as bands overlap + # band used - eventually can add more + # authoritative place for range as well + # name, dbname, acceptable ranges + # maybe should be in config somewhere + # null means no band set + # only odd for GSM as bands overlap bands = { - 'GSM850' : {'choices' : ('GSM850', 'GSM850'), - "valid_values" : set(range(128,252,2))}, - 'GSM900' : {'choices' : ('GSM900', 'GSM900'), - "valid_values" : set(range(0,125,1))}, - 'GSM1800' : {'choices' : ('GSM1800', 'GSM1800'), - "valid_values" : set(range(512,886,2))}, - 'GSM1900' : {'choices' : ('GSM1900', 'GSM1900'), - "valid_values" : set(range(512,811,2))} + 'GSM850': {'choices': ('GSM850', 'GSM850'), + "valid_values": set(range(128, 252, 2))}, + 'GSM900': {'choices': ('GSM900', 'GSM900'), + "valid_values": set(range(0, 125, 1))}, + 'GSM1800': {'choices': ('GSM1800', 'GSM1800'), + "valid_values": set(range(512, 886, 2))}, + 'GSM1900': {'choices': ('GSM1900', 'GSM1900'), + "valid_values": set(range(512, 811, 2))} } band = models.CharField( max_length=20, choices=[bands[i]['choices'] for i in bands.keys()], null=True) - #channel number used - #none is unknown or invalid + # channel number used + # none is unknown or invalid channel = models.IntegerField(null=True, blank=True) + class Meta: + default_permissions = () + permissions = ( + ('view_bts', 'View BTS(Tower)'), + ('add_bts', 'Add BTS(Tower)'), + ('change_bts', 'Change BTS(Tower)'), + ('deregister_bts', 'Deregister BTS(Tower)') + ) + def __unicode__(self): return "BTS(%s, %s, last active: %s)" % ( self.uuid, self.inbound_url, self.last_active) - #custom validations - #this is run after every time an object is updated - #authoritatively enforcing the DB values + # custom validations + # this is run after every time an object is updated + # authoritatively enforcing the DB values def clean(self): super(BTS, self).clean() if (self.band is None and self.channel is None): # valid bad state @@ -319,13 +337,13 @@ def valid_band(self, band): return band in BTS.bands def valid_band_and_channel(self, band, channel): - #null means channel is not set + # null means channel is not set return (self.valid_band(band) and (channel in BTS.bands[band]['valid_values'])) - #use this to set band/channel as to never set to invalid + # use this to set band/channel as to never set to invalid def update_band_and_channel(self, band=None, channel=None): - #can't use self.band as the default argument + # can't use self.band as the default argument if not band: band = self.band if not channel: @@ -373,8 +391,8 @@ def mark_active(self): self.status = 'active' self.save() up_event = SystemEvent( - date=django.utils.timezone.now(), bts=self, - type='bts up') + date=django.utils.timezone.now(), bts=self, + type='bts up') up_event.save() def last_active_time(self): @@ -444,10 +462,11 @@ def set_default_versions(sender, instance=None, created=False, **kwargs): post_save.connect(BTS.set_default_versions, sender=BTS) - """ Base class for a thing that issues recurring charges, like a number. """ + + class ChargingEntity(models.Model): created = models.DateTimeField(auto_now_add=True) last_charged = models.DateTimeField(null=True, blank=True) @@ -460,6 +479,7 @@ class ChargingEntity(models.Model): Return a new datetime incremented by the specified number of units, one of "day", "month", or "year". """ + def add_time(self, sourcedate, num, unit): if unit == "month": month = sourcedate.month - 1 + num @@ -473,12 +493,13 @@ def add_time(self, sourcedate, num, unit): elif unit == "day": return sourcedate + datetime.timedelta(days=num) elif unit == "year": - return sourcedate + datetime.timedelta(days=num*365) + return sourcedate + datetime.timedelta(days=num * 365) """ Charge for this recurring entity. This can be called any time, and will only generate a new charge if the entity has expired. """ + def charge(self, curr_date=None, reason="recharge"): if curr_date is None: curr_date = django.utils.timezone.now() @@ -496,6 +517,7 @@ def charge(self, curr_date=None, reason="recharge"): Sets everything back to null or their default value. """ + def reset(self): self.last_charged = None self.valid_through = None @@ -525,6 +547,15 @@ class Subscriber(models.Model): # When toggled, this will protect a subsriber from getting "vacuumed." You # can still delete subs with the usual "deactivate" button. prevent_automatic_deactivation = models.BooleanField(default=False) + role = models.TextField(null=True, blank=True, default="Subscriber") + + class Meta: + default_permissions = () + permissions = ( + ('view_subscriber', 'View subscriber list'), + ('change_subscriber', 'Edit subscriber'), + ('deactive_subscriber', 'Deactive subscriber'), + ) @classmethod def update_balance(cls, imsi, other_bal): @@ -551,7 +582,7 @@ def balance(self, amt): try: bal = crdt.PNCounter.from_json(self.crdt_balance) except ValueError: - logging.error("Balance string: %s" % (self.crdt_balance, )) + logging.error("Balance string: %s" % (self.crdt_balance,)) raise if (bal.is_used()): @@ -566,7 +597,7 @@ def change_balance(self, amt): try: bal = crdt.PNCounter.from_json(self.crdt_balance) except ValueError: - logging.error("Balance string: %s" % (self.crdt_balance, )) + logging.error("Balance string: %s" % (self.crdt_balance,)) raise if amt > 0: @@ -671,7 +702,7 @@ def is_camped(self): # TODO(omar): this is incomplete status information. We should also # include IMSI detach events. Issue #20 on openbts. if self.last_camped is None: - return False + return False t3212_secs = int(ConfigurationKey.objects.get( network=self.network, key="GSM.Timer.T3212").value) * 60 last_camped_secs = (django.utils.timezone.now() - self.last_camped) \ @@ -792,6 +823,13 @@ class UsageEvent(models.Model): timespan = models.DecimalField(null=True, max_digits=7, decimal_places=1) date_synced = models.DateTimeField(auto_now_add=True) + class Meta: + default_permissions = () + permissions = ( + ('view_usage', 'View usage activities'), + ('download_usage', 'Download usage activities') + ) + def voice_sec(self): """Gets the number of seconds for this call. @@ -948,11 +986,11 @@ class Network(models.Model): # The user group associated with the network auth_group = models.OneToOneField(Group, null=True, blank=True, - on_delete=models.CASCADE) + on_delete=models.CASCADE) # Each network is associated with an auth user that the BTS will use # to authenticate on API calls auth_user = models.OneToOneField(User, null=True, blank=True, - on_delete=models.CASCADE) + on_delete=models.CASCADE) # Each network is associated with a ledger and its own billing account stripe_cust_token = models.CharField(max_length=1024, blank=True, default="") @@ -980,8 +1018,10 @@ class Network(models.Model): environment = models.TextField(default="default") class Meta: + default_permissions = () permissions = ( ('view_network', 'View network'), + ('change_network', 'Change network'), ) @property @@ -1087,7 +1127,7 @@ def recharge_if_necessary(self): return False except stripe.StripeError: # TODO(matt): alert the staff. - logger.error('Recharge failed for %s' % (self, )) + logger.error('Recharge failed for %s' % (self,)) return False def update_card(self, token): @@ -1181,7 +1221,6 @@ def delete_card(self): self.save() return True - def calculate_operator_cost(self, directionality, sms_or_call, destination_number=''): """Calculates the cost to an operator of a call or SMS. @@ -1432,14 +1471,14 @@ def create_auth(sender, instance, created, **kwargs): authenticate. """ if not instance.auth_group or not instance.auth_user: - instance.auth_group, created_group = Group.objects.get_or_create(name='network_%s' - % instance.pk) + instance.auth_group, created_group = Group.objects.get_or_create(name='%s_GROUP_%s' % + (instance.name, instance.pk)) if created_group: assign_perm('view_network', instance.auth_group, instance) post_save.disconnect(UserProfile.new_user_hook, sender=User) - instance.auth_user, created_user = User.objects.get_or_create(username='network_%s' - % instance.pk) + instance.auth_user, created_user = User.objects.get_or_create(username='%s_USER_%s' % + (instance.name, instance.pk)) if created_user: Token.objects.create(user=instance.auth_user) instance.auth_group.user_set.add(instance.auth_user) @@ -1451,6 +1490,7 @@ def create_ledger(sender, instance, created, **kwargs): if not Ledger.objects.filter(network=instance).exists(): Ledger.objects.create(network=instance) + # Whenever we update the Ledger, attempt to recharge the Network bill. post_save.connect(Network.ledger_save_handler, sender=Ledger) @@ -1542,7 +1582,7 @@ class Destination(models.Model): country_code = models.TextField() country_name = models.TextField() destination_group = models.ForeignKey('DestinationGroup', null=True, - on_delete=models.CASCADE) + on_delete=models.CASCADE) prefix = models.TextField() def __unicode__(self): @@ -1718,6 +1758,7 @@ class TimeseriesStat(models.Model): bts = models.ForeignKey(BTS, null=True, blank=True, on_delete=models.CASCADE) network = models.ForeignKey('Network', on_delete=models.CASCADE) + class BTSLogfile(models.Model): """This model stores log file uploads that have come from client. Until we get S3 or something similar setup, we are storing file data @@ -1728,23 +1769,23 @@ class BTSLogfile(models.Model): requested = models.DateTimeField(auto_now_add=True) logfile = models.FileField(upload_to='logfiles/', null=True, blank=True) log_name = models.CharField(max_length=60, - choices=[('syslog', 'Syslog'), ('endaga', 'Endaga')]) + choices=[('syslog', 'Syslog'), ('endaga', 'Endaga')]) task_id = models.CharField(max_length=50, null=True, blank=True) status = models.CharField(max_length=10, default='pending', - choices=[('pending', 'Pending'), ('trying', 'Trying'), - ('error', 'Error'), ('accepted', 'Accepted'), ('done', 'Done')]) + choices=[('pending', 'Pending'), ('trying', 'Trying'), + ('error', 'Error'), ('accepted', 'Accepted'), ('done', 'Done')]) window_start = models.DateTimeField(blank=True, null=True, - help_text='Gather log entries after this time') + help_text='Gather log entries after this time') window_end = models.DateTimeField(blank=True, null=True, - help_text='Gather log entries before this time') + help_text='Gather log entries before this time') bts = models.ForeignKey(BTS, on_delete=models.CASCADE) def req_params(self): return { - 'start': self.window_start.isoformat('T') if self.window_start else 'None', - 'end': self.window_end.isoformat('T') if self.window_end else 'None', - 'log_name': self.log_name, - 'msgid': str(self.uuid) + 'start': self.window_start.isoformat('T') if self.window_start else 'None', + 'end': self.window_end.isoformat('T') if self.window_end else 'None', + 'log_name': self.log_name, + 'msgid': str(self.uuid) } def save(self, *args, **kwargs): @@ -1752,7 +1793,7 @@ def save(self, *args, **kwargs): if not self.pk: super(BTSLogfile, self).save(*args, **kwargs) task = celery_app.send_task('endagaweb.tasks.req_bts_log', - (self,)) + (self,)) self.task_id = task.id super(BTSLogfile, self).save(*args, **kwargs) @@ -1762,6 +1803,7 @@ def delete(self, *args, **kwargs): if self.logfile: self.logfile.delete() + class FileUpload(models.Model): name = models.CharField(max_length=255, primary_key=True) data = models.BinaryField(default='') # a base64 encoded TextField @@ -1769,3 +1811,62 @@ class FileUpload(models.Model): created_time = models.DateTimeField(auto_now_add=True) modified_time = models.DateTimeField(auto_now_add=True) accessed_time = models.DateTimeField(auto_now=True) + + +class SMSBroadcast(models.Model): + """ Global permission set for SMS Broadcasting module in network section""" + + class Meta: + managed = False # No database table creation or deletion operations \ + # will be performed for this model. + default_permissions = () + permissions = ( + ('add_sms', 'Add SMS broadcast'), + ('send_sms', 'Send SMS broadcast from subscriber'), + ) + + +class Credit(models.Model): + """ Global permission set for Credit Adjustment module in subscribers""" + + class Meta: + managed = False + default_permissions = () + permissions = ( + ('add_credit', 'Add credit adjustment to subscriber'), + ) + + +class Notification(models.Model): + """ Global permission set for Credit Adjustment module in subscribers""" + + class Meta: + managed = False + default_permissions = () + permissions = ( + ('view_notification', 'View Notification'), + ) + + +class Report(models.Model): + """ Global permission set for Report module""" + + class Meta: + managed = False + default_permissions = () + permissions = ( + ('view_report', 'View reports'), + ('download_report', 'Download reports') + ) + + +class Graph(models.Model): + """ Global permission set for Report module""" + + class Meta: + managed = False + default_permissions = () + permissions = ( + ('view_graph', 'View graph'), + ('download_graph', 'Download graph') + ) diff --git a/cloud/endagaweb/settings/prod.py b/cloud/endagaweb/settings/prod.py index 653f2f0e..682ff121 100644 --- a/cloud/endagaweb/settings/prod.py +++ b/cloud/endagaweb/settings/prod.py @@ -293,6 +293,14 @@ } } +# Email settings for sending reset mail +# EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend' +# EMAIL_HOST = 'smtp.gmail.com' +# EMAIL_USE_TLS = True +# EMAIL_PORT = 587 +# EMAIL_HOST_USER = 'abc@gmail.com' +# EMAIL_HOST_PASSWORD = 'password' + EMAIL_BACKEND = 'django_mailgun.MailgunBackend' MAILGUN_ACCESS_KEY = os.environ.get("MAILGUN_ACCESS_KEY", 'key-testkeypleaseignore') MAILGUN_SERVER_NAME = os.environ.get("MAILGUN_SERVER_NAME", '') diff --git a/cloud/endagaweb/static/js/dashboard/validator.js b/cloud/endagaweb/static/js/dashboard/validator.js new file mode 100644 index 00000000..6311a22e --- /dev/null +++ b/cloud/endagaweb/static/js/dashboard/validator.js @@ -0,0 +1,414 @@ +/* ======================================================================== + * Bootstrap (plugin): validator.js v0.11.9 + * ======================================================================== + * The MIT License (MIT) + * + * Copyright (c) 2016 Cina Saffary. + * Made by @1000hz in the style of Bootstrap 3 era @fat + * + * Permission is hereby granted, free of charge, to any person obtaining a copy + * of this software and associated documentation files (the "Software"), to deal + * in the Software without restriction, including without limitation the rights + * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell + * copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN + * THE SOFTWARE. + * ======================================================================== */ + + ++function ($) { + 'use strict'; + + // VALIDATOR CLASS DEFINITION + // ========================== + + function getValue($el) { + return $el.is('[type="checkbox"]') ? $el.prop('checked') : + $el.is('[type="radio"]') ? !!$('[name="' + $el.attr('name') + '"]:checked').length : + $el.is('select[multiple]') ? ($el.val() || []).length : + $el.val() + } + + var Validator = function (element, options) { + this.options = options + this.validators = $.extend({}, Validator.VALIDATORS, options.custom) + this.$element = $(element) + this.$btn = $('button[type="submit"], input[type="submit"]') + .filter('[form="' + this.$element.attr('id') + '"]') + .add(this.$element.find('input[type="submit"], button[type="submit"]')) + + this.update() + + this.$element.on('input.bs.validator change.bs.validator focusout.bs.validator', $.proxy(this.onInput, this)) + this.$element.on('submit.bs.validator', $.proxy(this.onSubmit, this)) + this.$element.on('reset.bs.validator', $.proxy(this.reset, this)) + + this.$element.find('[data-match]').each(function () { + var $this = $(this) + var target = $this.attr('data-match') + + $(target).on('input.bs.validator', function (e) { + getValue($this) && $this.trigger('input.bs.validator') + }) + }) + + // run validators for fields with values, but don't clobber server-side errors + this.$inputs.filter(function () { + return getValue($(this)) && !$(this).closest('.has-error').length + }).trigger('focusout') + + this.$element.attr('novalidate', true) // disable automatic native validation + } + + Validator.VERSION = '0.11.9' + + Validator.INPUT_SELECTOR = ':input:not([type="hidden"], [type="submit"], [type="reset"], button)' + + Validator.FOCUS_OFFSET = 20 + + Validator.DEFAULTS = { + delay: 500, + html: false, + disable: true, + focus: true, + custom: {}, + errors: { + match: 'Does not match', + minlength: 'Not long enough' + }, + feedback: { + success: 'glyphicon-ok', + error: 'glyphicon-remove' + } + } + + Validator.VALIDATORS = { + 'native': function ($el) { + var el = $el[0] + if (el.checkValidity) { + return !el.checkValidity() && !el.validity.valid && (el.validationMessage || "error!") + } + }, + 'match': function ($el) { + var target = $el.attr('data-match') + return $el.val() !== $(target).val() && Validator.DEFAULTS.errors.match + }, + 'minlength': function ($el) { + var minlength = $el.attr('data-minlength') + return $el.val().length < minlength && Validator.DEFAULTS.errors.minlength + } + } + + Validator.prototype.update = function () { + var self = this + + this.$inputs = this.$element.find(Validator.INPUT_SELECTOR) + .add(this.$element.find('[data-validate="true"]')) + .not(this.$element.find('[data-validate="false"]') + .each(function () { self.clearErrors($(this)) }) + ) + + this.toggleSubmit() + + return this + } + + Validator.prototype.onInput = function (e) { + var self = this + var $el = $(e.target) + var deferErrors = e.type !== 'focusout' + + if (!this.$inputs.is($el)) return + + this.validateInput($el, deferErrors).done(function () { + self.toggleSubmit() + }) + } + + Validator.prototype.validateInput = function ($el, deferErrors) { + var value = getValue($el) + var prevErrors = $el.data('bs.validator.errors') + + if ($el.is('[type="radio"]')) $el = this.$element.find('input[name="' + $el.attr('name') + '"]') + + var e = $.Event('validate.bs.validator', {relatedTarget: $el[0]}) + this.$element.trigger(e) + if (e.isDefaultPrevented()) return + + var self = this + + return this.runValidators($el).done(function (errors) { + $el.data('bs.validator.errors', errors) + + errors.length + ? deferErrors ? self.defer($el, self.showErrors) : self.showErrors($el) + : self.clearErrors($el) + + if (!prevErrors || errors.toString() !== prevErrors.toString()) { + e = errors.length + ? $.Event('invalid.bs.validator', {relatedTarget: $el[0], detail: errors}) + : $.Event('valid.bs.validator', {relatedTarget: $el[0], detail: prevErrors}) + + self.$element.trigger(e) + } + + self.toggleSubmit() + + self.$element.trigger($.Event('validated.bs.validator', {relatedTarget: $el[0]})) + }) + } + + + Validator.prototype.runValidators = function ($el) { + var errors = [] + var deferred = $.Deferred() + + $el.data('bs.validator.deferred') && $el.data('bs.validator.deferred').reject() + $el.data('bs.validator.deferred', deferred) + + function getValidatorSpecificError(key) { + return $el.attr('data-' + key + '-error') + } + + function getValidityStateError() { + var validity = $el[0].validity + return validity.typeMismatch ? $el.attr('data-type-error') + : validity.patternMismatch ? $el.attr('data-pattern-error') + : validity.stepMismatch ? $el.attr('data-step-error') + : validity.rangeOverflow ? $el.attr('data-max-error') + : validity.rangeUnderflow ? $el.attr('data-min-error') + : validity.valueMissing ? $el.attr('data-required-error') + : null + } + + function getGenericError() { + return $el.attr('data-error') + } + + function getErrorMessage(key) { + return getValidatorSpecificError(key) + || getValidityStateError() + || getGenericError() + } + + $.each(this.validators, $.proxy(function (key, validator) { + var error = null + if ((getValue($el) || $el.attr('required')) && + ($el.attr('data-' + key) !== undefined || key == 'native') && + (error = validator.call(this, $el))) { + error = getErrorMessage(key) || error + !~errors.indexOf(error) && errors.push(error) + } + }, this)) + + if (!errors.length && getValue($el) && $el.attr('data-remote')) { + this.defer($el, function () { + var data = {} + data[$el.attr('name')] = getValue($el) + $.get($el.attr('data-remote'), data) + .fail(function (jqXHR, textStatus, error) { errors.push(getErrorMessage('remote') || error) }) + .always(function () { deferred.resolve(errors)}) + }) + } else deferred.resolve(errors) + + return deferred.promise() + } + + Validator.prototype.validate = function () { + var self = this + + $.when(this.$inputs.map(function (el) { + return self.validateInput($(this), false) + })).then(function () { + self.toggleSubmit() + self.focusError() + }) + + return this + } + + Validator.prototype.focusError = function () { + if (!this.options.focus) return + + var $input = this.$element.find(".has-error :input:first") + if ($input.length === 0) return + + $('html, body').animate({scrollTop: $input.offset().top - Validator.FOCUS_OFFSET}, 250) + $input.focus() + } + + Validator.prototype.showErrors = function ($el) { + var method = this.options.html ? 'html' : 'text' + var errors = $el.data('bs.validator.errors') + var $group = $el.closest('.form-group') + var $block = $group.find('.help-block.with-errors') + var $feedback = $group.find('.form-control-feedback') + + if (!errors.length) return + + errors = $('