(.*)
', response.content.decode('utf8')) raise RuntimeError(errors[0] if errors else 'Unknown %i error' % response.status_code) def get_id(self, session, saas): blog_id = saas.data.get('blog_id') search = self.get_main_url() search += '/wp-admin/network/sites.php?s=%s&action=blogs' % saas.name regex = re.compile( '%s' % saas.name ) sys.stdout.write("Search URL: %s\n" % search) content = session.get(search, verify=self.VERIFY).content.decode('utf8') # Get id ids = regex.search(content) if not ids and not blog_id: raise RuntimeError("Blog '%s' not found" % saas.name) if ids: ids = ids.groups() if len(ids) > 1 and not blog_id: raise ValueError("Multiple matches") # Get wpnonce try: wpnonce = re.search(r'(.*)', content).groups()[0] except TypeError: # No search results, try some luck wpnonce = content wpnonce = re.search(r'_wpnonce=([^"]*)"', wpnonce).groups()[0] return blog_id or int(ids[0]), wpnonce def create_blog(self, saas, server): if saas.data.get('blog_id'): return session = requests.Session() self.login(session) # Check if blog already exists try: blog_id, wpnonce = self.get_id(session, saas) except RuntimeError: url = self.get_main_url() url += '/wp-admin/network/site-new.php' sys.stdout.write("Create URL: %s\n" % url) content = session.get(url, verify=self.VERIFY).content.decode('utf8') wpnonce = re.compile('name="_wpnonce_add-blog"\s+value="([^"]*)"') wpnonce = wpnonce.search(content).groups()[0] url += '?action=add-site' data = { 'blog[domain]': saas.name, 'blog[title]': saas.name, 'blog[email]': saas.account.email, '_wpnonce_add-blog': wpnonce, } # Validate response response = session.post(url, data=data, verify=self.VERIFY) self.validate_response(response) blog_id = re.compile(r'') content = response.content.decode('utf8') blog_id = blog_id.search(content).groups()[0] sys.stdout.write("Created blog ID: %s\n" % blog_id) saas.data['blog_id'] = int(blog_id) saas.save(update_fields=('data',)) else: sys.stdout.write("Retrieved blog ID: %s\n" % blog_id) saas.data['blog_id'] = int(blog_id) saas.save(update_fields=('data',)) def delete_blog(self, saas, server): session = requests.Session() self.login(session) try: id, wpnonce = self.get_id(session, saas) except RuntimeError: pass else: delete = self.get_main_url() delete += '/wp-admin/network/sites.php?action=confirm&action2=deleteblog' delete += '&id=%d&_wpnonce=%s' % (id, wpnonce) sys.stdout.write("Search URL: %s\n" % delete) content = session.get(delete, verify=self.VERIFY).content.decode('utf8') wpnonce = re.compile('name="_wpnonce"\s+value="([^"]*)"') wpnonce = wpnonce.search(content).groups()[0] data = { 'action': 'deleteblog', 'id': id, '_wpnonce': wpnonce, '_wp_http_referer': '/wp-admin/network/sites.php', } delete = self.get_main_url() delete += '/wp-admin/network/sites.php?action=deleteblog' sys.stdout.write("Delete URL: %s\n" % delete) response = session.post(delete, data=data, verify=self.VERIFY) self.validate_response(response) def save(self, saas): self.append(self.create_blog, saas) context = self.get_context(saas) context['IDENT'] = "b.domain = '%(domain)s'" % context if context['blog_id']: context['IDENT'] = "b.blog_id = '%(blog_id)s'" % context self.append(textwrap.dedent(""" # Update custom URL mapping existing=( $(mysql -Nrs %(db_name)s --execute=" SELECT b.blog_id, b.domain, m.domain, b.path FROM wp_domain_mapping AS m, wp_blogs AS b WHERE m.blog_id = b.blog_id AND m.active AND %(IDENT)s;") ) if [[ ${existing[0]} != "" ]]; then echo "Existing blog with ID ${existing[0]}" # Clear custom domain if [[ "%(custom_domain)s" == "" ]]; then mysql %(db_name)s --execute=" DELETE FROM m USING wp_domain_mapping AS m, wp_blogs AS b WHERE m.blog_id = b.blog_id AND m.active AND %(IDENT)s; UPDATE wp_blogs SET path='/' WHERE blog_id = ${existing[0]};" elif [[ "${existing[2]}" != "%(custom_domain)s" || "${existing[3]}" != "%(custom_path)s" ]]; then mysql %(db_name)s --execute=" UPDATE wp_domain_mapping as m, wp_blogs as b SET m.domain = '%(custom_domain)s', b.path = '%(custom_path)s' WHERE m.blog_id = b.blog_id AND m.active AND %(IDENT)s;" fi elif [[ "%(custom_domain)s" != "" ]]; then echo "Non existing blog with custom domain %(domain)s" blog=( $(mysql -Nrs %(db_name)s --execute=" SELECT blog_id, path FROM wp_blogs WHERE domain = '%(domain)s';") ) if [[ "${blog[0]}" != "" ]]; then echo "Blog %(domain)s found, ID: ${blog[0]}" mysql %(db_name)s --execute=" UPDATE wp_domain_mapping SET active = 0 WHERE active AND blog_id = ${blog[0]}; INSERT INTO wp_domain_mapping (blog_id, domain, active) VALUES (${blog[0]}, '%(custom_domain)s', 1);" if [[ "${blog[1]}" != "%(custom_path)s" ]]; then mysql %(db_name)s --execute=" UPDATE wp_blogs SET path = '%(custom_path)s' WHERE blog_id = ${blog[0]};" fi else echo "Blog %(domain)s not found" fi fi""") % context ) def delete(self, saas): self.append(self.delete_blog, saas) def get_context(self, saas): domain = saas.get_site_domain() context = { 'db_name': settings.SAAS_WORDPRESS_DB_NAME, 'domain': domain, 'custom_domain': '', 'custom_path': '/', 'blog_id': saas.data.get('blog_id', ''), } if saas.custom_url: custom_url = urlparse(saas.custom_url) context.update({ 'custom_domain': custom_url.netloc, 'custom_path': custom_url.path, }) return context class WordpressMuTraffic(ApacheTrafficByHost): __doc__ = ApacheTrafficByHost.__doc__ verbose_name = _("Wordpress MU Traffic") default_route_match = "saas.service == 'wordpress'" doc_settings = (settings, ('SAAS_TRAFFIC_IGNORE_HOSTS', 'SAAS_WORDPRESS_LOG_PATH') ) log_path = settings.SAAS_WORDPRESS_LOG_PATH