[sqlite] Implement processing thread activity on web worker
ClosedPublic
Actions

Authored by will on Apr 9 2024, 10:58 PM.

Details

Reviewers

atul
kamil

Commits

rCOMMc175e1714d27: [sqlite] Implement processing thread activity on web worker

Summary

This code introduces the thread activity store sqlite ops to web worker

Depends on D11614

Test Plan

Ran the following code on web and confirmed the results:

await sharedWorker.schedule({
  type: workerRequestMessageTypes.PROCESS_STORE_OPERATIONS,
  storeOperations: {
    threadActivityStoreOperations: [
      {
        type: 'replace_thread_activity_entry',
        payload: {
          id: 'worker_test_A_id',
          threadActivityStoreEntry: JSON.stringify({
            lastNavigatedTo: 1,
            lastPruned: 2,
          }),
        },
      },
      {
        type: 'replace_thread_activity_entry',
        payload: {
          id: 'worker_test_B_id',
          threadActivityStoreEntry: JSON.stringify({
            lastNavigatedTo: 3,
            lastPruned: 4,
          }),
        },
      },
      {
        type: 'remove_thread_activity_entries',
        payload: {
          ids: ['worker_test_B_id'],
        },
      },
    ],
  },
});

Screenshot 2024-04-09 at 4.09.11 PM.png (1×1 px, 263 KB)

Diff Detail

Repository

rCOMM Comm

Lint

Lint Not Applicable

Unit

Tests Not Applicable

Event Timeline

will created this revision.Apr 9 2024, 10:58 PM

Herald added subscribers: tomek, ashoat. · View Herald TranscriptApr 9 2024, 10:58 PM

will edited the summary of this revision. (Show Details)Apr 9 2024, 10:59 PM

will edited the test plan for this revision. (Show Details)

will added a parent revision: D11614: [sqlite] Implement C++ code for native to get sqlite thread activity entries.

will edited the test plan for this revision. (Show Details)

will added a child revision: D11616: [native] migrate threadActivityStore to SQLite.Apr 9 2024, 11:05 PM

Harbormaster completed remote builds in B28118: Diff 38974.Apr 9 2024, 11:13 PM

will requested review of this revision.Apr 9 2024, 11:13 PM

kamil accepted this revision.Apr 10 2024, 5:42 AM

This revision is now accepted and ready to land.Apr 10 2024, 5:42 AM

Closed by commit rCOMMc175e1714d27: [sqlite] Implement processing thread activity on web worker (authored by will). · Explain WhyApr 19 2024, 1:08 PM

This revision was automatically updated to reflect the committed changes.

will added a commit: rCOMMc175e1714d27: [sqlite] Implement processing thread activity on web worker.

Revision Contents
Changeset List

Path

Size

lib/

types/

store-ops-types.js

6 lines

web/

shared-worker/

worker/

process-operations.js

48 lines

Diff 39321

View Options

lib/types/store-ops-types.js

	// @flow			// @flow

				import { useActionSheet } from '@expo/react-native-action-sheet';
				import invariant from 'invariant';
	import * as React from 'react';			import * as React from 'react';
	import { View, Text } from 'react-native';			import { View, Text, TouchableOpacity, Platform } from 'react-native';
				import { useSafeAreaInsets } from 'react-native-safe-area-context';

				import { NeynarClientContext } from 'lib/components/neynar-client-provider.react.js';
				import { useCurrentUserFID } from 'lib/utils/farcaster-utils.js';

	import type { TagFarcasterChannelNavigationProp } from './tag-farcaster-channel-navigator.react';			import type { TagFarcasterChannelNavigationProp } from './tag-farcaster-channel-navigator.react';
	import type { NavigationRoute } from '../../navigation/route-names';			import SWMansionIcon from '../../components/swmansion-icon.react.js';
				import { type NavigationRoute } from '../../navigation/route-names.js';
				import { useSelector } from '../../redux/redux-utils.js';
				import { useStyles, useColors } from '../../themes/colors.js';

	type Props = {			type Props = {
	+navigation: TagFarcasterChannelNavigationProp<'TagFarcasterChannel'>,			+navigation: TagFarcasterChannelNavigationProp<'TagFarcasterChannel'>,
	+route: NavigationRoute<'TagFarcasterChannel'>,			+route: NavigationRoute<'TagFarcasterChannel'>,
	};			};

	// eslint-disable-next-line no-unused-vars			// eslint-disable-next-line no-unused-vars
	function TagFarcasterChannel(props: Props): React.Node {			function TagFarcasterChannel(props: Props): React.Node {
				const styles = useStyles(unboundStyles);

				const colors = useColors();

				const fid = useCurrentUserFID();
				invariant(fid, 'FID should be set');

				const [selectedChannel, setSelectedChannel] = React.useState<?string>(null);

				const [channelOptions, setChannelOptions] = React.useState<
				$ReadOnlyArray<string>,
				>([]);

				const neynarClientContext = React.useContext(NeynarClientContext);
				invariant(neynarClientContext, 'NeynarClientContext is missing');

				const { client } = neynarClientContext;

				React.useEffect(() => {
				void (async () => {
				const data = await client.fetchFollowedFarcasterChannels(fid);

				const result = data.map(channel => channel.name);

				setChannelOptions(result);
				})();
				}, [client, fid]);

				const activeTheme = useSelector(state => state.globalThemeInfo.activeTheme);

				const { showActionSheetWithOptions } = useActionSheet();

				const insets = useSafeAreaInsets();

				const onOptionSelected = React.useCallback(
				(selectedIndex: ?number) => {
				if (
				selectedIndex === undefined \|\|
				selectedIndex === null \|\|
				selectedIndex === channelOptions.length
				) {
				return;
				}

				setSelectedChannel(channelOptions[selectedIndex]);
				},
				[channelOptions],
				);

				const onPressSelectChannel = React.useCallback(() => {
				const options =
				Platform.OS === 'ios' ? [...channelOptions, 'Cancel'] : channelOptions;

				const cancelButtonIndex = Platform.OS === 'ios' ? options.length - 1 : -1;

				const containerStyle = {
				paddingBottom: insets.bottom,
				};

				showActionSheetWithOptions(
				{
				options,
				cancelButtonIndex,
				containerStyle,
				userInterfaceStyle: activeTheme ?? 'dark',
				},
				onOptionSelected,
				);
				}, [
				activeTheme,
				channelOptions,
				insets.bottom,
				onOptionSelected,
				showActionSheetWithOptions,
				]);

				const channelSelectionStyles = React.useMemo(
				() => [styles.sectionContainer, styles.touchableSectionContainer],
				[styles.sectionContainer, styles.touchableSectionContainer],
				);

				const channelSelectionTextContent = selectedChannel
				? selectedChannel
				: 'No Farcaster channel tagged';

	const tagFarcasterChannel = React.useMemo(			const tagFarcasterChannel = React.useMemo(
	() => (			() => (
	<View>			<View>
	<Text>TagFarcasterChannel</Text>			<View style={styles.sectionContainer}>
				<Text style={styles.sectionText}>
				Tag a Farcaster channel so followers can find your Comm community!
				</Text>
				</View>
				<Text style={styles.sectionHeaderText}>FARCASTER CHANNEL</Text>
				<TouchableOpacity
				style={channelSelectionStyles}
				onPress={onPressSelectChannel}
				>
				<Text style={styles.sectionText}>{channelSelectionTextContent}</Text>
				<SWMansionIcon
				name="edit-1"
				size={20}
				color={colors.panelForegroundSecondaryLabel}
				/>
				</TouchableOpacity>
	</View>			</View>
	),			),
	[],			[
				styles.sectionContainer,
				styles.sectionText,
				styles.sectionHeaderText,
				channelSelectionStyles,
				onPressSelectChannel,
				channelSelectionTextContent,
				colors.panelForegroundSecondaryLabel,
				],
	);			);

	return tagFarcasterChannel;			return tagFarcasterChannel;
	}			}

				const unboundStyles = {
				sectionContainer: {
				backgroundColor: 'panelForeground',
				marginBottom: 24,
				padding: 16,
				},
				sectionText: {
				color: 'panelForegroundLabel',
				fontSize: 14,
				},
				sectionHeaderText: {
				fontSize: 14,
				fontWeight: '400',
				lineHeight: 20,
				color: 'panelForegroundLabel',
				paddingHorizontal: 16,
				paddingBottom: 4,
				},
				touchableSectionContainer: {
				flexDirection: 'row',
				justifyContent: 'space-between',
				alignItems: 'center',
				},
				};

	export default TagFarcasterChannel;			export default TagFarcasterChannel;