Function callback

shift/shift.ts:672–698

()

          existed.targetId,
          ids,
          existed.options
        );
        const first = existed.messages[0];
        if (first)
          updateStats(existed.sourceId, existed.targetId, getMediaType(first));
      } else {
        console.log("[SHIFT] 组未触发类型过滤，跳过转发");
      }
    } catch (e) {
      if (!isAbortError(e)) {
        console.error("[SHIFT] 组转发执行失败", e);
      }
    }
  };

  if (context) {
    existed.timer = context.setTimeout(() => {
      if (existed.disposeTimer) {
        void existed.disposeTimer();
        existed.disposeTimer = undefined;
      }
      const task = context.runTask(callback, { label: "shift-group-forward" });
      task.catch((error) => {
        if (!isAbortError(error)) {
          console.error("[SHIFT] 组转发执行失败", error);
        }
      });
    }, 1200, { label: "shift-group-buffer" });
    existed.disposeTimer = () => clearTimeout(existed.timer!);
  } else {