Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion src/Frontend/src/stores/ConfigurationStore.ts
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ export const useConfigurationStore = defineStore("ConfigurationStore", () => {

return {
configuration,
refresh,
isMassTransitConnected,
};
});
Expand Down
25 changes: 0 additions & 25 deletions src/Frontend/src/stores/EditRetryStore.ts

This file was deleted.

20 changes: 13 additions & 7 deletions src/Frontend/src/stores/MessageStore.ts
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
import { acceptHMRUpdate, defineStore, storeToRefs } from "pinia";
import { computed, reactive, Ref, ref } from "vue";
import { computed, reactive, Ref, ref, watch } from "vue";
import Header from "@/resources/Header";
import type EndpointDetails from "@/resources/EndpointDetails";
import { FailedMessage, ExceptionDetails, FailedMessageStatus } from "@/resources/FailedMessage";
import { useEditRetryStore } from "@/stores/EditRetryStore";
import { useConfigurationStore } from "@/stores/ConfigurationStore";
import Message, { MessageStatus } from "@/resources/Message";
import moment from "moment/moment";
import { parse, stringify } from "lossless-json";
import xmlFormat from "xml-formatter";
import { DataContainer } from "./DataContainer";
import { useServiceControlStore } from "./ServiceControlStore";
import { EditAndRetryConfig } from "@/resources/Configuration";
import EditRetryResponse from "@/resources/EditRetryResponse";
import { EditedMessage } from "@/resources/EditMessage";
import useEnvironmentAndVersionsAutoRefresh from "@/composables/useEnvironmentAndVersionsAutoRefresh";
Expand Down Expand Up @@ -65,22 +65,28 @@ export const useMessageStore = defineStore("MessageStore", () => {
const headers = ref<DataContainer<Header[]>>({ data: [] });
const body = ref<DataContainer<{ value?: string; content_type?: string; no_content?: boolean }>>({ data: {} });
const state = reactive<DataContainer<Model>>({ data: { failure_metadata: {}, failure_status: {}, dialog_status: {}, invoked_saga: {} } });
const edit_and_retry_config = ref<EditAndRetryConfig>({ enabled: false, locked_headers: [], sensitive_headers: [] });
const conversationData = ref<DataContainer<Message[]>>({ data: [] });

const editRetryResponse = ref<EditRetryResponse | null>(null);
let bodyLoadedId = "";
let conversationLoadedId = "";
const conversationData = ref<DataContainer<Message[]>>({ data: [] });
const editRetryStore = useEditRetryStore();

const configStore = useConfigurationStore();
const serviceControlStore = useServiceControlStore();
const { serviceControlUrl } = storeToRefs(serviceControlStore);
const { store: environmentStore } = useEnvironmentAndVersionsAutoRefresh();
const areSimpleHeadersSupported = environmentStore.serviceControlIsGreaterThan("5.2.0");

const { config: edit_and_retry_config } = storeToRefs(editRetryStore);
const { configuration } = storeToRefs(configStore);
const error_retention_period = computed(() => moment.duration(configuration.value?.data_retention?.error_retention_period).asHours());

// eslint-disable-next-line promise/catch-or-return,promise/prefer-await-to-then,promise/valid-params
Promise.all([editRetryStore.loadConfig(), configStore.refresh()]).then();
watch(serviceControlUrl, loadConfig, { immediate: true });
async function loadConfig() {
if (!serviceControlUrl.value) return;
const [, data] = await serviceControlStore.fetchTypedFromServiceControl<EditAndRetryConfig>("edit/config");
edit_and_retry_config.value = data;
}

function reset() {
state.data = { failure_metadata: {}, failure_status: {}, dialog_status: {}, invoked_saga: {} };
Expand Down
Loading