当前逻辑梳理

[felinae98]

scheduler.exec_fetch 中的逻辑：

def single_fetch(platform, target):
 	platform_obj = platform(ctx)
	new_raw_posts = platform.get_new_posts(target)
    new_posts = [theme.render(raw_post) for new_raw_posts]
    subscribers = config.get_subscribers_from_target(target)
	to_send: list[tuple[subscriber, list[post]]] = dispatch(new_posts, subscribers)
	send(to_send)

[AzideCupric]

flowchart LR
    subgraph scheduler
    A[Scheduler] -->|pick| B(Platform)
    B -->|fetch| C[Post]
    E[Send]
    end

    subgraph theme
    F[Theme] -->|render| D
    C --> D[message]
    D --> E[Send]
    end

Loading

整个scheduler涉及的模块

[AzideCupric]

• platform 的语义感觉要重新考虑下
  • dispatch_user 这种逻辑是不应该放在这里
  • 理论上拿到 raw_posts ，platform 的职责就该结束了
  • 感觉把 dispatch user 丢出 platform 能清爽不少
• platform.parse 和 theme 的职责要划清楚
• scheduler 的代码写的过于魔法了（调度部分）
  • 参见
  • 动态权重

[suyiiyii]

研究了一下，画了个图

源码

```mermaid zenuml title 一份快递是如何送到你手里的 Scheduler #FFEBE6 Platform #0747A6 Post #E3FCEF Theme #69a658 "send.py" @starter(Scheduler) Scheduler.exec_fetch{ Post = Platform.do_fetch_new_post(SubUnit) { Platform.get_sub_list(Target) Platform.filter_common_with_diff dispatch_user_post{ Platform.parse } } msgs = Post.generate_messages(Post){ Post.generate{ msgs = Theme.do_render } } "send.py".send_msgs(msgs) } ```

我认为可以提出一个 Manager，用来具体执行逻辑，其他模块仅提供方法供 Manager 调用，同时在这里存放一些不好分类的函数。
可以把 Post 变成一个纯数据类。
这样操作下来有一个有疑问的点是，RawPost 在经过处理之后还需要返回 Platform 转换成 RawPost，才能进行下一步，这样是否不够优雅。

Details

zenuml
    title 一份快递是如何送到你手里的
    Scheduler #FFEBE6
    Manager #de8705
    Platform #0747A6
    Post #E3FCEF
    Theme #69a658
    "send.py"
    @Starter(Scheduler)
    Scheduler.exec_fetch{
      RawPost = Platform.do_fetch_new_post(SubUnit) {
        Platform.get_sub_list(Target)
        Platform.filter_common_with_diff
      }
      
     Manager.process(RawPost){
        Manager.do_filter
        Manager.dispatch
        Post = Platform.parse
        MessageFactory = Theme.do_render(Post)
        "send.py".send_msgs(MessageFactory)
      }
    }

Loading

[AzideCupric]

能不能让下一级直接“消费”上一级传来的输入数据，处理之后传给下一级，也就是不再回到上一级，而是一级级传下去？

[AzideCupric]

scheduler的活看起来有些杂了，理论上scheduler职责只需要每次挑一个platform让他干活