def get_docs_to_commit(self):
        try:
            spec = {'synced': False}
            fields = {'_id': 0}
            cur = self.db.docs.find(spec, fields)
        except Exception as e:
            raise DatabaseException(e)
        return list(cur)
def parse_record(self, metadata, line):
        factors = line.split('|')
        if len(factors) < 7:
            return

        registry, cc, type_, start, value, dete, status = factors[:7]
        if type_ not in ('ipv4', 'ipv6'):
            return

        return Record(metadata, start, type_, value, cc)