Cn-Curator: 基于转发的好文推荐系统 | Cn-Curator: Reward Awesome Posts by Resteem

RESTEEM_ACCOUNT = "rivalhw"
INFO_ACCOUNT = "rivalhw"
CURATION_CYCLE = 1.01 # days

class CnReaderSummary(InfoRecipe):

    def mode(self):
        return "query.comment.post"

    def config(self):
        return {
            "account": RESTEEM_ACCOUNT,
            "days": CURATION_CYCLE,
            "reblog": True
        }

    def by(self):
        return INFO_ACCOUNT

    def title(self, data):
        return "好文天天赞{}榜上有名".format(get_zh_time_str())

    def body(self, data):
        date = get_zh_time_str()
        count = len(data)
        head = ["作者", "文章"]
        body = []
        for item in data:
            row = [
                "@" + item['author'],
                "<a href=\"{}\">{}</a>".format(self.get_url(item['authorperm']), item['title'])
            ]
            body.append(row)
        table = build_table(head=head, data=body)
        return POST_TEMPLATE.format(date=date, count=count, table=table)

    def tags(self, data):
        return ["cn-reader", "cn", "partiko", "zzan"]

    def ready(self, data):
        # post only there're more than 0 resteemed posts
        return data and len(data) > 0

    def get_url(self, authorperm):
        return APP_URL + "/" + authorperm

RESTEEM_ACCOUNT = "rivalhw"
VOTER_ACCOUNT = "rivalhw"
CURATION_CYCLE = 1.01 # days

class CnReaderVoter(VoteRecipe):

    def __init__(self):
        super().__init__()
        self.posts_num = 0
        self.voted_posts = 0

    def mode(self):
        return "query.comment.post"

    def config(self):
        return {
            "account": RESTEEM_ACCOUNT,
            "days": CURATION_CYCLE,
            "reblog": True
        }

    def by(self):
        return VOTER_ACCOUNT

    def what_to_vote(self, ops):
        if not self.ops.is_upvoted_by(self.by()):
            logger.info("We will vote the post {}".format(self.ops.get_url()))
            self.posts_num += 1
            return True
        return False

    def who_to_vote(self, author):
        return True

    def when_to_vote(self, ops):
        return VOTE_TIMING # mins

    def how_to_vote(self, post):
        self.voted_posts += 1
        logger.info("voting {} / {} posts".format(self.voted_posts, self.posts_num))
        weight = self.voter.estimate_vote_pct_for_n_votes(days=CURATION_CYCLE, n=self.posts_num) * VOTE_PERCENTAGE
        if weight  > 100:
            weight = 100
        return weight

    def after_success(self, res):
        if self.voted_posts == self.posts_num:
            logger.info("Done with voting. Exit.")
            sys.exit()