| 1410 | } |
| 1411 | |
| 1412 | bool toolboxEnsureTopic( |
| 1413 | void* ctx, DataSourceHandle source, PJ_string_view_t topic_name, TopicHandle* out_topic, |
| 1414 | PJ_error_t* out_error) noexcept { |
| 1415 | return guardHostCallback(out_error, [&] { |
| 1416 | auto* impl = static_cast<DatastoreToolboxHostState*>(ctx); |
| 1417 | if (!impl->core.write.ensureTopic(source, toStringView(topic_name), out_topic)) { |
| 1418 | propagateError(out_error, impl->core.write.lastError()); |
| 1419 | return false; |
| 1420 | } |
| 1421 | return true; |
| 1422 | }); |
| 1423 | } |
| 1424 | |
| 1425 | bool toolboxEnsureField( |
| 1426 | void* ctx, TopicHandle topic, PJ_string_view_t field_name, PJ_primitive_type_t type, FieldHandle* out_field, |
nothing calls this directly
no test coverage detected