def get_bold_colors(self, str):
     bolds = str.split(' ')
     for bold in bolds:
         try:
             self.colors[bold]['b'] = True
         except:
             print encode(_('The param "%s" does not exist for bold colors')) % bold

 def listdir(self,directory):
     files = []
     dirs = []
 
     if(not directory.startswith('/')):
         directory = '/' + directory
     
     #get the id of this folder
     parentFolder = self._getGoogleFile(directory)
 
     #need to do this after
     if(not directory.endswith('/')):
             directory = directory + '/'
 
     if(parentFolder != None):
     
         fileList = self.drive.ListFile({'q':"'" + parentFolder['id'] + "' in parents and trashed = false"}).GetList()
    
         for aFile in fileList:
             if(aFile['mimeType'] == self.FOLDER_TYPE):
                 dirs.append(utils.encode(aFile['title']))
             else:
                 files.append(utils.encode(aFile['title']))
             
 
     return [dirs,files]    

    def generate_config_file(self, config_file):
        conf = ConfigParser.RawConfigParser()
        conf.read(config_file)

        # COLOR
        conf.add_section('colors')
        for c in self.colors:
            conf.set('colors', c, self.colors[c]['c'])
        conf.set('colors', 'bold', '')
        # KEYS
        conf.add_section('keys')
        for k in self.keys:
            conf.set('keys', k, self.keys[k])
        # PARAMS
        conf.add_section('params')
        for p in self.params:
            if self.params[p] == True:
                value = 1
            elif self.params[p] == False:
                value = 0
            elif self.params[p] == None:
                continue
            else:
                value = self.params[p]

            conf.set('params', p, value)

        with open(config_file, 'wb') as config:
            conf.write(config)

        print encode(_('Genereting configuration file in %s')) % config_file

	def _raise_exception():
		if raise_exception:
			if flags.rollback_on_exception:
				db.rollback()
			import inspect
			if inspect.isclass(raise_exception) and issubclass(raise_exception, Exception):
				raise raise_exception, encode(msg)
			else:
				raise ValidationError, encode(msg)

 def check_for_default_config(self):
     default_dir = '/tyrs'
     default_file = '/tyrs/tyrs.cfg'
     if not os.path.isfile(self.xdg_config + default_file):
         if not os.path.exists(self.xdg_config + default_dir):
             try:
                 os.makedirs(self.xdg_config + default_dir)
             except:
                 print encode(_('Couldn\'t create the directory in %s/tyrs')) % self.xdg_config
         self.generate_config_file(self.xdg_config + default_file)

    def test_incomplete_task(self):
        """Send task messages without all required keys."""
        c = encode(source(constant))
        msg1 = {"module": c, "params": encode(())}
        msg2 = {"module": c, "dataset": []}
        msg3 = {"dataset": [], "params": encode(())}

        for msg in (msg1, msg2, msg3):
            self.write_command("task", msg)
            assert_true("missing key" in self.read_error_string())

def print_ask_service(token_file):
    print ''
    print encode(_('Couldn\'t find any profile.'))
    print ''
    print encode(_('It should reside in: %s')) % token_file
    print encode(_('If you want to setup a new account, then follow these steps'))
    print encode(_('If you want to skip this, just press return or ctrl-C.'))
    print ''

    print ''
    print encode(_('Which service do you want to use?'))
    print ''
    print '1. Twitter'
    print '2. Identi.ca'
    print ''

def print_ask_service(config_file):
    print ''
    print encode(_('There is no profile detected.'))
    print ''
    print encode(_('It should be in %s')) % config_file
    print encode(_('If you want to setup a new account, let\'s go through some basic steps'))
    print encode(_('If you want to skip this, just press return or ctrl-C.'))
    print ''

    print ''
    print encode(_('Which service do you want to use?'))
    print ''
    print '1. Twitter'
    print '2. Identi.ca'
    print ''

    def get_header(self, status):
        retweeted = ""
        reply = ""
        retweet_count = ""
        retweeter = ""
        source = self.get_source(status)
        nick = self.get_nick(status)
        time = self.get_time(status)

        if self.is_reply(status):
            reply = u" \u2709"
        if status.rt:
            retweeted = u" \u267b "
            retweeter = nick
            nick = self.origin_of_retweet(status)

        if self.get_retweet_count(status):
            retweet_count = str(self.get_retweet_count(status))

        header_template = self.conf.params["header_template"]
        header = unicode(header_template).format(
            time=time,
            nick=nick,
            reply=reply,
            retweeted=retweeted,
            source=source,
            retweet_count=retweet_count,
            retweeter=retweeter,
        )

        return encode(header)

 def open_shell(self):
     curses.endwin()
     if self.stdin_flag:
         os.system('sh')
     else:
         os.system('cd \"%s\"; sh' % encode(os.path.dirname(self.fc.filename)))
     curses.curs_set(0)

    def get_nick(self, status):
        if hasattr(status, 'user'):
            nick = status.user.screen_name
        else:
            nick = status.sender_screen_name

        return encode(nick)

 def send_refs(self, refs, worker=None):
     if worker is None:
         worker = self._worker
     # Encode the objects in the refs.
     refs = [(x, encode(y)) for (x, y) in refs]
     msg = {"refs": refs}
     self.write_command("refs", msg, worker=worker)

def resolve(query, dnsIP='192.55.83.30'):   # Default IP is local host
    _, Qs, _, _, _ = utils.dissectDNS(query)
    name = Qs[0][0]
    if name in cache:
        return cache[name]

    ID = struct.unpack('!H', query[0:2])[0]
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    sock.sendto(query, (dnsIP, 53))

    whatReady = select.select([sock], [], [])
    if whatReady:  # Pythonic way of saying list is not empty
        rcvd = sock.recv(512*8)
        print utils.isAA(rcvd)
        sock.close()
        oneStep = doOneStep(rcvd)

        if oneStep is not None:
            if len(oneStep) == 2:
                if oneStep[1] == NOCHANGE:  # Continue our journey
                    return resolve(query, oneStep[0])
                elif oneStep[1] == ANSWER:
                    _, Qs, _, _, _ = utils.dissectDNS(query)
                    return oneStep[0]
            else:
                # CNAMEQUERY: make query with new address
                address = oneStep[2]
                query = utils.encode(address, False, ID)
                if oneStep[0] is not None:
                    return resolve(query, oneStep[0])
                else:
                    return resolve(query)

 def put(self,source,dest):
     
     aFile = xbmcvfs.File(xbmc.translatePath(source),'r')
     
     self.zip.writestr(utils.encode(dest),aFile.read(),compress_type=zipfile.ZIP_DEFLATED)
     
     return True

    def display(self):
        """show status bar"""

        self.win.erase()
        adir = self.app.act_pane.act_tab
        maxw = self.app.maxw
        if len(adir.selections) > 0:
            if maxw >= 45:
                size = 0
                for f in adir.selections:
                    size += adir.files[f][files.FT_SIZE]
                self.win.addstr('    %s bytes in %d files' % \
                                (num2str(size), len(adir.selections)))
        else:
            if maxw >= 80:
                self.win.addstr('File: %4d of %-4d' % \
                                (adir.file_i + 1, adir.nfiles))
                filename = adir.sorted[adir.file_i]
                if adir.vfs:
                    realpath = os.path.join(vfs.join(self.app.act_pane.act_tab),
                                            filename)
                else:
                    realpath = files.get_realpath(adir.path, filename,
                                                  adir.files[filename][files.FT_TYPE])
                path = (len(realpath)>maxw-35) and \
                    '~' + realpath[-(maxw-37):] or realpath
                self.win.addstr(0, 20, 'Path: ' + utils.encode(path))
        if maxw > 10:
            try:
                self.win.addstr(0, maxw-8, 'F1=Help')
            except:
                pass
        self.win.refresh()

 def __run(self, cmd, path, mode):
     if mode == PowerCLI.RUN_NEEDCURSESWIN:
         curses.endwin()
         try:
             msg = utils.get_shell_output3('cd "%s" && %s' % (path, cmd))
         except KeyboardInterrupt:
             os.system('reset')
             msg = 'Stopped by user'
         st = -1 if msg else 0
     elif mode == PowerCLI.RUN_BACKGROUND:
         utils.run_in_background(cmd, path)
         st, msg = 0, ''
     else: # PowerCLI.RUN_NORMAL
         st, msg = utils.ProcessFunc('Executing PowerCLI', cmd,
                                     utils.run_shell, cmd, path, True).run()
     if st == -1:
         messages.error('Cannot execute PowerCLI command:\n  %s\n\n%s' % \
                            (cmd, str(msg)))
     elif st != -100 and msg is not None and msg != '':
         if self.app.prefs.options['show_output_after_exec']:
             curses.curs_set(0)
             if messages.confirm('Executing PowerCLI', 'Show output', 1):
                 lst = [(l, 2) for l in msg.split('\n')]
                 pyview.InternalView('Output of "%s"' % utils.encode(cmd),
                                     lst, center=0).run()
     return st

 def __find(self, title):
     self.pattern = messages.Entry(title, 'Type search string', '', True, False).run()
     if self.pattern is None or self.pattern == '':
         return -1
     filename = os.path.abspath(self.fc.filename)
     mode = (self.mode==MODE_TEXT) and 'n' or 'b'
     try:
         cmd = '%s -i%c \"%s\" \"%s\"' % (sysprogs['grep'], mode,
                                          self.pattern, filename)
         st, buf = run_shell(encode(cmd), path=u'.', return_output=True)
     except OSError:
         self.show()
         messages.error('Find error: Can\'t open file')
         return -1
     if st == -1:
         self.show()
         messages.error('Find error\n' + buf)
         self.matches = []
         return -1
     else:
         try:
             self.matches = [int(l.split(':')[0]) for l in buf.split('\n') if l]
         except (ValueError, TypeError):
             self.matches = []
         return 0

 def ask_root_url(self):
     message.print_ask_root_url()
     url = raw_input(encode(_('Your choice? > ')))
     if url == '':
         self.base_url = 'https://identi.ca/api'
     else:
         self.base_url = url

    def get_header(self, status):
        retweeted = ''
        reply = ''
        retweet_count = ''
        retweeter = ''
        source = self.get_source(status)
        nick = self.get_nick(status)
        timer = self.get_time(status)

        if self.is_reply(status):
            reply = u' \u2709'
        if status.rt:
            retweeted = u" \u267b "
            retweeter = nick
            nick = self.origin_of_retweet(status)

        if self.get_retweet_count(status):
            retweet_count = str(self.get_retweet_count(status))
            
        tyrs.container['completion'].add(get_exact_nick(nick))
        header_template = self.conf.params['header_template'] 
        header = unicode(header_template).format(
            time = timer,
            nick = nick,
            reply = reply,
            retweeted = retweeted,
            source = source,
            retweet_count = retweet_count,
            retweeter = retweeter
            )

        return encode(header)

 def put(self,source,dest):
     
     aFile = xbmcvfs.File(xbmc.translatePath(source),'r')
     
     self.zip.writestr(utils.encode(dest),aFile.read())
     
     return True