gpt-image-2-web 0.6.3

Self-hosted Docker/Web server for GPT Image 2.
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

#![allow(unused_imports)]

use super::*;

pub(crate) fn queue_snapshot_locked(inner: &JobQueueInner) -> Value {
    json!({
        "max_parallel": inner.max_parallel,
        "running": inner.running,
        "queued": inner.queue.len(),
        "queued_job_ids": inner.queue.iter().map(|job| job.id.clone()).collect::<Vec<_>>(),
    })
}

pub(crate) fn append_queue_event(
    inner: &mut JobQueueInner,
    job_id: &str,
    kind: &str,
    event_type: &str,
    data: Value,
) -> Value {
    let seq = inner.next_seq.entry(job_id.to_string()).or_insert_with(|| {
        list_history_job_events(job_id)
            .ok()
            .and_then(|events| {
                events
                    .iter()
                    .filter_map(|event| event.get("seq").and_then(Value::as_u64))
                    .max()
            })
            .unwrap_or(0)
    });
    *seq += 1;
    let mut event = json!({
        "seq": *seq,
        "kind": kind,
        "type": event_type,
        "data": data,
    });
    if let Ok(persisted_seq) = append_history_job_event(job_id, &event)
        && persisted_seq > 0
        && persisted_seq != *seq
    {
        *seq = persisted_seq;
        event["seq"] = json!(persisted_seq);
    }
    let events = inner.events.entry(job_id.to_string()).or_default();
    events.push(event.clone());
    if events.len() > 200 {
        events.remove(0);
    }
    event
}

pub(crate) fn terminal_event_type(status: Option<&str>) -> &'static str {
    match status {
        Some("failed") => "job.failed",
        Some("cancelled") | Some("canceled") => "job.cancelled",
        Some("partial_failed") => "job.partial_failed",
        _ => "job.completed",
    }
}

pub(crate) fn terminal_status_runs_storage_upload(status: Option<&str>) -> bool {
    matches!(status, Some("completed") | Some("partial_failed"))
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn terminal_event_type_tracks_terminal_status() {
        assert_eq!(terminal_event_type(Some("completed")), "job.completed");
        assert_eq!(
            terminal_event_type(Some("partial_failed")),
            "job.partial_failed"
        );
        assert_eq!(terminal_event_type(Some("failed")), "job.failed");
        assert_eq!(terminal_event_type(Some("cancelled")), "job.cancelled");
        assert_eq!(terminal_event_type(Some("canceled")), "job.cancelled");
    }

    #[test]
    fn terminal_storage_upload_skips_failed_and_cancelled_statuses() {
        assert!(terminal_status_runs_storage_upload(Some("completed")));
        assert!(terminal_status_runs_storage_upload(Some("partial_failed")));
        assert!(!terminal_status_runs_storage_upload(Some("failed")));
        assert!(!terminal_status_runs_storage_upload(Some("cancelled")));
        assert!(!terminal_status_runs_storage_upload(Some("canceled")));
        assert!(!terminal_status_runs_storage_upload(Some("running")));
        assert!(!terminal_status_runs_storage_upload(Some("uploading")));
        assert!(!terminal_status_runs_storage_upload(Some("unknown")));
        assert!(!terminal_status_runs_storage_upload(None));
    }
}