Compare commits
	
		
			No commits in common. "e2df92e6b411f00183a8e689ce3f56bd93a7a538" and "aaadff6306dc47f382a8b97a2611d2c67c4b5231" have entirely different histories.
		
	
	
		
			e2df92e6b4
			...
			aaadff6306
		
	
		
							
								
								
									
										4
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										4
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							@ -213,7 +213,3 @@ flycheck_*.el
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
/__simulate_fail.json
 | 
					/__simulate_fail.json
 | 
				
			||||||
/mailing_list.yaml
 | 
					/mailing_list.yaml
 | 
				
			||||||
 | 
					 | 
				
			||||||
.vscode/
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
*.code-workspace
 | 
					 | 
				
			||||||
 | 
				
			|||||||
							
								
								
									
										34
									
								
								README.md
									
									
									
									
									
								
							
							
						
						
									
										34
									
								
								README.md
									
									
									
									
									
								
							@ -3,7 +3,7 @@
 | 
				
			|||||||
version: 0.2
 | 
					version: 0.2
 | 
				
			||||||
 | 
					
 | 
				
			||||||
survBot is a small program used to track station quality channels of DSEBRA stations via PowBox output over SOH channels
 | 
					survBot is a small program used to track station quality channels of DSEBRA stations via PowBox output over SOH channels
 | 
				
			||||||
 by analyzing contents of a Seiscomp data archive.
 | 
					 by analysing contents of a Seiscomp3 datapath.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
## Requirements
 | 
					## Requirements
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -60,33 +60,33 @@ The directory `/path/to/conf-dir` should contain the `parameters.yaml` file, and
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
The e-mail server settings can be configured in the `parameters.yaml` file. The following settings are available:
 | 
					The e-mail server settings can be configured in the `parameters.yaml` file. The following settings are available:
 | 
				
			||||||
 | 
					
 | 
				
			||||||
* `mailserver`: the address of the mail server
 | 
					- `mailserver`: the address of the mail server
 | 
				
			||||||
* `auth_type`: the authentication type for the mail server (`None`, `SSL`, `TLS`)
 | 
					- `auth_type`: the authentication type for the mail server (`None`, `SSL`, `TLS`)
 | 
				
			||||||
* `port`: the port of the mail server
 | 
					- `port`: the port of the mail server
 | 
				
			||||||
* `user`: the username for the mail server (if required)
 | 
					- `user`: the username for the mail server (if required)
 | 
				
			||||||
* `password`: the password for the mail server (if required)
 | 
					- `password`: the password for the mail server (if required)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
The `user` and `password` fields are optional, and can be left empty if the mail server does not require authentication. The `auth_type` field can be set to `None` if no authentication is required, `SSL` if the mail server requires SSL authentication, or `TLS` if the mail server requires TLS authentication. If the `user` or `password` fields are set to `Docker` ore `ENV` the program will try to read the values from the docker secrets `mail_user` and `mail_password` or environment variables `MAIL_USER` and `MAIL_PASSWORD` respectively. Docker secrets are only available in Docker Swarm mode, i.e. if the program is run as a service.
 | 
					The `user` and `password` fields are optional, and can be left empty if the mail server does not require authentication. The `auth_type` field can be set to `None` if no authentication is required, `SSL` if the mail server requires SSL authentication, or `TLS` if the mail server requires TLS authentication. If the `user` or `password` fileds are set to `Docker` ore `ENV` the program will try to read the values from the docker secrets `mail_user` and `mail_password` or environment variables `MAIL_USER` and `MAIL_PASSWORD` respectively. Docker secrets are only available in Docker Swarm mode, i.e. if the program is run as a service.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
## Version Changes
 | 
					## Version Changes
 | 
				
			||||||
 | 
					
 | 
				
			||||||
### 0.2
 | 
					### 0.2
 | 
				
			||||||
 | 
					
 | 
				
			||||||
* surveillance of mass, clock and gaps
 | 
					- surveillance of mass, clock and gaps
 | 
				
			||||||
* individual mailing lists for different stations
 | 
					- individual mailing lists for different stations
 | 
				
			||||||
* html mail with recent status information
 | 
					- html mail with recent status information
 | 
				
			||||||
* updated web page design
 | 
					- updated web page design
 | 
				
			||||||
* restructured parameter file
 | 
					- restructured parameter file
 | 
				
			||||||
* recognize if PBox is disconnected
 | 
					- recognize if PBox is disconnected
 | 
				
			||||||
 | 
					
 | 
				
			||||||
### 0.2-docker
 | 
					### 0.2-docker
 | 
				
			||||||
 | 
					
 | 
				
			||||||
* added Dockerfile for easy deployment
 | 
					- added Dockerfile for easy deployment
 | 
				
			||||||
* added more settings for connection to a mail server
 | 
					- added more settings for connection to a mail server
 | 
				
			||||||
 | 
					
 | 
				
			||||||
## Staff
 | 
					## Staff
 | 
				
			||||||
 | 
					
 | 
				
			||||||
Original author: M.Paffrath (<marcel.paffrath@rub.de>)
 | 
					Original author: M.Paffrath (marcel.paffrath@rub.de)
 | 
				
			||||||
Contributions: Kasper D. Fischer (<kasper.fischer@rub.de>)
 | 
					Contributions by: Kasper D. Fischer (kasper.fischer@rub.de)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
Jan 2025
 | 
					Jan 2025
 | 
				
			||||||
 | 
				
			|||||||
@ -13,7 +13,7 @@ logging_level: WARN        # set logging level (info, warning, debug)
 | 
				
			|||||||
track_changes: True        # tracks all changes since GUI startup by text highlighting (GUI only)
 | 
					track_changes: True        # tracks all changes since GUI startup by text highlighting (GUI only)
 | 
				
			||||||
warn_count: False          # show number of warnings and errors in table
 | 
					warn_count: False          # show number of warnings and errors in table
 | 
				
			||||||
min_sample: 5              # minimum samples for raising Warn/FAIL
 | 
					min_sample: 5              # minimum samples for raising Warn/FAIL
 | 
				
			||||||
dt_thresh: [300, 1800]     # threshold (s) for timing delay colourisation (yellow/red)
 | 
					dt_thresh: [300, 1800]     # threshold (s) for timing delay colorization (yellow/red)
 | 
				
			||||||
html_figures: True         # Create html figure directory and links
 | 
					html_figures: True         # Create html figure directory and links
 | 
				
			||||||
reread_parameters: True    # reread parameters file (change parameters on runtime, not for itself/GUI refresh/datapath)
 | 
					reread_parameters: True    # reread parameters file (change parameters on runtime, not for itself/GUI refresh/datapath)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -117,11 +117,6 @@ data_channels: ["HHZ", "HHN", "HHE"]
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
# ---------------------------------------- OPTIONAL PARAMETERS ---------------------------------------------------------
 | 
					# ---------------------------------------- OPTIONAL PARAMETERS ---------------------------------------------------------
 | 
				
			||||||
# deactivate powbox surveillance for stations (e.g. for solar powered), key: station, value: status message (abbr.)
 | 
					 | 
				
			||||||
no_pbox_stations: {'GR33': 'SOL', 'GR27B': 'DCN', 'RP01': 'noPBox', 'RP02': 'noPBox', 'RP03': 'noPBox', 'RP04': 'noPBox', 'RP05B': 'noPBox', 'RP06': 'noPBox', 'RP07': 'noPBox', 'RP08': 'noPBox'}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
# deactivate mass position surveillance for stations without connected mass channels (e.g. STS-2 instruments), key: station, value: status message (abbr.)
 | 
					 | 
				
			||||||
no_mass_stations: {'BIA': 'DCN', 'KNEZ': 'DCN', 'KRUS': 'DCN', 'OHR': 'DCN', 'OTOV': 'DCN', 'SKO': 'DCN', 'STIP': 'DCN', 'VAY': 'DCN', 'ZUPA': 'DCN'}
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
# add links to html table with specified key as column and value as relative link, interpretable string parameters:
 | 
					# add links to html table with specified key as column and value as relative link, interpretable string parameters:
 | 
				
			||||||
# nw (e.g. 1Y), st (e.g. GR01A), nwst_id (e.g. 1Y.GR01A)
 | 
					# nw (e.g. 1Y), st (e.g. GR01A), nwst_id (e.g. 1Y.GR01A)
 | 
				
			||||||
@ -135,7 +130,7 @@ add_links:
 | 
				
			|||||||
add_global_links:
 | 
					add_global_links:
 | 
				
			||||||
  # for example: - {"text": "our homepage", "URL": "https://www.rub.de"}
 | 
					  # for example: - {"text": "our homepage", "URL": "https://www.rub.de"}
 | 
				
			||||||
  - {"text": "show recent events on map",
 | 
					  - {"text": "show recent events on map",
 | 
				
			||||||
     "URL": "https://fdsnws.geophysik.ruhr-uni-bochum.de/map/?lat=39.5&lon=21&zoom=7&baselayer=osm"}
 | 
					     "URL": "https://fdsnws.geophysik.ruhr-uni-bochum.de/map/?lat=39.5&lon=21&zoom=7&baselayer=mapnik"}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
# html logo at page bottom (path relative to html directory)
 | 
					# html logo at page bottom (path relative to html directory)
 | 
				
			||||||
html_logo: "logo.png"
 | 
					html_logo: "logo.png"
 | 
				
			||||||
@ -145,14 +140,14 @@ EMAIL:
 | 
				
			|||||||
  # specify mail server and credentials
 | 
					  # specify mail server and credentials
 | 
				
			||||||
  # port, auth_type, user and password are only required if mailserver is not set to "localhost"
 | 
					  # port, auth_type, user and password are only required if mailserver is not set to "localhost"
 | 
				
			||||||
  # user and password can be set to "ENV" or "DOCKER" to read from environment variables or docker secrets
 | 
					  # user and password can be set to "ENV" or "DOCKER" to read from environment variables or docker secrets
 | 
				
			||||||
  mailserver: "smtp.example.org"      # mail server
 | 
					  mailserver: "smtp.rub.de"           # mail server
 | 
				
			||||||
  auth_type: "SSL"                    # mail authentication type, can be "SSL", "TLS" or "None"
 | 
					  auth_type: "SSL"                    # mail authentication type, can be "SSL", "TLS" or "None"
 | 
				
			||||||
  port: 465                           # mail port, default 465 for SSL, 587 for TLS
 | 
					  port: 465                           # mail port, default 465 for SSL, 587 for TLS
 | 
				
			||||||
  user: "DOCKER"                      # mail user, read from environment variable if set to "ENV" or from docker secret if set to "DOCKER"
 | 
					  user: "DOCKER"                      # mail user, read from environment variable if set to "ENV" or from docker secret if set to "DOCKER"
 | 
				
			||||||
  password: "DOCKER"                  # mail password, read from environment variable if set to "ENV" or from docker secret if set to "DOCKER"
 | 
					  password: "DOCKER"                  # mail password, read from environment variable if set to "ENV" or from docker secret if set to "DOCKER"
 | 
				
			||||||
  # specify mail recipients, sender and blacklists
 | 
					  # specify mail recipients, sender and blacklists
 | 
				
			||||||
  addresses: ["test@example.org"]  # list of mail addresses for info mails
 | 
					  addresses: ["marcel.paffrath@rub.de", "kasper.fischer@rub.de"]  # list of mail addresses for info mails
 | 
				
			||||||
  sender: "<test@example.org>"              # mail sender
 | 
					  sender: "RUB SeisObs <seisobs@ruhr-uni-bochum.de>"              # mail sender
 | 
				
			||||||
  stations_blacklist: []                                          # do not send emails for specific stations
 | 
					  stations_blacklist: []                                          # do not send emails for specific stations
 | 
				
			||||||
  networks_blacklist: []                                          # do not send emails for specific network
 | 
					  networks_blacklist: []                                          # do not send emails for specific network
 | 
				
			||||||
  # specify recipients for single stations in a yaml: key = email-address, val = station list (e.g. [1Y.GR01, 1Y.GR02])
 | 
					  # specify recipients for single stations in a yaml: key = email-address, val = station list (e.g. [1Y.GR01, 1Y.GR02])
 | 
				
			||||||
 | 
				
			|||||||
@ -19,7 +19,7 @@ th {
 | 
				
			|||||||
    background-color: #17365c;
 | 
					    background-color: #17365c;
 | 
				
			||||||
    color: #fff;
 | 
					    color: #fff;
 | 
				
			||||||
    border-radius: 3px;
 | 
					    border-radius: 3px;
 | 
				
			||||||
    padding: 10px 2px;
 | 
					    padding: 10px, 2px;
 | 
				
			||||||
    position: sticky;
 | 
					    position: sticky;
 | 
				
			||||||
    top: 0;
 | 
					    top: 0;
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
				
			|||||||
							
								
								
									
										34
									
								
								survBot.py
									
									
									
									
									
								
							
							
						
						
									
										34
									
								
								survBot.py
									
									
									
									
									
								
							@ -1,8 +1,8 @@
 | 
				
			|||||||
#!/usr/bin/env python
 | 
					#!/usr/bin/env python
 | 
				
			||||||
# -*- coding: utf-8 -*-
 | 
					# -*- coding: utf-8 -*-
 | 
				
			||||||
 | 
					
 | 
				
			||||||
__version__ = '0.3'
 | 
					__version__ = '0.2-docker'
 | 
				
			||||||
__author__ = ['Marcel Paffrath <marcel.paffrath@rub.de>', 'Kasper D. Fischer <kasper.fischer@rub.de>']
 | 
					__author__ = 'Marcel Paffrath <marcel.paffrath@rub.de>'
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import os
 | 
					import os
 | 
				
			||||||
import io
 | 
					import io
 | 
				
			||||||
@ -234,7 +234,7 @@ class SurveillanceBot(object):
 | 
				
			|||||||
        self.gaps = self.dataStream.get_gaps(min_gap=self.parameters['THRESHOLDS'].get('min_gap'))
 | 
					        self.gaps = self.dataStream.get_gaps(min_gap=self.parameters['THRESHOLDS'].get('min_gap'))
 | 
				
			||||||
        self.dataStream.merge()
 | 
					        self.dataStream.merge()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        # organize data in dictionary with key for each station
 | 
					        # organise data in dictionary with key for each station
 | 
				
			||||||
        for trace in self.dataStream:
 | 
					        for trace in self.dataStream:
 | 
				
			||||||
            nwst_id = get_nwst_id(trace)
 | 
					            nwst_id = get_nwst_id(trace)
 | 
				
			||||||
            if not nwst_id in self.data.keys():
 | 
					            if not nwst_id in self.data.keys():
 | 
				
			||||||
@ -351,7 +351,7 @@ class SurveillanceBot(object):
 | 
				
			|||||||
            first_exec = False
 | 
					            first_exec = False
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    def console_print(self, itemlist, str_len=21, sep='|', seplen=3):
 | 
					    def console_print(self, itemlist, str_len=21, sep='|', seplen=3):
 | 
				
			||||||
        assert len(sep) <= seplen, f'Make sure separator has less than {seplen} characters'
 | 
					        assert len(sep) <= seplen, f'Make sure seperator has less than {seplen} characters'
 | 
				
			||||||
        sl = sep.ljust(seplen)
 | 
					        sl = sep.ljust(seplen)
 | 
				
			||||||
        sr = sep.rjust(seplen)
 | 
					        sr = sep.rjust(seplen)
 | 
				
			||||||
        string = sl
 | 
					        string = sl
 | 
				
			||||||
@ -595,7 +595,6 @@ class StationQC(object):
 | 
				
			|||||||
        self.status_track = status_track
 | 
					        self.status_track = status_track
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        self.powbox_active = self.is_pbox_activated_check()
 | 
					        self.powbox_active = self.is_pbox_activated_check()
 | 
				
			||||||
        self.mass_active = self.is_mass_activated_check()
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
        self.start()
 | 
					        self.start()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -1081,11 +1080,6 @@ class StationQC(object):
 | 
				
			|||||||
        """ Analyse datalogger mass channels. """
 | 
					        """ Analyse datalogger mass channels. """
 | 
				
			||||||
        key = 'mass'
 | 
					        key = 'mass'
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        # skip processing if mass is not active
 | 
					 | 
				
			||||||
        if not self.mass_active:
 | 
					 | 
				
			||||||
            self.set_mass_inactive_error(key)
 | 
					 | 
				
			||||||
            return
 | 
					 | 
				
			||||||
        
 | 
					 | 
				
			||||||
        # build stream with all channels
 | 
					        # build stream with all channels
 | 
				
			||||||
        st = Stream()
 | 
					        st = Stream()
 | 
				
			||||||
        for channel in channels:
 | 
					        for channel in channels:
 | 
				
			||||||
@ -1305,7 +1299,7 @@ class StationQC(object):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
        # Warn in case of voltage under OK-level (1V)
 | 
					        # Warn in case of voltage under OK-level (1V)
 | 
				
			||||||
        if len(under) > 0:
 | 
					        if len(under) > 0:
 | 
				
			||||||
            # try calculate number of occurrences from gaps between indices
 | 
					            # try calculate number of occurences from gaps between indices
 | 
				
			||||||
            n_occurrences = len(np.where(np.diff(under) > 1)[0]) + 1
 | 
					            n_occurrences = len(np.where(np.diff(under) > 1)[0]) + 1
 | 
				
			||||||
            voltage_dict[-1] = under
 | 
					            voltage_dict[-1] = under
 | 
				
			||||||
            self.status_other(detailed_message=f'Trace {trace.get_id()}: '
 | 
					            self.status_other(detailed_message=f'Trace {trace.get_id()}: '
 | 
				
			||||||
@ -1347,12 +1341,6 @@ class StationQC(object):
 | 
				
			|||||||
        msg = self.parameters.get('no_pbox_stations')[self.station]
 | 
					        msg = self.parameters.get('no_pbox_stations')[self.station]
 | 
				
			||||||
        self.error(key, detailed_message=f'PowBox not connected', disc=msg)
 | 
					        self.error(key, detailed_message=f'PowBox not connected', disc=msg)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    def is_mass_activated_check(self):
 | 
					 | 
				
			||||||
        return self.station not in self.parameters.get('no_mass_stations', [])
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
    def set_mass_inactive_error(self, key):
 | 
					 | 
				
			||||||
        msg = self.parameters.get('no_mass_stations')[self.station]
 | 
					 | 
				
			||||||
        self.error(key, detailed_message=f'Mass channels not connected', disc=msg)
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
class Status(object):
 | 
					class Status(object):
 | 
				
			||||||
    """ Basic Status class. All status classes are derived from this class."""
 | 
					    """ Basic Status class. All status classes are derived from this class."""
 | 
				
			||||||
@ -1407,15 +1395,15 @@ class StatusOK(Status):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
class StatusWarn(Status):
 | 
					class StatusWarn(Status):
 | 
				
			||||||
    def __init__(self, message='WARN', count=1, last_occurrence=None, detailed_messages=None, show_count=False):
 | 
					    def __init__(self, message='WARN', count=1, last_occurence=None, detailed_messages=None, show_count=False):
 | 
				
			||||||
        super(StatusWarn, self).__init__(message=message, count=count, last_occurrence=last_occurrence,
 | 
					        super(StatusWarn, self).__init__(message=message, count=count, last_occurrence=last_occurence,
 | 
				
			||||||
                                         detailed_messages=detailed_messages, show_count=show_count)
 | 
					                                         detailed_messages=detailed_messages, show_count=show_count)
 | 
				
			||||||
        self.set_warn()
 | 
					        self.set_warn()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
class StatusError(Status):
 | 
					class StatusError(Status):
 | 
				
			||||||
    def __init__(self, message='FAIL', count=1, last_occurrence=None, detailed_messages=None, show_count=False):
 | 
					    def __init__(self, message='FAIL', count=1, last_occurence=None, detailed_messages=None, show_count=False):
 | 
				
			||||||
        super(StatusError, self).__init__(message=message, count=count, last_occurrence=last_occurrence,
 | 
					        super(StatusError, self).__init__(message=message, count=count, last_occurrence=last_occurence,
 | 
				
			||||||
                                          detailed_messages=detailed_messages, show_count=show_count)
 | 
					                                          detailed_messages=detailed_messages, show_count=show_count)
 | 
				
			||||||
        self.set_error()
 | 
					        self.set_error()
 | 
				
			||||||
        self.default_message = message
 | 
					        self.default_message = message
 | 
				
			||||||
@ -1432,8 +1420,8 @@ class StatusError(Status):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
class StatusOther(Status):
 | 
					class StatusOther(Status):
 | 
				
			||||||
    def __init__(self, messages=None, count=1, last_occurrence=None, detailed_messages=None):
 | 
					    def __init__(self, messages=None, count=1, last_occurence=None, detailed_messages=None):
 | 
				
			||||||
        super(StatusOther, self).__init__(count=count, last_occurrence=last_occurrence,
 | 
					        super(StatusOther, self).__init__(count=count, last_occurrence=last_occurence,
 | 
				
			||||||
                                          detailed_messages=detailed_messages)
 | 
					                                          detailed_messages=detailed_messages)
 | 
				
			||||||
        if messages is None:
 | 
					        if messages is None:
 | 
				
			||||||
            messages = []
 | 
					            messages = []
 | 
				
			||||||
 | 
				
			|||||||
							
								
								
									
										7
									
								
								utils.py
									
									
									
									
									
								
							
							
						
						
									
										7
									
								
								utils.py
									
									
									
									
									
								
							@ -6,7 +6,6 @@ import logging
 | 
				
			|||||||
import matplotlib
 | 
					import matplotlib
 | 
				
			||||||
import numpy as np
 | 
					import numpy as np
 | 
				
			||||||
import smtplib
 | 
					import smtplib
 | 
				
			||||||
import os
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
from obspy import Stream
 | 
					from obspy import Stream
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -175,7 +174,7 @@ def transform_trace(data, transf):
 | 
				
			|||||||
        elif operator_str == '/':
 | 
					        elif operator_str == '/':
 | 
				
			||||||
            data = data / val
 | 
					            data = data / val
 | 
				
			||||||
        else:
 | 
					        else:
 | 
				
			||||||
            raise IOError(f'Unknown arithmetic operator string: {operator_str}')
 | 
					            raise IOError(f'Unknown arithmethic operator string: {operator_str}')
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    return data
 | 
					    return data
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -302,7 +301,7 @@ def get_credential(source, param):
 | 
				
			|||||||
    # return source if no credential was found
 | 
					    # return source if no credential was found
 | 
				
			||||||
    return source
 | 
					    return source
 | 
				
			||||||
 | 
					
 | 
				
			||||||
def connect_to_mail_server(mail_params):
 | 
					def connect_to_mail_server(self, mail_params):
 | 
				
			||||||
    """
 | 
					    """
 | 
				
			||||||
    Connect to mail server and return server object.
 | 
					    Connect to mail server and return server object.
 | 
				
			||||||
    """
 | 
					    """
 | 
				
			||||||
@ -326,5 +325,5 @@ def connect_to_mail_server(mail_params):
 | 
				
			|||||||
        else:
 | 
					        else:
 | 
				
			||||||
            logging.error('Unknown authentication type. Mails can not be sent')
 | 
					            logging.error('Unknown authentication type. Mails can not be sent')
 | 
				
			||||||
            return
 | 
					            return
 | 
				
			||||||
        s.login(user, password)
 | 
					        s.login(mail_params.get('user'), mail_params.get('password'))
 | 
				
			||||||
    return s
 | 
					    return s
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user