Page MenuHomePhabricator
Differential D13028

[SQLite] implement resetting Outbound P2P messages
ClosedPublic
Actions

Authored by kamil on Aug 8 2024, 4:23 AM.
Tags
None
Referenced Files
Unknown Object (File)
Sat, Apr 5, 12:19 PM
Unknown Object (File)
Sat, Apr 5, 5:36 AM
Unknown Object (File)
Thu, Apr 3, 10:22 PM
Unknown Object (File)
Feb 22 2025, 11:12 PM
Unknown Object (File)
Feb 22 2025, 11:11 PM
Unknown Object (File)
Feb 22 2025, 11:09 PM
Unknown Object (File)
Feb 6 2025, 2:06 AM
Unknown Object (File)
Jan 25 2025, 6:01 PM
View All 48 Files
Subscribers
ashoat

Details

Reviewers
tomek
Commits
rCOMMdacfe284e5b0: [SQLite] implement resetting Outbound P2P messages
Summary

ENG-6982.

It is possible to do it as one query but will be more complicated and less readable, I can update if reviewers think it worth it.

Each query is described in code comments.

Test Plan

Tests

Diff Detail

Repository
rCOMM Comm
Branch
resending-2
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

kamil created this revision.Aug 8 2024, 4:23 AM
kamil held this revision as a draft.
Herald added a subscriber: ashoat. · View Herald TranscriptAug 8 2024, 4:23 AM
kamil added a child revision: D13029: [web] introduce resetting Outbound P2P Messages to shared worker.Aug 8 2024, 4:25 AM
Harbormaster failed remote builds in B31007: Diff 43256!Aug 8 2024, 4:46 AM
kamil published this revision for review.Aug 8 2024, 5:06 AM
tomek accepted this revision.Aug 12 2024, 1:11 AM
tomek added inline comments.
native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp
2580–2611

What happens if one of them succeeds and one fails?

This revision is now accepted and ready to land.Aug 12 2024, 1:11 AM
kamil added inline comments.Aug 13 2024, 3:26 AM
native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp
2580–2611

good call, I am going to wrap this in transaction in the following diffs

Harbormaster completed remote builds in B31007: Diff 43256.Aug 13 2024, 3:43 AM
Closed by commit rCOMMdacfe284e5b0: [SQLite] implement resetting Outbound P2P messages (authored by kamil). · Explain WhyAug 13 2024, 4:10 AM
This revision was automatically updated to reflect the committed changes.
kamil added a commit: rCOMMdacfe284e5b0: [SQLite] implement resetting Outbound P2P messages.

Revision Contents
Changeset List

PathSize
native/
cpp/
CommonCpp/
DatabaseManagers/
2 lines
2 lines
78 lines
web/
cpp/
3 lines
shared-worker/
_generated/
queries/
82 lines
types/
1 line

Diff 43256

View Options

native/cpp/CommonCpp/DatabaseManagers/DatabaseQueryExecutor.h

Show All 27 Lines
import { import {
type ServerServerRequest, type ServerServerRequest,
serverServerRequestValidator, serverServerRequestValidator,
type ClientServerRequest, type ClientServerRequest,
type ClientResponse, type ClientResponse,
type ClientClientResponse, type ClientClientResponse,
} from './request-types.js'; } from './request-types.js';
import type { SessionState, SessionIdentification } from './session-types.js'; import type { SessionState, SessionIdentification } from './session-types.js';
import { type RawThreadInfos } from './thread-types.js'; import type {
RawThreadInfos,
MinimallyEncodedRawThreadInfos,
} from './thread-types.js';
import { import {
type ClientUpdatesResult, type ClientUpdatesResult,
type ClientUpdatesResultWithUserInfos, type ClientUpdatesResultWithUserInfos,
type ServerUpdatesResult, type ServerUpdatesResult,
serverUpdatesResultValidator, serverUpdatesResultValidator,
type ServerUpdatesResultWithUserInfos, type ServerUpdatesResultWithUserInfos,
serverUpdatesResultWithUserInfosValidator, serverUpdatesResultWithUserInfosValidator,
} from './update-types.js'; } from './update-types.js';
▲ Show 20 Lines • Show All 134 Lines • ▼ Show 20 Lines
export const stateSyncPayloadTypes = Object.freeze({ export const stateSyncPayloadTypes = Object.freeze({
FULL: 0, FULL: 0,
INCREMENTAL: 1, INCREMENTAL: 1,
}); });
export const fullStateSyncActionType = 'FULL_STATE_SYNC'; export const fullStateSyncActionType = 'FULL_STATE_SYNC';
export type BaseFullStateSync = { export type BaseFullStateSync = {
+messagesResult: MessagesResponse, +messagesResult: MessagesResponse,
+threadInfos: RawThreadInfos,
+rawEntryInfos: $ReadOnlyArray<RawEntryInfo>, +rawEntryInfos: $ReadOnlyArray<RawEntryInfo>,
+userInfos: $ReadOnlyArray<UserInfo>, +userInfos: $ReadOnlyArray<UserInfo>,
+updatesCurrentAsOf: number, +updatesCurrentAsOf: number,
}; };
const baseFullStateSyncValidator = tShape<BaseFullStateSync>({ const baseFullStateSyncValidator = tShape<BaseFullStateSync>({
messagesResult: messagesResponseValidator, messagesResult: messagesResponseValidator,
threadInfos: t.dict(tID, rawThreadInfoValidator),
rawEntryInfos: t.list(rawEntryInfoValidator), rawEntryInfos: t.list(rawEntryInfoValidator),
userInfos: t.list(userInfoValidator), userInfos: t.list(userInfoValidator),
updatesCurrentAsOf: t.Number, updatesCurrentAsOf: t.Number,
}); });
export type ClientFullStateSync = { export type ClientFullStateSync = $ReadOnly<{
...BaseFullStateSync, ...BaseFullStateSync,
+threadInfos: MinimallyEncodedRawThreadInfos,
+currentUserInfo: CurrentUserInfo, +currentUserInfo: CurrentUserInfo,
}; }>;
export type StateSyncFullActionPayload = { export type StateSyncFullActionPayload = $ReadOnly<{
...ClientFullStateSync, ...ClientFullStateSync,
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+keyserverID: string, +keyserverID: string,
}; }>;
export type ClientStateSyncFullSocketPayload = { export type ClientStateSyncFullSocketPayload = $ReadOnly<{
...ClientFullStateSync, ...ClientFullStateSync,
+type: 0, +type: 0,
// Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID // Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID
+sessionID?: string, +sessionID?: string,
}; }>;
export type ServerFullStateSync = { export type ServerFullStateSync = $ReadOnly<{
...BaseFullStateSync, ...BaseFullStateSync,
+threadInfos: RawThreadInfos,
+currentUserInfo: CurrentUserInfo, +currentUserInfo: CurrentUserInfo,
}; }>;
const serverFullStateSyncValidator = tShape<ServerFullStateSync>({ const serverFullStateSyncValidator = tShape<ServerFullStateSync>({
...baseFullStateSyncValidator.meta.props, ...baseFullStateSyncValidator.meta.props,
threadInfos: t.dict(tID, rawThreadInfoValidator),
currentUserInfo: currentUserInfoValidator, currentUserInfo: currentUserInfoValidator,
}); });
export type ServerStateSyncFullSocketPayload = { export type ServerStateSyncFullSocketPayload = {
atulAuthorUnsubmitted
Done
Inline Actions

Get the following when I try making this $ReadOnly:

922a45.png (754×1 px, 374 KB)

atul: Get the following when I try making this `$ReadOnly`: {F1058362}
...ServerFullStateSync, ...ServerFullStateSync,
+type: 0, +type: 0,
// Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID // Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID
+sessionID?: string, +sessionID?: string,
}; };
const serverStateSyncFullSocketPayloadValidator = const serverStateSyncFullSocketPayloadValidator =
tShape<ServerStateSyncFullSocketPayload>({ tShape<ServerStateSyncFullSocketPayload>({
...serverFullStateSyncValidator.meta.props, ...serverFullStateSyncValidator.meta.props,
▲ Show 20 Lines • Show All 328 Lines • Show Last 20 Lines
View Options

native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.h

Show All 27 Lines
import { import {
type ServerServerRequest, type ServerServerRequest,
serverServerRequestValidator, serverServerRequestValidator,
type ClientServerRequest, type ClientServerRequest,
type ClientResponse, type ClientResponse,
type ClientClientResponse, type ClientClientResponse,
} from './request-types.js'; } from './request-types.js';
import type { SessionState, SessionIdentification } from './session-types.js'; import type { SessionState, SessionIdentification } from './session-types.js';
import { type RawThreadInfos } from './thread-types.js'; import type {
RawThreadInfos,
MinimallyEncodedRawThreadInfos,
} from './thread-types.js';
import { import {
type ClientUpdatesResult, type ClientUpdatesResult,
type ClientUpdatesResultWithUserInfos, type ClientUpdatesResultWithUserInfos,
type ServerUpdatesResult, type ServerUpdatesResult,
serverUpdatesResultValidator, serverUpdatesResultValidator,
type ServerUpdatesResultWithUserInfos, type ServerUpdatesResultWithUserInfos,
serverUpdatesResultWithUserInfosValidator, serverUpdatesResultWithUserInfosValidator,
} from './update-types.js'; } from './update-types.js';
▲ Show 20 Lines • Show All 134 Lines • ▼ Show 20 Lines
export const stateSyncPayloadTypes = Object.freeze({ export const stateSyncPayloadTypes = Object.freeze({
FULL: 0, FULL: 0,
INCREMENTAL: 1, INCREMENTAL: 1,
}); });
export const fullStateSyncActionType = 'FULL_STATE_SYNC'; export const fullStateSyncActionType = 'FULL_STATE_SYNC';
export type BaseFullStateSync = { export type BaseFullStateSync = {
+messagesResult: MessagesResponse, +messagesResult: MessagesResponse,
+threadInfos: RawThreadInfos,
+rawEntryInfos: $ReadOnlyArray<RawEntryInfo>, +rawEntryInfos: $ReadOnlyArray<RawEntryInfo>,
+userInfos: $ReadOnlyArray<UserInfo>, +userInfos: $ReadOnlyArray<UserInfo>,
+updatesCurrentAsOf: number, +updatesCurrentAsOf: number,
}; };
const baseFullStateSyncValidator = tShape<BaseFullStateSync>({ const baseFullStateSyncValidator = tShape<BaseFullStateSync>({
messagesResult: messagesResponseValidator, messagesResult: messagesResponseValidator,
threadInfos: t.dict(tID, rawThreadInfoValidator),
rawEntryInfos: t.list(rawEntryInfoValidator), rawEntryInfos: t.list(rawEntryInfoValidator),
userInfos: t.list(userInfoValidator), userInfos: t.list(userInfoValidator),
updatesCurrentAsOf: t.Number, updatesCurrentAsOf: t.Number,
}); });
export type ClientFullStateSync = { export type ClientFullStateSync = $ReadOnly<{
...BaseFullStateSync, ...BaseFullStateSync,
+threadInfos: MinimallyEncodedRawThreadInfos,
+currentUserInfo: CurrentUserInfo, +currentUserInfo: CurrentUserInfo,
}; }>;
export type StateSyncFullActionPayload = { export type StateSyncFullActionPayload = $ReadOnly<{
...ClientFullStateSync, ...ClientFullStateSync,
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+keyserverID: string, +keyserverID: string,
}; }>;
export type ClientStateSyncFullSocketPayload = { export type ClientStateSyncFullSocketPayload = $ReadOnly<{
...ClientFullStateSync, ...ClientFullStateSync,
+type: 0, +type: 0,
// Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID // Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID
+sessionID?: string, +sessionID?: string,
}; }>;
export type ServerFullStateSync = { export type ServerFullStateSync = $ReadOnly<{
...BaseFullStateSync, ...BaseFullStateSync,
+threadInfos: RawThreadInfos,
+currentUserInfo: CurrentUserInfo, +currentUserInfo: CurrentUserInfo,
}; }>;
const serverFullStateSyncValidator = tShape<ServerFullStateSync>({ const serverFullStateSyncValidator = tShape<ServerFullStateSync>({
...baseFullStateSyncValidator.meta.props, ...baseFullStateSyncValidator.meta.props,
threadInfos: t.dict(tID, rawThreadInfoValidator),
currentUserInfo: currentUserInfoValidator, currentUserInfo: currentUserInfoValidator,
}); });
export type ServerStateSyncFullSocketPayload = { export type ServerStateSyncFullSocketPayload = {
atulAuthorUnsubmitted
Done
Inline Actions

Get the following when I try making this $ReadOnly:

922a45.png (754×1 px, 374 KB)

atul: Get the following when I try making this `$ReadOnly`: {F1058362}
...ServerFullStateSync, ...ServerFullStateSync,
+type: 0, +type: 0,
// Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID // Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID
+sessionID?: string, +sessionID?: string,
}; };
const serverStateSyncFullSocketPayloadValidator = const serverStateSyncFullSocketPayloadValidator =
tShape<ServerStateSyncFullSocketPayload>({ tShape<ServerStateSyncFullSocketPayload>({
...serverFullStateSyncValidator.meta.props, ...serverFullStateSyncValidator.meta.props,
▲ Show 20 Lines • Show All 328 Lines • Show Last 20 Lines
View Options

native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp

Show All 27 Lines
import { import {
type ServerServerRequest, type ServerServerRequest,
serverServerRequestValidator, serverServerRequestValidator,
type ClientServerRequest, type ClientServerRequest,
type ClientResponse, type ClientResponse,
type ClientClientResponse, type ClientClientResponse,
} from './request-types.js'; } from './request-types.js';
import type { SessionState, SessionIdentification } from './session-types.js'; import type { SessionState, SessionIdentification } from './session-types.js';
import { type RawThreadInfos } from './thread-types.js'; import type {
RawThreadInfos,
MinimallyEncodedRawThreadInfos,
} from './thread-types.js';
import { import {
type ClientUpdatesResult, type ClientUpdatesResult,
type ClientUpdatesResultWithUserInfos, type ClientUpdatesResultWithUserInfos,
type ServerUpdatesResult, type ServerUpdatesResult,
serverUpdatesResultValidator, serverUpdatesResultValidator,
type ServerUpdatesResultWithUserInfos, type ServerUpdatesResultWithUserInfos,
serverUpdatesResultWithUserInfosValidator, serverUpdatesResultWithUserInfosValidator,
} from './update-types.js'; } from './update-types.js';
▲ Show 20 Lines • Show All 134 Lines • ▼ Show 20 Lines
export const stateSyncPayloadTypes = Object.freeze({ export const stateSyncPayloadTypes = Object.freeze({
FULL: 0, FULL: 0,
INCREMENTAL: 1, INCREMENTAL: 1,
}); });
export const fullStateSyncActionType = 'FULL_STATE_SYNC'; export const fullStateSyncActionType = 'FULL_STATE_SYNC';
export type BaseFullStateSync = { export type BaseFullStateSync = {
+messagesResult: MessagesResponse, +messagesResult: MessagesResponse,
+threadInfos: RawThreadInfos,
+rawEntryInfos: $ReadOnlyArray<RawEntryInfo>, +rawEntryInfos: $ReadOnlyArray<RawEntryInfo>,
+userInfos: $ReadOnlyArray<UserInfo>, +userInfos: $ReadOnlyArray<UserInfo>,
+updatesCurrentAsOf: number, +updatesCurrentAsOf: number,
}; };
const baseFullStateSyncValidator = tShape<BaseFullStateSync>({ const baseFullStateSyncValidator = tShape<BaseFullStateSync>({
messagesResult: messagesResponseValidator, messagesResult: messagesResponseValidator,
threadInfos: t.dict(tID, rawThreadInfoValidator),
rawEntryInfos: t.list(rawEntryInfoValidator), rawEntryInfos: t.list(rawEntryInfoValidator),
userInfos: t.list(userInfoValidator), userInfos: t.list(userInfoValidator),
updatesCurrentAsOf: t.Number, updatesCurrentAsOf: t.Number,
}); });
export type ClientFullStateSync = { export type ClientFullStateSync = $ReadOnly<{
...BaseFullStateSync, ...BaseFullStateSync,
+threadInfos: MinimallyEncodedRawThreadInfos,
+currentUserInfo: CurrentUserInfo, +currentUserInfo: CurrentUserInfo,
}; }>;
export type StateSyncFullActionPayload = { export type StateSyncFullActionPayload = $ReadOnly<{
...ClientFullStateSync, ...ClientFullStateSync,
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+keyserverID: string, +keyserverID: string,
}; }>;
export type ClientStateSyncFullSocketPayload = { export type ClientStateSyncFullSocketPayload = $ReadOnly<{
...ClientFullStateSync, ...ClientFullStateSync,
+type: 0, +type: 0,
// Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID // Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID
+sessionID?: string, +sessionID?: string,
}; }>;
export type ServerFullStateSync = { export type ServerFullStateSync = $ReadOnly<{
...BaseFullStateSync, ...BaseFullStateSync,
+threadInfos: RawThreadInfos,
+currentUserInfo: CurrentUserInfo, +currentUserInfo: CurrentUserInfo,
}; }>;
const serverFullStateSyncValidator = tShape<ServerFullStateSync>({ const serverFullStateSyncValidator = tShape<ServerFullStateSync>({
...baseFullStateSyncValidator.meta.props, ...baseFullStateSyncValidator.meta.props,
threadInfos: t.dict(tID, rawThreadInfoValidator),
currentUserInfo: currentUserInfoValidator, currentUserInfo: currentUserInfoValidator,
}); });
export type ServerStateSyncFullSocketPayload = { export type ServerStateSyncFullSocketPayload = {
atulAuthorUnsubmitted
Done
Inline Actions

Get the following when I try making this $ReadOnly:

922a45.png (754×1 px, 374 KB)

atul: Get the following when I try making this `$ReadOnly`: {F1058362}
...ServerFullStateSync, ...ServerFullStateSync,
+type: 0, +type: 0,
// Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID // Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID
+sessionID?: string, +sessionID?: string,
}; };
const serverStateSyncFullSocketPayloadValidator = const serverStateSyncFullSocketPayloadValidator =
tShape<ServerStateSyncFullSocketPayload>({ tShape<ServerStateSyncFullSocketPayload>({
...serverFullStateSyncValidator.meta.props, ...serverFullStateSyncValidator.meta.props,
▲ Show 20 Lines • Show All 328 Lines • Show Last 20 Lines
View Options

web/cpp/SQLiteQueryExecutorBindings.cpp

Show All 27 Lines
import { import {
type ServerServerRequest, type ServerServerRequest,
serverServerRequestValidator, serverServerRequestValidator,
type ClientServerRequest, type ClientServerRequest,
type ClientResponse, type ClientResponse,
type ClientClientResponse, type ClientClientResponse,
} from './request-types.js'; } from './request-types.js';
import type { SessionState, SessionIdentification } from './session-types.js'; import type { SessionState, SessionIdentification } from './session-types.js';
import { type RawThreadInfos } from './thread-types.js'; import type {
RawThreadInfos,
MinimallyEncodedRawThreadInfos,
} from './thread-types.js';
import { import {
type ClientUpdatesResult, type ClientUpdatesResult,
type ClientUpdatesResultWithUserInfos, type ClientUpdatesResultWithUserInfos,
type ServerUpdatesResult, type ServerUpdatesResult,
serverUpdatesResultValidator, serverUpdatesResultValidator,
type ServerUpdatesResultWithUserInfos, type ServerUpdatesResultWithUserInfos,
serverUpdatesResultWithUserInfosValidator, serverUpdatesResultWithUserInfosValidator,
} from './update-types.js'; } from './update-types.js';
▲ Show 20 Lines • Show All 134 Lines • ▼ Show 20 Lines
export const stateSyncPayloadTypes = Object.freeze({ export const stateSyncPayloadTypes = Object.freeze({
FULL: 0, FULL: 0,
INCREMENTAL: 1, INCREMENTAL: 1,
}); });
export const fullStateSyncActionType = 'FULL_STATE_SYNC'; export const fullStateSyncActionType = 'FULL_STATE_SYNC';
export type BaseFullStateSync = { export type BaseFullStateSync = {
+messagesResult: MessagesResponse, +messagesResult: MessagesResponse,
+threadInfos: RawThreadInfos,
+rawEntryInfos: $ReadOnlyArray<RawEntryInfo>, +rawEntryInfos: $ReadOnlyArray<RawEntryInfo>,
+userInfos: $ReadOnlyArray<UserInfo>, +userInfos: $ReadOnlyArray<UserInfo>,
+updatesCurrentAsOf: number, +updatesCurrentAsOf: number,
}; };
const baseFullStateSyncValidator = tShape<BaseFullStateSync>({ const baseFullStateSyncValidator = tShape<BaseFullStateSync>({
messagesResult: messagesResponseValidator, messagesResult: messagesResponseValidator,
threadInfos: t.dict(tID, rawThreadInfoValidator),
rawEntryInfos: t.list(rawEntryInfoValidator), rawEntryInfos: t.list(rawEntryInfoValidator),
userInfos: t.list(userInfoValidator), userInfos: t.list(userInfoValidator),
updatesCurrentAsOf: t.Number, updatesCurrentAsOf: t.Number,
}); });
export type ClientFullStateSync = { export type ClientFullStateSync = $ReadOnly<{
...BaseFullStateSync, ...BaseFullStateSync,
+threadInfos: MinimallyEncodedRawThreadInfos,
+currentUserInfo: CurrentUserInfo, +currentUserInfo: CurrentUserInfo,
}; }>;
export type StateSyncFullActionPayload = { export type StateSyncFullActionPayload = $ReadOnly<{
...ClientFullStateSync, ...ClientFullStateSync,
+calendarQuery: CalendarQuery, +calendarQuery: CalendarQuery,
+keyserverID: string, +keyserverID: string,
}; }>;
export type ClientStateSyncFullSocketPayload = { export type ClientStateSyncFullSocketPayload = $ReadOnly<{
...ClientFullStateSync, ...ClientFullStateSync,
+type: 0, +type: 0,
// Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID // Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID
+sessionID?: string, +sessionID?: string,
}; }>;
export type ServerFullStateSync = { export type ServerFullStateSync = $ReadOnly<{
...BaseFullStateSync, ...BaseFullStateSync,
+threadInfos: RawThreadInfos,
+currentUserInfo: CurrentUserInfo, +currentUserInfo: CurrentUserInfo,
}; }>;
const serverFullStateSyncValidator = tShape<ServerFullStateSync>({ const serverFullStateSyncValidator = tShape<ServerFullStateSync>({
...baseFullStateSyncValidator.meta.props, ...baseFullStateSyncValidator.meta.props,
threadInfos: t.dict(tID, rawThreadInfoValidator),
currentUserInfo: currentUserInfoValidator, currentUserInfo: currentUserInfoValidator,
}); });
export type ServerStateSyncFullSocketPayload = { export type ServerStateSyncFullSocketPayload = {
atulAuthorUnsubmitted
Done
Inline Actions

Get the following when I try making this $ReadOnly:

922a45.png (754×1 px, 374 KB)

atul: Get the following when I try making this `$ReadOnly`: {F1058362}
...ServerFullStateSync, ...ServerFullStateSync,
+type: 0, +type: 0,
// Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID // Included iff client is using sessionIdentifierTypes.BODY_SESSION_ID
+sessionID?: string, +sessionID?: string,
}; };
const serverStateSyncFullSocketPayloadValidator = const serverStateSyncFullSocketPayloadValidator =
tShape<ServerStateSyncFullSocketPayload>({ tShape<ServerStateSyncFullSocketPayload>({
...serverFullStateSyncValidator.meta.props, ...serverFullStateSyncValidator.meta.props,
▲ Show 20 Lines • Show All 328 Lines • Show Last 20 Lines
View Options

web/shared-worker/_generated/comm_query_executor.wasm

Loading...
View Options

web/shared-worker/queries/outbound-p2p-message-queries.test.js

Loading...
View Options

web/shared-worker/types/sqlite-query-executor.js

Loading...