Paths

Table of Contentst

-
services/tunnelbroker/src/
-
tunnelbroker/
-
src/
-
main.rs
-
notifs/apns/
-
apns/
-
mod.rs
-
websockets/
-
mod.rs
-
session.rs

Differential D12616

[Tunnelbroker] implement sending APNs notifs by client
ClosedPublic
Actions

Authored by kamil on Jun 28 2024, 5:46 AM.

Tags

None

Referenced Files

	Unknown Object (File)
	Thu, Apr 17, 12:38 PM

	Unknown Object (File)
	Thu, Apr 17, 8:21 AM

	Unknown Object (File)
	Thu, Apr 17, 4:25 AM

	Unknown Object (File)
	Thu, Apr 17, 3:59 AM

	Unknown Object (File)
	Wed, Apr 16, 2:28 PM

	Unknown Object (File)
	Sat, Apr 12, 7:54 PM

	Unknown Object (File)
	Mar 26 2025, 11:13 AM

	Unknown Object (File)
	Mar 7 2025, 1:42 AM

View All 87 Files

Subscribers

Details

Reviewers

bartek
marcin

Commits

rCOMMae75b01335c7: [Tunnelbroker] implement sending APNs notifs by client

Summary

Handle APNsNotif message from device

Depends on D12615

Test Plan

Tested in D12617.

Diff Detail

Repository

Branch

apns-tb

Lint

No Lint Coverage

Unit

No Test Coverage

Event Timeline

kamil created this revision.Jun 28 2024, 5:46 AM

kamil held this revision as a draft.

Herald added subscribers: tomek, ashoat. · View Herald TranscriptJun 28 2024, 5:47 AM

kamil added a child revision: D12617: [lib] implement sending APNs notifs using Tunnelbroker.Jun 28 2024, 5:51 AM

kamil edited the test plan for this revision. (Show Details)Jun 28 2024, 5:52 AM

Harbormaster completed remote builds in B29995: Diff 41794.Jun 28 2024, 6:03 AM

kamil published this revision for review.Jun 28 2024, 6:34 AM

kamil added inline comments.

services/tunnelbroker/src/websockets/session.rs
403

marcin accepted this revision.Jul 2 2024, 2:11 AM

This revision is now accepted and ready to land.Jul 2 2024, 2:11 AM

use Some

Harbormaster completed remote builds in B30055: Diff 41886.Jul 2 2024, 6:23 AM

Closed by commit rCOMMae75b01335c7: [Tunnelbroker] implement sending APNs notifs by client (authored by kamil). · Explain WhyJul 2 2024, 8:35 AM

This revision was automatically updated to reflect the committed changes.

kamil added a commit: rCOMMae75b01335c7: [Tunnelbroker] implement sending APNs notifs by client.

Revision Contents
Changeset List

Path

Size

services/

tunnelbroker/

src/

7 lines

notifs/

apns/

2 lines

websockets/

21 lines

74 lines

Diff 41794

services/tunnelbroker/src/main.rs

	Show First 20 Lines • Show All 494 Lines • ▼ Show 20 Lines		messageStoreThreads: sqliteQueryExecutor
	})),			})),
	reports: sqliteQueryExecutor.getAllReports(),			reports: sqliteQueryExecutor.getAllReports(),
	users: sqliteQueryExecutor.getAllUsers(),			users: sqliteQueryExecutor.getAllUsers(),
	keyservers: sqliteQueryExecutor.getAllKeyservers(),			keyservers: sqliteQueryExecutor.getAllKeyservers(),
	communities: sqliteQueryExecutor.getAllCommunities(),			communities: sqliteQueryExecutor.getAllCommunities(),
	integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),			integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),
	syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),			syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),
	auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),			auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),
				threadActivityEntries: [],
	};			};
	}			}

	export {			export {
	processDBStoreOperations,			processDBStoreOperations,
	getProcessingStoreOpsExceptionMessage,			getProcessingStoreOpsExceptionMessage,
	getClientStoreFromQueryExecutor,			getClientStoreFromQueryExecutor,
	};			};

services/tunnelbroker/src/notifs/apns/mod.rs

	Show First 20 Lines • Show All 494 Lines • ▼ Show 20 Lines		messageStoreThreads: sqliteQueryExecutor
	})),			})),
	reports: sqliteQueryExecutor.getAllReports(),			reports: sqliteQueryExecutor.getAllReports(),
	users: sqliteQueryExecutor.getAllUsers(),			users: sqliteQueryExecutor.getAllUsers(),
	keyservers: sqliteQueryExecutor.getAllKeyservers(),			keyservers: sqliteQueryExecutor.getAllKeyservers(),
	communities: sqliteQueryExecutor.getAllCommunities(),			communities: sqliteQueryExecutor.getAllCommunities(),
	integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),			integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),
	syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),			syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),
	auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),			auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),
				threadActivityEntries: [],
	};			};
	}			}

	export {			export {
	processDBStoreOperations,			processDBStoreOperations,
	getProcessingStoreOpsExceptionMessage,			getProcessingStoreOpsExceptionMessage,
	getClientStoreFromQueryExecutor,			getClientStoreFromQueryExecutor,
	};			};

services/tunnelbroker/src/websockets/mod.rs

	Show First 20 Lines • Show All 494 Lines • ▼ Show 20 Lines		messageStoreThreads: sqliteQueryExecutor
	})),			})),
	reports: sqliteQueryExecutor.getAllReports(),			reports: sqliteQueryExecutor.getAllReports(),
	users: sqliteQueryExecutor.getAllUsers(),			users: sqliteQueryExecutor.getAllUsers(),
	keyservers: sqliteQueryExecutor.getAllKeyservers(),			keyservers: sqliteQueryExecutor.getAllKeyservers(),
	communities: sqliteQueryExecutor.getAllCommunities(),			communities: sqliteQueryExecutor.getAllCommunities(),
	integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),			integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),
	syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),			syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),
	auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),			auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),
				threadActivityEntries: [],
	};			};
	}			}

	export {			export {
	processDBStoreOperations,			processDBStoreOperations,
	getProcessingStoreOpsExceptionMessage,			getProcessingStoreOpsExceptionMessage,
	getClientStoreFromQueryExecutor,			getClientStoreFromQueryExecutor,
	};			};

services/tunnelbroker/src/websockets/session.rs

	Show First 20 Lines • Show All 494 Lines • ▼ Show 20 Lines		messageStoreThreads: sqliteQueryExecutor
	})),			})),
	reports: sqliteQueryExecutor.getAllReports(),			reports: sqliteQueryExecutor.getAllReports(),
	users: sqliteQueryExecutor.getAllUsers(),			users: sqliteQueryExecutor.getAllUsers(),
	keyservers: sqliteQueryExecutor.getAllKeyservers(),			keyservers: sqliteQueryExecutor.getAllKeyservers(),
	communities: sqliteQueryExecutor.getAllCommunities(),			communities: sqliteQueryExecutor.getAllCommunities(),
	integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),			integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),
	syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),			syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),
	auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),			auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),
				threadActivityEntries: [],
	};			};
	}			}

	export {			export {
	processDBStoreOperations,			processDBStoreOperations,
	getProcessingStoreOpsExceptionMessage,			getProcessingStoreOpsExceptionMessage,
	getClientStoreFromQueryExecutor,			getClientStoreFromQueryExecutor,
	};			};