Connect to the local MongoDB server. Return a handle of tuixue database.

Create a websocket connection.

For a given session, return whether or not the session is in the cache

Fetch global USEbassy data.

This method fix the problem of `cls.find_visa_status_overview` as the previous method doesn't convert the querying date into the embassy

Fill in the missing minute and return the visa status detail with consecutive duplicate removed

Find all of the email address for given new visa status. param `inclusion` spcify the filtering strategy of email list. It can be one of

Return a region-country-embassy mapping

Return a region to embassy code mapping. In JSON convention.

Incase the connection drop or something...

Program entry, a simple command line interface

Initiate the database with following handling of datetime object regarding timezone. 1. All of the `available_date` data are stored as i

Clear all the previous visa_status data. Write all file based data into MongoDB.

Initialize the database with old version of email records.

Initate latest_written in sequentail order.

When there is no session cache file or reading a sessoin cache file in __init__ is failing, this method will be called to generate a new

Keep websocket alive for `for` seconds.

Dispatch new visa status event to all subscriber.

Load test with concurrently running websocket.

Listen to the visa status update event and dispatch event to the broadcaster.

Determine whether or not a email notification should be sent. And send the notification if needed. Return a flag indicating wheter the em

Parse the query, return a dictionary. The keys of returned dict will ALWAYS be `str`. The values can be list of str or list of

Parse the attributes of url.

Put the session to be replaced in the task queue for visa fetched to update.

Publish a new visa status event. Meant to be called by notifier.

Remove the email subscription from given email address. If the subscription list is empty after unsubscribing, the document will be delet

The method called when a new fetched result is obtained from crawler backend. The `'latest_written'` collection will always be modified,

Send notification to QQ group and Telegram channel.

Send the email for confirmation of email subscription.