feat(ui): add some error tracking

core/src/main/java/io/kestra/core/services/CollectorService.java

@@ -116,7 +116,7 @@ public void report() {
  );
  this.handleResponse(result);
  } catch (HttpClientResponseException t) {
- log.warn("Unable to report anonymous usage with body '{}'", t.getResponse().getBody(String.class), t);
+ log.debug("Unable to report anonymous usage with body '{}'", t.getResponse().getBody(String.class), t);
  } catch (Exception t) {
  log.error("Unable to handle anonymous usage", t);
  }

ui/src/App.vue

@@ -19,6 +19,7 @@
  import Errors from "./components/errors/Errors.vue";
  import {mapState} from "vuex";
  import Utils from "./utils/utils";
+ import {pageFromRoute} from "@/utils/eventsRouter";
 
  export default {
  name: "App",
@@ -66,6 +67,11 @@
  this.$store.dispatch("plugin/icons")
  this.$store.dispatch("misc/loadConfigs")
  .then(value => {
+ this.$store.dispatch("api/events", {
+ type: "PAGE",
+ page: pageFromRoute(this.$router.currentRoute.value)
+ });
+
  this.$store.dispatch("api/loadFeeds", {
  version: value.version,
  iid: value.uuid,

ui/src/components/ErrorToast.vue

@@ -1,5 +1,6 @@
 <script>
  import {ElNotification, ElTable, ElTableColumn} from "element-plus";
+ import {pageFromRoute} from "@/utils/eventsRouter";
  import {h} from "vue"
 
  export default {
@@ -43,6 +44,29 @@
  this.$nextTick(() => {
  this.close();
 
+ const error = {
+ type: "ERROR",
+ error: {
+ message: this.text,
+ errors: this.items,
+ },
+ page: pageFromRoute(this.$route)
+ };
+
+ if (this.message.response) {
+ error.error.response = {};
+ error.error.request = {};
+
+ if (this.message.response.status) {
+ error.error.response.status = this.message.response.status;
+ }
+
+ error.error.request.url = this.message.response.config.url;
+ error.error.request.method = this.message.response.config.method;
+ }
+
+ this.$store.dispatch("api/events", error);
+
  const children = [
  h("span", {innerHTML: this.text})
  ];

ui/src/components/Tabs.vue

@@ -7,7 +7,6 @@
  :label="tab.title"
  :name="tab.name || 'default'"
  :disabled="tab.disabled"
- @tab-change="tabChanged"
  >
  <template #label>
  <router-link :to="to(tab)">
@@ -75,9 +74,6 @@
  return {name: this.routeName, params: {...this.$route.params, ...{tab: tab.name}}};
  }
  },
- tabChanged() {
- console.log(arguments);
- }
  },
  computed: {
  activeTab() {

ui/src/components/inputs/Editor.vue

@@ -246,7 +246,6 @@
 
  if (!this.fullHeight) {
  editor.onDidContentSizeChange(e => {
- console.log()
  this.$refs.container.style.height = (e.contentHeight + 7) + "px";
  });
  }

ui/src/stores/api.js

@@ -1,3 +1,7 @@
+import axios from "axios";
+
+let counter = 0;
+const API_URL = "https://api.kestra.io";
 
 export default {
  namespaced: true,
@@ -7,7 +11,7 @@ export default {
 
  actions: {
  loadFeeds({commit}, options) {
- return this.$http.get("https://api.kestra.io/v1/feeds/latest", {
+ return axios.get(API_URL + "/v1/feeds/latest", {
  params: {
  iid: options.iid,
  uid: options.uid,
@@ -18,6 +22,24 @@ export default {
 
  return response.data;
  })
+ },
+ events({rootGetters}, data) {
+ let configs = rootGetters["misc/configs"];
+ let uid = localStorage.getItem("uid");
+
+ if (configs === undefined || uid === null || configs["isAnonymousUsageEnabled"] === false) {
+ return;
+ }
+
+ return axios.post(API_URL + "/v1/reports/events", {
+ ...data,
+ ...{
+ iid: configs.uuid,
+ uid: uid,
+ date: new Date().toISOString(),
+ counter: counter++,
+ }
+ });
  }
  },
  mutations: {

ui/src/stores/miscs.js

@@ -18,5 +18,9 @@ export default {
  state.configs = configs
  }
  },
- getters: {}
+ getters: {
+ configs(state) {
+ return state.configs;
+ }
+ }
 }

ui/src/utils/axios.js

@@ -79,6 +79,7 @@ export default (callback, store, router) => {
  }, errorResponse => {
  if (errorResponse.code && errorResponse.code === "ECONNABORTED") {
  store.dispatch("core/showMessage", {
+ response: errorResponse,
  content: errorResponse,
  variant: "error"
  })
@@ -114,6 +115,7 @@ export default (callback, store, router) => {
 
  if (errorResponse.response.data) {
  store.dispatch("core/showMessage", {
+ response: errorResponse.response,
  content: errorResponse.response.data,
  variant: "error"
  })

ui/src/utils/eventsRouter.js

@@ -0,0 +1,27 @@
+import {nextTick} from "vue";
+
+export const pageFromRoute = (route) => {
+ return {
+ origin: window.location.origin,
+ path: route.path,
+ params: Object.keys(route.params)
+ .map((key) => ({key: key, value: route.params[key]})),
+ queries: Object.keys(route.query)
+ .map((key) => {
+ return {key: key, values: (route.query[key] instanceof Array ? route.query[key] : [route.query[key]] )}
+ }),
+ name: route.name,
+ hash: route.hash !== "" ? route.hash: undefined,
+ }
+}
+
+export default (app, store, router) => {
+ router.afterEach((to) => {
+ nextTick().then(() => {
+ store.dispatch("api/events", {
+ type: "PAGE",
+ page: pageFromRoute(to)
+ });
+ });
+ });
+}

ui/src/utils/init.js

@@ -13,6 +13,7 @@ import Toast from "./toast";
 import filters from "./filters";
 import ElementPlus from "element-plus";
 import createUnsavedChanged from "./unsavedChange";
+import createEventsRouter from "./eventsRouter";
 import "./global"
 
 export default (app, routes, stores, translations) => {
@@ -83,6 +84,7 @@ export default (app, routes, stores, translations) => {
 
  // navigation guard
  createUnsavedChanged(app, store, router);
+ createEventsRouter(app, store, router);
 
  return {store, router};
 }

webserver/src/main/java/io/kestra/webserver/controllers/MiscController.java

@@ -1,5 +1,6 @@
 package io.kestra.webserver.controllers;
 
+import com.fasterxml.jackson.annotation.JsonInclude;
 import io.kestra.core.repositories.ExecutionRepositoryInterface;
 import io.kestra.core.services.InstanceService;
 import io.kestra.core.utils.VersionProvider;
@@ -27,6 +28,9 @@ public class MiscController {
  @Inject
  InstanceService instanceService;
 
+ @io.micronaut.context.annotation.Value("${kestra.anonymous-usage-report.enabled}")
+ protected Boolean isAnonymousUsageEnabled;
+
  @Get("/ping")
  @Hidden
  public HttpResponse<?> ping() {
@@ -42,14 +46,21 @@ public Configuration configuration() {
  .uuid(instanceService.fetch())
  .version(versionProvider.getVersion())
  .isTaskRunEnabled(executionRepository.isTaskRunEnabled())
+ .isAnonymousUsageEnabled(this.isAnonymousUsageEnabled)
  .build();
  }
 
  @Value
  @Builder
  public static class Configuration {
  String uuid;
+
  String version;
+
+ @JsonInclude
  Boolean isTaskRunEnabled;
+
+ @JsonInclude
+ Boolean isAnonymousUsageEnabled;
  }
 }