File size: 4,400 Bytes
fc93158
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
import { describe, expect, it } from "vitest";
import {
  resolveActiveFallbackState,
  resolveFallbackTransition,
  type FallbackNoticeState,
} from "./fallback-state.js";

const baseAttempt = {
  provider: "fireworks",
  model: "fireworks/minimax-m2p5",
  error: "Provider fireworks is in cooldown (all profiles unavailable)",
  reason: "rate_limit" as const,
};

describe("fallback-state", () => {
  it("treats fallback as active only when state matches selected and active refs", () => {
    const state: FallbackNoticeState = {
      fallbackNoticeSelectedModel: "fireworks/minimax-m2p5",
      fallbackNoticeActiveModel: "deepinfra/moonshotai/Kimi-K2.5",
      fallbackNoticeReason: "rate limit",
    };

    const resolved = resolveActiveFallbackState({
      selectedModelRef: "fireworks/minimax-m2p5",
      activeModelRef: "deepinfra/moonshotai/Kimi-K2.5",
      state,
    });

    expect(resolved.active).toBe(true);
    expect(resolved.reason).toBe("rate limit");
  });

  it("does not treat runtime drift as fallback when persisted state does not match", () => {
    const state: FallbackNoticeState = {
      fallbackNoticeSelectedModel: "anthropic/claude",
      fallbackNoticeActiveModel: "deepinfra/moonshotai/Kimi-K2.5",
      fallbackNoticeReason: "rate limit",
    };

    const resolved = resolveActiveFallbackState({
      selectedModelRef: "fireworks/minimax-m2p5",
      activeModelRef: "deepinfra/moonshotai/Kimi-K2.5",
      state,
    });

    expect(resolved.active).toBe(false);
    expect(resolved.reason).toBeUndefined();
  });

  it("marks fallback transition when selected->active pair changes", () => {
    const resolved = resolveFallbackTransition({
      selectedProvider: "fireworks",
      selectedModel: "fireworks/minimax-m2p5",
      activeProvider: "deepinfra",
      activeModel: "moonshotai/Kimi-K2.5",
      attempts: [baseAttempt],
      state: {},
    });

    expect(resolved.fallbackActive).toBe(true);
    expect(resolved.fallbackTransitioned).toBe(true);
    expect(resolved.fallbackCleared).toBe(false);
    expect(resolved.stateChanged).toBe(true);
    expect(resolved.reasonSummary).toBe("rate limit");
    expect(resolved.nextState.selectedModel).toBe("fireworks/minimax-m2p5");
    expect(resolved.nextState.activeModel).toBe("deepinfra/moonshotai/Kimi-K2.5");
  });

  it("normalizes fallback reason whitespace for summaries", () => {
    const resolved = resolveFallbackTransition({
      selectedProvider: "fireworks",
      selectedModel: "fireworks/minimax-m2p5",
      activeProvider: "deepinfra",
      activeModel: "moonshotai/Kimi-K2.5",
      attempts: [{ ...baseAttempt, reason: "rate_limit\n\tburst" }],
      state: {},
    });

    expect(resolved.reasonSummary).toBe("rate limit burst");
  });

  it("refreshes reason when fallback remains active with same model pair", () => {
    const resolved = resolveFallbackTransition({
      selectedProvider: "fireworks",
      selectedModel: "fireworks/minimax-m2p5",
      activeProvider: "deepinfra",
      activeModel: "moonshotai/Kimi-K2.5",
      attempts: [{ ...baseAttempt, reason: "timeout" }],
      state: {
        fallbackNoticeSelectedModel: "fireworks/minimax-m2p5",
        fallbackNoticeActiveModel: "deepinfra/moonshotai/Kimi-K2.5",
        fallbackNoticeReason: "rate limit",
      },
    });

    expect(resolved.fallbackTransitioned).toBe(false);
    expect(resolved.stateChanged).toBe(true);
    expect(resolved.nextState.reason).toBe("timeout");
  });

  it("marks fallback as cleared when runtime returns to selected model", () => {
    const resolved = resolveFallbackTransition({
      selectedProvider: "fireworks",
      selectedModel: "fireworks/minimax-m2p5",
      activeProvider: "fireworks",
      activeModel: "fireworks/minimax-m2p5",
      attempts: [],
      state: {
        fallbackNoticeSelectedModel: "fireworks/minimax-m2p5",
        fallbackNoticeActiveModel: "deepinfra/moonshotai/Kimi-K2.5",
        fallbackNoticeReason: "rate limit",
      },
    });

    expect(resolved.fallbackActive).toBe(false);
    expect(resolved.fallbackCleared).toBe(true);
    expect(resolved.fallbackTransitioned).toBe(false);
    expect(resolved.stateChanged).toBe(true);
    expect(resolved.nextState.selectedModel).toBeUndefined();
    expect(resolved.nextState.activeModel).toBeUndefined();
    expect(resolved.nextState.reason).toBeUndefined();
  });
});