refactor: Use Web Workers to process seismic data

CHANGELOG.md

@@ -2,6 +2,21 @@
 
 Starting from v2.2.5, all notable changes to this project will be documented in this file.
 
+# v3.3.2
+
+### Bug Fixes
+
+- Handle auto flag properly for event data sources of China.
+- Fixed occasional checksum error in legacy mode.
+
+### Refactor
+
+- Use Web Workers to process seismic data.
+
+### Chore
+
+- chore: Update slgo dependency to v0.0.4.
+
 ## v3.3.1
 
 ### Bug Fixes

VERSION

@@ -1 +1 @@
-v3.3.1
+v3.3.2

frontend/src/craco.config.ts

@@ -38,6 +38,19 @@ module.exports = {
 			const buildPath = resolve(__dirname, "..", "dist");
 			webpackConfig.output!.path = buildPath;
 			paths.appBuild = buildPath;
+
+            // Add worker-loader for Web Workers
+			webpackConfig.module!.rules!.unshift({
+				test: /\.worker\.ts$/,
+				use: {
+					loader: "worker-loader",
+					options: {
+						// Use directory structure & typical names of chunks produces by "react-scripts"
+						filename: "static/js/[name].[contenthash:8].js"
+					}
+				}
+			});
+
 			return webpackConfig;
 		}
 	}

frontend/src/package.json

@@ -12,6 +12,8 @@
         "@mui/x-date-pickers": "^6.16.0",
         "@reduxjs/toolkit": "^1.9.6",
         "axios": "^1.5.1",
+        "bignumber.js": "^9.1.2",
+        "comlink": "^4.4.1",
         "date-fns": "^2.30.0",
         "file-saver": "^2.0.5",
         "formik": "^2.4.6",
@@ -68,6 +70,7 @@
         "react-scripts": "5.0.1",
         "tailwindcss": "^3.3.3",
         "tailwindcss-animated": "^1.0.1",
-        "typescript": "^4.9.5"
+        "typescript": "^4.9.5",
+        "worker-loader": "3.0.x"
     }
 }

frontend/src/src/Main.tsx

@@ -19,10 +19,9 @@ import { ReduxStoreProps } from "./config/store";
 import { sendUserAlert } from "./helpers/interact/sendUserAlert";
 import { sendUserConfirm } from "./helpers/interact/sendUserConfirm";
 import { requestRestApi } from "./helpers/request/requestRestApi";
-import { onUpdate as UpdateADC } from "./stores/adc";
 import { onUpdate as UpdateCredential } from "./stores/credential";
-import { onUpdate as UpdateGeophone } from "./stores/geophone";
-import { onUpdate as UpdateStation } from "./stores/station";
+import { onUpdate as UpdateSensor } from "./stores/sensor";
+import { onUpdate as UpdateStation } from "./stores/stream";
 
 interface MainProps {
 	currentLocale: string;
@@ -94,13 +93,10 @@ export const Main = ({ currentLocale, locales, onSwitchLocale, onLoginStateChang
 			endpoint: endpoints.station
 		});
 		if (res?.data) {
-			const initialized = true;
-			const { sensitivity, frequency } = res.data.sensor;
-			dispatch(UpdateGeophone({ sensitivity, frequency, initialized }));
-			const { resolution, fullscale } = res.data.sensor;
-			dispatch(UpdateADC({ resolution, fullscale, initialized }));
+			const { resolution, velocity } = res.data.sensor;
+			dispatch(UpdateSensor({ resolution, velocity, initialized: true }));
 			const { station, network, location, channel } = res.data.stream;
-			dispatch(UpdateStation({ station, network, location, initialized, channel }));
+			dispatch(UpdateStation({ station, network, location, channel, initialized: true }));
 		}
 	}, [dispatch]);
 	useEffect(() => {

frontend/src/src/config/global.tsx

@@ -1,10 +1,3 @@
-import {
-	CSISIntensityStandard,
-	CWAIntensityStandard,
-	IntensityStandard,
-	JMAIntensityStandard,
-	MMIIntensityStandard
-} from "../helpers/seismic/intensityStandard";
 import { i18nConfig } from "./i18n";
 
 interface GlobalConfig {
@@ -23,31 +16,20 @@ interface GlobalConfig {
 		readonly maximum: number;
 		readonly minimum: number;
 	};
-	readonly scales: IntensityStandard[];
 	readonly footer: Record<keyof typeof i18nConfig.resources, string>;
 }
 
-const scales = [
-	new JMAIntensityStandard(),
-	new CWAIntensityStandard(),
-	new MMIIntensityStandard(),
-	new CSISIntensityStandard()
-];
-
 export const globalConfig: GlobalConfig = {
-	scales,
 	name: "Observer",
 	author: "AnyShake",
 	title: "AnyShake Observer",
 	homepage: "https://anyshake.org",
-	repository: "https://github.com/AnyShake",
+	repository: "https://github.com/anyshake/observer",
 	duration: { default: 300, maximum: 3600, minimum: 10 },
 	retention: { default: 120, maximum: 600, minimum: 10 },
 	footer: {
-		"en-US": "Constructing Realtime Seismic Network Ambitiously.",
-		"zh-CN": "雄心勃勃，致力于构建实时地震网络",
-		"zh-TW": "雄心勃勃，致力於建置即時地震網路"
+		"en-US": "Listen to the whispering earth.",
+		"zh-CN": "听见地球。",
+		"zh-TW": "聽見地球。",
 	}
 };
-
-export const fallbackScale = scales[0];