( t *testing.T, db database.Store, ps dbpubsub.Pubsub, )
| 409 | } |
| 410 | |
| 411 | func newOpenAIResponsesTestServer( |
| 412 | t *testing.T, |
| 413 | db database.Store, |
| 414 | ps dbpubsub.Pubsub, |
| 415 | ) *chatd.Server { |
| 416 | t.Helper() |
| 417 | return newActiveTestServer(t, db, ps, func(cfg *chatd.Config) { |
| 418 | // Let CreateChat and SendMessage publish their pending status |
| 419 | // before wake-driven processing starts. The responses tests are |
| 420 | // not exercising periodic polling, and PostgreSQL can otherwise |
| 421 | // deliver that stale pending notification after processChat |
| 422 | // subscribes to control events. |
| 423 | cfg.PendingChatAcquireInterval = testutil.WaitLong |
| 424 | }) |
| 425 | } |
| 426 | |
| 427 | func insertOpenAIResponsesModelConfig( |
| 428 | t *testing.T, |
no test coverage detected