a.tolmachev
329 lines
13 KiB
JavaScript
329 lines
13 KiB
JavaScript
(function() {
|
|
function tKey(key) {
|
|
return typeof t === 'function' ? t(key) : key;
|
|
}
|
|
|
|
function currentProtocolCapabilities() {
|
|
return window.CrankWizardState.currentProtocolCapabilities();
|
|
}
|
|
|
|
function text(id) {
|
|
var element = document.getElementById(id);
|
|
return element ? String(element.value || '').trim() : '';
|
|
}
|
|
|
|
function set(id, value) {
|
|
var element = document.getElementById(id);
|
|
if (element) {
|
|
element.value = value || '';
|
|
}
|
|
}
|
|
|
|
function number(id) {
|
|
var value = text(id);
|
|
if (!value) return null;
|
|
var parsed = Number(value);
|
|
return Number.isFinite(parsed) ? parsed : null;
|
|
}
|
|
|
|
function lines(id) {
|
|
var value = text(id);
|
|
return value
|
|
? value.split('\n').map(function(item) { return item.trim(); }).filter(Boolean)
|
|
: [];
|
|
}
|
|
|
|
function checked(id) {
|
|
var element = document.getElementById(id);
|
|
return !!(element && element.checked);
|
|
}
|
|
|
|
function selectedMode() {
|
|
return text('streaming-mode') || 'unary';
|
|
}
|
|
|
|
function transportOptionsForMode(mode) {
|
|
var capabilities = currentProtocolCapabilities();
|
|
var behaviors = (capabilities.supports_transport_behaviors || []).slice();
|
|
if (mode === 'unary') return behaviors.filter(function(value) { return value === 'request_response'; });
|
|
if (mode === 'window') return behaviors.filter(function(value) {
|
|
return value === 'request_response' || value === 'server_stream';
|
|
});
|
|
if (mode === 'session') return behaviors.filter(function(value) {
|
|
return value === 'server_stream' || value === 'stateful_session';
|
|
});
|
|
if (mode === 'async_job') return behaviors.filter(function(value) {
|
|
return value === 'deferred_result';
|
|
});
|
|
return behaviors;
|
|
}
|
|
|
|
function modeOptionsForProtocol() {
|
|
var capabilities = currentProtocolCapabilities();
|
|
return (capabilities.supports_execution_modes || ['unary']).filter(function(mode) {
|
|
return transportOptionsForMode(mode).length > 0 || mode === 'unary';
|
|
});
|
|
}
|
|
|
|
function updateStreamingTransportOptions(preferredValue) {
|
|
var element = document.getElementById('streaming-transport-behavior');
|
|
if (!element) return;
|
|
var options = transportOptionsForMode(selectedMode());
|
|
element.innerHTML = '';
|
|
options.forEach(function(value) {
|
|
var option = document.createElement('option');
|
|
option.value = value;
|
|
option.textContent = tKey('wizard.streaming.transport.' + value);
|
|
element.appendChild(option);
|
|
});
|
|
if (preferredValue && options.indexOf(preferredValue) >= 0) {
|
|
element.value = preferredValue;
|
|
} else if (options.length) {
|
|
element.value = options[0];
|
|
}
|
|
}
|
|
|
|
function updateStreamingModeOptions(preferredValue) {
|
|
var element = document.getElementById('streaming-mode');
|
|
if (!element) return;
|
|
var options = modeOptionsForProtocol();
|
|
element.innerHTML = '';
|
|
options.forEach(function(value) {
|
|
var option = document.createElement('option');
|
|
option.value = value;
|
|
option.textContent = tKey('wizard.streaming.mode.' + value);
|
|
element.appendChild(option);
|
|
});
|
|
if (preferredValue && options.indexOf(preferredValue) >= 0) {
|
|
element.value = preferredValue;
|
|
} else {
|
|
element.value = options.indexOf('unary') >= 0 ? 'unary' : (options[0] || 'unary');
|
|
}
|
|
updateStreamingTransportOptions();
|
|
}
|
|
|
|
function ensureStreamingToolFamilyDefaults(mode) {
|
|
var base = text('tool-name') || 'stream_tool';
|
|
if (mode === 'session') {
|
|
if (!text('streaming-start-tool-name')) set('streaming-start-tool-name', base + '_start');
|
|
if (!text('streaming-poll-tool-name')) set('streaming-poll-tool-name', base + '_poll');
|
|
if (!text('streaming-stop-tool-name')) set('streaming-stop-tool-name', base + '_stop');
|
|
}
|
|
if (mode === 'async_job') {
|
|
if (!text('streaming-start-tool-name')) set('streaming-start-tool-name', base + '_start');
|
|
if (!text('streaming-status-tool-name')) set('streaming-status-tool-name', base + '_status');
|
|
if (!text('streaming-result-tool-name')) set('streaming-result-tool-name', base + '_result');
|
|
if (!text('streaming-cancel-tool-name')) set('streaming-cancel-tool-name', base + '_cancel');
|
|
}
|
|
}
|
|
|
|
function updateStreamingConfigVisibility() {
|
|
var mode = selectedMode();
|
|
var card = document.getElementById('wizard-streaming-config-card');
|
|
var help = document.getElementById('streaming-mode-help');
|
|
var toolFamily = document.getElementById('streaming-tool-family-block');
|
|
var asyncRow = document.getElementById('streaming-async-tool-family-row');
|
|
if (!card) return;
|
|
|
|
var isUnary = mode === 'unary';
|
|
var isSession = mode === 'session';
|
|
var isAsyncJob = mode === 'async_job';
|
|
|
|
[
|
|
'streaming-window-duration-ms',
|
|
'streaming-poll-interval-ms',
|
|
'streaming-upstream-timeout-ms',
|
|
'streaming-idle-timeout-ms',
|
|
'streaming-session-lifetime-ms',
|
|
'streaming-max-items',
|
|
'streaming-max-bytes',
|
|
'streaming-max-field-length',
|
|
'streaming-sampling-rate',
|
|
'streaming-items-path',
|
|
'streaming-summary-path',
|
|
'streaming-done-path',
|
|
'streaming-cursor-path',
|
|
'streaming-status-path',
|
|
'streaming-redacted-paths',
|
|
'streaming-truncate-item-fields',
|
|
'streaming-drop-duplicates'
|
|
].forEach(function(id) {
|
|
var node = document.getElementById(id);
|
|
if (!node) return;
|
|
var group = node.closest('.form-group') || node.closest('.checkbox-pill');
|
|
if (group) {
|
|
group.hidden = isUnary;
|
|
}
|
|
});
|
|
|
|
if (help) {
|
|
help.textContent = isUnary
|
|
? tKey('wizard.streaming.help.unary')
|
|
: (isSession
|
|
? tKey('wizard.streaming.help.session')
|
|
: (isAsyncJob
|
|
? tKey('wizard.streaming.help.async_job')
|
|
: tKey('wizard.streaming.help.window')));
|
|
}
|
|
|
|
if (toolFamily) toolFamily.hidden = !(isSession || isAsyncJob);
|
|
if (asyncRow) asyncRow.hidden = !isAsyncJob;
|
|
|
|
ensureStreamingToolFamilyDefaults(mode);
|
|
}
|
|
|
|
function bindStreamingConfigControls() {
|
|
updateStreamingModeOptions();
|
|
updateStreamingConfigVisibility();
|
|
|
|
var mode = document.getElementById('streaming-mode');
|
|
if (mode) {
|
|
mode.addEventListener('change', function() {
|
|
updateStreamingTransportOptions();
|
|
updateStreamingConfigVisibility();
|
|
});
|
|
}
|
|
}
|
|
|
|
function serializeStreamingConfig() {
|
|
if (selectedMode() === 'unary') {
|
|
return null;
|
|
}
|
|
|
|
var config = {
|
|
mode: selectedMode(),
|
|
transport_behavior: text('streaming-transport-behavior') || 'request_response',
|
|
aggregation_mode: text('streaming-aggregation-mode') || 'summary_plus_samples',
|
|
window_duration_ms: number('streaming-window-duration-ms'),
|
|
poll_interval_ms: number('streaming-poll-interval-ms'),
|
|
upstream_timeout_ms: number('streaming-upstream-timeout-ms'),
|
|
idle_timeout_ms: number('streaming-idle-timeout-ms'),
|
|
max_session_lifetime_ms: number('streaming-session-lifetime-ms'),
|
|
max_items: number('streaming-max-items'),
|
|
max_bytes: number('streaming-max-bytes'),
|
|
max_field_length: number('streaming-max-field-length'),
|
|
sampling_rate: number('streaming-sampling-rate'),
|
|
items_path: text('streaming-items-path') || null,
|
|
summary_path: text('streaming-summary-path') || null,
|
|
done_path: text('streaming-done-path') || null,
|
|
cursor_path: text('streaming-cursor-path') || null,
|
|
status_path: text('streaming-status-path') || null,
|
|
redacted_paths: lines('streaming-redacted-paths'),
|
|
truncate_item_fields: checked('streaming-truncate-item-fields'),
|
|
drop_duplicates: checked('streaming-drop-duplicates'),
|
|
tool_family: {},
|
|
};
|
|
|
|
if (config.mode === 'session') {
|
|
config.tool_family.start_tool_name = text('streaming-start-tool-name') || null;
|
|
config.tool_family.poll_tool_name = text('streaming-poll-tool-name') || null;
|
|
config.tool_family.stop_tool_name = text('streaming-stop-tool-name') || null;
|
|
} else if (config.mode === 'async_job') {
|
|
config.tool_family.start_tool_name = text('streaming-start-tool-name') || null;
|
|
config.tool_family.status_tool_name = text('streaming-status-tool-name') || null;
|
|
config.tool_family.result_tool_name = text('streaming-result-tool-name') || null;
|
|
config.tool_family.cancel_tool_name = text('streaming-cancel-tool-name') || null;
|
|
}
|
|
|
|
return config;
|
|
}
|
|
|
|
function validateStreamingConfig(capabilities) {
|
|
var config = serializeStreamingConfig();
|
|
if (!config) {
|
|
return { valid: true, errors: [] };
|
|
}
|
|
|
|
var errors = [];
|
|
var capability = (capabilities || []).find(function(item) {
|
|
return item.protocol === window.wizardProtocol;
|
|
});
|
|
|
|
if (capability && Array.isArray(capability.supports_execution_modes)) {
|
|
var supported = capability.supports_execution_modes.map(String);
|
|
if (supported.indexOf(config.mode) === -1) {
|
|
errors.push('Selected execution mode is not supported by the current protocol.');
|
|
}
|
|
}
|
|
|
|
if (!config.max_items || config.max_items <= 0) {
|
|
errors.push('Max items must be a positive integer.');
|
|
}
|
|
|
|
if (!config.max_bytes || config.max_bytes <= 0) {
|
|
errors.push('Max bytes must be a positive integer.');
|
|
}
|
|
|
|
if (config.mode === 'window' && (!config.window_duration_ms || config.window_duration_ms <= 0)) {
|
|
errors.push('Window duration must be set for window mode.');
|
|
}
|
|
|
|
if (config.mode === 'session' && (!config.poll_interval_ms || config.poll_interval_ms <= 0)) {
|
|
errors.push('Poll interval must be set for session mode.');
|
|
}
|
|
|
|
if (config.mode === 'async_job' && (!config.max_session_lifetime_ms || config.max_session_lifetime_ms <= 0)) {
|
|
errors.push('Session lifetime must be set for async job mode.');
|
|
}
|
|
|
|
return {
|
|
valid: errors.length === 0,
|
|
errors: errors,
|
|
config: config,
|
|
};
|
|
}
|
|
|
|
window.CrankStreamingForm = {
|
|
selectedStreamingMode: selectedMode,
|
|
bindStreamingConfigControls: bindStreamingConfigControls,
|
|
collectStreamingConfig: serializeStreamingConfig,
|
|
applyStreamingConfig: function(streaming) {
|
|
updateStreamingModeOptions(streaming && streaming.mode ? streaming.mode : 'unary');
|
|
if (!streaming) {
|
|
updateStreamingConfigVisibility();
|
|
return;
|
|
}
|
|
|
|
if (streaming.window_duration_ms != null) set('streaming-window-duration-ms', String(streaming.window_duration_ms));
|
|
if (streaming.poll_interval_ms != null) set('streaming-poll-interval-ms', String(streaming.poll_interval_ms));
|
|
if (streaming.upstream_timeout_ms != null) set('streaming-upstream-timeout-ms', String(streaming.upstream_timeout_ms));
|
|
if (streaming.idle_timeout_ms != null) set('streaming-idle-timeout-ms', String(streaming.idle_timeout_ms));
|
|
if (streaming.max_session_lifetime_ms != null) set('streaming-session-lifetime-ms', String(streaming.max_session_lifetime_ms));
|
|
if (streaming.max_items != null) set('streaming-max-items', String(streaming.max_items));
|
|
if (streaming.max_bytes != null) set('streaming-max-bytes', String(streaming.max_bytes));
|
|
if (streaming.max_field_length != null) set('streaming-max-field-length', String(streaming.max_field_length));
|
|
if (streaming.sampling_rate != null) set('streaming-sampling-rate', String(streaming.sampling_rate));
|
|
set('streaming-items-path', streaming.items_path || '');
|
|
set('streaming-summary-path', streaming.summary_path || '');
|
|
set('streaming-done-path', streaming.done_path || '');
|
|
set('streaming-cursor-path', streaming.cursor_path || '');
|
|
set('streaming-status-path', streaming.status_path || '');
|
|
set('streaming-redacted-paths', (streaming.redacted_paths || []).join('\n'));
|
|
var truncate = document.getElementById('streaming-truncate-item-fields');
|
|
if (truncate) truncate.checked = !!streaming.truncate_item_fields;
|
|
var dedupe = document.getElementById('streaming-drop-duplicates');
|
|
if (dedupe) dedupe.checked = !!streaming.drop_duplicates;
|
|
set('streaming-aggregation-mode', streaming.aggregation_mode || 'summary_plus_samples');
|
|
|
|
updateStreamingTransportOptions(streaming.transport_behavior);
|
|
|
|
var toolFamily = streaming.tool_family || {};
|
|
set('streaming-start-tool-name', toolFamily.start_tool_name || '');
|
|
set('streaming-poll-tool-name', toolFamily.poll_tool_name || '');
|
|
set('streaming-stop-tool-name', toolFamily.stop_tool_name || '');
|
|
set('streaming-status-tool-name', toolFamily.status_tool_name || '');
|
|
set('streaming-result-tool-name', toolFamily.result_tool_name || '');
|
|
set('streaming-cancel-tool-name', toolFamily.cancel_tool_name || '');
|
|
|
|
updateStreamingConfigVisibility();
|
|
},
|
|
serializeStreamingConfig: serializeStreamingConfig,
|
|
deserializeStreamingConfig: function(streaming) {
|
|
if (typeof window.applyStreamingConfig === 'function') {
|
|
window.applyStreamingConfig(streaming);
|
|
}
|
|
},
|
|
validateStreamingConfig: validateStreamingConfig,
|
|
};
|
|
}());
|